//head.h? ? ? ? ? ? 頭文件
//TcpGrpSer.c? ? ?服務(wù)器端
//TcpGrpUsr.c? ? ?客戶端
通過IO多路復(fù)用實現(xiàn)服務(wù)器在單進程單線程下可以與多個客戶端交互
?API
epoll函數(shù)
#include<sys/epoll.h> int epoll_create(int size); 功能：創(chuàng)建一個epoll句柄//創(chuàng)建紅黑樹根節(jié)點 epoll把要監(jiān)測的事件文件描述符掛載到紅黑樹上 參數(shù)：size 沒有意義，但是必須>0 返回值：成功返回根節(jié)點對應(yīng)的文件描述符，失敗返回-1 int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event); 功能:實現(xiàn)對于epoll的控制 參數(shù)： epfd:epoll_create創(chuàng)建的句柄 op：控制方式 EPOLL_CTL_ADD:添加要監(jiān)測的事件文件描述符 EPOLL_CTL_MOD：修改epoll檢測的事件類型 EPOLL_CTL_DEL：將文件描述符從epoll刪除 fd:要操作的文件描述符 event:事件結(jié)構(gòu)體 typedef union epoll_data { void *ptr; int fd;//使用這個 uint32_t u32; uint64_t u64; } epoll_data_t; struct epoll_event { uint32_t events; //EPOLLIN(讀) EPOLLOUT（寫） epoll_data_t data; /* User data variable */ }; 返回值：成功返回0，失敗返回-1 int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout); 功能：阻塞等待準(zhǔn)備好的文件描述符 參數(shù)： epfd:epoll句柄 events:存放就緒事件描述符的結(jié)構(gòu)體數(shù)組首地址 maxevents:監(jiān)聽的事件最大個數(shù) timeout:超時檢測 >0:毫秒級檢測 ==0：立即返回 -1：不關(guān)心是否超時 返回值： >0:準(zhǔn)備好的文件描述符的個數(shù) ==0：超時 <0:失敗
?head.h
#ifndef __HEAD_H__
#define __HEAD_H__
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<math.h>
#include<errno.h>
#include<fcntl.h>
#include<signal.h>
#include<sys/stat.h>
#include<sys/wait.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include<sys/shm.h>
#include<sys/time.h>
#include<sys/sem.h>
#include<pthread.h>
#include<semaphore.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<sys/select.h>
#include<poll.h>
#include<sys/epoll.h>
#include<sys/fcntl.h>
#define NUM 10
#define ERR_MSG(msg) \
do \
{ \
printf("line: %d\n", __LINE__); \
perror(msg); \
} while (0)
#define PORT 6666 // 端口號的網(wǎng)絡(luò)字節(jié)序 1024～49151
#define IP "192.168.250.100" // ifconfig查看本機IP (ipv4)
#endif
TcpGrpSer.c
#include "head.h"
int main(int argc, const char *argv[])
{
// 創(chuàng)建流式套接字
int sfd = socket(AF_INET, SOCK_STREAM, 0);
if (sfd < 0)
{
ERR_MSG("socket");
return -1;
}
// 填充服務(wù)器自身的地址信息結(jié)構(gòu)體
// 真實的地址信息結(jié)構(gòu)體根據(jù)地址族制定AF_INET ;
struct sockaddr_in sin;
sin.sin_family = AF_INET; // 必須填充AF_INET
sin.sin_port = htons(PORT); // 端口號的網(wǎng)絡(luò)字節(jié)序 1024～49151
sin.sin_addr.s_addr = inet_addr(IP); // ifconfig查看本機IP
int reuse = 1;
if (setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0) // 允許端口快速被重復(fù)使用
{
ERR_MSG("setsockopt");
return -1;
}
// 綁定連接
if (bind(sfd, (struct sockaddr *)&sin, sizeof(sin)) < 0)
{
ERR_MSG("bind");
return -1;
}
printf("bind success\n");
// 設(shè)置監(jiān)聽
if (listen(sfd, 128) < 0)
{
ERR_MSG("listen");
return -1;
}
struct epoll_event event;
struct epoll_event events[10]; // 存放就緒事件描述符的數(shù)組
char buf[128] = {0};
// 創(chuàng)建epoll句柄
int epfd = epoll_create(1);
if (epfd < 0)
{
ERR_MSG("epoll_create");
exit(-1);
}
// 添加準(zhǔn)備就緒事件進入epoll;
event.events = EPOLLIN; // 讀事件
event.data.fd = sfd; // 監(jiān)聽套接字放入列表
if (epoll_ctl(epfd, EPOLL_CTL_ADD, sfd, &event) < 0)
{
ERR_MSG("epoll_ctl");
exit(-1);
}
event.events = EPOLLIN; // 讀事件
event.data.fd = 0; // 終端輸入套接字放入列表
if (epoll_ctl(epfd, EPOLL_CTL_ADD, 0, &event) < 0)
{
ERR_MSG("epoll_ctl");
exit(-1);
}
// 監(jiān)聽事件是否發(fā)生
int s_res = 0;
struct sockaddr_in cin;
socklen_t len = sizeof(cin);
struct sockaddr_in savcin[1024];
int flags[1024] = {0};
int newfd = -1;
ssize_t res = 0;
while (1)
{
// 監(jiān)測文件描述符是否準(zhǔn)備就緒
// 如果成功，s_res接收返回的事件個數(shù)，就緒的事件存儲到events數(shù)組中
s_res = epoll_wait(epfd, events, 10, -1);
if (s_res < 0)
{
ERR_MSG("select");
return -1;
}
// 與客戶端通信
for (int i = 0; i < s_res; i++)
{
if (events[i].events & EPOLLIN)
{
if (events[i].data.fd == sfd)
{
printf("客戶端連技事件\n");
newfd = accept(sfd, (struct sockaddr *)&cin, &len);
if (newfd < 0)
{
perror("accept");
return -1;
}
savcin[newfd] = cin;
flags[newfd] = 1;
printf("[%s:%d] 客戶端連接成功 newfd = %d __%d__ \n",
inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), newfd, __LINE__);
event.events = EPOLLIN | EPOLLET; // 讀事件
event.data.fd = newfd; // 新套接字放入鏈表
if (epoll_ctl(epfd, EPOLL_CTL_ADD, newfd, &event) < 0)
{
ERR_MSG("epoll_ctl");
exit(-1);
}
}
else if (0 == events[i].data.fd)
{
printf("觸發(fā)鍵盤輸入事件\n");
int sndfd=-1;
res=scanf("%d %s",&sndfd,buf);
while(getchar() !=10);
if(res!=2)
{
printf("請輸入正確數(shù)據(jù)格式：[fd(4~1023)] string\n");
continue;
}
//判斷文件是否合法
if(flags[i])
{
printf("sndfd = %d 是非法文件描述符\n",sndfd);
continue;
}
if(send(sndfd,buf,sizeof(buf),0)<0)
{
ERR_MSG("send");
}
bzero(buf,sizeof(buf));
}
else
{
printf("客戶端交互事件\n");
// res = scanf("%s", buf);
// while (getchar() != 10)
res = recv(events[i].data.fd, buf, sizeof(buf), 0);
if (res < 0)
{
ERR_MSG("send");
return -1;
}
else if (0 == res)
{
printf("[%s:%d] 客戶端下線 newfd = %d __%d__ \n",
inet_ntoa(savcin[i].sin_addr), ntohs(savcin[i].sin_port), events[i].data.fd, __LINE__);
close(i); // 關(guān)閉文件描述符
flags[i] = 0;
}
printf("[%s:%d] 客戶端 newfd = %d : %s, __%d__ \n",
inet_ntoa(savcin[i].sin_addr), ntohs(savcin[i].sin_port), events[i].data.fd, buf, __LINE__);
}
}
}
}
if (close(sfd) < 0)
{
ERR_MSG("close");
return -1;
}
return 0;
}
TcpGrpUsr.c文章來源：http://www.zghlxwxcb.cn/news/detail-665075.html
#include "head.h"
int main(int argc, const char *argv[])
{
//創(chuàng)建流式套接字
int sfd = socket(AF_INET,SOCK_STREAM,0);
if(sfd<0)
{
ERR_MSG("socket");
return -1;
}
int reuse = 1;
if(setsockopt(sfd, SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse)) < 0) //允許端口快速被重復(fù)使用
{
ERR_MSG("setsockopt");
return -1;
}
//填充服務(wù)器自身的地址信息結(jié)構(gòu)體
//真實的地址信息結(jié)構(gòu)體根據(jù)地址族制定AF_INET ; man 7 ip
struct sockaddr_in sin;
sin.sin_family = AF_INET; //必須填充AF_INET
sin.sin_port = htons(PORT); //端口號的網(wǎng)絡(luò)字節(jié)序 1024～49151
sin.sin_addr.s_addr = inet_addr(IP); //ifconfig查看本機IP
if(connect(sfd,(struct sockaddr *)&sin,sizeof(sin))<0)
{
perror("connect");
return -1;
}
printf("連接成功\n");
//創(chuàng)建集合
struct pollfd fds[2];
fds[0].fd = 0;
fds[0].events = POLLIN;
fds[1].fd = sfd;
fds[1].events = POLLIN;
char buf[128]="";
int res=0;
while(1)
{
//阻塞方式監(jiān)測集合
res = poll(fds,2,-1);
if(res < 0)
{
ERR_MSG("poll");
return -1;
}
else if(0 == res)
{
printf("time out...\n"); //超時
break;
}
//判斷0文件描述符是否右POLLIN事件
if((fds[0].revents & POLLIN))
{
fgets(buf,sizeof(buf),stdin);
buf[strlen(buf)-1] = 0;
if(send(sfd,buf,sizeof(buf),0) < 0)
{
ERR_MSG("send");
return -1;
}
printf("發(fā)送成功\n");
}
//判斷sfd文件描述符是否右POLLIN事件
if(fds[1].revents & POLLIN)
{
//接收數(shù)據(jù)
bzero(buf,sizeof(buf));
res = recv(sfd,buf,sizeof(buf),0);
if(res<0)
{
ERR_MSG("recv");
return -1;
}
else if(res == 0)
{
printf("[%s:%d] 服務(wù)器下線__%d__ \n",\
inet_ntoa(sin.sin_addr),ntohs(sin.sin_port),__LINE__);
break;
}
printf("[%s:%d] cfd = %d : %s__%d__ \n",\
inet_ntoa(sin.sin_addr),ntohs(sin.sin_port),sfd,buf,__LINE__);
}
}
if(close(sfd)<0)
{
ERR_MSG("close");
return -1;
}
return 0;
}
![網(wǎng)絡(luò)編程 IO多路復(fù)用 [epoll版] (TCP網(wǎng)絡(luò)聊天室),網(wǎng)絡(luò)編程,網(wǎng)絡(luò),php,開發(fā)語言](https://imgs.yssmx.com/Uploads/2023/08/665075-1.png)
?文章來源地址http://www.zghlxwxcb.cn/news/detail-665075.html
到了這里，關(guān)于網(wǎng)絡(luò)編程 IO多路復(fù)用 [epoll版] (TCP網(wǎng)絡(luò)聊天室)的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
