step5 . day6 网络编程 基于TCP协议的多并发模式（使用多进程、多线程、select函数分别实现）...
實(shí)現(xiàn)TCP服務(wù)器端多路并發(fā)的方法有①多進(jìn)程②多線程③IO多路復(fù)用（select poll epoll函數(shù)）
1.多進(jìn)程實(shí)現(xiàn)并發(fā)模式（僅在服務(wù)器端更改之前代碼實(shí)現(xiàn)）
服務(wù)器端
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <linux/in.h>
#include <string.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <signal.h>
#include <sys/wait.h>
#define SIZE 128
void handler(int sign);
int main(int argc, const char *argv[])
{
if(argc<2){
printf("Usrmsg:%s <Port>\n",argv[0]);
return -1;
}
//1.創(chuàng)建套接字文件，用于鏈接
int socket_fd;
socket_fd = socket(AF_INET,SOCK_STREAM,0);
if(socket_fd == -1){
perror("socket");
return -1;
}
printf("socket Created ok\n");
//填充結(jié)構(gòu)體sockaddr_in,用于傳參
int bind_fd;
struct sockaddr_in serveraddr,connectaddr; //定義填充的結(jié)構(gòu)體
bzero((void *)&serveraddr, sizeof(serveraddr));
serveraddr.sin_family = AF_INET; //IPV4協(xié)議
serveraddr.sin_port = htons(atoi(argv[1])); //本地端口號轉(zhuǎn)化位網(wǎng)絡(luò)字節(jié)碼
serveraddr.sin_addr.s_addr = htonl(INADDR_ANY);//本地IP轉(zhuǎn)化位網(wǎng)絡(luò)字節(jié)碼,任意IP
//2.綁定socket文件描述符、端口、IP
bind_fd = bind(socket_fd,(struct sockaddr*)&serveraddr,sizeof(serveraddr));
if(bind_fd == -1){
perror("bind");
return -1;
}
printf("bind ok\n");
//3.監(jiān)聽，將套接字文件屬性該主動為被動模式
int listen_fd;
listen_fd = listen(socket_fd,10);
if(listen_fd == -1){
perror("listen");
return -1;
}
printf("listen ok\n");
int addrsize = sizeof(connectaddr);
int accept_fd;
int recvbyte;
char bufrecv[SIZE] = {0};
while(1){
accept_fd = accept(socket_fd,(struct sockaddr*)&connectaddr,&addrsize);
if(accept_fd == -1){
perror("accept");
return -1;
}
printf("connect ok\n");
pid_t pid = fork();
if(pid < 0){
perror("fork");
return -1;
}
if(pid == 0){
close(socket_fd);
while(1){
memset(bufrecv,0,SIZE);
int port = ntohs(connectaddr.sin_port);
char *ip = (char *)(inet_ntoa(connectaddr.sin_addr.s_addr));
recvbyte = recv(accept_fd, bufrecv,sizeof(bufrecv),0);
if(recvbyte <= 0){
printf("client failed connect\n");
return -1;
}
printf("IP:%s Port:%d online. send: %s\n",ip,port,bufrecv);
}
// close(accept_fd);
}
else{
close(accept_fd);
signal(SIGCHLD,handler);
}
}
close(socket_fd);
return 0;
}
void handler(int sign){
waitpid(-1,NULL,WNOHANG);
printf("signal = %d\n",sign);
}
?
2.多線程實(shí)現(xiàn)并發(fā)
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <linux/in.h>
#include <string.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <pthread.h>
#define SIZE 128
void *connectfun(void *arg);
int main(int argc, const char *argv[])
{
if(argc<2){
printf("Usrmsg:%s <Port>\n",argv[0]);
return -1;
}
//1.創(chuàng)建套接字文件，用于鏈接
int socket_fd;
socket_fd = socket(AF_INET,SOCK_STREAM,0);
if(socket_fd == -1){
perror("socket");
return -1;
}
printf("socket Created ok\n");
//填充結(jié)構(gòu)體sockaddr_in,用于傳參
int bind_fd;
struct sockaddr_in serveraddr,connectaddr; //定義填充的結(jié)構(gòu)體
bzero((void *)&serveraddr, sizeof(serveraddr));
serveraddr.sin_family = AF_INET; //IPV4協(xié)議
serveraddr.sin_port = htons(atoi(argv[1])); //本地端口號轉(zhuǎn)化位網(wǎng)絡(luò)字節(jié)碼
serveraddr.sin_addr.s_addr = htonl(INADDR_ANY);//本地IP轉(zhuǎn)化位網(wǎng)絡(luò)字節(jié)碼,任意IP
//2.綁定socket文件描述符、端口、IP
bind_fd = bind(socket_fd,(struct sockaddr*)&serveraddr,sizeof(serveraddr));
if(bind_fd == -1){
perror("bind");
return -1;
}
printf("bind ok\n");
//3.監(jiān)聽，將套接字文件屬性該主動為被動模式
int listen_fd;
listen_fd = listen(socket_fd,10);
if(listen_fd == -1){
perror("listen");
return -1;
}
printf("listen ok\n");
int addrsize = sizeof(connectaddr);
int accept_fd;
while(1){
accept_fd = accept(socket_fd,(struct sockaddr*)&connectaddr,&addrsize);
if(accept_fd == -1){
perror("accept");
return -1;
}
printf("connect ok\n");
pthread_t pid ;
pthread_create(&pid, NULL,connectfun,(void*)&accept_fd);
}
close(socket_fd);
return 0;
}
void *connectfun(void *arg){
pthread_detach(pthread_self());
char bufrecv[SIZE] = {0};
int recvbyte;
while(1){
memset(bufrecv,0,SIZE);
recvbyte = recv(*(int *)arg, bufrecv,sizeof(bufrecv),0);
if(recvbyte <= 0){
printf("client failed connect\n");
return NULL;
}
printf("send: %s\n",bufrecv);
}
}
?
3.select函數(shù)實(shí)現(xiàn)多并發(fā)
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <linux/in.h>
#include <string.h>
#include <sys/stat.h>
#include <fcntl.h>
#define SIZE 128
int main(int argc, const char *argv[])
{
if(argc<2){
printf("Usrmsg:%s <Port>\n",argv[0]);
return -1;
}
//1.創(chuàng)建套接字文件，用于鏈接
int socket_fd;
socket_fd = socket(AF_INET,SOCK_STREAM,0);
if(socket_fd == -1){
perror("socket");
return -1;
}
printf("socket Created ok\n");
//填充結(jié)構(gòu)體sockaddr_in,用于傳參
int bind_fd;
struct sockaddr_in serveraddr,connectaddr; //定義填充的結(jié)構(gòu)體
bzero((void *)&serveraddr, sizeof(serveraddr));
serveraddr.sin_family = AF_INET; //IPV4協(xié)議
serveraddr.sin_port = htons(atoi(argv[1])); //本地端口號轉(zhuǎn)化位網(wǎng)絡(luò)字節(jié)碼
serveraddr.sin_addr.s_addr = htonl(INADDR_ANY);//本地IP轉(zhuǎn)化位網(wǎng)絡(luò)字節(jié)碼,任意IP
//2.綁定socket文件描述符、端口、IP
bind_fd = bind(socket_fd,(struct sockaddr*)&serveraddr,sizeof(serveraddr));
if(bind_fd == -1){
perror("bind");
return -1;
}
printf("bind ok\n");
//3.監(jiān)聽，將套接字文件屬性該主動為被動模式
int listen_fd;
listen_fd = listen(socket_fd,10);
if(listen_fd == -1){
perror("listen");
return -1;
}
printf("listen ok\n");
//創(chuàng)建監(jiān)聽集合
fd_set readfds,tempfds;
//清空集合
FD_ZERO(&readfds);
FD_ZERO(&tempfds);
//將關(guān)心的文件描述符加入集合
FD_SET(0,&readfds);
FD_SET(socket_fd,&readfds);
//設(shè)置最大監(jiān)聽個數(shù)
int maxfd = socket_fd;
int addrsize = sizeof(connectaddr);
int accept_fd;
int recvbyte;
int val;
char bufsend[SIZE] = {0};
char bufrecv[SIZE] = {0};
while(1){
tempfds = readfds;
val = select(maxfd + 1,&tempfds,NULL,NULL,NULL);
//4.阻塞函數(shù)，等待客戶鏈接請求，不關(guān)心鏈接的是那個客戶端，填NULL
if(val < 0)
{
perror("select failed.");
return -1;
}
int i = 0;
for(i = 0;i<maxfd+1;i++){
if(FD_ISSET(i,&tempfds)){
if(i == 0)
{
fgets(bufsend,sizeof(bufsend),stdin);
send(socket_fd, bufsend, sizeof(bufsend),0);
printf("send ok.\n");
}
if(i == socket_fd)
{
accept_fd = accept(socket_fd,(struct sockaddr*)&connectaddr,&addrsize);
if(accept_fd == -1){
perror("accept");
return -1;
}
printf("accept ok\n");
int port = ntohs(connectaddr.sin_port);
char *ip = (char *)(inet_ntoa(connectaddr.sin_addr.s_addr));
printf("IP:%s Port:%d online.\n",ip,port);
FD_SET(accept_fd,&readfds);
maxfd = maxfd > accept_fd ? maxfd : accept_fd;
}
else{
recvbyte = recv(i, bufrecv,sizeof(bufrecv),0);
if(recvbyte <= 0)
{
FD_CLR(i,&readfds);
close(i);
continue;
}
printf("%s\n",bufrecv);
}
}
}
}
close(socket_fd);
close(accept_fd);
return 0;
}
轉(zhuǎn)載于:https://www.cnblogs.com/huiji12321/p/11380865.html
總結(jié)
以上是生活随笔為你收集整理的step5 . day6 网络编程 基于TCP协议的多并发模式（使用多进程、多线程、select函数分别实现）...的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： step5 . day5 网络编程 基于
- 下一篇： 学习，编译ffmpeg tutorial