上網看了很多方式，最後覺得這種方式比較簡單易懂，這邊主要有三個類（包括註解的配置檔案）就可以實現後臺內容

文末會展示結果例項，如果是你所需要的效果，直接拿去用吧~專案中複製直接用

本文根據網上整理並修改！！！

本文思路來自：連結

現在開始。開始前請確保pom已經引入需要的包

首先是配置檔案類（註解）

/** 
 * Spring WebSocket的配置，這裡採用的是註解的方式 
 */  
  
@Configuration  
@EnableWebMvc//這個標註可以不加，如果有加，要extends WebMvcConfigurerAdapter  
@EnableWebSocket  
public class WebSocketConfig extends WebMvcConfigurerAdapter implements WebSocketConfigurer {  
  
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {  
        //1.註冊WebSocket  
        String websocket_url = "/websocket/socketServer";                        //設定websocket的地址  
        registry.addHandler(webSocketHandler(), websocket_url).                          //註冊Handler  
                addInterceptors(new WebSocketHandshakeInterceptor());                   //註冊Interceptor  
  
        //2.註冊SockJS，提供SockJS支援(主要是相容ie8)  
        String sockjs_url = "/sockjs/socketServer";                              //設定sockjs的地址  
        registry.addHandler(webSocketHandler(), sockjs_url).                            //註冊Handler  
                addInterceptors(new WebSocketHandshakeInterceptor()).                   //註冊Interceptor  
                withSockJS();                                                           //支援sockjs協議  
    }  
  
    @Bean
    public TextWebSocketHandler webSocketHandler() {  
        return new WebSocketHandler();  
    }  
}  
 

然後是連線攔截器類，主要是攔截連線並且設定使用者session標識作用，這樣在最後一個處理請求類可以分清是哪個已連線使用者發出的請求~，

/** 
 * WebSocket握手攔截器 
 */  
public class WebSocketHandshakeInterceptor implements HandshakeInterceptor {  
 
    public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse serverHttpResponse, WebSocketHandler webSocketHandler, Map<String, Object> attributes) throws Exception {  

    	if (request instanceof ServletServerHttpRequest) {
    		ServletServerHttpRequest servletRequest = (ServletServerHttpRequest) request;  
            HttpSession session = servletRequest.getServletRequest().getSession(false);  
            if (session != null) {  
                String userName = (String) session.getAttribute("SESSION_USERNAME");  //這邊獲得登入時設定的唯一使用者標識
                if (userName == null) {  
                    userName = "未知" + session.getId();  
                }  
                attributes.put("WEBSOCKET_USERNAME", userName);  //將使用者標識放入引數列表後，下一步的websocket處理器可以讀取這裡面的資料
            }  
        }  
        return true;  
    }  
  
    public void afterHandshake(ServerHttpRequest serverHttpRequest, ServerHttpResponse serverHttpResponse, WebSocketHandler webSocketHandler, Exception e) {  
        System.out.println("After Handshake");  
    }
}  
 

我在參考部落格的基礎上修改成一對一識別的方式，識別使用者的方式是根據‘@‘分隔符處理傳來的字串，格式是

“目標使用者標識@文字資訊”，這樣可以知道是要發給哪個已連線使用者的，如果沒有找到這個使用者標識，返回給使用者對方不線上或者對方線上異常 資訊。。。返回的資訊可以是“狀態碼@文字資訊（或者是提示資訊）”前端根據狀態碼來顯示是否是正常聊天內容還是異常資訊。。。 在文末看例項就知道啦

處理器：

/**
 * Websocket處理器
 */

public class WebSocketHandler extends TextWebSocketHandler {

	// 已建立連線的使用者
	private static final ArrayList<WebSocketSession> users = new ArrayList<WebSocketSession>();

	/**
	 * 處理前端傳送的文字資訊 js呼叫websocket.send時候，會呼叫該方法
	 * 
	 * @param session
	 * @param message
	 * @throws Exception
	 */
	@Override
	protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
		String username = (String) session.getAttributes().get("WEBSOCKET_USERNAME");

		// 獲取提交過來的訊息詳情
		System.out.println("收到使用者 " + username + " 的訊息:" + message.toString());
		// 分割成id和資訊內容
		String[] messageInfo = message.getPayload().split("@");
		if (messageInfo.length != 2) {
			sendMessageToUser(username, new TextMessage("
 
[email protected]伺服器出錯請稍後再發送吧"));
		} else {
			String target = messageInfo[0];
			String content = messageInfo[1];
			// 遍歷所有已連線使用者
			for (WebSocketSession user : users) {
				if (user.getAttributes().get("WEBSOCKET_USERNAME").equals(target)) {
					//遇到匹配使用者 連線正常則傳送訊息
					if (user.isOpen()) {
						sendMessageToUser(target, new TextMessage("[email protected]"+content));
					}else{//若異常則傳送失敗
						sendMessageToUser(username, new TextMessage("[email protected]對方線上異常,傳送失敗"));
					}
					return;
				}
			}
			//未找到匹配使用者 傳送失敗
			sendMessageToUser(username, new TextMessage("[email protected]對方暫時不線上"));
		}
	}

	/**
	 * 當新連線建立的時候，被呼叫 連線成功時候，會觸發頁面上onOpen方法
	 * 
	 * @param session
	 * @throws Exception
	 */
	@Override
	public void afterConnectionEstablished(WebSocketSession session) throws Exception {
		users.add(session);
		String username = (String) session.getAttributes().get("WEBSOCKET_USERNAME");
		System.out.println("使用者 " + username + " Connection Established");
		session.sendMessage(new TextMessage(username + " connect"));
	}

	/**
	 * 當連線關閉時被呼叫
	 * 
	 * @param session
	 * @param status
	 * @throws Exception
	 */
	@Override
	public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
		String username = (String) session.getAttributes().get("WEBSOCKET_USERNAME");
		System.out.println("使用者 " + username + " Connection closed. Status: " + status);
		users.remove(session);
	}

