1. 前言

本次使用TCP連接，1個server，多個client。

server和多個client之間，可以互相發送消息。

2. 代碼

tcp_sever_fork.cpp? 如下：

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#define PORT 8890

#define QUEUE_SIZE 10

#define BUFFER_SIZE 1024

//傳進來的sockfd，就是互相建立好連接之后的socket文件描述符

//通過這個sockfd，可以完成 [服務端][客戶端] 互相收發數據

void str_echo(int sockfd)

{

char buffer[BUFFER_SIZE];

pid_t pid = getpid();

while(1)

{

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

int len = recv(sockfd, buffer, sizeof(buffer),0);

if(strcmp(buffer,"exit\n")==0)

{

printf("child process: %d exited.\n",pid);

break;

}

printf("pid:%d receive:\n",pid);

fputs(buffer, stdout);

send(sockfd, buffer, len, 0);

}

close(sockfd);

}

int main(int argc, char **argv)

{

//定義IPV4的TCP連接的套接字描述符

int server_sockfd = socket(AF_INET,SOCK_STREAM, 0);

//定義sockaddr_in

struct sockaddr_in server_sockaddr;

server_sockaddr.sin_family = AF_INET;

server_sockaddr.sin_addr.s_addr = htonl(INADDR_ANY);

server_sockaddr.sin_port = htons(PORT);

//bind成功返回0，出錯返回-1

if(bind(server_sockfd,(struct sockaddr *)&server_sockaddr,sizeof(server_sockaddr))==-1)

{

perror("bind");

exit(1);//1為異常退出

}

printf("bind success.\n");

//listen成功返回0，出錯返回-1，允許同時幀聽的連接數為QUEUE_SIZE

if(listen(server_sockfd,QUEUE_SIZE) == -1)

{

perror("listen");

exit(1);

}

printf("listen success.\n");

for(;;)

{

struct sockaddr_in client_addr;

socklen_t length = sizeof(client_addr);

//進程阻塞在accept上，成功返回非負描述字，出錯返回-1

int conn = accept(server_sockfd, (struct sockaddr*)&client_addr,&length);

if(conn<0)

{

perror("connect");

exit(1);

}

printf("new client accepted.\n");

pid_t childid;

if(childid=fork()==0)//子進程

{

printf("child process: %d created.\n", getpid());

close(server_sockfd);//在子進程中關閉監聽

str_echo(conn);//處理監聽的連接

exit(0);

}

}

printf("closed.\n");

close(server_sockfd);

return 0;

}

tcp_client_fork.cpp ?代碼如下：

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#define PORT 8890

#define BUFFER_SIZE 1024

int main(int argc, char **argv)

{

if(argc!=2)

{

printf("usage: client IP \n");

exit(0);

}

//定義IPV4的TCP連接的套接字描述符

int sock_cli = socket(AF_INET,SOCK_STREAM, 0);

//定義sockaddr_in

struct sockaddr_in servaddr;

memset(&servaddr, 0, sizeof(servaddr));

servaddr.sin_family = AF_INET;

servaddr.sin_addr.s_addr = inet_addr(argv[1]);

servaddr.sin_port = htons(PORT); //服務器端口

//連接服務器，成功返回0，錯誤返回-1

if (connect(sock_cli, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0)

{

perror("connect");

exit(1);

}

printf("connect server(IP:%s).\n",argv[1]);

char sendbuf[BUFFER_SIZE];

char recvbuf[BUFFER_SIZE];

//客戶端將控制臺輸入的信息發送給服務器端，服務器原樣返回信息

while (fgets(sendbuf, sizeof(sendbuf), stdin) != NULL)

{

send(sock_cli, sendbuf, strlen(sendbuf),0); ///發送

if(strcmp(sendbuf,"exit\n")==0)

{

printf("client exited.\n");

break;

}

printf("client receive:\n");

recv(sock_cli, recvbuf, sizeof(recvbuf),0); ///接收

fputs(recvbuf, stdout);

memset(sendbuf, 0, sizeof(sendbuf));

memset(recvbuf, 0, sizeof(recvbuf));

}

close(sock_cli);

return 0;

}

3. 效果

編譯： #?g++ -o ?tcpserver ?tcp_sever_fork.cpp

#?g++ -o ?tcpclient ? ?tcp_client_fork.cpp

(1)首先，運行server

(2)然后再運行client

(3)互發消息

(4)運行多個客戶端，并互發消息

4. 結論

很明顯，可以看到，實驗結果表明，server端可以同時和多個client端通信。

總結

以上是生活随笔為你收集整理的Linux tcp同时多个连接,Linux下网络编程（2）——TCP多连接，1个server，多个client...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。