Java
Java 开发者有三种选择:JeroMQ 是一个纯 Java 实现,JZMQ 是 libzmq 的 Java 绑定,JCZMQ 是 czmq 的 Java 绑定。
JeroMQ
示例
下面展示了如何实现一个服务器,它打印收到的消息并回复“Hello, world!”
import org.zeromq.ZMQ;
import org.zeromq.ZContext;
public class HelloWorldServer
{
public static void main(String[] args) throws Exception
{
try (ZContext context = new ZContext()) {
// Socket to talk to clients
ZMQ.Socket socket = context.createSocket(ZMQ.REP);
socket.bind("tcp://*:5555");
while (!Thread.currentThread().isInterrupted()) {
// Block until a message is received
byte[] reply = socket.recv(0);
// Print the message
System.out.println(
"Received: [" + new String(reply, ZMQ.CHARSET) + "]"
);
// Send a response
String response = "Hello, world!";
socket.send(response.getBytes(ZMQ.CHARSET), 0);
}
}
}
}
JZMQ
Github | https://github.com/zeromq/jzmq |
文档 | https://github.com/zeromq/jzmq/blob/master/README.md |
JCZMQ
Github | https://github.com/zeromq/czmq/tree/master/bindings/jni |
文档 | https://github.com/zeromq/czmq/blob/master/bindings/jni/README.md |
示例