config

• WebSocketConfig.java

package com.example.spring_boot_websocket.config;

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

/**
 * WebSocket配置類
 * 開啟WebSocket支持
 */
@Configuration
public class WebSocketConfig {
    @Bean
    public ServerEndpointExporter serverEndpointExporter(){
        return new ServerEndpointExporter();
    }
}

• WebSocketServer.java

package com.example.spring_boot_websocket.config;

import org.springframework.stereotype.Component;

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;

/**
 * WebSocket服務(wù)端
 */
//客戶端向服務(wù)器端建立WebSocket連接的URL
@ServerEndpoint("/websocket")
@Component
public class WebSocketServer {
    //靜態(tài)變量，用來記錄當(dāng)前在線連接數(shù)，可選
    private static int onlineCount = 0;

    //concurrent包的線程安全set，用來存放每個(gè)客戶端對應(yīng)的MyWebSocket對象
    private static CopyOnWriteArraySet<WebSocketServer> webSocketSet = new CopyOnWriteArraySet<WebSocketServer>();

    //與某個(gè)客戶端的連接會話，需要通過它來給客戶端發(fā)送數(shù)據(jù)
    private Session session;

    /**
     * 連接建立成功調(diào)用的方法
     */
    @OnOpen
    public void onOpen(Session session){
        this.session = session;
        webSocketSet.add(this);
        addOnlineCount();           //在線數(shù)加1
        System.out.println("有新窗口開始監(jiān)聽,當(dāng)前在線人數(shù)為" + getOnlineCount());
        try {
            sendMessage("連接成功");
        } catch (IOException e) {
            System.out.println("WebSocket IO異常");
        }
    }

    /**
     * 連接關(guān)閉調(diào)用的方法
     */
    @OnClose
    public void onClose() {
        webSocketSet.remove(this);  //從set中刪除
        subOnlineCount();           //在線數(shù)減1
        System.out.println("有連接關(guān)閉！當(dāng)前在線人數(shù)為" + getOnlineCount());
    }

    /**
     * 收到客戶端消息后調(diào)用的方法
     *
     * @param message 客戶端發(fā)送過來的消息
     */
    @OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("收到客戶端的信息:" + message);
        //群發(fā)消息
        for (WebSocketServer item : webSocketSet) {
            try {
                item.sendMessage(message);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * @param session
     * @param error
     */
    @OnError
    public void onError(Session session, Throwable error) {
        System.out.println("發(fā)生錯(cuò)誤");
        error.printStackTrace();
    }

    /**
     * 實(shí)現(xiàn)服務(wù)器主動(dòng)推送
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
    }


    /**
     * 群發(fā)自定義消息
     */
    public static void sendInfo(String message) throws IOException {
        System.out.println("推送消息內(nèi)容:" + message);
        for (WebSocketServer item : webSocketSet) {
            try {
                item.sendMessage(message);
            } catch (IOException e) {
                continue;
            }
        }
    }

    public static synchronized int getOnlineCount() {
        return onlineCount;
    }

    public static synchronized void addOnlineCount() {
        WebSocketServer.onlineCount++;
    }

    public static synchronized void subOnlineCount() {
        WebSocketServer.onlineCount--;
    }
}

Controller

• WebSocketController.java

package com.example.spring_boot_websocket.controller;

import com.example.spring_boot_websocket.config.WebSocketServer;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import java.io.IOException;

@RestController
public class WebSocketController {

    @RequestMapping("/socket/push")
    public String pushMsg(HttpServletRequest request) {
        String message = request.getParameter("fuwu");
        try {
            WebSocketServer.sendInfo(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return "server";
    }
}

界面

• index.html

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>websocket</title>
</head>
<body>
<h2>websocket</h2>
<h1>服務(wù)器端信息顯示區(qū)</h1>
<textarea id="fuwu" style="width: 200px; height: 300px">

</textarea>
<h1>客戶信息輸入?yún)^(qū)</h1>
<textarea id="kehu" style="width: 200px">

</textarea>
<button onclick="myFirst()">發(fā)送</button>

<script>
    function myFirst() {
        socket.send(document.getElementById("kehu").value);
        document.getElementById("kehu").value =null;
    }
    var socket;
    if (typeof(WebSocket) == "undefined") {
        console.log("您的瀏覽器不支持WebSocket");
    } else {
        console.log("您的瀏覽器支持WebSocket");
        //實(shí)現(xiàn)化WebSocket對象，指定要連接的服務(wù)器地址與端口建立連接
        socket = new WebSocket("ws://localhost:8080/websocket");
//        打開事件
        socket.onopen = function () {
            console.log("Socket已打開");
//            socket.send("這是來自客戶端的消息:" + new Date());
        };
        //獲得服務(wù)器端消息事件
        socket.onmessage = function (msg) {
            console.log(msg.data);
            alert(msg.data);
            document.getElementById("fuwu").value = document.getElementById("fuwu").value+"\n"+ msg.data;
        };
        //關(guān)閉事件
        socket.onclose = function () {
            console.log("Socket已關(guān)閉");
        };
        //發(fā)生了錯(cuò)誤事件
        socket.onerror = function () {
            alert("Socket發(fā)生了錯(cuò)誤");
        }
    }
</script>

</body>
</html>

• server.html

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>服務(wù)器</title>
</head>
<body>
<h1>
    <form action="/socket/push" name="loginfrom" accept-charset="utf-8" method="post">
            <textarea id="fuwu" name="fuwu">

            </textarea>
        <input type="submit" value="群發(fā)" >
    </form>
</h1>
</body>
</html>