Java Springboot websocket使用案例詳解
更新時間：2021年09月01日 10:53:17 作者：碼路編程
這篇文章主要介紹了Java Springboot websocket使用案例詳解,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內容,需要的朋友可以參考下
什么是WebSocket
WebSocket是一種在單個TCP連接上進行全雙工通信的協(xié)議 …
為什么要實現(xiàn)握手監(jiān)控管理
如果說，連接隨意創(chuàng)建，不管的話，會存在錯誤，broken pipe
表面看單純報錯，并沒什么功能缺陷等，但實際，請求數(shù)增加，容易導致系統(tǒng)奔潰。這邊畫重點。
出現(xiàn)原因有很多種，目前我這邊出現(xiàn)的原因，是因為客戶端已關閉連接，服務端還持續(xù)推送導致。
如何使用
下面將使用springboot集成的webSocket
導入Maven
首先SpringBoot版本
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.8.RELEASE</version>
</parent>
集成websocket
// 加個web集成吧
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
Java代碼
Config配置
首先，我們需要重寫WebSocketHandlerDecoratorFactory
主要用來監(jiān)控客戶端握手連接進來以及揮手關閉連接
代碼
需要一個管理Socket的類
package com.li.manager;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.socket.WebSocketSession;
import java.util.concurrent.ConcurrentHashMap;
/**
* socket管理器
*/
@Slf4j
public class SocketManager {
private static ConcurrentHashMap<String, WebSocketSession> manager = new ConcurrentHashMap<String, WebSocketSession>();
public static void add(String key, WebSocketSession webSocketSession) {
log.info("新添加webSocket連接 {} ", key);
manager.put(key, webSocketSession);
}
public static void remove(String key) {
log.info("移除webSocket連接 {} ", key);
manager.remove(key);
}
public static WebSocketSession get(String key) {
log.info("獲取webSocket連接 {}", key);
return manager.get(key);
}
}
package com.li.factory;
import com.li.manager.SocketManager;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.CloseStatus;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.WebSocketHandlerDecorator;
import org.springframework.web.socket.handler.WebSocketHandlerDecoratorFactory;
import java.security.Principal;
/**
* 服務端和客戶端在進行握手揮手時會被執(zhí)行
*/
@Component
@Slf4j
public class WebSocketDecoratorFactory implements WebSocketHandlerDecoratorFactory {
@Override
public WebSocketHandler decorate(WebSocketHandler handler) {
return new WebSocketHandlerDecorator(handler) {
@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
log.info("有人連接啦 sessionId = {}", session.getId());
Principal principal = session.getPrincipal();
if (principal != null) {
log.info("key = {} 存入", principal.getName());
// 身份校驗成功，緩存socket連接
SocketManager.add(principal.getName(), session);
}
super.afterConnectionEstablished(session);
}
@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
log.info("有人退出連接啦 sessionId = {}", session.getId());
Principal principal = session.getPrincipal();
if (principal != null) {
// 身份校驗成功，移除socket連接
SocketManager.remove(principal.getName());
}
super.afterConnectionClosed(session, closeStatus);
}
};
}
}
注意：以上session變量，需要注意兩點，一個是getId(),一個是getPrincipal().getName()
getId() ： 返回的是唯一的會話標識符。
getPrincipal() : 經(jīng)過身份驗證，返回Principal實例，未經(jīng)過身份驗證，返回null
Principal: 委托人的抽象概念,可以是公司id，名字，用戶唯一識別token等
當你按上面代碼使用，你會發(fā)現(xiàn)getPrincipal()返回null，為什么？這邊還需要重寫一個DefaultHandshakeHandler
代碼
package com.li.handler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.server.ServerHttpRequest;
import org.springframework.http.server.ServletServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.server.support.DefaultHandshakeHandler;
import javax.servlet.http.HttpServletRequest;
import java.security.Principal;
import java.util.Map;
/**
* 我們可以通過請求信息，比如token、或者session判用戶是否可以連接，這樣就能夠防范非法用戶
*/
@Slf4j
@Component
public class PrincipalHandshakeHandler extends DefaultHandshakeHandler {
@Override
protected Principal determineUser(ServerHttpRequest request, WebSocketHandler wsHandler, Map<String, Object> attributes) {
/**
* 這邊可以按你的需求，如何獲取唯一的值，既unicode
* 得到的值，會在監(jiān)聽處理連接的屬性中，既WebSocketSession.getPrincipal().getName()
* 也可以自己實現(xiàn)Principal()
*/
if (request instanceof ServletServerHttpRequest) {
ServletServerHttpRequest servletServerHttpRequest = (ServletServerHttpRequest) request;
HttpServletRequest httpRequest = servletServerHttpRequest.getServletRequest();
/**
* 這邊就獲取你最熟悉的陌生人,攜帶參數(shù)，你可以cookie，請求頭，或者url攜帶，這邊我采用url攜帶
*/
final String token = httpRequest.getParameter("token");
if (StringUtils.isEmpty(token)) {
return null;
}
return new Principal() {
@Override
public String getName() {
return token;
}
};
}
return null;
}
}
需要的東西都有了，那準備裝載吧
代碼
package com.li.config;
import com.li.factory.WebSocketDecoratorFactory;
import com.li.handler.PrincipalHandshakeHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketTransportRegistration;
/**
* WebSocketConfig配置
*/
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
@Autowired
private WebSocketDecoratorFactory webSocketDecoratorFactory;
@Autowired
private PrincipalHandshakeHandler principalHandshakeHandler;
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
/**
* myUrl表示 你前端到時要對應url映射
*/
registry.addEndpoint("/myUrl")
.setAllowedOrigins("*")
.setHandshakeHandler(principalHandshakeHandler)
.withSockJS();
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
/**
* queue 點對點
* topic 廣播
* user 點對點前綴
*/
registry.enableSimpleBroker("/queue", "/topic");
registry.setUserDestinationPrefix("/user");
}
@Override
public void configureWebSocketTransport(WebSocketTransportRegistration registration) {
registration.addDecoratorFactory(webSocketDecoratorFactory);
super.configureWebSocketTransport(registration);
}
}
終于完成了
最后，來一個通過http請求，將其發(fā)送到客戶端
代碼
package com.li.controller;
import com.li.manager.SocketManager;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.socket.WebSocketSession;
import java.util.Map;
@RestController
@Slf4j
public class TestController {
@Autowired
private SimpMessagingTemplate template;
/**
* 服務器指定用戶進行推送,需要前端開通 var socket = new SockJS(host+'/myUrl' + '?token=1234');
*/
@RequestMapping("/sendUser")
public void sendUser(String token) {
log.info("token = {} ,對其發(fā)送您好", token);
WebSocketSession webSocketSession = SocketManager.get(token);
if (webSocketSession != null) {
/**
* 主要防止broken pipe
*/
template.convertAndSendToUser(token, "/queue/sendUser", "您好");
}
}
/**
* 廣播，服務器主動推給連接的客戶端
*/
@RequestMapping("/sendTopic")
public void sendTopic() {
template.convertAndSend("/topic/sendTopic", "大家晚上好");
}
/**
* 客戶端發(fā)消息，服務端接收
*
* @param message
*/
// 相當于RequestMapping
@MessageMapping("/sendServer")
public void sendServer(String message) {
log.info("message:{}", message);
}
/**
* 客戶端發(fā)消息，大家都接收，相當于直播說話
*
* @param message
* @return
*/
@MessageMapping("/sendAllUser")
@SendTo("/topic/sendTopic")
public String sendAllUser(String message) {
// 也可以采用template方式
return message;
}
/**
* 點對點用戶聊天，這邊需要注意，由于前端傳過來json數(shù)據(jù)，所以使用@RequestBody
* 這邊需要前端開通var socket = new SockJS(host+'/myUrl' + '?token=4567'); token為指定name
* @param map
*/
@MessageMapping("/sendMyUser")
public void sendMyUser(@RequestBody Map<String, String> map) {
log.info("map = {}", map);
WebSocketSession webSocketSession = SocketManager.get(map.get("name"));
if (webSocketSession != null) {
log.info("sessionId = {}", webSocketSession.getId());
template.convertAndSendToUser(map.get("name"), "/queue/sendUser", map.get("message"));
}
}
}
前端代碼
可以直接啟動
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8" />
<title>Spring Boot WebSocket+廣播式</title>
</head>
<body>
<noscript>
<h2 style="color:#ff0000">貌似你的瀏覽器不支持websocket</h2>
</noscript>
<div>
<div>
<button id="connect" onclick="connect()">連接</button>
<button id="disconnect" onclick="disconnect();">斷開連接</button>
</div>
<div id="conversationDiv">
<label>輸入你的名字</label> <input type="text" id="name" />
<br>
<label>輸入消息</label> <input type="text" id="messgae" />
<button id="send" onclick="send();">發(fā)送</button>
<p id="response"></p>
</div>
</div>
<script src="https://cdn.bootcss.com/sockjs-client/1.1.4/sockjs.min.js"></script>
<script src="https://cdn.bootcss.com/stomp.js/2.3.3/stomp.min.js"></script>
<script src="https://cdn.bootcss.com/jquery/3.3.1/jquery.min.js"></script>
<script type="text/javascript">
var stompClient = null;
//gateway網(wǎng)關的地址
var host="http://127.0.0.1:8888";
function setConnected(connected) {
document.getElementById('connect').disabled = connected;
document.getElementById('disconnect').disabled = !connected;
document.getElementById('conversationDiv').style.visibility = connected ? 'visible' : 'hidden';
$('#response').html();
}
// SendUser ***********************************************
function connect() {
//地址+端點路徑，構建websocket鏈接地址,注意，對應config配置里的addEndpoint
var socket = new SockJS(host+'/myUrl' + '?token=4567');
stompClient = Stomp.over(socket);
stompClient.connect({}, function(frame) {
setConnected(true);
console.log('Connected:' + frame);
//監(jiān)聽的路徑以及回調
stompClient.subscribe('/user/queue/sendUser', function(response) {
showResponse(response.body);
});
});
}
/*
function connect() {
//地址+端點路徑，構建websocket鏈接地址,注意，對應config配置里的addEndpoint
var socket = new SockJS(host+'/myUrl');
stompClient = Stomp.over(socket);
stompClient.connect({}, function(frame) {
setConnected(true);
console.log('Connected:' + frame);
//監(jiān)聽的路徑以及回調
stompClient.subscribe('/topic/sendTopic', function(response) {
showResponse(response.body);
});
});
}*/
function disconnect() {
if (stompClient != null) {
stompClient.disconnect();
}
setConnected(false);
console.log("Disconnected");
}
function send() {
var name = $('#name').val();
var message = $('#messgae').val();
/*//發(fā)送消息的路徑,由客戶端發(fā)送消息到服務端
stompClient.send("/sendServer", {}, message);
*/
/*// 發(fā)送給所有廣播sendTopic的人,客戶端發(fā)消息，大家都接收，相當于直播說話 注：連接需開啟 /topic/sendTopic
stompClient.send("/sendAllUser", {}, message);
*/
/* 這邊需要注意，需要啟動不同的前端html進行測試，需要改不同token ，例如 token=1234，token=4567
* 然后可以通過寫入name 為token 進行指定用戶發(fā)送
*/
stompClient.send("/sendMyUser", {}, JSON.stringify({name:name,message:message}));
}
function showResponse(message) {
var response = $('#response');
response.html(message);
}
</script>
</body>
</html>
到此這篇關于Java Springboot websocket使用案例詳解的文章就介紹到這了,更多相關Java Springboot websocket使用內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
本篇文章主要介紹了詳述 DB2 分頁查詢及 Java 實現(xiàn)的示例，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-09-09
JWT令牌中包含了一個用戶名和哈希值,這些都需要進行驗證,本文主要介紹了SpringBoot JWT令牌的使用,具有一定的參考價值,感興趣的可以了解一下2024-03-03
簡單講解Android開發(fā)中觸摸和點擊事件的相關編程方法
這篇文章主要介紹了Android開發(fā)中觸摸和點擊事件的相關編程方法,包括事件偵聽器等安卓開發(fā)中常用的接口的基本使用方法,需要的朋友可以參考下2015-12-12
這篇文章主要介紹了SpringBoot整合Swagger的方法示例，詳細介紹了SpringBoot如何整合Swagger以及swagger注解，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-10-10
Java 5個人坐在一起(有關第五個人歲數(shù)的問題)
利用遞歸的方法，遞歸分為回推和遞推兩個階段。要想知道第五個人歲數(shù)，需知道第四人的歲數(shù)，依次類推，推到第一人（10歲），再往回推,需要的朋友可以參考下2017-02-02
這篇文章主要介紹了Spring的注解@Qualifier小結，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-08-08
下面小編就為大家?guī)硪黄狫ava基礎的幾道練習題(分享)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧，希望可以幫到你2021-07-07
這篇文章主要介紹了詳解SpringCloudGateway內存泄漏問題，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-07-07
這篇文章主要介紹了Springboot集成jdbcTemplate過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-04-04
解決java文件流處理異常 mark/reset not supported問題
這篇文章主要介紹了解決java文件流處理異常 mark/reset not supported問題，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-10-10