一、通過select搭建TCP服務(wù)器
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <string.h>
#include <unistd.h>
#include <sys/time.h>
#define PORT 8808
#define IP "192.168.122.92"
int main(int argc, const char *argv[])
{
//創(chuàng)建流式套接字
int sfd = socket(AF_INET,SOCK_STREAM,0);
if(sfd < 0)
{
perror("socket");
fprintf(stderr,"socket failed __%d__\n",__LINE__);
return -1;
}
printf("socket success...\n");
//設(shè)置允許端口號(hào)復(fù)用
int reuse = 1;
if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0)
{
perror("setsockopt");
return -1;
}
//填充地址信息結(jié)構(gòu)體，真是的地址信息結(jié)構(gòu)體根據(jù)地址族制定
struct sockaddr_in sin;
sin.sin_family = AF_INET;
sin.sin_port = htons(PORT);
sin.sin_addr.s_addr = inet_addr(IP);
//綁定服務(wù)器IP和端口號(hào)
if(bind(sfd,(struct sockaddr *)&sin,sizeof(sin)) < 0)
{
perror("bind");
fprintf(stderr,"bind failed __%d__\n",__LINE__);
return -1;
}
printf("bind success...\n");
//將套接字設(shè)置為被動(dòng)監(jiān)聽狀態(tài)
if(listen(sfd,10) < 0)
{
perror("listen");
return -1;
}
printf("listen success...\n");
//從已完成連接的隊(duì)列中獲取一個(gè)客戶信息，生成一個(gè)新的文件描述符，該文件描述符才是與客戶端通信的文件描述符
struct sockaddr_in cin[1021];
socklen_t addrlen = sizeof(cin);
int s_res = -1;
fd_set readfds;
fd_set tempfds;
FD_ZERO(&readfds);
FD_ZERO(&tempfds);
FD_SET(0,&readfds);
FD_SET(sfd,&readfds);
ssize_t res = 0;
char buf[128] = "";
int newfd = -1;
int maxfd = sfd;
int j = 0;
while(1)
{
tempfds = readfds;
s_res = select(maxfd+1,&tempfds,NULL,NULL,NULL);
if(s_res < 0)
{
perror("select");
return -1;
}
else if(0 == s_res)
{
break;
}
for(int i=0;i<=maxfd;i++)
{
if(!FD_ISSET(i,&tempfds))
continue;
if(0 == i)
{
fgets(buf,sizeof(buf),stdin);
buf[strlen(buf)-1] = 0;
printf("%s\n",buf);
}
else if(sfd == i)
{
newfd = accept(sfd,(struct sockaddr *)&(cin[j]),&addrlen);
cin[newfd] = cin[j];
if(newfd < 0)
{
perror("accept");
return -1;
}
printf("[%s : %d] accept success\n",inet_ntoa(cin[newfd].sin_addr),ntohs(cin[newfd].sin_port));
FD_SET(newfd,&readfds);
maxfd = maxfd > newfd ? maxfd : newfd;
}
else
{
bzero(buf,sizeof(buf));
res = recv(i,buf,sizeof(buf),0);
if(res < 0)
{
perror("recv");
return -1;
}
else if(0 == res)
{
printf("[%s : %d] client offline\n",inet_ntoa(cin[i].sin_addr),ntohs(cin[i].sin_port));
close(i);
FD_CLR(i,&readfds);
while(FD_ISSET(maxfd,&readfds) == 0 && maxfd-->=0);
continue;
}
printf("[%s : %d] %s\n",inet_ntoa(cin[i].sin_addr),ntohs(cin[i].sin_port),buf);
//發(fā)送數(shù)據(jù)
if(send(i,buf,sizeof(buf),0) < 0)
{
perror("send");
return -1;
}
}
}
}
//關(guān)閉所有文件描述符
close(sfd);
return 0;
}二、通過select搭建TCP客戶端
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <string.h>
#include <unistd.h>
#define PORT 8808
#define IP "192.168.122.92"
int main(int argc, const char *argv[])
{
//創(chuàng)建流式套接字
int cfd = socket(AF_INET,SOCK_STREAM,0);
if(cfd < 0)
{
perror("socket");
fprintf(stderr,"socket failed __%d__\n",__LINE__);
return -1;
}
printf("socket success...\n");
//設(shè)置允許端口號(hào)復(fù)用
int reuse = 1;
if(setsockopt(cfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0)
{
perror("setsockopt");
return -1;
}
//填充地址信息結(jié)構(gòu)體，真是的地址信息結(jié)構(gòu)體根據(jù)地址族制定
struct sockaddr_in sin;
sin.sin_family = AF_INET;
sin.sin_port = htons(PORT);
sin.sin_addr.s_addr = inet_addr(IP);
//連接服務(wù)器
if(connect(cfd,(struct sockaddr *)&sin,sizeof(sin)) < 0)
{
perror("connetc");
return -1;
}
printf("connect success...\n");
ssize_t res = 0;
char buf[128] = "";
int s_res = -1;
fd_set readfds;
fd_set tempfds;
FD_ZERO(&readfds);
FD_SET(0,&readfds);
FD_SET(cfd,&readfds);
while(1)
{
tempfds = readfds;
s_res = select(cfd+1,&tempfds,NULL,NULL,NULL);
if(s_res < 0)
{
perror("select");
return -1;
}
else if(0 == s_res)
{
break;
}
if(FD_ISSET(0,&tempfds))
{
bzero(buf,sizeof(buf));
fgets(buf,sizeof(buf),stdin);
buf[strlen(buf)-1] = 0;
//發(fā)送數(shù)據(jù)
if(send(cfd,buf,sizeof(buf),0) < 0)
{
perror("send");
return -1;
}
}
if(FD_ISSET(cfd,&tempfds))
{
//接受數(shù)據(jù)
bzero(buf,sizeof(buf));
res = recv(cfd,buf,sizeof(buf),0);
if(res < 0)
{
perror("recv");
return -1;
}
else if(0 == res)
{
printf("[%s : %d] server offline\n",IP,PORT);
break;
}
printf("[%s : %d] %s\n",IP,PORT,buf);
}
}
//關(guān)閉所有文件描述符
close(cfd);
return 0;
}三、通過poll搭建客戶端
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <string.h>
#include <unistd.h>
#include <poll.h>
#define PORT 8808
#define IP "192.168.122.92"
int main(int argc, const char *argv[])
{
//創(chuàng)建流式套接字
int cfd = socket(AF_INET,SOCK_STREAM,0);
if(cfd < 0)
{
perror("socket");
fprintf(stderr,"socket failed __%d__\n",__LINE__);
return -1;
}
printf("socket success...\n");
//設(shè)置允許端口號(hào)復(fù)用
int reuse = 1;
if(setsockopt(cfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0)
{
perror("setsockopt");
return -1;
}
//填充地址信息結(jié)構(gòu)體，真是的地址信息結(jié)構(gòu)體根據(jù)地址族制定
struct sockaddr_in sin;
sin.sin_family = AF_INET;
sin.sin_port = htons(PORT);
sin.sin_addr.s_addr = inet_addr(IP);
//連接服務(wù)器
if(connect(cfd,(struct sockaddr *)&sin,sizeof(sin)) < 0)
{
perror("connetc");
return -1;
}
printf("connect success...\n");
ssize_t res = 0;
char buf[128] = "";
int p_res = -1;
struct pollfd fds[2];
fds[0].fd = 0;
fds[0].events = POLLIN;
fds[1].fd = cfd;
fds[1].events = POLLIN;
while(1)
{
p_res = poll(fds,2,-1);
if(p_res < 0)
{
perror("select");
return -1;
}
else if(0 == p_res)
{
break;
}
if(fds[0].revents & POLLIN != 0)
{
bzero(buf,sizeof(buf));
fgets(buf,sizeof(buf),stdin);
buf[strlen(buf)-1] = 0;
//發(fā)送數(shù)據(jù)
if(send(cfd,buf,sizeof(buf),0) < 0)
{
perror("send");
return -1;
}
}
if(fds[1].revents & POLLIN)
{
//接受數(shù)據(jù)
bzero(buf,sizeof(buf));
res = recv(cfd,buf,sizeof(buf),0);
if(res < 0)
{
perror("recv");
return -1;
}
else if(0 == res)
{
printf("[%s : %d] server offline\n",IP,PORT);
break;
}
printf("[%s : %d] %s\n",IP,PORT,buf);
}
}
//關(guān)閉所有文件描述符
close(cfd);
return 0;
}文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-663082.html
文章來(lái)源：http://www.zghlxwxcb.cn/news/detail-663082.html
到了這里，關(guān)于IO多路復(fù)用練習(xí)的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
![[Linux] 網(wǎng)絡(luò)編程 - 初見TCP套接字編程: 實(shí)現(xiàn)簡(jiǎn)單的單進(jìn)程、多進(jìn)程、多線程、線程池tcp服務(wù)器](https://imgs.yssmx.com/Uploads/2024/02/568904-1.gif)
