问题标签 [jzmq]

我的程序使用 ZMQ 进行通信。即，服务器（C++，Linux）创建一个 XPUB 套接字，然后在一个线程中读取它，并在另一个线程中发布数据（写入）。

客户端（java、jzmq、linux）创建一个 SUB 套接字，并使用它进行订阅。

一段时间后，服务器端在读取线程中收到 SIGABRT。

什么可能是问题的根源？在不同的线程中读/写或创建 XPUB/SUB 对？

如果问题出在多线程中，那么使用 XPUB 套接字的正确范例是什么？

我学会了如何ZeroMQ在 a 上使用localhost，但我没有在远程 IP 上做到这一点。

Q1:我需要经纪人吗？
如果是这样，
Q2:哪个经纪人以及如何去做。？

更新：

好的。我正在使用ZMQWea​​ther Update 示例，但使用的是远程 IP（不是localhost）。这是我使用C# ZMQ绑定所做的（但是，我可以使用任何其他语言）：

ZMQ服务器：

代理人：

客户：

当我运行它时，我在服务器中得到错误，在代理中出错- 服务器得到

Invalid end point

和代理得到EINVAL(22)：

Invalid argument at ZeroMQ.ZSocket.Bind(String endpoint)

我正在尝试实现进程间通信。

模型： Part A -> 向 Part B发送消息。

我已经使用ZMQ教程中的客户端-服务器示例（代码附在下面）实现了这一点，但面临进程被“锁定”的问题。

实施这种模型的最佳实践是什么？

它不是经典的“客户端-服务器”。实际上只有一部分将数据发送到第二部分，第二部分使用它。

是否有发送超时消息的选项，它不会锁定进程？

任何输入/示例将不胜感激！

Server:

Client:

Problem: I have a number of file uploads coming via HTTP in parallel ( uploads receiver ). I'm storing them temporarily on a local disk. Another process ( uploads submitter ) gets notified about new uploads and does specific processing ( parsing, extracting metadata, uploading to S3 etc ). Once upload processing done I want uploads receiver to be notified by submitter to reply back with status ( whether submission is ok or error ) to the remote uploader. Using ZeroMQ PUB/SUB pattern, what would be better:

• subscribe all upload receiver threads to a single topic. Each receiver thread would have to filter messages based on upload id or something to find a notification that belongs to it.
• subscribe each receiver thread to a new topic which represents particular upload. This one seems more reasonable assuming topics are cheap in ZeroMQ, i.e. not much resources is needed to keep them and they can be auto-expired. I expect new uploads to come at dozens of files per second, single upload processing may take up to several seconds so theoretically I can have up to thousand of topics active at the same moment of time. Also I may not always be able to unsubscribe due to various failure modes.

导入 org.zeromq.ZMQ；

- 对于上述导入语句，我在 jzmq 主文件夹中使用“org 文件夹”，该文件夹由 ZMQ.java 文件组成。

- 所以，编译没有问题。当我开始运行程序时，它显示以下异常

线程“main”中的异常 java.lang.UnsatisfiedLinkError：java.lang.ClassLoader.loadLibrary(Unknown Source) at java.lang.Runtime.loadLibrary0(Unknown Source) at java.lang.System 的 java.library.path 中没有 jzmq .loadLibrary(Unknown Source) at org.zeromq.ZMQ.(ZMQ.java:41) at server.main(Server.java:13)

我应该怎么做？java中的ZeroMQ helloworld示例必须下载哪些包以及必须使用哪些导入语句？

我看到很多人在某处使用 libzmq.dll、jzmq.dll 和一些 jar 文件来避免该异常。但我想要一个明确的答案。

我已经完成了一个示例 ZeroMQ PGM 多播应用程序，它工作正常。

但是回复处理不起作用。这是正确的方法吗？
如果是 - 如何从接收方回复发送方？

发件人：

接收者：

我正在使用 JZMQ（PGM 协议）开发一个 JAVA 多播应用程序。

是否可以通过同一个套接字发送和接收数据？

如果ZMQ.PUB使用，则仅send()有效，recv()无效。

如果ZMQ.SUB使用，send()则不起作用。

有没有其他方法可以同时使用send()和recv()使用同一个 Socket？

我有几个经销商连接到一个路由器插座。经销商异步发送数据，路由器收集/处理数据。我需要做的是找到一种方法来知道经销商何时停止发送数据/与路由器套接字断开连接。

我构建了所有连接身份的地图。

我有一个连接路由器端口的显示器，我收到连接/断开连接的通知。

问题是我找不到一种方法来识别监视器通知是针对哪个经销商的。通知只给我一个没什么用的FD。

有没有办法在通知和连接 ID 之间进行映射？

import org.zeromq无法解决，怎么办？

我正在尝试为我的网络应用订阅 ZMQ。第一次使用 ZMQ，我有点沮丧。有人可以帮忙吗？

自从我上次使用 Java 以来已经有一段时间了。

我在 python 中的服务器：

我的 C 客户端：

当我从 C 客户端发送消息时，python 中打印的数据是乱码，如下所示：

如何在 Python 中解码消息以正确打印出来？