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