epoll + 非阻塞I/O 怎么改进才能变成 多线程 + epoll + 非阻塞I/O

windoze

回复 11# __BlueGuy_

那个echo server的例子刨掉头文件和using总共只有5行，你竟然说你看不懂？

写成这样能看懂不？

1. 
   
2. #include <fibio/fiberize.hpp>
   
3. #include <fibio/iostream.hpp>
   
4. 
   
5. using namespace fibio;
   
6. 
   
7. void connection_handler(tcp_stream &s) {
   
8.     s << s.rdbuf();
   
9. }
   
10. 
    
11. int fibio::main(int argc, char *argv[]) {
    
12.     tcp_listener l("0.0.0.0", 7);  // 7 is the port for echo service
    
13.     boost::system::error_code ec=l.start(connection_handler);
    
14.     return ec.value();
    
15. }
    

复制代码

yulihua49

windoze 发表于 2014-11-03 20:21
回复 11# __BlueGuy_

那个echo server的例子刨掉头文件和using总共只有5行，你竟然说你看不懂？

看起来很简单的样子。
但是不能理解其中的机制。多线程啊，事件啊是怎么处理的。
看到  l.start 启动了服务，唯一的一个服务函数也看见了。
是什么模式？TPC，每连接一个线程？同步的还是异步，阻塞否？
包是怎么组织的？每个字符都echo？还是换行符来确定一行？
如果需要定义用户自己的session，在哪里定义，怎么绑定到特定到用户？

cobras

貌似C++的问题之一初显啊！

leiing

来学习

windoze

回复 13# yulihua49

Fiberized.IO，听名字差不多就该猜到了，里面是线程池+fiber+AsyncI/O，fiber在进行阻塞操作时切换，阻塞操作完成后再切回来继续执行。这里的fiber差不多是一个M:N的green thread。

这个server是每连接一个fiber的模型，所有fiber共享一个kernel thread pool。

1. 
   
2. s << s.rdbuf();
   

复制代码

这句里面其实做了不少工作
1、发起tcp读，fiber挂起并切换，这里读数据使用的是readsome，会读不确定长度的一块并放进streambuf的缓冲区里。
2、读到一块数据（或出错）后，fiber恢复，并对之前读到的数据发起一个写操作，再次挂起。如果出错，s.eof()为真，s.operator<<(s.rdbuf)这条语句就执行完了。
3、写操作完成后，fiber恢复，再次开始读。

实现的原理你可以看看 https://github.com/windoze/fibio ... tream/streambuf.hpp ,  和 https://github.com/windoze/fibio ... er/fiber_object.cpp
基本上最重要的细节都在这两个文件里。

yulihua49

windoze 发表于 2014-11-05 09:52
回复 13# yulihua49

Fiberized.IO，听名字差不多就该猜到了，里面是线程池+fiber+AsyncI/O，fiber在进行 ...

我理解就是fiber就是session，就是context。做得不错，学习学习。

windoze

回复 17# yulihua49

服务端实际结构类似于每连接一线程，所以对于单连接协议来说fiber，或者更准确说tcp_stream可以拿来当作session/context。

yulihua49

windoze 发表于 2014-11-05 19:35
回复 17# yulihua49

服务端实际结构类似于每连接一线程，所以对于单连接协议来说fiber，或者更准确说tc ...

每个连接都有一个fiber，每个fiber是否固定持有一个线程？如果是，那就是TPC。如果是TPOOL，应该不固定线程，全系统有固定数量的线程，轮流处理所有的fiber。
还有，我理解你那个echo，是异步非阻塞，每次收多少回多少。
但是真正的应用，这样是不行的。至少，要有组包规则，就是什么样的数据是一个完整的包。如果在connect_handle()里处理组包，有点太“絮”了。
我们在做交易中间件时，各个不同的环节有不同的组包规则，如连接开始后要协商秘钥，这时是定长字节流，之后后是TLV协议，这需要状态管理。可是你这里没有放应用级状态的地方，就是应用级context。

windoze

回复 19# yulihua49

fiber和线程不是固定关系，所有fiber共享一个线程池。
echo server你说的没错，是异步非阻塞I/O，但体现在fiber里是同步阻塞I/O。