1、多線程網(wǎng)絡(luò)服務(wù)
為嘉善等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計(jì)制作服務(wù)，及嘉善網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站建設(shè)、外貿(mào)網(wǎng)站建設(shè)、嘉善網(wǎng)站設(shè)計(jì)，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達(dá)到每一位用戶的要求，就會得到認(rèn)可，從而選擇與我們長期合作。這樣，我們也可以走得更遠(yuǎn)！
：多線程網(wǎng)絡(luò)模式類似于多進(jìn)程網(wǎng)絡(luò)模式；不同的是：新客戶端到來時，啟動的是一個線程(每來一個客戶，將創(chuàng)建一個線程)。
模型分析
2、代碼實(shí)現(xiàn)
同樣用處理整數(shù)運(yùn)算來模擬多線程的并發(fā)處理
(1)、utili.h
#include#include #include #include #include #include #include #include #define SERVER_PORT 9090 #define SERVER_IP "127.0.0.1" #define LISTEN_QUEUE 5 #define BUFFER_SIZE 255 typedef enum{ADD,SUB,MUL,DIV,MOD, QUIT}OPER_TYPE; typedef struct OperStruct{ int op1; int op2; OPER_TYPE oper; }OperStruct;
(2)、ser.c
重慶分公司
重慶分公司
#include"../utili.h"
void* Thread_Handler(void *arg);
void* Thread_Handler(void *arg){
int sockConn = *(int *)arg;
OperStruct op;
int result;
while(1){
int res = recv(sockConn, &op, sizeof(op), 0);
if(res == -1){
printf("recv data fail.\n");
continue;
}
if(op.oper == ADD){
result = op.op1 + op.op2;
}else if(op.oper == SUB){
result = op.op1 - op.op2;
}else if(op.oper == MUL){
result = op.op1 * op.op2;
}else if(op.oper == DIV){
result = op.op1 / op.op2;
}else if(op.oper == QUIT){
break;
}
res = send(sockConn, &result, sizeof(result), 0);
if(res == -1){
printf("send data fail.\n");
continue;
}
}
close(sockConn);
pthread_exit(0);
}
int main(void){
int sockSer = socket(AF_INET, SOCK_STREAM, 0);
if(sockSer == -1){
perror("socket");
return -1;
}
struct sockaddr_in addrSer, addrCli;
addrSer.sin_family = AF_INET;
addrSer.sin_port = htons(SERVER_PORT);
addrSer.sin_addr.s_addr = inet_addr(SERVER_IP);
socklen_t len = sizeof(struct sockaddr);
int res = bind(sockSer, (struct sockaddr*)&addrSer, len);
if(res == -1){
perror("bind");
close(sockSer);
return -1;
}
listen(sockSer, LISTEN_QUEUE);
int sockConn;
while(1){
printf("Server Wait Client Connect.......\n");
sockConn = accept(sockSer, (struct sockaddr*)&addrCli, &len);
if(sockConn == -1){
printf("Server Accept Client Connect Fail.\n");
continue;
}else{
printf("Server Accept Client Connect Success.\n");
printf("Client IP:>%s\n", inet_ntoa(addrCli.sin_addr));
printf("Client Port:>%d\n",ntohs(addrCli.sin_port));
}
pthread_t tid;
pthread_create(&tid, NULL, Thread_Handler, &sockConn);
}
close(sockSer);
return 0;
}(3)、cli.c
#include"utili.h"
void InputData(OperStruct *pt);
void InputData(OperStruct *pt){
printf("please input op1 and op2 : ");
scanf("%d %d", &(pt->op1), &(pt->op2));
}
//Cli
int main(void){
int sockCli = socket(AF_INET, SOCK_STREAM, 0);
if(sockCli == -1){
perror("socket");
return -1;
}
struct sockaddr_in addrSer;
addrSer.sin_family = AF_INET;
addrSer.sin_port = htons(SERVER_PORT);
addrSer.sin_addr.s_addr = inet_addr(SERVER_IP);
socklen_t len = sizeof(struct sockaddr);
int res = connect(sockCli, (struct sockaddr*)&addrSer, len);
if(res == -1){
perror("connect");
close(sockCli);
return -1;
}else{
printf("Client Connect Server Success.\n");
}
char cmd[2];
OperStruct op;
int result;
while(1){
printf("Please input operator : ");
scanf("%s",cmd);
if(strcmp(cmd, "+") == 0){
op.oper = ADD;
InputData(&op);
}else if(strcmp(cmd,"-") == 0){
op.oper = SUB;
InputData(&op);
}else if(strcmp(cmd,"*") == 0){
op.oper = MUL;
InputData(&op);
}else if(strcmp(cmd,"/") == 0){
op.oper = DIV;
InputData(&op);
}else if(strcmp(cmd, "quit") == 0){
op.oper = QUIT;
}else{
printf("Cmd invalid.\n");
}
res = send(sockCli, &op, sizeof(op), 0);
if(res == -1){
printf("send data fail.\n");
continue;
}
if(op.oper == QUIT)
break;
res = recv(sockCli, &result, sizeof(result), 0);
if(res == -1){
printf("recv data fail.\n");
continue;
}
printf("result = %d\n", result);
}
close(sockCli);
return 0;
}運(yùn)行結(jié)果
客戶1
客戶2
3、分析總結(jié)
多線程網(wǎng)絡(luò)服務(wù)也存在線程的動態(tài)申請與釋放，還是有一定的開銷，若存在大量用戶在線，很可能帶來線程間切換開銷。
