JAVA使用EPoll来进行NIO处理的方法(转) - lelong - ITeye技术网站
博客分类：
JDK 6.0 以及JDK 5.0 update 9 的 nio支持epoll （仅限 Linux 系统 ），对并发idle connection会有大幅度的性能提升，这就是很多网络服务器应用程序需要的。
启用的方法如下：
-Djava.nio.channels.spi.SelectorProvider=sun.nio.ch.EPollSelectorProvider
例如在 Linux 下运行的 Tomcat 使用 NIO Connector ，那么启用 epoll 对性能的提升会有帮助。
而 Tomcat 要启用这个选项的做法是在 catalina.sh 的开头加入下面这一行
CATALINA_OPTS='-Djava.nio.channels.spi.SelectorProvider=sun.nio.ch.EPollSelectorProvider'
Epoll是Linux内核为处理大批量句柄而作了改进的poll。要使用epoll只需要这三个系统调用：epoll_create(2)， epoll_ctl(2)， epoll_wait(2)。它是在2.5.44内核中被引进的(epoll(4) is a new API introduced in Linux kernel 2.5.44)，在2.6内核中得到广泛应用，例如LightHttpd。
一 epoll - epoll的优点
支持一个进程打开大数目的socket描述符(FD)
select 最不能忍受的是一个进程所打开的FD是有一定限制的，由FD_SETSIZE设置，默认值是2048。对于那些需要支持的上万连接数目的IM服务器来说显然太少了。这时候你一是可以选择修改这个宏然后重新编译内核，不过资料也同时指出这样会带来网络效率的下降，二是可以选择多进程的解决方案(传统的Apache方案)，不过虽然linux上面创建进程的代价比较小，但仍旧是不可忽视的，加上进程间数据同步远比不上线程间同步的高效，所以也不是一种完美的方案。不过 epoll则没有这个限制，它所支持的FD上限是最大可以打开文件的数目，这个数字一般远大于2048,举个例子,在1GB内存的机器上大约是10万左右，具体数目可以cat /proc/sys/fs/file-max察看,一般来说这个数目和系统内存关系很大。
IO效率不随FD数目增加而线性下降
传统的select/poll另一个致命弱点就是当你拥有一个很大的socket集合，不过由于网络延时，任一时间只有部分的socket是"活跃"的，但是select/poll每次调用都会线性扫描全部的集合，导致效率呈现线性下降。但是epoll不存在这个问题，它只会对"活跃"的socket进行操作---这是因为在内核实现中epoll是根据每个fd上面的callback函数实现的。那么，只有"活跃"的socket才会主动的去调用 callback函数，其他idle状态socket则不会，在这点上，epoll实现了一个"伪"AIO，因为这时候推动力在os内核。在一些 benchmark中，如果所有的socket基本上都是活跃的---比如一个高速LAN环境，epoll并不比select/poll有什么效率，相反，如果过多使用epoll_ctl,效率相比还有稍微的下降。但是一旦使用idle connections模拟WAN环境,epoll的效率就远在select/poll之上了。
使用mmap加速内核与用户空间的消息传递。
这点实际上涉及到epoll的具体实现了。无论是select,poll还是epoll都需要内核把FD消息通知给用户空间，如何避免不必要的内存拷贝就很重要，在这点上，epoll是通过内核于用户空间mmap同一块内存实现的。而如果你想我一样从2.5内核就关注epoll的话，一定不会忘记手工 mmap这一步的。
这一点其实不算epoll的优点了，而是整个linux平台的优点。也许你可以怀疑linux平台，但是你无法回避linux平台赋予你微调内核的能力。比如，内核TCP/IP协议栈使用内存池管理sk_buff结构，那么可以在运行时期动态调整这个内存pool(skb_head_pool)的大小--- 通过echo XXXX&/proc/sys/net/core/hot_list_length完成。再比如listen函数的第2个参数(TCP完成3次握手的数据包队列长度)，也可以根据你平台内存大小动态调整。更甚至在一个数据包面数目巨大但同时每个数据包本身大小却很小的特殊系统上尝试最新的NAPI网卡驱动架构。
二 epoll - epoll的使用
令人高兴的是，2.6内核的epoll比其2.5开发版本的/dev/epoll简洁了许多，所以，大部分情况下，强大的东西往往是简单的。唯一有点麻烦是epoll有2种工作方式:LT和ET。
LT(level triggered)是缺省的工作方式，并且同时支持block和no-block socket.在这种做法中，内核告诉你一个文件描述符是否就绪了，然后你可以对这个就绪的fd进行IO操作。如果你不作任何操作，内核还是会继续通知你的，所以，这种模式编程出错误可能性要小一点。传统的select/poll都是这种模型的代表．
ET (edge-triggered)是高速工作方式，只支持no-block socket。在这种模式下，当描述符从未就绪变为就绪时，内核通过epoll告诉你。然后它会假设你知道文件描述符已经就绪，并且不会再为那个文件描述符发送更多的就绪通知，直到你做了某些操作导致那个文件描述符不再为就绪状态了(比如，你在发送，接收或者接收请求，或者发送接收的数据少于一定量时导致了一个EWOULDBLOCK 错误）。但是请注意，如果一直不对这个fd作IO操作(从而导致它再次变成未就绪)，内核不会发送更多的通知(only once),不过在TCP协议中，ET模式的加速效用仍需要更多的benchmark确认。
epoll只有epoll_create,epoll_ctl,epoll_wait 3个系统调用，具体用法请参考http://www.xmailserver.org/linux-patches/nio-improve.html在/rn/有一个完整的例子。
浏览 14997
浏览: 385113 次
来自: 深圳
[u][b][i][flash=200,200][url][i ...
不错 今天用到了 时间戳排序的话有一样的就排序数据乱了
xuhu_java 写道您好！我想问一下
select rou ...
您好！我想问一下select round( ...
还有一种情况是
decimal_places为负数epoll培训_图文_百度文库
两大类热门资源免费畅读
续费一年阅读会员，立省24元！
评价文档：
上传于||暂无简介
大小：1.18MB
登录百度文库，专享文档复制特权，财富值每天免费拿！
你可能喜欢服务器端：#-*- coding:utf8 -*-import socketimport selectimport osaddress = &0.0.0.0&port = 10001sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)def main():
global address,port,sock
epoll = select.epoll()
#获取创建好的sock的文件描述符
fd = sock.fileno()
sock.bind((address,port))
sock_dict = {}
sock_dict[fd] = sock
#对该sock进行注册
epoll.register(fd,select.EPOLLIN)
sock.listen(5)
while True:
events = epoll.poll(1)
for fileno,event in events:
#获取到的文件描述符和sock的相同就说明是一个新的连接
if fileno == fd:
(client,address) = sock.accept()
print address
client.setblocking(0)
#将新的连接进行注册，用来接收消息
epoll.register(client.fileno(),select.EPOLLIN)
sock_dict[client.fileno()] = client
elif event & select.EPOLLIN:
print &fileno:&,fileno
data = sock_dict[fileno].recv(128)
if data == '你好':
print &Data:&,data.decode('UTF-8')
sock_dict[fileno].send(&你好&)
elif len(data) == 0:
print &线路%d已下线&%fileno
epoll.unregister(fileno)
print &Data:&,dataif __name__ == '__main__':
main()客户端：#coding: UTF-8
import socketimport selectaddress = &127.0.0.1&port = 10001sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)def main():
global address,port,sock
sock.connect((address,port))
epoll = select.epoll()
fd = sock.fileno()
#这里的epoll注册只是用来异步接收服务端发过来的消息
epoll.register(fd,select.EPOLLIN)
while True:
events = epoll.poll(1)
for fileno,event in events:
if fileno == fd:
if event & select.EPOLLIN:
data = sock.recv(128)
print data
data = raw_input(&&&)
if data == 'q':
elif data == '':
print &不能发送空消息&
sock.send(data)
sock.close()main()& & 首先来看一个简单的例子(官方文件ev.pod中可以找到)& & #include&& & #include&& & ev_io&stdin_& & ev_timer&timeout_& & static&void& & stdin_cb(EV_P_&ev_io *w, int revents)& & {& & puts("stdin ready");& & ev_io_stop(EV_A_ w);& & ev_break(EV_A_ EVBREAK_ALL);& & }& & static&void& & timeout_cb(EV_P_&ev_timer *w, int revents)& & {& & puts("timeout");& & ev_break(EV_A_ EVBREAK_ONE);& & }& & int&main()& & {& & struct ev_loop *loop = EV_DEFAULT;& & ev_io_init(&stdin_watcher, stdin_cb,&0, EV_READ);& & ev_io_start(loop, &stdin_watcher);& & ev_timer_init(&timeout_watcher,&timeout_cb, 5.5, 0. );& & ev_timer_start(loop,&&timeout_watcher);& & ev_run(loop,0);& & return 0;& & }& & 我们只关心如下几句：& & struct&ev_loop *loop = EV_DEFAULT;& & ev_io_init(&stdin_watcher,&stdin_cb, 0, EV_READ);& & ev_io_start(loop,&&stdin_watcher);& & ev_run(loop,&0);& & 首先来看ev_io_init中做了些什么操作：& & ev.h文件中& & #define&ev_io_init(ev,cb,fd,events)& & do { ev_init ((ev), (cb)); ev_io_set&((ev),(fd),(events)); } while (0)& & #define&ev_init(ev,cb_) do {&&&&&&&&&&\& & ((ev_watcher *)(void&*)(ev))->active&=&&&\& & ((ev_watcher *)(void *)(ev))->pending =&0;&&\& & ev_set_priority ((ev), 0);&&&&&&&&&&\& & ev_set_cb ((ev), cb_);&&&&&&&&&&&&\& & } while&(0)& & #define&ev_io_set(ev,fd_,events_)& & do { (ev)->fd = (fd_); (ev)->events&= (events_) | EV__IOFDSET; } while (0)& & #define&ev_set_cb(ev,cb_)& & ev_cb (ev) = (cb_)& & #define&ev_cb(ev)& & (ev)->cb /* rw */& & 通过定义可以看出ev_io_init主要操作时：& & &stdin_watcher->active=stdin_watcher->pending=0；& & &stdin_watcher->priority=0；& & &stdin_watcher->cb=stdin_cb(函数)；& & &stdin_watcher->fd；& & &stdin_watcher->events=EV_READ|EV__IOFDSET& & 同样,ev_io_start做了一些赋值操作,这里不过多讲解；& & 下面通过一张函数调用图来展libev的函数调用：& &
声明：该文章系网友上传分享，此内容仅代表网友个人经验或观点，不代表本网站立场和观点；若未进行原创声明，则表明该文章系转载自互联网；若该文章内容涉嫌侵权，请及时向
上一篇：下一篇：
相关经验教程
的原创经验被浏览，获得 ￥0.001 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.001 收益
的原创经验被浏览，获得 ￥0.001 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.001 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.001 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.001 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益
的原创经验被浏览，获得 ￥0.005 收益