1

我必须创建响应客户端请求的 tcp 服务器,并以固定频率将事件发送给客户端。Tcp 服务器代码:

from("netty:tcp://localhost:7100?sync=true&allowDefaultCodec=false&encoder=#stringEncode&decoder=#stringDecode")
                .to("bean:echoService");

当我的服务器必须从客户端向 msg 发送响应时,将调用 EchoService bean 代码

@Service
    public class EchoService {
      public String sayHello(Object guestName) {
        System.out.println("Input guestName : "+ guestName);
        return "Hello " + guestName;
      }
    }

我还有另一个 MessageService bean,它以固定频率发送 Hi 消息。我想将此 bean 集成到我的服务器,以便我可以向客户端发送“Hi”消息

 @Service
        public class MessageService {
          public String sayHi() {
            System.out.println("sending hi : ");
            return "Hi ";
          }
        }

我无法决定如何将 MessageService bean“hi”msg 与 tcp 服务器集成以发送 TCP 客户端。PS:- 我是骆驼的新手。

4

0 回答 0