我必须创建响应客户端请求的 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:- 我是骆驼的新手。