问题标签 [jeromq]

我正在尝试将 ZMQ 订阅者嵌入到 Runnable 中。我能够第一次启动 Runnable，一切似乎都很好。问题是当我中断线程并尝试启动一个新线程时，订阅者没有收到任何消息。例如：

1. 我有一个可运行的发布者

   /li>

2. 我有一个订阅者可运行：

   /li>

3. 我的主要代码如下所示：

   /li>

第一次启动订阅者时，我能够接收所有消息：

一旦我中断线程并从同一个 Runnable 启动一个新线程，我就无法再阅读消息了。它永远在等待

关于我做错了什么的任何见解？

谢谢

我正在尝试在我的 android 设备上对 ZeroMQ 进行编程，并且我知道如何使用 ZeroMQ（来自 C++、Php、.Net，我一直在使用它。）如果我列出我到目前为止所做的事情：

• 从 Android Studio 的依赖项中，我从 maven 中央搜索添加了org.zeromq:jeromq:0.3.5 。
• 之后，我输入了如下代码：

当我运行它时，我遇到了如下异常：

我实际上并不是编程新手，而是 Android/Java 方面的新手。我无法弄清楚如何解决这个问题。我在互联网上搜索但找不到任何东西。

如果你能帮助我，我会很高兴。

提前致谢。

（另外，我忘了包括这个：）

我正在尝试
通过实现此示例（如何在 MATLAB 中使用 jeromq）来使用 MATLAB 中的 JeroMQ：

脚本运行到以下行：

message = socket.recv(0);

但卡在那里。

然后 MATLAB 将不再响应，必须使用任务管理器将其杀死。

如果还有其他事情要做，有人可以给出提示吗？

使用 ZeroMQ.Context和.Socket实例，我可以
在我的代码下方推送/拉取消息，例如设置：

我的问题是：

Q1：如何在队列中实现主备模式？

我的意思是会有 2 个队列，为一个主机和端口创建，如果一个队列（活动）失败，另一个（即备用）队列将立即启动以侦听/拉取消息。

任何实施它的示例或指导都会更有帮助。

Q2：有没有内置的类来做这种类型的任务？

ZMQueue我检查了实现 Runnable 接口的 JeroMQ 类的源代码，如下所示：

正如您所见，里面run()只有一个语句，即调用

ZMQ.proxy()- 这里发生了什么？

在构造函数中，
它把一个Context实例作为参数并且什么都不做。

任何人都可以解释一下，这个类实现的目的是什么？

在 JeroMQ 中，如何使用单个消息发送具有文件内容类型和其他属性的文件。

在客户端：

构建文件消息并发送到服务器

有没有办法为消息设置属性？喜欢：

在服务器中，接收文件：

我正在使用0.4.0的版本，jeromq并且我试图使用此链接中的以下示例，但它在此行上给出了编译错误ZMQ.poll(items, 10);。看起来最近版本发生了一些变化，jeromq但文档和代码尚未更新。任何人都可以帮助我了解如何调整下面的代码以与最新版本的jeromq.

下面是代码：

我正在尝试在 android 应用程序中使用 ZMQ。理想情况下，我应该在应用程序关闭时创建一次上下文并 term() 它。

但与 c++ 应用程序不同。android 上没有 main() 函数。基于关于活动生命周期的谷歌文档。函数onCreate()、onStop()可以被多次调用，函数onDestroy()只被系统调用。

解决方案 1：在 asyncTask() 中创建/销毁 ZMQ 上下文。但这将非常昂贵。

解决方案2：基于线程Android全局变量，我可以创建一个全局ZMQ.Context context变量。这种方法的问题是：没有合适的函数来调用context.term();。

解决方案3。创建单例类

单例的问题与解决方案 2 相同。我必须ZmqHelper.release() //which calls context.term()在某个阶段手动调用。我不确定调用函数 term() 来破坏 zmq 上下文的好地方在哪里。

那么在 android 应用程序中创建/终止 ZMQ 上下文的正确方法是什么？

环境：

Ubuntu：16.04 LTS

安卓工作室：2.3.3

ZMQ：org.zeromq:jeromq:0.4.0

在 C++ ZMQ Publisher 中，我将字符串打包在 message_t 中，如下所示：

我想弄清楚如何在 JeroMQ (Java ZMQ) 中接收；这是我到目前为止所拥有的：

同样在 PyZMQ (Python ZMQ) 中：

但是，我的 JeroMQ 尝试或 PyZMQ 尝试都没有收到我的字符串消息。

一般来说，我是使用消息队列编程的新手，我一直在尝试开发一个简单的 Android 应用程序，该应用程序使用ZeroMQ. 我在不同的线程中在同一设备上运行服务器和客户端程序。这是我的Server课：

这是客户端类：

这是主要活动的片段，它在另一个线程中启动服务器并实现一个 clickListener 来调用客户端。

我遇到的问题是，一旦应用程序启动它就会自动关闭。当我socket.bind("tcp://*:5570");从服务器中删除线路时，它不再关闭，但也无法按预期方式工作，因为服务器不会监听。

我在清单中授予了INTERNET和ACCESS_WIFI_STATE权限。

对此问题的任何帮助表示赞赏。

编辑：我在该.bind()行放置了一个断点，这是我得到的错误：

EDIT2：完整的 logcat 错误：

看起来像一个简单的 classNotFound 错误，但它指的是“android 包”附带的一个类，这意味着它不属于任何外部库。那怎么找不到呢？