- 浏览: 159100 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
yuanyu5237:
Michyo 写道你好,我是用了您的第二段模块代码,但是为什么 ...
32位linux内核2.6.38.2添加系统调用,并编写模块模拟ps命令显示进程信息 -
yuanyu5237:
haolifeng 写道如果不对客户端的连接文件描述符进行监听 ...
简单epoll多线程服务器 -
haolifeng:
如果不对客户端的连接文件描述符进行监听,你这个服务器是有问题的 ...
简单epoll多线程服务器 -
haolifeng:
我对你的代码有一个问题,当获得客户端的连接文件描述符后,为什么 ...
简单epoll多线程服务器 -
Michyo:
你好,我是用了您的第二段模块代码,但是为什么添加了模块后没有输 ...
32位linux内核2.6.38.2添加系统调用,并编写模块模拟ps命令显示进程信息
简单epoll多线程服务器
- 博客分类:
- C/C++
学习
/* Linux 2.6 x86_64 only*/ #include <pthread.h> #include <string.h> #include <stdlib.h> #include <unistd.h> #include <stdio.h> #include <fcntl.h> #include <arpa/inet.h> #include <sys/epoll.h> #include <sys/errno.h> #include <sys/socket.h> #define THREAD_MAX 20 #define LISTEN_MAX 20 #define SERVER_IP "127.0.0.1" typedef struct { char ip4[128]; int port; int fd; } LISTEN_INFO; //服务器参数 static LISTEN_INFO s_listens[LISTEN_MAX]; //线程池参数 static unsigned int s_thread_para[THREAD_MAX][8];//线程参数 static pthread_t s_tid[THREAD_MAX];//线程ID pthread_mutex_t s_mutex[THREAD_MAX];//线程锁 //私有函数 static int init_thread_pool(void);//初始化数据 static int init_listen4(char *ip4, int port, int max_link); //初始化监听 //线程函数 void * test_server4(unsigned int thread_para[]); //设置文件描述符为NonBlock bool setNonBlock(int fd) { int flags = fcntl(fd, F_GETFL, 0); flags |= O_NONBLOCK; if(-1 == fcntl(fd, F_SETFL, flags)) return false; return true; } int main(int argc, char *argv[])//客户端驱动 { //临时变量 int i, j, rc; int sock_listen; //监听套接字 int sock_cli; //客户端连接 int listen_index; int epfd; int nfds; struct epoll_event ev; struct epoll_event events[LISTEN_MAX]; socklen_t addrlen; //地址信息长度 struct sockaddr_in addr4; //IPv4地址结构 //线程池初始化 rc = init_thread_pool(); if (0 != rc) exit(-1); //初始化服务监听 for(i = 0; i < LISTEN_MAX; i++) { sprintf(s_listens[i].ip4, "%s", SERVER_IP); s_listens[i].port = 40000 + i; //创建监听 rc = init_listen4(s_listens[i].ip4, s_listens[i].port, 64); if (0 > rc) { fprintf(stderr, "无法创建服务器监听于%s:%d\r\n", s_listens[i].ip4, s_listens[i].port); exit(-1); } else { fprintf(stdout, "已创建服务器监听于%s:%d\r\n", s_listens[i].ip4, s_listens[i].port); } s_listens[i].fd = rc; } //设置集合 epfd = epoll_create(8192); for (i = 0; i < LISTEN_MAX; i++) { //加入epoll事件集合 ev.events = EPOLLIN | EPOLLET; ev.data.u32 = i;//记录listen数组下标 if (epoll_ctl(epfd, EPOLL_CTL_ADD, s_listens[i].fd, &ev) < 0) { fprintf(stderr, "向epoll集合添加套接字失败(fd =%d)\r\n", rc); exit(-1); } } //服务循环 for( ; ; ) { //等待epoll事件 nfds = epoll_wait(epfd, events, LISTEN_MAX, -1); //处理epoll事件 for(i = 0; i < nfds; i++) { //接收客户端连接 listen_index = events[i].data.u32; sock_listen = s_listens[listen_index].fd; addrlen = sizeof(struct sockaddr_in); bzero(&addr4, addrlen); sock_cli = accept(sock_listen, (struct sockaddr *)&addr4, &addrlen); if(0 > sock_cli) { fprintf(stderr, "接收客户端连接失败\n"); continue; } else { char *myIP = inet_ntoa(addr4.sin_addr); printf("accept a connection from %s...\n", myIP); } setNonBlock(sock_cli); //查询空闲线程对 for(j = 0; j < THREAD_MAX; j++) { if (0 == s_thread_para[j][0]) break; } if (j >= THREAD_MAX) { fprintf(stderr, "线程池已满, 连接将被放弃\r\n"); shutdown(sock_cli, SHUT_RDWR); close(sock_cli); continue; } //复制有关参数 s_thread_para[j][0] = 1;//设置活动标志为"活动" s_thread_para[j][1] = sock_cli;//客户端连接 s_thread_para[j][2] = listen_index;//服务索引 //线程解锁 pthread_mutex_unlock(s_mutex + j); }//end of for(i;;) }//end of for(;;) exit(0); } static int init_thread_pool(void) { int i, rc; //初始化线程池参数 for(i = 0; i < THREAD_MAX; i++) { s_thread_para[i][0] = 0;//设置线程占用标志为"空闲" s_thread_para[i][7] = i;//线程池索引 pthread_mutex_lock(s_mutex + i);// 这个地方为什么要加锁?不加锁创建监听有时会不成功 } //创建线程池 for(i = 0; i < THREAD_MAX; i++) { rc = pthread_create(s_tid + i, 0, (void* (*)(void *))test_server4, (void *)(s_thread_para[i])); if (0 != rc) { fprintf(stderr, "线程创建失败\n"); return(-1); } } //成功返回 return(0); } static int init_listen4(char *ip4, int port, int max_link) { //临时变量 int sock_listen4; struct sockaddr_in addr4; unsigned int optval; struct linger optval1; //初始化数据结构 bzero(&addr4, sizeof(addr4)); //inet_pton将点分十进制IP转换为整数 inet_pton(AF_INET, ip4, &(addr4.sin_addr)); addr4.sin_family = AF_INET; //htons将无符号short从主机字节序(x86:Big-Endian)转换为网络字节序 addr4.sin_port = htons(port); //创建流类型的SOCKET sock_listen4 = socket(AF_INET, SOCK_STREAM, 0); if (0 > sock_listen4) { fprintf(stderr, "创建socket异常, sock_listen4:%d\n", sock_listen4); perror("创建socket异常"); return(-1); } //设置SO_REUSEADDR选项(服务器快速重起) optval = 0x1; setsockopt(sock_listen4, SOL_SOCKET, SO_REUSEADDR, &optval, 4); //设置SO_LINGER选项(防范CLOSE_WAIT挂住所有套接字) optval1.l_onoff = 1; optval1.l_linger = 60; setsockopt(sock_listen4, SOL_SOCKET, SO_LINGER, &optval1, sizeof(struct linger)); if (0 > bind(sock_listen4, (struct sockaddr *)&addr4, sizeof(addr4))) { fprintf(stderr, "bind socket异常, sock_listen4:%d\n", sock_listen4); perror("bind socket异常"); close(sock_listen4); return(-1); } if (0 > listen(sock_listen4, max_link)) { fprintf(stderr, "listen socket异常, sock_listen4:%d\n", sock_listen4); perror("listen socket异常"); close(sock_listen4); return(-1); } return (sock_listen4); } void * test_server4(unsigned int thread_para[]) { //临时变量 int sock_cli; //客户端连接 int pool_index; //线程池索引 int listen_index; //监听索引 char buff[32768]; //传输缓冲区 int i, j, len; char *p; //线程脱离创建者 pthread_detach(pthread_self()); pool_index = thread_para[7]; wait_unlock: pthread_mutex_lock(s_mutex + pool_index);//等待线程解锁 //线程变量内容复制 sock_cli = thread_para[1];//客户端连接 listen_index = thread_para[2];//监听索引 //接收请求 len = recv(sock_cli, buff, sizeof(buff), MSG_NOSIGNAL); printf("%s\n", buff); //构造响应 p = buff; //HTTP头 p += sprintf(p, "HTTP/1.1 200 OK\r\n"); p += sprintf(p, "Content-Type: text/html\r\n"); p += sprintf(p, "Connection: closed\r\n\r\n"); //页面 p += sprintf(p, "<html>\r\n<head>\r\n"); p += sprintf(p, "<meta content=\"text/html; charset=UTF-8\" http-equiv=\"Content-Type\">\r\n"); p += sprintf(p, "</head>\r\n"); p += sprintf(p, "<body style=\"background-color: rgb(229, 229, 229);\">\r\n"); p += sprintf(p, "<center>\r\n"); p += sprintf(p, "<H3>连接状态</H3>\r\n"); p += sprintf(p, "<p>服务器地址 %s:%d</p>\r\n", s_listens[listen_index].ip4, s_listens[listen_index].port); j = 0; for(i = 0; i < THREAD_MAX; i++) { if (0 != s_thread_para[i][0]) j++; } p += sprintf(p, "<H3>线程池状态</H3>\r\n"); p += sprintf(p, "<p>线程池总数 %d 活动线程总数 %d</p>\r\n", THREAD_MAX, j); p += sprintf(p, "</center></body></html>\r\n"); len = p - buff; //发送响应 send(sock_cli, buff, len, MSG_NOSIGNAL); memset(buff, 0, 32768); //释放连接 shutdown(sock_cli, SHUT_RDWR); close(sock_cli); //线程任务结束 thread_para[0] = 0;//设置线程占用标志为"空闲" goto wait_unlock; pthread_exit(NULL); }g++ epollthreadpoll.cpp lpthread
评论
3 楼
yuanyu5237
2013-12-19
haolifeng 写道
如果不对客户端的连接文件描述符进行监听,你这个服务器是有问题的!
这个实现确实不好,使用了epoll,就没必要多线程,这里客户端获得连接后就单独在另外的线程里处理,没有继续进行事件监听,这是我的理解,不知道对不对
2 楼
haolifeng
2013-06-08
如果不对客户端的连接文件描述符进行监听,你这个服务器是有问题的!
1 楼
haolifeng
2013-06-08
我对你的代码有一个问题,当获得客户端的连接文件描述符后,为什么不对这些文件描述符添加到epoll事件集合中进行事件监听?
发表评论
-
C++ Programming Tutorial 2 Building and Running a Basic Program
2014-07-03 15:49 26#include <iostream> ... -
C++ Programming Tutorial 1 Installing Dev C++
2014-07-03 15:39 119Dev C++ -
C++教程60 类模板
2014-07-03 15:12 615#include <iostream> ... -
C++教程59 函数模板
2014-07-03 15:07 669#include <iostream> ... -
简单epoll服务器
2012-07-30 15:04 1264学习 #include <stdio.h&g ... -
一个多进程框架
2012-07-30 12:04 1051从别处找来的,记一下,学习~ /*========== ... -
gcc加载时的共享库设置
2012-03-21 17:13 814export LD_LIBRARY_PATH=/usr/loc ... -
libevent—前言
2012-03-14 14:48 0Libevent 千里之行,始于足下 Libeve ... -
libevent—异步IO编程
2012-03-14 13:57 2761原地址:http://www.wangafu.net/~nic ... -
C语言实现的mapreduce小程序
2012-03-05 14:47 2253#include <stdio.h> ... -
linux下itoa
2012-02-10 16:22 945#include <stdio.h> char ... -
ACE Logging facility
2011-08-30 23:21 0#include "ace/OS.h" ... -
ACE simple server & client
2011-08-30 22:50 0#include "ace/SOCK_Acce ... -
linux下C语言连接mysql数据库
2010-11-16 10:41 3085我用的是ubuntu10.10, mysql是使用sudo ...
相关推荐
linux下完整的epoll多线程高并发服务器代码
EPOLL多线程TCP服务器,可以动态获取连接客户机并且向客户机发送数据
Linux网络编程(四)——epoll+多线程实现简单的聊天(linux 服务器端 windows客户端)
这两类都要使用到IO多路复用,O多路复用是指单个进程/线程就可以同时处理多个IO请求。有三个方式select、poll、epoll。 select:将文件描述符放入一个集合中,调用select时,将这个集合从用户空间拷贝到内核空间...
epoll 编写的多线程服务器 可以学习使用
基于epoll的包含线程池、定时器、日志的多进程多线程的WebServer服务器源码.zip基于epoll的包含线程池、定时器、日志的多进程多线程的WebServer服务器源码.zip基于epoll的包含线程池、定时器、日志的多进程多线程的...
基于epoll 的多线程,服务器客户端模型。 网络模块和数据处理模块进行了分离。
开发环境:linux gcc 功能描述:基于TCP远程桌面代理服务、透传数据包。 使用技术:多线程,epoll
线程池 epoll 总结了一两种常用的线程模型, 归纳了进程间通讯与线程同步的最佳实践,以期用简单规范的方式开发多线程程序。
Reactor 模型开发效率上比起直接使用 IO 复用要高,它通常是单线程的,设计目标是希望单线程使用一颗 CPU 的全部资源,但也有附带优点,即每个事件处理中很多时候可以不考虑共享资源的互斥访问。可是缺点也是明显的...
LINUX平台下基于EPOLL的FTP服务器设计与实现,王亚昌,,网络服务器通常采用多进程、多线程并发机制或者是基于select/poll的I/O复用模型实现,传统的FTP服务器大都使用前者。本文针对Linux 2.6内�
【项目资源】: 包含前端、后端、移动开发、操作系统、人工智能、物联网、信息化管理、数据库、硬件开发、大数据、课程资源、音视频、网站开发等各种技术项目的源码。 ... 【项目质量】: 所有源码都经过严格测试,...
自己写的epoll server并发服务器模型代码,可以直接使用。有比较详细的注释,实现了单线程处理多个连接请求。
多线程,epoll,libevent网络库分别实现的三个网络HTTP服务器程序
客户端涉及到的技术点:常用QT控件(QWidget, QListWidget, QLabel, QPushButton)、QT信号与槽、QJsonObject完成json数据的解析、QT多线程、QTcpSocket连接服务器、服务端涉及到的技术点; epoll多路IO转接机制:常用...
编写连接数巨大的高负载服务器程序时,经典的多线程模式和 select模式都不再适 用。应当抛弃它们,采用 epoll/kqueue/dev_poll 来捕获 I/O 事件。最后简要介绍了 AIO。 --------- from 搜狗实验室
主要讲解了目前高性能服务器的高并发和大流量应对的服务端开发注意事项。
lx_async_server一个基于epoll的linux c web服务器lx_async_server使用epoll实现异步web服务,同时可以指定线程的数量,每一个线程独立工作以充分利用硬件的cpu及内存等资源。默认情况下,服务器会根据cpu的个数起...
Linux网络编程 TCP/IP基础知识 涵盖socket epoll 多线程
不过资料也同时指出这样会带来网络效率的下降,二是可以选择多进程的解决方案(传统的 Apache方案),不过虽然linux上面创建进程的代价比较小,但仍旧是不可忽视的,加上进程间数据同步远比不上线程间同步的高效,所以...