文件名称：处理消息-机械工程材料性能数据手册
文件大小：3.1MB
文件格式：PDF
更新时间：2024-06-27 22:44:30
zmq
// 二、与发布者进行同步 void *syncclient = zmq_socket (context, ZMQ_REQ); zmq_connect (syncclient, "tcp://localhost:5562"); // - 发送请求 s_send (syncclient, ""); // - 等待应答 char *string = s_recv (syncclient); free (string); // 三、处理消息 int update_nbr = 0; while (1) { char *string = s_recv (subscriber); if (strcmp (string, "END") == 0) { free (string); break; } free (string); update_nbr++; } printf ("收到 %d 条消息\n", update_nbr); zmq_close (subscriber); zmq_close (syncclient); zmq_term (context); return 0; } 以下这段 shell脚本会启动 10个订阅者、1个发布者： echo "正在启动订阅者..." for a in 1 2 3 4 5 6 7 8 9 10; do