WebSocket:客户端与服务端双向信息传输

一.WebSocket是什么

        WebSocket 是基于 TCP 的一种新的网络协议。

        像HTTP,客户端跟服务器的交互，咱们是不是就可以基于HTTP来进行交互？首先我们客户端浏览器可以发送一个请求，也就是一个request,那么这个请求就可以请求到我们这个服务器, 服务器接收到这个请求之后，它就可以进行相应的处理，之后就可以给浏览器一个响应，也就是一个response，那么这其实就是一个请求与响应的过程。

        客户端浏览器跟我们这个服务器它的交互的顺序，一定是客户端先发送一个请求，然后服务器才能给他一个响应，这个顺序能颠倒过来吗？肯定是不可以的。那么我们这个服务器是不可能主动给我们客户端浏览器来发送消息，一定是浏览器先请求服务器，然后服务器是不是才能给它一个响应。

        所以说这种交互方式我们通常称为什么？叫做请求响应模式

        客户端发送这个请求之后，那么它是不是就会跟我们这个服务器建立一个连接，那么当我这个服务器响应完之后，这个连接就不存在了, 所以说基于HTTP建立的这种连接，我们可以称为叫做短连接

        WebSocket跟 HTTP协议就非常不一样了，首先第一步是需要客户端发送一个请求，那么请求服务端这个过程叫做handshake，翻译过来其实就是握手，说白了就是客户端需要跟服务端建立这么一个连接，我们这个服务器就会给客户端一个应答，一旦它应答上之后，客户端浏览器跟这个服务器其实就建立好这个连接了，那么一旦这个连接建立好了，那么我们这个客户端跟服务器就可以进行双向通信了(浏览器既可以主动向服务器发送数据，同时这个服务器也可以向客户端浏览器来主动发送数据)。而且还是一直保持连接状态,除法一方断开

二.应用场景

        弹幕, 金融报价实时更新的图像等

三.实现步骤：

1). 准备WebSocket客户端html页面

2). 导入WebSocket的maven坐标

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

3). 导入配置类WebSocketConfiguration，注册WebSocket的服务端组件

@Configuration
public class WebSocketConfiguration {

    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }

}

4).导入WebSocket服务端组件WebSocketServer，用于和客户端通信

@Component
@ServerEndpoint("/ws/{sid}")
public class WebSocketServer {

    //存放会话对象
    private static Map<String, Session> sessionMap = new HashMap();

    /**
     * 连接建立成功调用的方法
     */
    @OnOpen
    public void onOpen(Session session, @PathParam("sid") String sid) {
        System.out.println("客户端：" + sid + "建立连接");
        sessionMap.put(sid, session);
    }

    /**
     * 收到客户端消息后调用的方法
     *
     * @param message 客户端发送过来的消息
     */
    @OnMessage
    public void onMessage(String message, @PathParam("sid") String sid) {
        System.out.println("收到来自客户端：" + sid + "的信息:" + message);
    }

    /**
     * 连接关闭调用的方法
     *
     * @param sid
     */
    @OnClose
    public void onClose(@PathParam("sid") String sid) {
        System.out.println("连接断开:" + sid);
        sessionMap.remove(sid);
    }

    /**
     * 群发
     *
     * @param message
     */
    public void sendToAllClient(String message) {
        Collection<Session> sessions = sessionMap.values();
        for (Session session : sessions) {
            try {
                //服务器向客户端发送消息
                session.getBasicRemote().sendText(message);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

}

5). 向客户端推送数据代码举例

    public void reminder(Long id) {
        // 查询订单是否存在
        Orders orders = orderMapper.getById(id);
        if (orders == null) {
            throw new OrderBusinessException(MessageConstant.ORDER_NOT_FOUND);
        }

        //基于WebSocket实现催单
        Map map = new HashMap();
        map.put("type", 2);//2代表用户催单
        map.put("orderId", id);
        map.put("content", "订单号：" + orders.getNumber());
        webSocketServer.sendToAllClient(JSON.toJSONString(map));
    }