SpringBoot结合WebSocket搭建群聊,同时还接入机器人回复

WebSocket是HTML5以后带来的一种新的客户端和服务端的双向通信方式,简言之就是客户端和服务端之间可以直接互相通信了。

在WebSocket出来之前呢,一般客户端和服务端的通信,多采用轮训的方式,由客户端获取服务端的信息,这种方式的弊端就是需要不断和服务器端建立连接。后来WebSocket出来后,改变了这种方式,前后两端只需要建立一次握手,就可以互相发送消息,这样就保证了信息的实时性。

搭建群聊服务

前台引入socket.js,进入聊天界面后

1.首先以游客角色登录获取到sessionID

2.然后客户端和服务端进行一次握手连接,后台记录游客的IP和sessionID,作为通信的标识,同时创建监听收信函数

<code>function connect(){
var socket = new SockJS('/endpointAric'); //连接SockJS的endpoint名称为"endpointWisely"
stompClient = Stomp.over(socket);//使用STMOP子协议的WebSocket客户端
stompClient.connect({},function(frame){//连接WebSocket服务端 //console.log('Connected:' + frame); //通过stompClient.subscribe订阅/topic/getResponse 目标(destination)发送的消息,这个是在控制器的@SentTo中定义的
stompClient.subscribe('/topic/getResponse',function(response){
if(JSON.parse(response.body).fromUserConnectId!=fromUserConnectId){
showResponse(JSON.parse(response.body),JSON.parse(response.body).groupId);
if(timeout1==null){
flash_title();
}
}else if(JSON.parse(response.body).fromUserConnectId==fromUserConnectId){
answers(JSON.parse(response.body),JSON.parse(response.body).groupId);
}
});
},function(err){
if (window.confirm("连接失败,点击确定重新连接,或者点击取消刷新页面重试")) {

connect();
} else {

}
});
}/<code>
SpringBoot结合WebSocket搭建群聊,同时还接入机器人回复

3.发送消息

<code>stompClient.send("/allChat",{},JSON.stringify({'name':news,"groupId":groupId,"fromUserConnectId":fromUserConnectId}));/<code>
SpringBoot结合WebSocket搭建群聊,同时还接入机器人回复


4.服务端收到消息后进行转发到客户端,转发客户端根据发送消息方的是个人还是群聊,匹配发送到对应的客户端

SpringBoot结合WebSocket搭建群聊,同时还接入机器人回复

5.后台用redis做了session共享,但是websocket是长连接,初始是连接到哪个服务,之后的交互必须在哪个服务,所以请求过来后,需要先核实目标是哪个服务,然后再由哪个服务转发。

后台引入spring-boot-starter-websocket即可

<code><dependency>
<groupid>org.springframework.boot/<groupid>
<artifactid>spring-boot-starter-websocket/<artifactid>
/<dependency>/<code>

6.尝试着做了语音通信,但是效果不太好,延迟比较大,容易出现断续的情况。

7.尝试着对接了图灵机器人,效果还可以

涉及组件

1.SpringBoot2.0

2.websocket

3.redis

4.tomcat集群

5.adminlte

6.nginx做负载


目前来看的话,websocket集群不知道还有什么好方案,当下我这边是做了转发。


分享到:


相關文章: