WebSocket

WebSocket 一次握手就可以使客户端和服务端建立长连接，并进行双向数据传输。

由于其双向传输特性，服务端可主动向客户端发送信息，实时性很高。

而与 HTTP 协议比起来 WebSocket 协议每次数据传输的头信息都较小，节约带宽。

在获取实时数据这方面时，那是比 ajax 轮询方式高到不知道哪去了。

事件

@OnOpen：当一个 WebSocket 连接成功时触发；
@OnClose：当一个 WebSocket 连接被关闭时触发；
@OnError：当一个 WebSocket 连接因错误而关闭时触发；
@OnMessage：当通过 WebSocket 收到数据时触发；

导包

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

配置ws服务

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;

@Configuration
public class WSConfig {
    //启动ws服务
    @Bean
    public ServerEndpointExporter getWebSocketServer() throws Exception {
        return new ServerEndpointExporter();
    }
}

配置服务

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

// 该注解可以将类定义成一个WebSocket服务器端
@ServerEndpoint("/{name}")
@Component
public class LuckySheetWebSocketServer {
    //存储连接及昵称
    static final Map<Session, String> connMap = new ConcurrentHashMap<>();

    private String name;

    @OnOpen
    public void onOpen(Session conn) {
       
    }

    @OnClose
    public void onClose(Session conn) {
    }

    @OnMessage
    public void onMessage(String message, Session conn) {
        if (null != message && message.length() != 0) {
        }
    }

    @OnError
    public void onError(Session conn, Throwable ex) {
        log.warn("链接错误", ex);
        try {
            conn.close();
        } catch (IOException e) {
            log.error("错误链接关闭失败", e);
        }
    }
     /**
     * 指定发消息
     *
     * @param message
     */
    public void sendMessage(String message) {
        try {
            this.session.getBasicRemote().sendText(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    /**
     * 群发消息
     *
     * @param message
     */
    public static void fanoutMessage(String message) {
        SESSIONS.forEach(ws -> ws.sendMessage(message));
    }

}