1. Reactor和Preactor模式
Reactor用于同步IO,Preactor用于异步IOReactor通常会和Connector模式一起使用,进一步解耦连接的建立与连接以后的逻辑
2. Reactor模式中的主要角色
2.1. Reactor
Reactor是IO事件的派发者。
2.2. Acceptor
Acceptor接受client连接,建立对...
分类:
其他好文 时间:
2014-07-22 00:30:34
阅读次数:
391
Ranch 是一个tcp处理的程序框架。官方的解释 Ranch is a socket acceptor pool for TCP protocols. 主要目的是提供一个方便,易用,高效,稳定的tcp处理基础程序。前面我也用它作为基础写了个简易的聊天的程序。cowboy底层通信处理也是ranc.....
分类:
其他好文 时间:
2014-07-16 23:04:19
阅读次数:
194
Jafka Acceptor接收到客户端请求并建立连接后,Acceptor会将Socket连接交给Processor进行处理。Processor通过以下的处理步骤进行客户端请求的处理:
1. 读取客户端请求。
2. 根据客户端请求类型的不同,调用相应的处理函数进行处理。
Processor读取客户端请求是一个比较有意思的事情,需要考虑两个方面的事情:第一,请求规则(Processor需要按照...
分类:
其他好文 时间:
2014-06-28 09:25:18
阅读次数:
278
这个虚类是kafka.network.Acceptor和kafka.network.Processor的父类,提供了一个抽象的Sever线程。它的有趣之处在于为子类的启动和停止提供了线程间的协作机制。当子类的shutdown方法被调用时,子类可以得知自己被停止,在子类做了适当的处理和清理后,调用自己...
分类:
编程语言 时间:
2014-05-25 19:19:18
阅读次数:
328
一、首先到官网下载quickFIX源代码,编译连接,可以使用自带的某个例子作为框架进行修改
二、找到配置文件 * .cfg并打开, 修改文件中DataDictionary字段使其适应当前版本
三、如果要连接的Acceptor需要用户名密码将字段添加到配置文件中以便程序可以获取
UserName=name
Password=123
根据约定配置S...
分类:
其他好文 时间:
2014-05-15 04:14:57
阅读次数:
494