0

在 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 屏幕截图显示连接被关闭

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

socket.setSocketOpt(ZMQ.ZMQ_TCP_KEEPALIVE,1)

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

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

4

1 回答 1

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();
于 2020-01-22T19:05:36.757 回答