作业--day34
发布时间：2023年12月21日
使用select完成TCP并发服务器和客户端
server.c
#include <myhead.h>
#define PORT 8888
#define IP "192.168.125.137"
int main(int argc, const char *argv[])
{
int sfd = socket(AF_INET, SOCK_STREAM, 0);
if(sfd == -1){
perror("socket error");
return -1;
}
int reuse = -1;
if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1){
perror("setsockopt error");
return -1;
}
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)) == -1){
perror("bind error");
return -1;
}
if(listen(sfd, 128) == -1){
perror("listen error");
return -1;
}
struct sockaddr_in cin;
socklen_t socklen = sizeof(cin);
char buf[128] = "";
fd_set readfds;
FD_ZERO(&readfds);
FD_SET(0, &readfds);
FD_SET(sfd, &readfds);
int res = -1;
fd_set tempfds;
struct sockaddr_in arr_cin[1024];
int maxfd = sfd;
while(1){
tempfds = readfds;
res = select(maxfd+1, &tempfds, NULL, NULL, NULL);
if(res == -1){
perror("select error");
return -1;
}else if(res == 0){
puts("time out");
return -1;
}
for(int index=0; index<=maxfd; index++){
if(!FD_ISSET(index, &tempfds)){
continue;
}
if(index == sfd){
int newfd = accept(sfd, (struct sockaddr *)&cin, &socklen);
if(newfd == -1){
perror("accept error");
return -1;
}
arr_cin[newfd] = cin;
printf("[%s: %d] 已连接\n", inet_ntoa(arr_cin[newfd].sin_addr), ntohs(arr_cin[newfd].sin_port));
FD_SET(newfd, &readfds);
if(newfd > maxfd){
maxfd = newfd;
}
}else if(index == 0){
fgets(buf, sizeof(buf), stdin);
buf[strlen(buf) - 1] = 0;
for(int i=4; i<=maxfd; i++){
send(i, buf, sizeof(buf), 0);
}
}else{
bzero(buf, sizeof(buf));
int res = recv(index, buf, sizeof(buf), 0);
if(res == 0){
puts("客户端已下线");
close(index);
FD_CLR(index, &readfds);
for(int i=maxfd; i>0; i--){
if(FD_ISSET(i, &readfds)){
maxfd = i;
break;
}
}
continue;
}
printf("[%s: %d] %s\n", inet_ntoa(arr_cin[index].sin_addr), ntohs(arr_cin[index].sin_port), buf);
strcat(buf, "*_*");
send(index, buf, sizeof(buf), 0);
}
}
}
close(sfd);
return 0;
}
client.c
#include <myhead.h>
#define PORT 8888
#define IP "192.168.125.137"
int main(int argc, const char *argv[])
{
int cfd = socket(AF_INET, SOCK_STREAM, 0);
if(cfd == -1){
perror("socket error");
return -1;
}
struct sockaddr_in sin;
sin.sin_family = AF_INET;
sin.sin_port = htons(PORT);
sin.sin_addr.s_addr = inet_addr(IP);
if(connect(cfd, (struct sockaddr*)&sin, sizeof(sin)) == -1){
perror("connect error");
return -1;
}
fd_set readfds;
fd_set tempfds;
FD_ZERO(&readfds);
FD_SET(0, &readfds);
FD_SET(cfd, &readfds);
int res = -1;
struct sockaddr_in arr_cin[1024];
char buf[128] = "";
while(1){
tempfds = readfds;
res = select(cfd+1, &tempfds, NULL, NULL, NULL);
if(res == -1){
perror("select error");
return -1;
}else if(res == 0){
puts("time out");
return -1;
}
if(FD_ISSET(cfd, &tempfds)){
bzero(buf, sizeof(buf));
res = recv(cfd, buf, sizeof(buf), 0);
if(res == 0){
puts("服务器已下线");
break;
}
printf("[%s: %d] %s\n", inet_ntoa(sin.sin_addr), ntohs(sin.sin_port), buf);
}
if(FD_ISSET(0, &tempfds)){
bzero(buf, sizeof(buf));
fgets(buf, sizeof(buf), stdin);
buf[strlen(buf) - 1] = 0;
send(cfd, buf, sizeof(buf), 0);
}
}
close(cfd);
return 0;
}
使用poll完成TCP并发服务器和客户端
server.c
#include <myhead.h>
#define PORT 8888
#define IP "192.168.125.137"
void del_arr(struct pollfd fds[], int *max, int index){
for(int i=index; i<(*max)-1; i++){
fds[i] = fds[i+1];
}
(*max) -= 1;
}
int main(int argc, const char *argv[])
{
int sfd = socket(AF_INET, SOCK_STREAM, 0);
if(sfd == -1){
perror("socket error");
return -1;
}
int reuse = -1;
if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1){
perror("setsockopt error");
return -1;
}
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)) == -1){
perror("bind error");
return -1;
}
if(listen(sfd, 128) == -1){
perror("listen error");
return -1;
}
struct sockaddr_in cin;
socklen_t socklen = sizeof(cin);
char buf[128] = "";
int res = -1;
struct pollfd fds[1024];
fds[0].fd = 0;
fds[0].events = POLLIN;
fds[1].fd = sfd;
fds[1].events = POLLIN;
struct sockaddr_in arr_cin[1024];
int newfd = -1;
int max = 2;
while(1){
res = poll(fds, max, -1);
if(res < 0){
perror("poll error");
return -1;
}else if(res == 0){
puts("time out");
return -1;
}
for(int index=0; index<max; index++){
if(fds[index].revents == POLLIN){
if(index == 0){
bzero(buf, sizeof(buf));
fgets(buf, sizeof(buf), stdin);
buf[strlen(buf) - 1] = 0;
for(int i=2; i<max; i++){
send(fds[i].fd, buf, sizeof(buf), 0);
}
}else if(index == 1){
if((newfd = accept(fds[index].fd, (struct sockaddr*)&cin, &socklen)) == -1){
perror("accept error");
return -1;
}
fds[max].fd = newfd;
fds[max].events = POLLIN;
max++;
arr_cin[newfd] = cin;
printf("[%s: %d] 已上线\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port));
}else{
bzero(buf, sizeof(buf));
res = recv(fds[index].fd, buf, sizeof(buf), 0);
if(res == 0){
puts("客户端已下线");
del_arr(fds, &max, index);
continue;
}
printf("[%s: %d] %s\n", inet_ntoa(arr_cin[fds[index].fd].sin_addr), ntohs(arr_cin[fds[index].fd].sin_port), buf);
}
}
}
}
close(sfd);
return 0;
}
client.c
#include <myhead.h>
#define PORT 8888
#define IP "192.168.125.137"
int main(int argc, const char *argv[])
{
int sfd = socket(AF_INET, SOCK_STREAM, 0);
if(sfd == -1){
perror("socket error");
return -1;
}
int reuse = -1;
if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1){
perror("setsockopt error");
return -1;
}
struct sockaddr_in sin;
sin.sin_family = AF_INET;
sin.sin_port = htons(PORT);
sin.sin_addr.s_addr = inet_addr(IP);
if(connect(sfd, (struct sockaddr*)&sin, sizeof(sin)) == -1){
perror("connect error");
return -1;
}
char buf[128] = "";
int res = -1;
struct pollfd fds[2];
fds[0].fd = 0;
fds[0].events = POLLIN;
fds[1].fd = sfd;
fds[1].events = POLLIN;
while(1){
res = poll(fds, 2, -1);
if(res < 0){
perror("poll error");
return -1;
}else if(res == 0){
puts("time out");
return -1;
}
if(fds[0].revents == POLLIN){
bzero(buf, sizeof(buf));
fgets(buf, sizeof(buf), stdin);
buf[strlen(buf) - 1] = 0;
send(sfd, buf, sizeof(buf), 0);
}
if(fds[1].revents == POLLIN){
bzero(buf, sizeof(buf));
res = recv(sfd, buf, sizeof(buf), 0);
if(res == 0){
puts("服务器已下线");
break;
}
printf("[%s: %d] %s\n", inet_ntoa(sin.sin_addr), ntohs(sin.sin_port), buf);
}
}
close(sfd);
return 0;
}
思维导图
文章来源:https://blog.csdn.net/qq_39831963/article/details/135117178
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符，请联系我的编程经验分享网邮箱：chenni525@qq.com进行投诉反馈，一经查实，立即删除！
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符，请联系我的编程经验分享网邮箱：chenni525@qq.com进行投诉反馈，一经查实，立即删除！
最新文章
- Python教程
- 深入理解 MySQL 中的 HAVING 关键字和聚合函数
- Qt之QChar编码（1）
- MyBatis入门基础篇
- 用Python脚本实现FFmpeg批量转换
- vue-springboot基于Java的仓库管理系统设计与实现 ep258
- windows高危端口使用批量排查
- 【python入门】day22：机票订购界面、北京地铁1号线运行图
- 时间注意力——给时间步赋予权重（有的时间不重要，权重很低，有的时间步重要，权重很高）
- C++知识补充（一）
- SLAM算法与工程实践——相机篇：传统相机使用（1）
- HarmonyOS 鸿蒙编译器运行失败
- 进口氟塑料容量瓶有哪些可以达到A级公差？
- harmonyOS鸿蒙内核概述
- 逆变器之变压器基础知识