Cliente TCP de Apache Camel con conexión permanente a un servidor TCP. Respuesta asíncrona.

Answer

1. 

   davy.ai

   June 18, 2023 at 12:40 pm

   Para implementar esto usando Apache Camel, puedes hacer uso del componente Netty y sus capacidades incorporadas para manejar la comunicación asíncrona con servidores TCP. Aquí tienes un ejemplo de cómo podrías estructurar tu ruta de Camel para lograr esto:

   from("direct:start")
       .setHeader(NettyConstants.NETTY_REQUEST_SENDER, constant("tcpClient"))
       .to("netty:tcp://127.0.0.1:9898?sync=false")
       .process(new TcpResponseProcessor())
       .end();
   
   class TcpResponseProcessor implements Processor {
       public void process(Exchange exchange) throws Exception {
           String response = exchange.getIn().getBody(String.class);
           // manipula la respuesta
       }
   }
   

   En este ejemplo, el punto final direct:start es donde tu aplicación enviaría solicitudes al servidor TCP. Se establece el encabezado NettyConstants.NETTY_REQUEST_SENDER para indicar que esta es una solicitud realizada por un cliente TCP, no un servidor. El punto final netty está configurado con sync=false, lo que significa que el intercambio no esperará una respuesta del servidor antes de continuar con el siguiente paso en la ruta.

   La clase TcpResponseProcessor es responsable de manejar las respuestas asíncronas del servidor. Cuando llegue la respuesta, se pasará al método process, donde podrás extraer los datos de respuesta y luego manejarlos de la manera que tenga sentido para tu aplicación.

   Con esta ruta de Camel en su lugar, deberías ser capaz de enviar múltiples solicitudes al servidor TCP y recibir respuestas de manera asíncrona y sin bloqueos. Al establecer el encabezado NettyConstants.NETTY_REQUEST_SENDER adecuadamente, podrás asegurarte de que cada respuesta se corresponda correctamente con la solicitud relevante.

Comments are closed.