一、tomcal的lib放入文件

tomcat-websocket.jar

websocket-api.jar

二、代碼示例

package com.test.ws;import com.test.core.json.Jmode;import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.concurrent.atomic.AtomicInteger;/*** Created by 51594 on 2024/3/18.*/
@ServerEndpoint("/ws/test")
public class WsTest {//靜態變量，用來記錄當前在線連接數。private static AtomicInteger onlineCount = new AtomicInteger(0);//concurrent包的線程安全Set，用來存放每個客戶端對應的MyWebSocket對象。// 若要實現服務端與單一客戶端通信的話，可以使用Map來存放，其中Key可以為用戶標識//單一對話//// private static ConcurrentHashMap<String, TestController> guestSet = new ConcurrentHashMap<String, TestController>();//廣播protected static CopyOnWriteArraySet<WsTest> guestSet = new CopyOnWriteArraySet<WsTest>();//與某個客戶端的連接會話，需要通過它來給客戶端發送數據private Session session;private int user_id = 0;private String user_name = "";@OnOpenpublic void onOpen(Session session) {// System.out.println(session.getMessageHandlers().);System.out.println("新客人為" + session.getId());this.session = session;guestSet.add(this);//加入map中addOnlineCount();           //在線數加1System.out.println("有新連接" + session.getId() + "加入！當前在線人數為" + getOnlineCount());}@OnClosepublic void onClose(Session session) {guestSet.remove(this);  //從set中刪除subOnlineCount();           //在線數減1System.out.println("有一連接關閉！當前在線人數為" + getOnlineCount());}public static int getOnlineCount() {return onlineCount.get();}public static void addOnlineCount() {onlineCount.incrementAndGet();}public static void subOnlineCount() {onlineCount.decrementAndGet();}/*** 發生錯誤時調用** @param session* @param error*/@OnErrorpublic void onError(Session session, Throwable error) {System.out.println("發生錯誤");error.printStackTrace();}/*** @param msg* @param session*/@OnMessagepublic void onMessage(String msg, Session session) {System.out.println("session----" + session);System.out.println("req----" + msg);try {session.getBasicRemote().sendText(Jmode.n().set("msg", msg).toJson());for (WsTest t : guestSet) {t.session.getBasicRemote().sendText(Jmode.n().set("id", session.getId()).set("msg", msg).toJson());}} catch (Exception e) {e.printStackTrace();}}
}

三、nginx配置：

	location /salews/ {proxy_pass              http://localhost:8001/sale/ws/;proxy_http_version 1.1;proxy_set_header Upgrade $http_upgrade;proxy_set_header Connection "Upgrade";proxy_set_header Host $host;proxy_read_timeout 86400;proxy_set_header X-Real-IP $remote_addr;proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;proxy_set_header Access-Control-Allow-Methods *;}