<dependency>
<groupId>org.zeromq</groupId>
<artifactId>jeromq</artifactId>
<version>0.5.1</version>
</dependency>
import org.zeromq.ZMQ;
public class Publisher {
public static void main(String[] args) {
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket socket = context.socket(ZMQ.PUB);
socket.bind("tcp://localhost:5555");
String message = "Hello, JeroMQ!";
socket.send(message.getBytes(), 0);
socket.close();
context.term();
}
}
import org.zeromq.ZMQ;
public class Subscriber {
public static void main(String[] args) {
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket socket = context.socket(ZMQ.SUB);
socket.connect("tcp://localhost:5555");
socket.subscribe("".getBytes());
byte[] message = socket.recv(0);
System.out.println("Received message: " + new String(message));
socket.close();
context.term();
}
}
shell
$ javac Publisher.java
$ java Publisher
$ javac Subscriber.java
$ java Subscriber
