大家好，又见面了，我是你们的朋友全栈君。

需求与背景

之前所有的请求都是浏览器发起，浏览器本身没有接受请求的能力。所以一些特殊需求都是用ajax轮询的方式来实现的。

比如：

股价展示页面实时的获取股价更新
赛事的文字直播，实时更新赛况
通过页面启动一个任务，前端想知道任务后台的实时运行状态

HTML5推广之后，服务端主动推送数据，浏览器接受数据的方式来解决

全双工通信（full-duplex communication）—— WebSocket

全双工就是双向通信，WebSocket就是移动电话（可以随时发送信息与接受信息，就是全双工）
<span role="heading" aria-level="2">服务器推送技术

本质上是一个额外的TCP连接，建立和关闭时握手使用HTTP协议，其他数据传输不使用HTTP协议

HTTP协议适用于复杂双向实时数据通讯场景
在Web网页上的客服、聊天室一般使用WebSocket开发

服务端主动推送： SSE（Server Send Event)

HTML5新标准，用来从服务端实时推送数据到浏览器端，直接建立在当前HTTP连接上
本质上是保持一个HTTP长连接、轻量协议。

=》客户端发送一个请求到服务端，服务端保持这个请求连接知道一个新的消息准备好，将消息返回到客户端。除非主动关闭，否则一直保持连接。

建立连接
服务端 -> 浏览器（连接保持）
关闭连接

SSE一大特色：重复利用1个连接来接受服务器发送的消息（event），从而避免不断轮询请求建立连接，造成服务资源紧张。

	是否基于新协议	是否双向通信	是否支持跨域
SSE	否（Http）	否（单向）	否（Firefox 支持跨域）
WebSocket	是（ws）	是	是

模拟网络支付场景

Eg: 淘宝买一个产品之后进行扫码支付，结合SSE实现这个过程

<span role="heading" aria-level="2">服务器推送技术

关键代码

<span role="heading" aria-level="2">服务器推送技术

浏览器前端实现

对于服务器端像浏览器发送的数据，浏览器端需要在JavaScript中使用EventSource对象来进行处理。EventSource使用的是标准的事件监听器方式，只需要在对象上添加相应事件处理方法。

事件名称	事件触发说明	事件处理方法
open	当服务器向浏览器第一次发送数据时产生	onopen
message	当收到服务器发送的消息时产生	onmessage
error	当出现异常时产生	onerror

兼容HTTPS协议

WebSocket的ws协议是基于HTTP协议实现的。
WebSocket的wss协议是基于HTTPS协议实现的。

一旦你的项目里面使用了https协议，你的websocket就要使用wss协议才可以。怎么让Spring Boot项目支持WSS协议？

WebSocket编程基础

连接的建立

前端JS向后端发送WSS连接建立请求

socket = new WebSocket("wss://localhost:8888/ws/asset");

SpringBoot服务端WebSocket服务接收类定义如下：

@Component
@Slf4j
@ServerEndpoint(value = "/ws/asset")
public class WebSocketServer{

}

全双工数据交互
前端后端都有
onopen事件监听，处理连接建立事件
onmessage事件监听，处理对方发过来的消息数据
onclose事件监听，处理连接关闭
onerror事件监听，处理交互过程中的异常

<span role="heading" aria-level="2">服务器推送技术

示例： websocket实现聊天软件

WebSocketServer本节内容的核心代码，websocket服务端代码

@ServerEndpoint(value = “/ws/asset”)表示websocket的接口服务地址
@OnOpen注解的方法，为连接建立成功时调用的方法
@OnClose注解的方法，为连接关闭调用的方法
@OnMessage注解的方法，为收到客户端消息后调用的方法
@OnError注解的方法，为出现异常时调用的方法

服务端代码

@Component
@Slf4j
@ServerEndpoint(value = "/ws/asset")
public class WebSocketServer {  

    //用来统计连接客户端的数量
    private static final AtomicInteger OnlineCount = new AtomicInteger(0);
    // concurrent包的线程安全Set，用来存放每个客户端对应的Session对象。  
    private static CopyOnWriteArraySet<Session> SessionSet = new CopyOnWriteArraySet<>();
    
    /** 
     * 连接建立成功调用的方法 
     */  
    @OnOpen
    public void onOpen(Session session) throws IOException {
        SessionSet.add(session);   
        int cnt = OnlineCount.incrementAndGet(); // 在线数加1  
        log.info("有连接加入，当前连接数为：{}", cnt);
    }

    /**
     * 收到客户端消息后调用的方法
     * @param message 客户端发送过来的消息
     */
    @OnMessage
    public void onMessage(String message, Session session) throws IOException {
        log.info("来自客户端的消息：{}",message);
        sendMessage(session, "Echo消息内容："+message);
        // broadCastInfo(message); 群发消息
    }


    /** 
     * 连接关闭调用的方法 
     */  
    @OnClose
    public void onClose(Session session) {  
        SessionSet.remove(session);  
        int cnt = OnlineCount.decrementAndGet();  
        log.info("有连接关闭，当前连接数为：{}", cnt);  
    }  

    /** 
     * 出现错误
     */  
    @OnError
    public void onError(Session session, Throwable error) {  
        log.error("发生错误：{}，Session ID： {}",error.getMessage(),session.getId());
    }  
  
    /** 
     * 发送消息，实践表明，每次浏览器刷新，session会发生变化。 
     * @param session  session
     * @param message  消息
     */  
    private static void sendMessage(Session session, String message) throws IOException {

        session.getBasicRemote().sendText(String.format("%s (From Server，Session ID=%s)",message,session.getId()));

    }  
  
    /** 
     * 群发消息 
     * @param message  消息
     */  
    public static void broadCastInfo(String message) throws IOException {
        for (Session session : SessionSet) {  
            if(session.isOpen()){  
                sendMessage(session, message);
            }  
        }  
    }
      
}

客户端代码：

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>websocket测试</title>
    <style type="text/css">
        h3,h4{
            text-align:center;
        }
    </style>
</head>
<body>

<h3>请输入要发送给服务器端的消息：</h3><br/>

<label for="text">输入发送信息</label><input id="text" type="text" />
<button onclick="sendToServer()">发送服务器消息</button>
<button onclick="closeWebSocket()">关闭连接</button>
<br>
信息:
<span id="message">

</span>
<script type="text/javascript">
    var socket;
    if (typeof (WebSocket) == "undefined") {
        console.log("遗憾：您的浏览器不支持WebSocket");
    } else {
        socket = new WebSocket("wss://localhost:8888/ws/asset");
        //连接打开事件
        socket.onopen = function() {
            console.log("Socket已打开");
        };
        //收到消息事件
        socket.onmessage = function(msg) {
            document.getElementById('message').innerHTML += msg.data + '<br/>';
        };
        //连接关闭事件
        socket.onclose = function() {
            console.log("Socket已关闭");
        };
        //发生了错误事件
        socket.onerror = function() {
            alert("Socket发生了错误");
        };

        //窗口关闭时，关闭连接
        window.unload=function() {
            socket.close();
        };
    }

    //关闭连接
    function closeWebSocket(){
        socket.close();
    }

    //发送消息给服务器
    function sendToServer(){
        var message = document.getElementById('text').value;
        socket.send(message);
    }
</script>

</body>
</html>

发布者：全栈程序员-用户IM，转载请注明出处：https://javaforall.cn/155724.html原文链接：https://javaforall.cn

【正版授权，激活自己账号】： Jetbrains全家桶Ide使用，1年售后保障，每天仅需1毛

【官方授权正版激活】： 官方授权正版激活支持Jetbrains家族下所有IDE 使用个人JB账号...