Spring框架也支持tcp连接,我编写下面的代码来设置一个简单的套接字服务器,我很困惑将下面的期货添加到我的套接字服务器：
>根据唯一标识符(例如从客户端收到的客户端密钥,可能使用TCP Connection Events)授权客户端
>直接向特定客户端发送消息(基于标识符)
>广播消息
更新：
>添加Config.sendMessage以向单个客户端发送消息
> Config.broadCast添加到广播消息
> authorizeIncomingConnection授权客户端,接受或拒绝连接
>添加tcpConnections静态字段以保留tcpEvent源
问题！
>正在使用tcpConnections HashMap好主意？！
>是我实施好的授权方法吗？
Main.java
@SpringBootApplication
public class Main {
public static void main(final String[] args) {
SpringApplication.run(Main.class,args);
}
}
Config.java
@EnableIntegration
@IntegrationComponentScan
@Configuration
public class Config implements ApplicationListenerMainController.java
@Controller
public class MainController {
@RequestMapping("/notify/{connectionId}/{message}")
@ResponseBody
public String home(@PathVariable String connectionId,@PathVariable String message) {
try {
Config.sendMessage(connectionId,message);
return "Client Notified !";
} catch (Exception e) {
return "Failed To Notify Client,cause : \n " + e.toString();
}
}
@RequestMapping("/broadCast/{message}")
@ResponseBody
public String home(@PathVariable String message) {
return Config.broadCast(message);
}
}
用法：
HTTP：//本地主机：8080 /通知/ {的ConnectionId} / {消息}
> broadCast
HTTP：//本地主机：8080 /广播/消息{}
最佳答案
TcpConnectionOpenEvent包含connectionId属性.来自该客户端的每条消息在IpHeaders.CONNECTION_ID消息头中都具有相同的属性.
原文链接：https://www.f2er.com/spring/431363.html>添加一个自定义路由器,跟踪每个连接的登录状态.
>查找连接ID,如果未经过身份验证,则路由到质询/响应子流.
>验证时,路由到正常流程.
要使用任意消息传递(而不是请求/响应),请使用TcpReceivingChannelAdapter和TcpSendingMessageHandler而不是入站网关.两者都配置为使用相同的连接工厂.对于发送到消息处理程序的每条消息,添加IpHeaders.CONNECTION_ID标头以定位特定客户端.
要广播,请为每个连接ID发送消息.
