<dependency>
<groupId>org.zeromq</groupId>
<artifactId>jzmq</artifactId>
<version>4.2.1</version>
</dependency>
import org.zeromq.ZMQ;
public class MessageSender {
public static void main(String[] args) {
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket socket = context.socket(ZMQ.PUSH);
socket.connect("tcp://localhost:5555");
String message = "Hello, JeroMQ!";
socket.send(message.getBytes());
socket.close();
context.term();
}
}
import org.zeromq.ZMQ;
public class MessageReceiver {
public static void main(String[] args) {
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket socket = context.socket(ZMQ.PULL);
socket.bind("tcp://*:5555");
byte[] message = socket.recv();
System.out.println("Received message: " + new String(message));
socket.close();
context.term();
}
}
