在 Matlab 中接收时 JeroMQ 订阅者连接中断

Question

在 Matlab 中使用 JeroMQ，当我尝试 recv 一条消息时，我的订阅者连接断开。我已经用 Wireshark 验证了这一点。我还注意到关闭 TCP 连接是由我的订阅端口发起的，而不是发布端口。

javaclasspath('jeromq-0.5.1.jar')
import org.zeromq.*;

ctx = zmq.Ctx();
socket = ctx.createSocket(ZMQ.SUB);
socket.connect('tcp://127.0.0.1:5996')
message = socket.recv(1) %this is when the connection gets dropped

Wireshark screenshot showing connection being closed

我不确定它是否有帮助，但我已经使用它进行了调查，

socket.setSocketOpt(ZMQ.ZMQ_TCP_KEEPALIVE,1)

但是 Matlab 报告说 ZMQ_TCP_KEEPALIVE 是一个无法识别的函数或变量。

我感谢线程上的人们让我在 Matlab 中正确地开始使用 JeroMQ。

Answer 1

我做了更多研究，并考虑了 Github 上一些朋友的建议。原来我的套接字直到稍后在 close() 函数的代码中才关闭。这是我的工作代码，供其他希望在 Matlab 中开始使用 JeroMQ 的人使用。似乎其他帖子上的一些代码已经过时了。

javaclasspath('jeromq-0.5.1.jar')
import org.zeromq.*;

%subscribe to ZMQ feed
context = ZContext();
socket = context.createSocket(ZMQ.SUB); 
success = false;
while(~success)
    success = socket.connect('tcp://127.0.0.1:5996');
end
socket.subscribe("");
socket.setTCPKeepAlive(1);

%receive a message
message = socket.recv(0); %nonblocking receive uses argument (1)

%when done
socket.close();

在 Matlab 中接收时 JeroMQ 订阅者连接中断

JeroMQ subscriber connection breaks when recv-ing in Matlab

matlab

zeromq

jeromq