1. reply -- request
简单的一问一答模式,
客户端(ZMQ_REQ) 提交一个请求, 然后等待服务器(ZMQ_REP) 响应,
然后此时服务器收到客户端请求, 然后做出回应
Paste_Image.png
代码
服务端 server.c
#include <assert.h>
#include <string.h>
#include <unistd.h>
#include <stdio.h>
#include <zmq.h>
int main(){
void *context = zmq_ctx_new();
void *responder = zmq_socket(context, ZMQ_REP);
int rc = zmq_bind(responder, "tcp://*:5555");
assert(rc == 0);
while(1){
char buf[10];
memset(buf, 0, 10);
zmq_recv(responder, buf, 10, 0);
printf("responder recv: %s\n", buf);
sleep(1);
zmq_send(responder, "s:reply", 7, 0);
}
return 0;
}
客户端 client.c
#include <assert.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>
#include <stdio.h>
#include <zmq.h>
int main(int argc, char const *argv[]) {
void *context = zmq_ctx_new();
void *requester = zmq_socket(context, ZMQ_REQ);
/* 这里连接的地址需要更换成自己要连接服务器的地址 */
int rc = zmq_connect(requester, "tcp://192.168.64.37:5555");
assert(rc == 0);
char msg[10] = "hello ser";
for(int i = 0; i < 10; i++){
printf("sending msg\n");
rc = zmq_send(requester, msg, strlen(msg), 0);
assert(rc > 0);
/* 接受回应 */
char buf[10];
memset(buf, 0, 10);
zmq_recv(requester, buf, 10, 0);
printf("recv: %s\n", buf);
}
return 0;
}
注意这里的模式.
**ZMQ_REP ( zmq_reply): **
用于服务端接收客户端请求, 发送自己响应内容的.
ZMQ_REQ(zmq_request):
用于客户端发送请求, 接收服务器响应
.
二者都是双向, 也就是能收能发(消息), 但是模式是 send...recv....send....recv...... 这样连续的.
不能客户端一直 send 请求, 服务器一直 recv 请求, 这样是会出错的.
因为游戏就是这么设定的.
你可以先开启服务端, 再开启客户端, 相反的顺序也是一样可以工作的.
但是如果你用 Ctrl + C 终止服务器, 在重新开启的话, 客户端就无法工作了, 这里需要以后更深入的研究.
你也可以试着开启多个客户端试一试
ZMQ_REQ
ZMQ_REP
2. subscriber -- publisher
更新中...
