Closed.Thisquestionneedstobemorefocused。它当前不接受答案。想改善这个问题吗？更新问题，使它仅关注editingthispost的一个问题。在5个月前关闭。Improvethisquestion我正在尝试与LAN上的每个人联系，以发现哪些设备当前正在使用ip并正在运行我的服务。每个运行该服务的设备都将在联机时知道连接了哪些其他设备。我有基本的网络经验(tcp/udp)，但是对于更复杂的通信程序包我还没有做很多事情。我想发表到目前为止的研究/尝试，并得到一些专家的答复，以限制我对future潜在解决方案的反复试验的时间。要求:当前使用Java，但需要
编辑:自己解决了，见下文(虽然我不确定我是否在这里偶然发现了一个错误)使用下面这个简单的hello-world请求-回复示例，在程序结束时关闭上下文失败:它要么简单地卡在ctx.close()处，要么抛出以下异常:Exceptioninthread"reaper-1"java.lang.NullPointerExceptionatzmq.Ctx.destroy_socket(Ctx.java:327)atzmq.ZObject.destroy_socket(ZObject.java:144)atzmq.SocketBase.check_destroy(SocketBase.java:9
我正在通过环回(127.0.0.1)在Linux上使用优化的JavaNIO选择器进行一些基准测试。我的测试很简单:一个程序将一个UDP数据包发送到另一个程序，另一个程序将其回显给发送者并计算往返时间。下一个数据包仅在前一个数据包被确认(返回时)时才发送。在执行基准测试之前，会使用几百万条消息进行适当的预热。消息有13个字节(不包括UDPheader)。对于往返时间，我得到以下结果:最短时间:13微秒平均时间:19微秒75%百分位数:18,567纳米90%百分位数:18,789纳米99%百分位数:19,184纳米99.9%百分位数:19,264纳米99.99%百分位数:19,310纳米9
使用ZeroMQ.Context和.Socket实例，我能够推送/拉取消息例如，在我的代码下面，用于类似设置的队列:ZMQ.Contextcontext=ZMQ.context(1);//SockettosendmessagesonZMQ.Socketsender=context.socket(ZMQ.PUSH);sender.bind("tcp://*:5557");//Sendmessagessender.send("0",0);ZMQ.Socketreceiver=context.socket(ZMQ.PULL);receiver.connect("tcp://localhost
Closed.Thisquestionneedstobemorefocused。它当前不接受答案。想要改善这个问题吗？更新问题，使它仅关注editingthispost的一个问题。4年前关闭。Improvethisquestion我正在一个项目中，我需要消耗大量记录，然后将这些记录发送到使用ZeroMQ的其他系统。流程如下:将来自多个线程的所有传入记录存储在CHM中。记录将以非常高的速度到达。从每隔1分钟运行一次的后台线程，将这些记录从CHM发送到ZeroMQ服务器。将每条记录发送到ZeroMQ服务器后，也将它们添加到重试存储桶中，这样，如果尚未收到该记录的确认，则可以在经过特定时间后
有没有办法检查JZMQ(zmq的java绑定(bind))套接字是否已连接？ZContextzmqContext=newZContext();ZMQ.SocketworkerSocket=zmqContext.createSocket(ZMQ.DEALER);workerSocket.setIdentity("ID".getBytes());workerSocket.connect("tcp://localhost:5556");在上面的代码之后，我想检查workerSocket是否已连接。检查连接状态会很好。 最佳答案 不，API
我有一个通过UDP接收数据的服务，我想添加一些zmq订阅者。我也想在不阻塞的情况下使用zmq套接字。我不想为它创建一个单独的线程。我可以使用zmq_socket::receive(msg,ZMQ_DONTWAIT)但这会导致繁忙的循环和100%的CPU使用率。我从1.58开始尝试boost::coroutines，但没有成功-我无法隐藏阻塞接收(套接字RCVTIMEO设置为-1).我相信我遗漏了一些东西，只是不正确地使用了这些工具。所以问题是隐藏阻塞接收的正确方法是什么？ 最佳答案 我不确定您使用的是哪个zeromq包装器库，所以这
我正在尝试通过REP-socket发送大消息(300MB)。有多个客户端，每个客户端都通过REQ-socket连接到服务器。服务器为每个客户端创建一个专用套接字，等待请求(包含标识符)并使用ZMQ_SENDMORE将消息分两部分发送:元数据(~1KB)数据(~300MB)之后REP-socket立即关闭。Context()实例随后在父线程中关闭。ZMQ_LINGER套接字的时间默认保留(无限)。有时会发送元数据，但不会发送图像数据。我跟踪了ZeroMQ中的调用，发现在将消息数据发送到网络之前，内部(windows)套接字已关闭。我认为只要队列中有未发送的消息，zmq_term()就会阻
我是ZMQ的新手，正在尝试在Python发布者和C++订阅者之间实现简单的Pub-Sub通信。按照官方文档，我想出了这些代码:Python发布者importzmqimportdatetimecontext=zmq.Context()socket=context.socket(zmq.PUB)socket.bind("tcp://127.0.0.1:5555")whileTrue:now=datetime.datetime.now()nowInMicroseconds=str(now.microsecond)socket.send_string(nowInMicroseconds)pri
我无法让ZeroMQC++包装器接收多部分消息。使用C版本的相同代码工作得很好，但它会导致异常，而C++根本没有任何解释。多部分处理代码如下:int_tmain(intargc,_TCHAR*argv[]){zmq::context_tcontext(1);zmq::socket_tsocket(context,ZMQ_REP);socket.bind("tcp://*:5555");while(true){//thefollowingtwolinesleadtoexceptionzmq::message_trequest;socket.recv(&request);//zmq_msg
