本篇博客講述的是單client單線程模型,該模型相同由主進程統一accept,僅僅是將fork改成了pthread_create。
與進程相比,線程有很是多長處(速度快,佔用資源少。數據可以共享)。服務器
該模型結構如圖所看到的:
markdown
與上一篇博客講述的模型很是類似,源碼同上一篇相比僅僅有少許更改而已,亦不解說。socket
服務器端代碼例如如下:post
/* author:arvik purpose:test the server simultaneity email:1216601195@qq.com csdn: http://blog.csdn.net/u012819339 */
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <time.h>
#include <string.h>
#include <unistd.h>
#include <stdio.h>
#include <arpa/inet.h>
#include <pthread.h>
#define BUFFLEN 1024
#define SERVER_PORT 8887
#define BACKLOG 3
static void handle_request(void *argv)
{
int s_c = *((int *)argv);
char buff[BUFFLEN];
int n = 0;
memset(buff, 0, sizeof(buff));
n = recv(s_c, buff, BUFFLEN, 0);
if(n>0)
{
printf("receive msg from client: %s\n", buff);
}
close(s_c);
}
static int handle_connect(int s_s)
{
int s_c;
struct sockaddr_in from;
socklen_t len = sizeof(from);
pthread_t thread_do;
while(1)
{
s_c = accept(s_s, (struct sockaddr*)&from, &len); //block
if(s_c>0)
{
pthread_create(&thread_do, NULL, (void*)handle_request, &s_c);
}
}
}
int main()
{
int s_s;
struct sockaddr_in local;
s_s = socket(AF_INET, SOCK_STREAM, 0);
memset(&local, 0, sizeof(local));
local.sin_family = AF_INET;
local.sin_addr.s_addr = inet_addr("127.0.0.1");//htonl(INADDR_ANY);
local.sin_port = htons(SERVER_PORT);
if(bind(s_s, (struct sockaddr*)&local, sizeof(local)))
{
printf("bind socket failed!\n");
return -1;
}
listen(s_s, BACKLOG);
handle_connect(s_s);
close(s_s);
return 0;
}
client代碼不變。ui
見上一篇博客!spa