	/**
	 * 傳輸錯誤時呼叫
	 * 
	 * @param session
	 * @param exception
	 * @throws Exception
	 */
	@Override
	public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
		String username = (String) session.getAttributes().get("WEBSOCKET_USERNAME");
		if (session.isOpen()) {
			session.close();
		}
		System.out.println("使用者: " + username + " websocket connection closed......");
		users.remove(session);
	}

	/**
	 * 給所有線上使用者傳送訊息
	 * 
	 * @param message
	 */
	public void sendMessageToUsers(TextMessage message) {
		for (WebSocketSession user : users) {
			try {
				if (user.isOpen()) {
					user.sendMessage(message);
				}
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

	/**
	 * 給某個使用者傳送訊息
	 * 
	 * @param userName
	 * @param message
	 */
	public void sendMessageToUser(String userName, TextMessage message) {
		for (WebSocketSession user : users) {
			if (user.getAttributes().get("WEBSOCKET_USERNAME").equals(userName)) {
				try {
					if (user.isOpen()) {
						user.sendMessage(message);
					}
				} catch (IOException e) {
					e.printStackTrace();
				}
				break;
			}
		}
	}
}

接下來是例項：

先建立一個登入控制器，這樣能區分使用者。

@Controller
public class WebSocketController {

	@Bean // 這個註解會從Spring容器拿出Bean
	public WebSocketHandler infoHandler() {
		return new WebSocketHandler();
	}

	@RequestMapping("/login")
	public String login(HttpServletRequest request, HttpServletResponse response) throws Exception {
		String username = request.getParameter("username");
		System.out.println(username + "登入");
		HttpSession session = request.getSession();
		session.setAttribute("SESSION_USERNAME", username);
		return "websocket";
	}
}

然後是登陸頁面 index.jsp

<%@ page language="java" contentType="text/html; charset=utf-8"
	pageEncoding="utf-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<body>
	<h2>Wellcome</h2>
	<form action="login">
		登入名：<input type="text" name="username" /> <input type="submit"
			value="登入" />
	</form>
</body>
</html>

聊天介面：websocket.jsp

<%@ page language="java" contentType="text/html; charset=utf-8"  
         pageEncoding="utf-8" %>  
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">  
<html>  
<head>  
    <meta http-equiv="Content-Type" content="text/html; charset=utf-8">  
    <title>Java API for WebSocket (JSR-356)</title>  
</head>  
<body>  
<script type="text/javascript" src="http://cdn.bootcss.com/jquery/3.1.0/jquery.min.js"></script>  
<script type="text/javascript" src="http://cdn.bootcss.com/sockjs-client/1.1.1/sockjs.js"></script>  
<script type="text/javascript">  
    var websocket = null;  
    if ('WebSocket' in window) {  
        //Websocket的連線  
        websocket = new WebSocket("ws://localhost:8080/Creator/websocket/socketServer");//WebSocket對應的地址  
    }  
    else if ('MozWebSocket' in window) {  
        //Websocket的連線  
        websocket = new MozWebSocket("ws://localhost:8080/Creator/websocket/socketServer");//SockJS對應的地址  
    }  
    else {  
        //SockJS的連線  
        websocket = new SockJS("http://localhost:8080/Creator/sockjs/socketServer");    //SockJS對應的地址  
    }  
    websocket.onopen = onOpen;  
    websocket.onmessage = onMessage;  
    websocket.onerror = onError;  
    websocket.onclose = onClose;  
  
    function onOpen(openEvt) {  
        //alert(openEvt.Data);   
    }  
  
    function onMessage(evt) {  
        $("#content").append(evt.data+"<br>"); // 接收後臺傳送的資料
    }  
    function onError() {  
    }  
    function onClose() {  
    }  
  
    function doSend() {  
        if (websocket.readyState == websocket.OPEN) {  
            websocket.send($("#targetName").val()+"@"+$("#inputMsg").val());//呼叫後臺handleTextMessage方法  
            alert("傳送成功!");  
        } else {  
        
            alert("連線失敗!"+websocket.readyState);  
        }  
    }  
  
    window.close = function () {  
        websocket.onclose();  
    }  
</script>  
請輸入目標名稱：<input type="text" id = "targetName" />
請輸入：<textarea rows="3" cols="100" id="inputMsg" name="inputMsg"></textarea>  
<button onclick="doSend();">傳送</button>  
<div id="content"></div>
</body>  
</html>  

最後看成果：

首先隨便傳送訊息，檢視會有什麼反應：

最後是雙方互相傳送訊息：

好了 大功告成！！