注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

Code@Pig Home

喜欢背着一袋Code傻笑的Pig .. 忧美.欢笑.记忆.忘却 .之. 角落

 
 
 

日志

 
 

[ZeroMQ] 深入分析(2) -- 线程间通讯"inproc://"  

2010-12-17 18:15:32|  分类: net_ZeroMQ |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |
==== 基本原理 ====

mb, mailbox, 线程间的事件通知domain socket, 每次send的command_t都很小,认为此一定是原子的(< PIPE_BUF)
mq, msg queue, 线程间 zmq_msg_t 传递的 lock-free queue

[ZeroMQ] 深入分析(2) -- 线程间通讯inproc:// - kasicass - Code@Pig Home
 

"inproc://" thread 间通讯,通过 domain socket 连接 thread,告知 command_t 之类的信息。
而 zmq_msg_t 通过 reader_t/writer_t(ypipe) 的 lock-less queue 来直接传递 pointer。

push = zmq_socket(ctx, ZMQ_PUSH);     // new push_t
zmq_bind(push, "inproc://xxx");               // 将 push 在 ctx.endpoints 注册

pull = zmq_socket(ctx, ZMQ_PULL);     // new pull_t
zmq_connect(pull, "inproc://xxx");         // 从 ctx.endpoints 中找到 push, 创建 reader_t/writer_t
                                                            // reader_t 绑定到 pull, 发消息 'bind' to pull.mailbox
                                                            // push 收到 'bind' 消息, 绑定 writer_t

zmq_send(push, &msg, 0);              // msg 丢给 writer_t
zmq_recv(pull, &msg, 0);                 // 从 reader_t 获取 msg


==== object_t 之间的消息通讯 ====
object_t ==> ctx.mailbox[tid] ==> [kernel pipe] ==> object_t


==== pipe.hpp ====
定义了 reader_t/writer_t, 一个 pipe 的两端;writer_t 还支持一个 swap_t (ypipe满了,则msg自动保存到磁盘)
create_pipe(), 创建一个 ypipe<zmq_msg_t> 给 reader_t/writer_t 使用。reader_t/writer_t 可以分别在不同的线程。
i_reader_events/i_writer_events, reader_t/writer_t 通过这两个 interface 知会上层 activated/terminated 等事件


==== push/pull pattern ====
通过 lb_t/fq_t (load balance/fair queue) 来实现:
-- one-push/multi-pull
                         /- writer_t/reader_t -> fq_t -> pull_t
push_t -> lb_t --- writer_t/reader_t -> fq_t -> pull_t
                         \- writer_t/reader_t -> fq_t -> pull_t

-- multi-push/one-pull
push_t -> lb_t -> writer_t/reader_t -\
push_t -> lb_t -> writer_t/reader_t --- fq_t -> pull_t
push_t -> lb_t -> writer_t/reader_t -/


==== fq.hpp ====
class fq_t : public i_reader_events
fair queue 实现 (round-robin)
fq_t ==> [r1|r2|...], 带一个 reader_t 的数组
recv() 时, 从 reader_t数组中选择一个 active 的来读


==== lb.hpp ====
class lb_t : public i_writer_events
load balance 实现 (round-robin)
lb_t ==> [w1|w2|...], writer_t的数组
send() 时, 从 writer_t数组 中选择一个 active 来写

ps. ZeroMQ 还有个 "sys://",内部实现和 "inproc://" 是一个东西,其用于 ZeroMQ kernel 给 app 发送内部的 log,由 app 自己 write to file。当然,2.1.0的 "sys://" 还没有向 app 发送任何具体的log内容。
  评论这张
 
阅读(6556)| 评论(0)
推荐 转载

历史上的今天

在LOFTER的更多文章

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2017