Как сервер поддерживает параллелизм в режиме jnanomsg rep / req - PullRequest
Новая
       17

Как сервер поддерживает параллелизм в режиме jnanomsg rep / req

0 голосов
/ 17 мая 2019

Когда я общаюсь в режиме jnanomsg rep / req, программирование на стороне сервера поддерживает однопоточную обработку сообщений.Как отправить пул потоков после получения сообщения, завершения обработки сообщения и возврата из пула потоков, аналогично программированию TCP

env: JDK1.7 jnanomsg 0.4.3 

private static void node1() {
        final RepSocket socket = new RepSocket();
        socket.bind(url);
        new Thread(new Runnable() {
            public void run() {
                while (true) {
                    try {
                        System.out.println("node1:" + socket.recvString());  
                        Thread.sleep(1000);
                        socket.send("world");

                    } catch (IOException e) {     
                        e.printStackTrace();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            }
        }).start();
    }

Я хочу в цикле while, когда сервер получает сообщение, он может получить дескриптор и передать дескриптор в поток для обработки следующих операций, таких как обработка полученных данных, возврат данных и т. Д. Но это не так.Похоже, он не доступен так же, как программирование TCP, которое все еще использует сокет только на стороне сервера

...