linux socket编程epoll模型实现群发消息

1.实现功能

本代码主要实现了socket编程epoll模型实现多个客户端连接服务器，客户端可以进行群发消息和接收用户输入文本信息，然后发送该信息给服务器，服务器收到后发送应答信息。客户端接收并显示该应答信息，文章的后面会附上完整代码哦！

1.1

服务器使用epoll模型，支持多个客户端同时连接。

多个客户端同时连接

实现代码：

实现功能：客户端输入3333给服务器后服务器对客户端进行应答返回3333

实现代码

上线的客户端会存放到客户容器中，发送数据时会对这些客户端描述符都进行发送

实现功能：输入user会获取到所有的在线客户端的文件描述符

实现代码

实现功能：客户端输入exit或ctrl+c后退出该客户端

实现代码

输入事件判断如果没有接收到数据说明按下ctrl+c了，所以进行清除该文件描述符

输入exit也一致

客户端代码

#include<sys/types.h>
#include <sys/socket.h>
#include<stdio.h>
#include<stdlib.h>
#include<errno.h>
#include <string.h>
#include <unistd.h>
#include <sys/time.h>
#include <arpa/inet.h>
#include <sys/select.h>
#include <pthread.h>
int socket_fd;
char buff[1024];
void* pthread_fun(void* arg)
{while (1){memset(buff, 0, 1024);fgets(buff, sizeof(buff), stdin);write(socket_fd, buff, strlen(buff));if (strncmp(buff, "exit", 4) == 0){break;}}
}
int main()
{int num;int count = 0;char buff1[1024];struct sockaddr_in server_addr;int clientlist[1024];int i = 0;bzero(&server_addr, sizeof(struct sockaddr_in));server_addr.sin_family = AF_INET;//IPV4server_addr.sin_port = htons(8888);inet_aton("127.0.0.1", &server_addr.sin_addr);socket_fd = socket(AF_INET, SOCK_STREAM, 0);if (socket_fd == -1){printf("socket error %s\n", strerror(errno));exit(-1);}if (connect(socket_fd, (struct sockaddr*)&server_addr, sizeof(struct sockaddr)) == -1){printf("connect error %s\n", strerror(errno));exit(-1);}printf("connect success\n");pthread_t thread;int res;res = pthread_create(&thread, NULL, pthread_fun, NULL);if (res != 0){printf("pthread_create error:%s\n", strerror(res));}while (true){memset(buff,0,sizeof(buff));read(socket_fd,buff,sizeof(buff));if (strncmp(buff, "exit", 4) == 0){break;}else if (strncmp(buff, "user", 4) == 0){memset(buff1, 0, sizeof(buff1));count = 0;read(socket_fd, clientlist, sizeof(clientlist));printf("client list\n");for (i = 0; i < 1024; i++){if (clientlist[i] != 0){memset(buff1, 0, sizeof(buff1));count++;sprintf(buff1, "client%d", clientlist[i]);printf("%d:%s\n",count,buff1);}}//printf("client list\n");//for (i = 0; clientlist[i]; i++)//{//   memset(buff1, 0, sizeof(buff1));//  count++;//    sprintf(buff1, "client%d", clientlist[i]);//  printf("%d:%s\n",count,buff1);//}//for (map<int, string>::iterator it = client_map.begin(); it != client_map.end(); it++)//{//  memset(buff1, 0, sizeof(buff1));//  count++;//    //sprintf(buff1, "client%d", it->first);// printf("%d\n",count);//}}else{printf("%s\n", buff);}}close(socket_fd);return 0;
}

