Springboot整合WebSocket(纯后端)

一、 HTTP协议与WebSocket区别

    HTTP协议是一种无状态的、无连接的、单向的应用层协议 它采用了请求/响应模型 通信请求只能由客户端发起,服务端对请求做出应答处理 这种通信模型有一个弊端:HTTP协议无法实现服务器主动向客户端发起消息 http协议
    WebSocket是一种网络通信协议 WebSocket是HTML5开始提供的一种在单个TCP连接上进行双工通讯的协议 websocket协议

二、客户端(浏览器)实现

  简单介绍下前端,不做代码方面内容

1、websocket对象

    实现 WebSockets 的 Web 浏览器将通过 WebSocket 对象公开所有必需的客户端功能(主要指支持 Htm15的浏览器) 以下API用于创建 WebSocket对象:
var ws = new webSocket(url);
参数url格式说明:ws://ip地址:端口号/资源名称

2、websocket事件

事件 事件处理 描述 open websocket对象.open 连接建立时触发 message websocket对象.message 客户端接收服务端数据时触发 error websocket对象.error 通信发生错误时触发 close websocket对象.close 连接关闭时触发

3、WebSocket方法

方法 描述 send() 使用连接发送数据

三、服务端实现

    Tomcat的7.0.5版本开始支持WebSocket,并且实现了Java WebSocket规范(JSR356) Java WebSocket应用由一系列的WebSocketEndpoint组成 Endpoint是一个java对象,代表WebSocket链接的一端 对于服务端,我们可以视为处理具体webSocket消息的接口,就像Servlet之与http请求一样 我们可以通过两种方式定义Endpoint: 第一种是编程式,即继承类 javax.websocket.Endpoint并实现其方法

1、连接过程

    Endpoint实例在WebSocket握手时创建,并在客户端与服务端链接过程中有效,最后在链接关闭时结束 在Endpoint接口中明确定义了与其生命周期相关的方法 规范实现者确保生命周期的各个阶段调用实例的相关方法 生命周期方法如下:
方法 描述 注解 onOpen() 当开启一个新的会话时调用,该方法是客户端与服务端握手成功后调用的方法 @OnOpen onClose() 当会话关闭时调用 @OnClose onError() 当连接过程异常时调用 @OnError OnMessage() 当连接过程异常时调用 @OnMessage

2、服务端接收客户端消息

    当采用注解方式定义Endpoint时 可以通过@OnMessage注解指定接收消息的方法

3、服务端推送消息给客户端

    发送消息则由RemoteEndpoint完成,其实例由session维护 我们可以通过Session.getBasicRemote获取同步消息发送的实例 也可以Session.getAsyncRemote获取异步消息发送的实例 然后调用其sendXxx()方法就可以发送消息

四、后端功能实现

    springboot项目导入websocket包
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
    websocket的配置信息
@Configuration
public class WebSocketConfig {
          
   
    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
          
   
        return new ServerEndpointExporter();
    }
}
    websocket的处理类,作用相当于HTTP请求中的controller
    测试 前端模拟连接开启三个用户
    后端用户连接成功,在线3人
    用户1发送消息给用户2
    用户1发送消息给用户2,用户2并回应用户1
    后台日志
经验分享 程序员 微信小程序 职场和发展