编程开源技术交流,分享技术与知识

网站首页 > 开源技术 正文

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

wxchong 2024-08-21 03:07:48 开源技术 8 ℃ 0 评论

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集群不知道还有什么好方案,当下我这边是做了转发。

本文由聊推原创,欢迎关注,带你一起长知识!

Tags:

本文暂时没有评论,来添加一个吧(●'◡'●)

欢迎 发表评论:

最近发表
标签列表