并发服务器

怼烎@ 2022-07-14 08:59 178阅读 0赞

客户端程序

\#include <stdio.h>

\#include <string.h>

\#include <stdlib.h>

\#include <sys/types.h>

\#include <sys/socket.h>

\#include <netdb.h>

\#define PORT 3333

\#define MAX\_SIZE 1024

int main(int argc, char \*argv\[\])

if(argc != 2)

printf("Please input server ip!\\n");

exit(1);

int sockfd;

int n\_write;

struct sockaddr\_in server\_addr;

char buffer\[MAX\_SIZE\];

if((sockfd = socket(AF\_INET,SOCK\_STREAM,0)) < 0)

perror("client socket error!\\n");

exit(1);

bzero(&server\_addr,0);

server\_addr.sin\_family = AF\_INET;

server\_addr.sin\_port = htons(PORT);

server\_addr.sin\_addr.s\_addr = inet\_addr(argv\[1\]);

if(connect(sockfd,(struct sockaddr \*)&server\_addr,sizeof server\_addr) < 0)

perror("connect server error!\\n");

exit(1);

while(1)

memset(buffer,0,sizeof(buffer));

printf("Please input send msg:\\n");

gets(buffer);

n\_write = write(sockfd,buffer,strlen(buffer));

if(n\_write == -1)

perror("send to server msg error!\\n");

exit(1);

return 0;

服务机程序

\#include <stdio.h>

\#include <stdlib.h>

\#include <string.h>

\#include <sys/types.h>

\#include <sys/socket.h>

\#include <sys/stat.h>

\#include <netdb.h>

\#define PORT 3333

\#define MAX\_SIZE 1024

void \* read\_msg(void \*arg)

int n\_read;

int new\_fd = \*((int \*)arg);

char buffer\[MAX\_SIZE\];

printf("new\_fd = %d\\n",new\_fd);

while(1)

memset(buffer,0,sizeof(buffer));

n\_read = read(new\_fd,buffer,sizeof(buffer));

if(n\_read < 0)

perror("recv client msg error!\\n");

exit(1);

if(n\_read == 0)

printf("client is close!!\\n");

close(new\_fd);

pthread\_exit(NULL);

buffer\[n\_read\] = '\\0';

printf("recv msg:%s\\n",buffer);

int main()

int sockfd;

int new\_fd;

struct sockaddr\_in server\_addr;

struct sockaddr\_in client\_addr;

int n\_read;

int ser\_size;

int opt = 1;

char buffer\[MAX\_SIZE\];

pthread\_t id;

if((sockfd = socket(AF\_INET,SOCK\_STREAM,0)) < 0)

perror("socket error!\\n");

exit(1);

printf("socket success.............!\\n");

if(setsockopt(sockfd,SOL\_SOCKET,SO\_REUSEADDR,&opt,sizeof(opt)) < 0)

perror("set socket option error!\\n");

exit(1);

bzero(&server\_addr,0);

server\_addr.sin\_family = AF\_INET;

server\_addr.sin\_port = htons(PORT);

server\_addr.sin\_addr.s\_addr = inet\_addr("192.168.1.10");

if(bind(sockfd,(struct sockaddr \*)&server\_addr,sizeof server\_addr) < 0)

perror("bind error!\\n");

exit(1);

printf("bind success.............!\\n");

listen(sockfd,5);

printf("listen success.............!\\n");

printf("accepting..................!\\n");

while(1)

ser\_size = sizeof client\_addr;

if((new\_fd = accept(sockfd,(struct sockaddr \*)&client\_addr,&ser\_size)) < 0)

perror("accept error!\\n");

exit(1);

printf("accept success.................!\\n");

pthread\_create(&id,NULL,read\_msg,&new\_fd);

return 0;

并发服务器

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关【并发服务器】高并发服务器模型select实现服务器和客户端通信

相关服务器并发量计算，网站并发量计算

相关 linux并发服务器epoll

相关 linux并发服务器poll

相关 linux并发服务器select

相关 Artical--4--并发服务器

相关服务器并发处理架构

相关并发服务器

相关 HTTP协议、web静态服务器-并发服务器

相关服务器并发处理架构