Java

Java

Java 开发者有三种选择:JeroMQ 是一个纯 Java 实现,JZMQ 是 libzmq 的 Java 绑定,JCZMQ 是 czmq 的 Java 绑定。

JeroMQ

Github https://github.com/zeromq/jeromq
文档 https://github.com/zeromq/jeromq/blob/master/README.md

示例

下面展示了如何实现一个服务器,它打印收到的消息并回复“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

Githubhttps://github.com/zeromq/jzmq
文档https://github.com/zeromq/jzmq/blob/master/README.md

JCZMQ

Githubhttps://github.com/zeromq/czmq/tree/master/bindings/jni
文档https://github.com/zeromq/czmq/blob/master/bindings/jni/README.md

示例

TBD...