Day5(网络编程)

网络编程)"/>

Day5(网络编程)

多进程并发服务器

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <stdlib.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#include <sys/wait.h>
#include <string.h>#define ERR_MSG(msg) do{\fprintf(stderr, "line:%d\n", __LINE__);\perror(msg);\return -1;\
}while(0)#define PORT 4444
#define IP "192.168.31.72"int reCliMes(int newfd, struct sockaddr_in cin);void zombine_callback(int sig)
{while(waitpid(-1, NULL, WNOHANG) > 0);
}int main(int argc, const char *argv[])
{//因为在开启多个进程后，如果不退出，会产生僵尸进程//所以使用信号方式回收僵尸进程 	使用kil -l 查看所有信号类型，17__sighandler_t s = signal(SIGCHLD, zombine_callback);if(s == SIG_ERR){ERR_MSG("signal");}//创建套接字int sfd = socket(AF_INET, SOCK_STREAM, 0);if(sfd < 0){ERR_MSG("socket");}printf("套接字创建成功 sfd = [%d]\n", sfd);//填充结构体,用来绑定客户端的IP地址以及PORT端口号struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(PORT);sin.sin_addr.s_addr = inet_addr(IP);//进行绑定if(bind(sfd, (struct sockaddr *)&sin, sizeof(sin)) < 0){ERR_MSG("bind");}//设置被动接听if(listen(sfd, 64) < 0){ERR_MSG("listen");}//开始建立多进程并发服务器pid_t cpid = 0;int newfd = -1;struct sockaddr_in cin; 	//用来存储发送客户端的信息socklen_t addrlen = sizeof(cin);while(1){//主线程使用accept接收newfd = accept(sfd, (struct sockaddr *)&cin, &addrlen);if(newfd < 0){ERR_MSG("accept");}fprintf(stderr, "客户端[%s:%d] newfd=[%d]已连接\n",\inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), newfd);//创建进行进行多线程收发客户端cpid = fork();if(cpid < 0){ERR_MSG("fork");}//使用子线程进行收信息else if(cpid == 0){close(sfd); 	//子进程用不到sfd因此直接关闭//接收客户端发送的信息reCliMes(newfd, cin);//关闭newfdclose(newfd);exit(0);}else{close(newfd);}}//关闭套接字close(sfd);return 0;
}int reCliMes(int newfd, struct sockaddr_in cin)
{ssize_t res = 0;char buf[128] = "";while(1){bzero(buf, sizeof(buf));//接收消息res = recv(newfd, buf, sizeof(buf), 0);if(res < 0){ERR_MSG("recv");}else if(0 == res){fprintf(stderr, "客户端[%s:%d] newfd=[%d]下线\n",\inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), newfd);break;}printf("客户端[%s:%d] newfd=[%d] 传输内容：[%s]\n",\inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), newfd, buf);//发送一个回馈消息strcat(buf," ----已收到");if(send(newfd, buf, sizeof(buf), 0) < 0){ERR_MSG("send");}}return 0;
}

输出结果：

ubuntu@ubuntu:05_并发服务器$ ./pro 
套接字创建成功 sfd = [3]
客户端[192.168.31.190:51599] newfd=[4]已连接
客户端[192.168.31.190:51603] newfd=[4]已连接
客户端[192.168.31.190:51606] newfd=[4]已连接
客户端[192.168.31.190:51599] newfd=[4] 传输内容：[11111]
客户端[192.168.31.190:51603] newfd=[4] 传输内容：[213]
客户端[192.168.31.190:51606] newfd=[4] 传输内容：[33]
客户端[192.168.31.190:51599] newfd=[4] 传输内容：[11111]
客户端[192.168.31.190:51599] newfd=[4] 传输内容：[11111]
客户端[192.168.31.190:51603] newfd=[4] 传输内容：[213]
客户端[192.168.31.190:51603] newfd=[4] 传输内容：[213]
客户端[192.168.31.190:51606] newfd=[4] 传输内容：[33]
客户端[192.168.31.190:51606] newfd=[4] 传输内容：[33]
客户端[192.168.31.190:51599] newfd=[4]下线
客户端[192.168.31.190:51603] newfd=[4]下线
客户端[192.168.31.190:51606] newfd=[4]下线

多线程并发服务器

head.h

#ifndef __HEAD__
#define __HEAD__#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <pthread.h>
#include <string.h>
#include <arpa/inet.h>
#include <unistd.h>#define ERR_MSG(msg) do{\fprintf(stderr, "line : %d", __LINE__);\perror(msg);\return -1;\
}while(0)#define PORT 4444
#define IP "192.168.31.72"struct cli_msg
{int newfd;struct sockaddr_in cin;
};void *deal_cliMsg(void *arg);#endif

