我正在浏览 ZeroMQ 网站上的示例,所有 Java 示例都不适用于 jzmq 库。我认为他们与其他 Java 实现一起使用,但我正在处理的项目是使用 jzmq。JZMQ有任何例子吗?
具体来说,如何创建轮询器?该示例具有:
context.createPoller(2);
在折旧的上下文中有一种方法:
context.getContext().poller();
并说要使用构造函数,但 ZMQ.Poller 构造函数是受保护的。
你应该如何建造一个?
我找到了一个使用 JZMQ 3.1.0 库创建轮询器的代码示例。它与其他 java API 略有不同。
//You use the constructor that takes the number of pollers
ZMQ.Poller poller = new ZMQ.Poller(2);
//then you register your socket contexts
int id1 = poller.register(socket1, ZMQ.Poller.POLLIN);
int id2 = poller.register(socket2, ZMQ.Poller.POLLIN);
希望这对其他人有帮助。