Apache Camel Netty Socket

Question

Я хочу использовать соединение netache camel netty в режиме клиента. А также этот клиент не находится в синхронном режиме. Я предоставил следующую конфигурацию для этого, но appache создал два подключения к серверу для получения сообщения и один для ответа на него. как мы можем использовать netty-коннектор в этом режиме.

from("netty4:tcp://localhost:7000?sync=false&allowDefaultCodec=false&encoder=#stringEncoder&decoder=#stringDecoder&clientMode=true&reconnect=true&reconnectInterval=1000") 
      .process(new Processor() { 
       public void process(Exchange exchange) throws Exception { 
        exchange.getOut().setBody("Hello " + exchange.getIn().getBody()); 
       } 
      }) 
      .to("netty4:tcp://localhost:7000?sync=false&allowDefaultCodec=false&encoder=#stringEncoder&decoder=#stringDecoder&clientMode=true"); 

и Hercules Utitly я вижу два соединения для этого запроса обработки

11:00:51 AM: 127.0.0.1 Client connected 
11:00:51 AM: 127.0.0.1 Client connected 

Answer 1

Так это то, что вы хотите, верно? «после получения запроса от сервера. Я хочу нажать это в MQ и ждать другого MQ для обработанного ответа. Поэтому, когда пакет обрабатывается и доступен в MQ, я хочу использовать такое же соединение для передачи ответа на сокет».

Итак, прежде всего, вероятно, согласен с некоторыми требованиями. Если вам нужно отправить ответ, т. Е. Клиент ждет ответа на запрос, который он отправил, то он должен быть синхронным, а не асинхронным.

Таким образом, вы можете просто написать:

from("netty4:tcp://localhost:7000?sync=true&allowDefaultCodec=false&encoder=#stringEncoder&decoder=#stringDecoder&clientMode=true&reconnect=true&reconnectInterval=1000") 
      .process(new Processor() { 
       public void process(Exchange exchange) throws Exception { 
        exchange.getOut().setBody("Hello " + exchange.getIn().getBody()); 
       } 
      }) 
      .to("ACTIVE_MQ"); 

Конечно же в активной части мэка вам необходимо установить ответ и тайм-аут, так что если вы не получите ответ в момент его раз из и вы уведомляете клиента с хорошим сообщением об ошибке.

Что произойдет, так это то, что сообщение получено и отправлено в активную очередь mq с соответствующим ответом на свойства. Если сообщение получено, ответ отправляется обратно по тому же соединению с клиентом.

Я бы посоветовал вам прочитать запрос/ответ JMS в Camel, поскольку это поможет вам настроить активную часть mq. http://camel.apache.org/jms.html