fun.c

#include "head.h"void *deal_cliMsg(void *arg)
{int newfd = ((struct cli_msg*)arg)->newfd;struct sockaddr_in cin = ((struct cli_msg*)arg)->cin;char buf[128] = "";ssize_t res = 0;while(1){//循环接受信息res = recv(newfd, buf, sizeof(buf), 0);if(res < 0){ERR_MSG("recv");}else if(0 == res){printf("[%s : %d] newfd = %d 断开连接\n", \inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), newfd);break;}printf("[%s : %d] newfd = %d 接受信息:[%s]\n", \inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), newfd, buf);//发送回馈信息strcat(buf,"---mwt");if(send(newfd, buf, sizeof(buf), 0) < 0){ERR_MSG("send");}}close(newfd);//退出线程pthread_exit(NULL);
}

main.c

#include "head.h"int main(int argc, const char *argv[])
{//创建套接字int sfd = socket(AF_INET, SOCK_STREAM, 0);if(sfd < 0){ERR_MSG("socket");}//填充自身信息结构体struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(PORT);sin.sin_addr.s_addr = inet_addr(IP); //绑定if(bind(sfd, (struct sockaddr*)&sin, sizeof(sin)) < 0){ERR_MSG("bind");}//设置被动监听if(listen(sfd, 128) < 0){ERR_MSG("listen");}//设置结构体装传过来的客户端信息struct sockaddr_in cin;socklen_t addrlne = sizeof(cin);char buf[128] = "";int newfd = -1;pthread_t tid;struct cli_msg info; while(1){bzero(buf, sizeof(buf));//在主线程acceptnewfd = accept(sfd, (struct sockaddr*)&cin, &addrlne);if(newfd < 0){ERR_MSG("accept");}printf("[%s : %d] newfd = %d上线\n", \inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), newfd);//创建子线程进行信息的收发info.cin = cin;info.newfd = newfd;if(pthread_create(&tid, NULL, deal_cliMsg, &info) != 0){fprintf(stderr, "pthread_create failed __%d__\n",__LINE__);return -1;}}//关闭所有套接字close(sfd);return 0;
}

结果：

ubuntu@ubuntu:02_pthread$ ./pth
[192.168.31.190 : 50092] newfd = 4上线
[192.168.31.190 : 50095] newfd = 5上线
[192.168.31.190 : 50096] newfd = 6上线
[192.168.31.190 : 50096] newfd = 6 接受信息:[11111]
[192.168.31.190 : 50095] newfd = 5 接受信息:[213]
[192.168.31.190 : 50092] newfd = 4 接受信息:[33]
[192.168.31.190 : 50096] newfd = 6 接受信息:[11111---mwt]
[192.168.31.190 : 50096] newfd = 6 接受信息:[11111---mwt---mwt]
[192.168.31.190 : 50095] newfd = 5 接受信息:[213---mwt]
[192.168.31.190 : 50095] newfd = 5 接受信息:[213---mwt---mwt]
[192.168.31.190 : 50092] newfd = 4 接受信息:[33---mwt]
[192.168.31.190 : 50092] newfd = 4 接受信息:[33---mwt---mwt]
[192.168.31.190 : 50096] newfd = 6 断开连接
[192.168.31.190 : 50095] newfd = 5 断开连接
[192.168.31.190 : 50092] newfd = 4 断开连接