linux网络编程----->高并发--->poll多路I/O转接服务器

简介:

做网络服务的时候并发服务端程序的编写必不可少。前端客户端应用程序是否稳定一部分取决于客户端自身,而更多的取决于服务器是否相应时间够迅速,够稳定.

    常见的linux并发服务器模型;


  • 多进程并发服务器

  • 多线程并发服务器

  • select多路I/O转接服务器

  • poll多路I/O转接服务器

  • epool多路I/O转接服务器.


    本次主要讨论poll多路I/转接并发服务器模型:

    wKioL1dlV3ORUbUGAAISrviO-QM731.png-wh_50


    前几章介绍完了多进程并发服务器,  多线程并发服务器selete多路I/O转接服务器,  本章开始介绍poll(linux特有)多路I/O转接模型.

    由于多进程和多线程模型在实现中相对简单, 但由于其开销和CPU高度中比较大, 所以一般不用多线程和多进程来实现服务模型. select由于其跨平台, 但其最高上限默认为1024, 修改突破1024的话需要重新编译linux内核, poll完美解决了1024的限制.


    主要用到API:

        poll(struct pollfd *fds, nfds_t nfds, int timeout);

        fds:  传入传出结构体数组

        nfds: 结构体数组数量

        timeout: 监听时间        

                            -1 阻塞等待

                            0 立刻返回, 不阻塞

                            >0 等待毫秒数

        struct pollfd{

                int fd;              //监听的文件描述符

                int events;      //监听的事件 POLLIN监听读 POLLOUT 监听写 POLLERR 监听异常

                int revents;    // 监听事件中满足条件返回的事件


    .server[以下代码都没有做错误判断,  加上错误判断会造成代码翻倍, 实际开发中需要特别注意返回值]

    

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <poll.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <string.h>
#include <ctype.h>
 
#define CLIENT_MAX 1024       //定义最大客户端监听
#define SERV_PORT 9096        //监听端口
 
int  main( int  argc,  char * argv[]){
     int  listenfd, connfd;
     struct  sockaddr_in serv_addr, clie_addr;
     socklen_t clie_addr_len;
     struct  pollfd event[CLIENT_MAX];
     int  maxi, opt, i, j, nready, n;
     char  buf[BUFSIZ];
     
     //创建tcp监听套接字
     listenfd = socket(AF_INET, SOCK_STREAM, 0);
 
     //设置端口复用
     opt = 1;
     setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt,  sizeof (opt));
 
     //初始化为0
     bzero(&serv_addr,  sizeof (serv_addr));
     serv_addr.sin_family = AF_INET;
     //设置端口并转换为网络字节序
     serv_addr.sin_port = htons(SERV_PORT);
     //设置本机任意ip
     serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
     //绑定listenfd
     bind(listenfd, ( struct  sockaddr*)&serv_addr,  sizeof (serv_addr));
 
     //设置同时连接上限
     listen(listenfd, SOMAXCONN);    //#define SOMAXCONN 128
     
     //将监听套接字连接至事件
     event[0].fd = listenfd;
     event[0].events = POLLIN;
 
     //初始化
     for (i = 1; i < CLIENT_MAX; i++){
         event[i].fd = -1;
     }
 
     maxi = 0;
     for (;;){
         nready = poll(event, maxi+1, -1);
         
         //客户端请求连接
         if (event[0].revents & POLLIN){
             clie_addr_len =  sizeof (clie_addr);
             //获取连接
             connfd = accept(listenfd, ( struct  sockaddr*)&clie_addr, &clie_addr_len);
             //打印提示
             printf ( "%s:%d client connect successfully!\n" , inet_ntoa(clie_addr.sin_addr), ntohs(clie_addr.sin_port));
 
             //添加至监听
             for (i = 1; i < CLIENT_MAX; i++){
                 if (0 > event[i].fd){
                     event[i].fd = connfd;
                     break ;
                 }      
             }
             //判断监听是否已满
             if (CLIENT_MAX == i){
                 //关闭连接
                 printf ( "too many clients!\n" );
                 close(connfd);
                 continue ;
             }
             //监听读事件
             event[i].events = POLLIN;
             if (i > maxi)
                 maxi = i;
 
             if (0 == (--nready))
                 continue ;
         }
 
         for (i = 1; i <= maxi; i++){
             if (0 > event[i].fd)
                 continue ;
 
             //是否有事件
             if (event[i].revents & POLLIN){
                 //清空
                 bzero(buf,  sizeof (buf));
                 n = read(event[i].fd, buf,  sizeof (buf));
                 //对方是否已关闭
                 if (0 == n){
                     clie_addr_len =  sizeof (clie_addr);
                     //获取客户端信息
                     getpeername(event[i].fd, ( struct  sockaddr*)&clie_addr, &clie_addr_len);
                     printf ( "%s:%d client disconnect successfully!\n" , inet_ntoa(clie_addr.sin_addr), ntohs(clie_addr.sin_port));
                     //关闭客户端连接
                     close(event[i].fd);
                     //将事件数组中初始化为-1
                     event[i].fd = -1;
                 } else  if (0 < n){
                     //转换为大写
                     for (j = 0; j < n; j++){
                         buf[j] =  toupper (buf[j]);
                     }
                     //回写给客户端
                     write(event[i].fd, buf, n);
                 }
                 if (0 == (--nready)){
                     break ;
                 }
             }
         }
     }
     close(listenfd);
     return  0; 
}



      本文转自asd1123509133 51CTO博客,原文链接:http://blog.51cto.com/lisea/1791967,如需转载请自行联系原作者





