失效链接处理 |
ZeroMQ官方文档【中文版】 PDF 下载
本站整理下载:
相关截图:
![]()
主要内容:
提问- - 回答
让我们从简单的代码开始,一段传统的 Hello World 程序。我们会创建一个客
户端和一个服务端,客户端发送 Hello 给服务端,服务端返回 World。下文是 C
语言编写的服务端,它在 5555 端口打开一个 ZMQ 套接字,等待请求,收到后应
答 World。
hwserver.c: Hello World server
//
// Hello World 服务端
// 绑定一个 REP 套接字至 tcp://*:5555
// 从客户端接收 Hello,并应答 World
//
#include <zmq.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
int main (void)
{
void *context = zmq_init (1);
// 与客户端通信的套接字
void *responder = zmq_socket (context, ZMQ_REP);
zmq_bind (responder, "tcp://*:5555");
while (1) {
// 等待客户端请求
zmq_msg_t request;
zmq_msg_init (&request);
zmq_recv (responder, &request, 0);
printf ("收到 Hello\n");
zmq_msg_close (&request);
// 做些“处理”
sleep (1);
zguide-cn haozu/zguide-cn
页 8
// 返回应答
zmq_msg_t reply;
zmq_msg_init_size (&reply, 5);
memcpy (zmq_msg_data (&reply), "World", 5);
zmq_send (responder, &reply, 0);
zmq_msg_close (&reply);
}
// 程序不会运行到这里,以下只是演示我们应该如何结束
zmq_close (responder);
zmq_term (context);
return 0;
}
使用 REQ-REP 套接字发送和接受消息是需要遵循一定规律的。客户端首先使用
zmq_send()发送消息,再用 zmq_recv()接收,如此循环。如果打乱了这个顺序
(如连续发送两次)则会报错。类似地,服务端必须先进行接收,后进行发送。
ZMQ 使用 C 语言作为它参考手册的语言,本指南也以它作为示例程序的语言。
如果你正在阅读本指南的在线版本,你可以看到示例代码的下方有其他语言的
实现。如以下是 C++语言:
|