點對點通信就像是私聊。websocket 實現點對點通信可以采用三種方式來實現。
<br/>
下面分別用三種方法來實現 zhangsan 與 lisi 的私聊。
[TOC]
# 1. convertAndSend方法實現
步驟如下:
**1. 調用方法convertAndSend**
```java
@RestController
public class TestController {
@Autowired
private SimpMessagingTemplate messagingTemplate;
@MessageMapping("/v5/point")
public void pointChat01(Map<String, Object> params) {
//關鍵點就是訂閱地址需要是動態的
messagingTemplate.convertAndSend("/topic/v5/chat/" + params.get("to"), params.get("message"));
}
}
```
**2. 前端代碼**
```js
//訂閱地址是:/topic/v5/chat/lisi,下面發送時傳入了 'to':'lisi' 到后端組成了該地址
client.subscribe('/topic/v5/chat/lisi', (res) => {})
client.send('/app/v5/point', {}, JSON.stringify({'to':'lisi', 'message':'你好,李四.'}))
```
<br/>
# 2. @SendToUser實現
步驟如下:
**1. 配置類中設置setUserDestinationPrefix**
```java
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/endpoint-websocket")
.setAllowedOrigins("*")
.withSockJS();
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableSimpleBroker("/topic");
registry.setApplicationDestinationPrefixes("/app");
//點對點通信時客戶端需要添加的前綴,不設置默認為/user
registry.setUserDestinationPrefix("/users/");
}
}
```
**2. 方法上標注注解`@SendToUser`**
```java
@RestController
public class TestController {
@Autowired
private SimpMessagingTemplate messagingTemplate;
/**
* 缺點就是訂閱地址是死的,zhangsan發送消息給lisi,則必須有一個@SendToUser("/topic/v6/lisi")方法
* 反過來又必須有一個 @SendToUser("/topic/v6/zhangsan") 的方法。
*/
@MessageMapping("/v6/point")
@SendToUser("/topic/v6/lisi")
public String pointChat02(String message) {
return message;
}
}
```
**3. 前端代碼**
```js
//添加了前綴 /users
client.subscribe('/users/topic/v6/lisi', (res) => {})
client.send('/app/v6/point', {}, '你好,李四.')
```
<br/>
# 3. convertAndSendToUser方法實現
步驟如下:
**1. 配置類中設置setUserDestinationPrefix**
```java
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/endpoint-websocket")
.setAllowedOrigins("*")
.withSockJS();
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableSimpleBroker("/topic");
registry.setApplicationDestinationPrefixes("/app");
//點對點通信時客戶端需要添加的前綴,不設置默認為/user
registry.setUserDestinationPrefix("/users/");
}
}
```
**2. 存儲用戶連接的sessionId**
```java
@Component
public class ConnectListener implements ApplicationListener<SessionConnectEvent> {
@Override
public void onApplicationEvent(SessionConnectEvent event) {
StompHeaderAccessor header = StompHeaderAccessor.wrap(event.getMessage());
//下面將通過前端傳遞一個key為userId的請求頭
String userId = header.getFirstNativeHeader("userId");
String sessionId = header.getSessionId();
//UserConstants.usersMap是我自己創建的一個public static Map對象,用來存儲每個用戶的sessionId
UserConstants.usersMap.put(userId, sessionId);
}
}
```
**3. 調用方法convertAndSendToUser**
```java
@RestController
public class TestController {
@Autowired
private SimpMessagingTemplate messagingTemplate;
/**
* 方法 convertAndSendToUser(String user, String destination, Object payload, @Nullable Map<String, Object> headers)
* user:用戶的sessionId
* destination:訂閱地址
* payload:訂閱的數據
* headers:請求頭
*/
@MessageMapping("/v7/point")
public void pointChat03(Map<String, Object> params) {
String sessionId = UserConstants.usersMap.get((String) params.get("userId"));
SimpMessageHeaderAccessor header = SimpMessageHeaderAccessor.create(SimpMessageType.MESSAGE);
//把sessionId放到請求頭中
header.setSessionId(sessionId);
header.setLeaveMutable(true);
//必須以配置類中的 registry.enableSimpleBroker("/topic") 注冊的 /topic 為前綴
messagingTemplate.convertAndSendToUser(sessionId, "/topic/message", "你好,李四!", header.getMessageHeaders());
}
}
```
**4. 前端代碼**
```js
//前端連接的時候傳入key為userId的請求頭
client.connect({'userId': 'lisi'}, () => {
//訂閱地址添加 /users 為前綴
client.subscribe('/users/topic/message', (res) => {})
})
//這里我也傳了 userId 去與后端匹配
client.send('/app/v7/point', {}, JSON.stringify({'userId': 'lisi', 'message': '你好,李四.'}))
```
- 跨域問題
- 跨域是什么
- 跨域解決方案
- 從后端解決
- nginx反向代理
- WebSocket
- websocket是什么
- websocket協議
- 使用場景
- 實現方式
- 注解與html5原生方式
- websocketAPI
- 實現步驟
- 文件上傳
- 文件下載
- 廣播通信
- 定時推送
- 編程與socketjs方式
- socketjs與stompjs框架
- 實現步驟
- 重載目的地
- SimpMessagingTemplate
- 定時向前端推送數據
- 5種監聽事件
- 點對點通信
- 攔截器
- HandshakeInterceptor
- ChannelInterceptor
- poi之excel表格
- 表格版本
- POI常用類
- POI依賴
- 寫表格
- 編寫表格過程
- 單元格邊框樣式
- 單元格背景色
- 凍結行或列
- 單元格合并
- 單元格內換行
- 文檔內跳轉
- 讀表格
- Web中的Excel操作
- 導出表格
- 讀取表格
- poi之word文檔
- word版本
- 寫word
- 基本使用
- 標題樣式
- 添加圖片
- EasyExcel表格
- EasyExcel是什么
- 與其他Excel工具對比
- EasyExcel依賴
- 讀Excel
- 簡單讀取
- 指定列位置
- 讀取多個sheet
- 格式轉換
- 多行表頭
- 同步讀
- 寫Excel
- 簡單寫入
- 單元格樣式
- 攔截器
- 列寬
- 凍結行或列
- 合并單元格
- 填充Excel
- SpringSecurity
- SpringSecurity是什么
- 同類型產品對比
- 環境搭建
- 相關概念
- 密碼加密
- Web權限控制
- UserDetailsService接口
- 登錄認證
- 自定義登錄頁
- 未授權跳轉登錄頁
- 權限控制
- 自定義403頁面
- 權限注解
- 記住我功能
- 注銷功能
- CSRF
- CSRF是什么
- CSRF保護演示
- 前后端分離權限控制
- 環境搭建
- 認證實現
- 會話管理
- 動態權限管理
- 微服務權限控制
- 權限控制方案
- SpringBoot整合RabbitMQ
- 整合步驟
- Fanout交換機演示
- Direct交換機演示
- Topic交換機演示
- @RabbitListener方法
- JWT認證與授權
- 環境搭建
- 密碼加密
- 認證與授權