$ sudo apt-get install libzmq-dev
import org.zeromq.ZContext;
import org.zeromq.ZMQ;
public class Publisher {
public static void main(String[] args) {
try (ZContext context = new ZContext()) {
ZMQ.Socket socket = context.createSocket(ZMQ.PUB);
socket.bind("tcp://*:5555");
while (!Thread.currentThread().isInterrupted()) {
String message = "Hello, JeroMQ!";
socket.send(message.getBytes(ZMQ.CHARSET), 0);
Thread.sleep(1000);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
import org.zeromq.ZContext;
import org.zeromq.ZMQ;
public class Subscriber {
public static void main(String[] args) {
try (ZContext context = new ZContext()) {
ZMQ.Socket socket = context.createSocket(ZMQ.SUB);
socket.connect("tcp://localhost:5555");
socket.subscribe("".getBytes(ZMQ.CHARSET));
while (!Thread.currentThread().isInterrupted()) {
byte[] message = socket.recv();
System.out.println("Received: " + new String(message, ZMQ.CHARSET));
}
}
}
}
