Java: zeromq，尝试在MT服务器中设置响应超时

Question

我正在使用ZeroMQ客户端/服务器应用程序，现在在我的MT服务器上我尝试设置超时，我尝试在服务器上设置:

socket.setReceiveTimeOut(2000);
socket.setSendTimeOut(2000);

没有运气，我如何设置超时响应。

这是我的多线程服务器代码，这是从zeromq示例mt服务器:

/*
 *  Multithreaded Hello World server in Java
 *
 *  @author Vadim Shalts
 *  @email [e-mail]
 *
 */
import org.zeromq.ZMQ;
import org.zeromq.ZMQQueue;
class mtserver {
   static void main(String[] args) {
      final ZMQ.Context context = ZMQ.context(1);
      ZMQ.Socket clients = context.socket(ZMQ.ROUTER);
      clients.bind ("tcp://*:5555");
      ZMQ.Socket workers = context.socket(ZMQ.DEALER);
      workers.bind ("inproc://workers");
      for(int thread_nbr = 0; thread_nbr < 5; thread_nbr++) {
         Thread worker_routine = new Thread() {
            @Override
            public void run() {
               ZMQ.Socket socket = context.socket(ZMQ.REP);
               socket.connect ("inproc://workers");
               while (true) {
                  //  Wait for next request from client (C string)
                  byte[] request = socket.recv (0);
                  System.out.println ("Received request: ["+new String(request,0,request.length-1)+"]");
                  //  Do some 'work'
                  try {
                     Thread.sleep (1000);
                  } catch(InterruptedException e) {
                     e.printStackTrace();
                  }
                  //  Send reply back to client (C string)
                  byte[] reply = "World ".getBytes();
                  reply[reply.length-1] = 0; //Sets the last byte of the reply to 0
                  socket.send(reply, 0);
               }
            }
         };
         worker_routine.start();
      }
      //  Connect work threads to client threads via a queue
      ZMQQueue zMQQueue = new ZMQQueue(context,clients, workers);
      zMQQueue.run();
      //  We never get here but clean up anyhow
      clients.close();
      workers.close();
      context.term();
   }
} 

Answer 1

为什么需要一个超时?原来的例子没有使用它

Answer 2

为什么需要在服务器上设置超时?

在客户端放置超时的自然位置。

插座。在客户端工作