WebSocket是HTML5以后带来的一种新的客户端和服务端的双向通信方式,简言之就是客户端和服务端之间可以直接互相通信了。
在WebSocket出来之前呢,一般客户端和服务端的通信,多采用轮训的方式,由客户端获取服务端的信息,这种方式的弊端就是需要不断和服务器端建立连接。后来WebSocket出来后,改变了这种方式,前后两端只需要建立一次握手,就可以互相发送消息,这样就保证了信息的实时性。
搭建群聊服务
前台引入socket.js,进入聊天界面后
1.首先以游客角色登录获取到sessionID
2.然后客户端和服务端进行一次握手连接,后台记录游客的IP和sessionID,作为通信的标识,同时创建监听收信函数
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 {
}
});
}
3.发送消息
stompClient.send("/allChat",{},JSON.stringify({'name':news,"groupId":groupId,"fromUserConnectId":fromUserConnectId}));
4.服务端收到消息后进行转发到客户端,转发客户端根据发送消息方的是个人还是群聊,匹配发送到对应的客户端
5.后台用redis做了session共享,但是websocket是长连接,初始是连接到哪个服务,之后的交互必须在哪个服务,所以请求过来后,需要先核实目标是哪个服务,然后再由哪个服务转发。
后台引入spring-boot-starter-websocket即可
<!-- webSocket --><dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
6.尝试着做了语音通信,但是效果不太好,延迟比较大,容易出现断续的情况。
7.尝试着对接了图灵机器人,效果还可以
涉及组件
1.SpringBoot2.0
2.websocket
3.redis
4.tomcat集群
5.adminlte
6.nginx做负载
目前来看的话,websocket集群不知道还有什么好方案,当下我这边是做了转发。
本文由聊推原创,欢迎关注,带你一起长知识!
本文暂时没有评论,来添加一个吧(●'◡'●)