zeroMq笔记

• Hwserver: Hello World server in Java

    //
    //  Hello World server in Java
    //  Binds REP socket to tcp://*:5555
    //  Expects "Hello" from client, replies with "World"
    //
    
    import org.zeromq.ZMQ;
    
    public class Hwserver {
    
        public static void main(String[] args) throws Exception {
            ZMQ.Context context = ZMQ.context(1);
    
            //  Socket to talk to clients
            ZMQ.Socket responder = context.socket(ZMQ.REP);
            responder.bind("tcp://*:5555");
    
            while (!Thread.currentThread().isInterrupted()) {
                // Wait for next request from the client
                byte[] request = responder.recv(0);
                System.out.println("Received " + new String (request));
    
                // Do some 'work'
                Thread.sleep(1000);
    
                // Send reply back to client
                String reply = "World";
                responder.send(reply.getBytes(), 0);
            }
            responder.close();
            context.term();
        }
}

• Hwclient: Hello World client in Java

//
//  Hello World client in Java
//  Connects REQ socket to tcp://localhost:5555
//  Sends "Hello" to server, expects "World" back
//

import org.zeromq.ZMQ;

public class Hwclient {

    public static void main(String[] args) {
        ZMQ.Context context = ZMQ.context(1);

        //  Socket to talk to server
        System.out.println("Connecting to hello world server…");

        ZMQ.Socket requester = context.socket(ZMQ.REQ);
        requester.connect("tcp://localhost:5555");

        for (int requestNbr = 0; requestNbr != 10; requestNbr++) {
            String request = "Hello";
            System.out.println("Sending Hello " + requestNbr);
            requester.send(request.getBytes(), 0);

            byte[] reply = requester.recv(0);
            System.out.println("Received " + new String(reply) + " " + requestNbr);
        }
        requester.close();
        context.term();
    }
}