相关文章
|
18天前
|
数据安全/隐私保护
Haskell网络编程:代理服务器的高级使用技巧
Haskell网络编程:代理服务器的高级使用技巧
|
2月前
|
存储 Unix Linux
Linux I/O 重定向与管道
【8月更文挑战第17天】重定向在Linux中改变命令I/O流向,默认有&quot;&gt;&quot;覆盖输出至文件及&quot;&gt;&gt;&quot;追加输出至文件末尾,便于保存结果;使用&quot;&lt;&quot;从文件读取输入而非键盘,高效处理数据。文件描述符如0(stdin)、1(stdout)、2(stderr)标识I/O资源,支持读写操作。管道以&quot;|&quot;连接命令,使前一命令输出成为后一命令输入,如排序用户或找出CPU占用最高的进程,构建复杂数据处理流程。
39 9
|
2月前
|
监控 Linux
在Linux中,如何监控磁盘I/O性能?
在Linux中,如何监控磁盘I/O性能?
|
2月前
|
Linux
Linux的I/O操作
Linux的I/O操作
|
2月前
|
存储 Unix Linux
Linux I/O 重定向与管道
【8月更文挑战第14天】输出重定向可将命令结果存入文件,如`&gt;`覆盖写入或`&gt;&gt;`追加写入。输入重定向从文件读取数据,如`&lt;`代替键盘输入。这些操作利用文件描述符(如0:stdin, 1:stdout, 2:stderr)管理I/O。管道`|`连接命令,使前一命令输出作为后一命令输入,便于数据处理,如排序用户`sort -t: -k3 -n /etc/passwd | head -3`或查找CPU占用高的进程`ps aux --sort=-%cpu | head -6`。
28 4
|
2月前
|
Unix Linux Shell
Linux I/O 重定向简介
Linux I/O 重定向简介
31 2
|
2月前
|
数据采集 资源调度 JavaScript
Node.js 适合做高并发、I/O密集型项目、轻量级实时应用、前端构建工具、命令行工具以及网络爬虫和数据处理等项目
【8月更文挑战第4天】Node.js 适合做高并发、I/O密集型项目、轻量级实时应用、前端构建工具、命令行工具以及网络爬虫和数据处理等项目
42 5
|
2月前
|
Linux 开发者
深入理解Linux I/O模型:同步、异步、阻塞与非阻塞
【8月更文挑战第1天】在探索操作系统的奥秘中,I/O模型作为影响性能的关键因素之一,常常让开发者们感到困惑。本文将通过浅显易懂的语言和实际代码示例,揭示Linux下同步与异步、阻塞与非阻塞的概念及其区别,并指导如何在实际应用中选择合适的I/O模型以优化程序性能。
81 1
|
2月前
|
监控
【网络编程】poll函数
【网络编程】poll函数
20 0
|
3月前
|
存储 Java Unix
(八)Java网络编程之IO模型篇-内核Select、Poll、Epoll多路复用函数源码深度历险!
select/poll、epoll这些词汇相信诸位都不陌生,因为在Redis/Nginx/Netty等一些高性能技术栈的底层原理中,大家应该都见过它们的身影,接下来重点讲解这块内容。

热门文章

最新文章