[ZeroMQ] 与 libevent 协同工作 (2.1.0 release)
2010-12-02 18:26:06| 分类：
net_ZeroMQ
| 标签：
|举报
|字号大中小 订阅
2.1.0 解决掉两个大问题：
1. 和其他 poll 机制共存的问题，比如：libevent
2. zmq_term() 会保证所有消息发送完全，不再需要 sleep(1) 了。
前提是所有的 zmqsocket 都要正确地 zmq_close()，否则 zmq_term() 会一直 block。
zmq_term() 的时候，会给所有的 zmq_recv() 的地方发送 -1 + ETERM，要正确处理此逻辑。
zeromq + libevent 真是很爽的组合。
------------------------- server.c -------------------------
#include <zmq.h>
#include <event.h>
#include <stdio.h>
void pair_callback(int _, short __, void *pair)
{
zmq_msg_t msg;
uint32_t events;
size_t len;
len = sizeof(events);
zmq_getsockopt(pair, ZMQ_EVENTS, &events, &len);
if ( events & ZMQ_POLLIN )
{
while (1)
{
zmq_msg_init(&msg);
if ( zmq_recv(pair, &msg, ZMQ_NOBLOCK) == -1 )
{
zmq_msg_close(&msg);
break;
}
printf("recv: %s\n", (char *)zmq_msg_data(&msg));
zmq_msg_close(&msg);
}
}
}
int main()
{
struct event_base *evbase;
struct event *ev;
void *ctx, *pair;
int pairfd;
size_t len;
ctx = zmq_init(1);
pair = zmq_socket(ctx, ZMQ_PULL);
zmq_bind(pair, "tcp://127.0.0.1:6666");
len = sizeof(pairfd);
zmq_getsockopt(pair, ZMQ_FD, &pairfd, &len);
evbase = event_base_new();
ev = event_new(evbase, pairfd, EV_READ|EV_PERSIST, pair_callback, pair);
event_add(ev, NULL);
event_base_dispatch(evbase);
return 0;
}
------------------------- client.c -------------------------
#include <zmq.h>
#include <string.h>
int main()
{
void *ctx, *pair;
zmq_msg_t msg;
ctx = zmq_init(1);
pair = zmq_socket(ctx, ZMQ_PUSH);
zmq_connect(pair, "tcp://127.0.0.1:6666");
zmq_msg_init_size(&msg, 6);
memcpy(zmq_msg_data(&msg), "hello", 6);
zmq_send(pair, &msg, 0);
zmq_msg_close(&msg);
zmq_close(pair);
zmq_term(ctx);
return 0;
}
------------------------------------------------------------
评论这张
转发至微博
转发至微博
关闭
玩LOFTER，免费冲印20张照片，人人有奖！
我要抢>
<#--最新日志，群博日志-->
<#--推荐日志-->
<#--引用记录-->
<#--博主推荐-->
<#--随机阅读-->
<#--首页推荐-->
<#--历史上的今天-->
<#--被推荐日志-->
<#--上一篇，下一篇-->
<#-- 热度 -->
<#-- 网易新闻广告 -->
<#--右边模块结构-->
<#--评论模块结构-->
<#--引用模块结构-->
<#--博主发起的投票-->
评论