Netty-SocketIO实现服务器消息推送_nettysocket io client

传统的Http是基于请求-响应式的协议，需要客户端主动向用户发送请求，才能得到服务器的响应，而在请求同步响应结束后，Http也会关闭，此时服务器便不能再向客户端主动发送消息了。即若客户端想得到服务端的消息，就必须首先发送请求才能得到消息回复。
在有些场景下，如股票价格实时显示、直播、在线聊天等场景，则需要服务器主动向客户端推送消息，显然Http协议并不太适合完全这项工作，而Netty-SocketIO是基于Netty框架下用Java实现Socket通信的组件，可用于服务器主动推送消息到客户端的情形。
文章基于Netty-Socket实现Java后台+socket.io.js前端实现服务器消息推送。

后台服务器部分

• 引入netty-socketio，在maven中引入jar包，注意版本，笔者刚开始尝试1.6.x的版本，不能正常使用，换成1.7.7版本之后就好了。

<!-- netty socketio -->
    <dependency>
        <groupId>com.corundumstudio.socketio</groupId>
        <artifactId>netty-socketio</artifactId>
        <version>1.7.7</version>
    </dependency>
1
2
3
4
5
6

• Socket服务器代码，socket服务地址端口设为本机localhost:8089，并在spring Bean加载的时候就开启服务。socket服务需要添加监听事项，本文用spring注入listeners

@Service
public class SocketService implements InitializingBean{
   

    @Autowired
    private EventListennter listeners;

    public void startServer() {
        Configuration config = new Configuration();
        config.setHostname("localhost");
        config.setPort(8089);

        SocketIOServer server = new SocketIOServer(config);
        server.addConnectListener(new ConnectListener() {
  // 添加客户端连接监听器
            @Override
            public void onConnect(SocketIOClient client) {
                System.err.println(client.getRemoteAddress() + " web客户端接入");
            }
        });

        server.addListeners(listeners);
        server.start();

    }

    @Override
    public void afterPropertiesSet() throws Exception {
        System.out.println("start socket");
        this.startServer();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

• 监听器：添加监听事项event

@Component
public class EventListennter {
   

    //维护每个客户端的SocketIOClient
    private Map<String, List<SocketIOClient>> clients = new ConcurrentHashMap<>();

    
1
2
3
4
5
6
7
8