0

クライアント/サーバーアプリケーションにZeroMQを使用していますが、MTサーバーでタイムアウトを設定しようとしましたが、サーバーで設定しようとしました:

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

運が悪ければ、応答にタイムアウトを設定するにはどうすればよいですか。

これは私のマルチスレッドサーバーコードです。これはmtサーバーのzeromqの例から取られています。

/*
 *  Multithreaded Hello World server in Java
 *
 *  @author Vadim Shalts
 *  @email vshalts@gmail.com
 *
 */

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();
   }
} 
4

2 に答える 2

0

サーバーでタイムアウトが必要なのはなぜですか?

クライアントにタイムアウトを配置する自然な場所。

socket.setReceiveTimeOut(int ミリ秒); クライアント側で動作します。

于 2015-04-28T08:56:51.607 に答える
0

なぜタイムアウトが必要なのですか?元の例では使用していません。

于 2012-12-30T00:37:53.487 に答える