服务器代码

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <arpa/inet.h>
#include <errno.h>
#include <unistd.h>
#include <sys/epoll.h>
#include <map>
#include <string>
using namespace std;
map<int, string> client_map;
int count = 0;
int clientlist[1024] = { 0 };
void handle_accept(int epollfd, int socket_fd);
int main()
{int i;int res;struct sockaddr_in server_addr;int socket_fd;socket_fd = socket(AF_INET, SOCK_STREAM, 0);if (socket_fd == -1){printf("socket error:%s", strerror(errno));exit(1);}//设置地址重用int opt;if (setsockopt(socket_fd, SOL_SOCKET, SO_REUSEADDR, (const char*)&opt, sizeof(opt)) < 0){perror("setsockopt\n");close(socket_fd);exit(1);}bzero(&server_addr, sizeof(struct sockaddr_in));server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = INADDR_ANY;server_addr.sin_port = htons(8888);res = bind(socket_fd, (const sockaddr*)&server_addr, sizeof(struct sockaddr_in));if (res == -1){printf("bind error:%s", strerror(errno));exit(1);}res = listen(socket_fd, 1024);if (res == -1){printf("listen error:%s", strerror(errno));exit(1);}//epoll流程int epollfd;int ret;epollfd = epoll_create(1500);struct epoll_event event;event.events = EPOLLIN;event.data.fd = socket_fd;//添加监听文件描述符事件epoll_ctl(epollfd, EPOLL_CTL_ADD, socket_fd, &event);int fd;while (1){struct epoll_event events[100];//查询就绪表 获取已经就绪的事件ret=epoll_wait(epollfd, events, 100, -1);printf("ret=%d\n", ret);for (i = 0; i < ret; i++){fd = events[i].data.fd;if ((fd == socket_fd) && (events[i].events & EPOLLIN)){handle_accept(epollfd, socket_fd);continue;}else if (events[i].events & EPOLLIN){int num;char buff[1024];char buff1[1024];//输入事件memset(buff, 0, sizeof(buff));memset(buff1, 0, sizeof(buff1));num=read(events[i].data.fd, buff, sizeof(buff));if (num <= 0){memset(&event, 0, sizeof(struct epoll_event));event.events = EPOLLIN;event.data.fd = events[i].data.fd;epoll_ctl(epollfd, EPOLL_CTL_DEL, events[i].data.fd, &event);close(events[i].data.fd);client_map.erase(events[i].data.fd);continue;}else{if (strncmp(buff,"exit",4) == 0){write(events[i].data.fd, buff, sizeof(buff));memset(&event, 0, sizeof(struct epoll_event));event.events = EPOLLIN;event.data.fd = events[i].data.fd;epoll_ctl(epollfd, EPOLL_CTL_DEL, events[i].data.fd, &event);close(events[i].data.fd);client_map.erase(events[i].data.fd);clientlist[events[i].data.fd-5] = 0;continue;}else if(strncmp(buff, "user", 4) == 0){//for (int i = 0; i < 1024; i++)//{// clientlist[i] = 0;//}write(events[i].data.fd, buff, sizeof(buff));i = 0;//for (map<int, string>::iterator it = client_map.begin(); it != client_map.end(); it++)//{//   clientlist[i] = it->first;//    i++;//    printf("i=%d\n", i);//}/*printf("it->first=%d\n", clientlist[0]);*/write(events[i].data.fd, clientlist , sizeof(clientlist));continue;}else{for (map<int, string>::iterator it = client_map.begin(); it != client_map.end(); it++){sprintf(buff1, "receive client%d content:%s", events[i].data.fd, buff);write(it->first, buff1, sizeof(buff1));}}}continue;}}}close(epollfd);close(socket_fd);return 0;
}
void handle_accept(int epollfd, int socket_fd)
{struct epoll_event ev;socklen_t len;struct sockaddr_in client_addr;int new_fd;len = sizeof(struct sockaddr);new_fd = accept(socket_fd, (struct sockaddr*)(&client_addr), &len);printf("1111\n");if (new_fd == -1){printf("accept error:%s", strerror(errno));exit(1);}else{printf("new_fd: %d IP:%s PORT %d\n", new_fd, inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));//添加来自客户端的描述符和事件ev.data.fd = new_fd;ev.events = EPOLLIN;epoll_ctl(epollfd, EPOLL_CTL_ADD, new_fd, &ev);//添加到用户上线容器中char str[80];sprintf(str, "clinet%d", count);client_map.insert(pair<int,string>(new_fd,str));clientlist[count] = new_fd;count++;}
}

第一次写博客写的比较糟，如果大家对代码有问题的话可以在下面留言，我会及时进行回复的

linux socket编程epoll模型实现群发消息相关推荐

linux线程同步 epoll,Linux网络编程--epoll 模型原理详解以及实例
1.简介 Linux I/O多路复用技术在比较多的TCP网络服务器中有使用,即比较多的用到select函数.Linux 2.6内核中有提高网络I/O性能的新方法,即epoll . epoll是什么?按 ...
socket编程 -- epoll模型服务端/客户端通信的实现
https://blog.csdn.net/y396397735/article/details/50680359 本例实现如下功能: 支持多客户端与一个服务端进行通信,客户端给服务端发送字符串数据, ...
对于linux socket与epoll配合相关的一些心得记录
对于linux socket与epoll配合相关的一些心得记录没有多少高深的东西,全当记录,虽然简单,但是没有做过测试还是挺容易让人糊涂的 int nRecvBuf=32*1024;//设置为32K ...
Linux Socket编程
IP socket 是在其上建立高级Internet 协议的最低级的层:从HTTP到SSL到POP3到Kerberos再到UDP-Time,每种Internet协议都建立在它的基础上.为了实现自定义的 ...
linux socket 编程
socket <script type="text/javascript"> </script> <script type="text/j ...
Linux网络服务器epoll模型的socket通讯的实现(一)
准备写一个网络游戏的服务器的通讯模块,参考网上看到的一些代码,在linux下面实现一个多线程的epoll模型的socket通讯的代码,以下是第一部分多线程的切换代码: 1 #include <s ...
【Linux Socket 编程入门】05 - 拉个骡子溜溜：TCP编程模型代码分析
(一) 看看以前学了啥前面介绍了socket的分类,IP地址,端口号(port),常用的socket数据结构以及常用的函数.现在我们来看一个例子,看看socket编程究竟是什么. (二) 一图看懂客 ...
网络编程——epoll模型编程
文章目录目的内容代码及测试结果 (1) 使用条件触发方式实现回声服务器端(及客户端): (2) 使用边缘触发方式实现回声服务器端(及客户端): (3) 实现聊天服务器端,使其可以在连接到服务器端 ...
linux下编程epoll实现将GPS定位信息上报到服务器
操作系统:CentOS 开发板:fl2440 开发模块:A7(GPS/GPRS),RT3070(无线网卡) ********************************************** ...

linux socket编程epoll模型实现群发消息

linux socket编程epoll模型实现群发消息相关推荐

最新文章

热门文章