WebSocket如何實現(xiàn)服務(wù)器消息推送客戶端

這篇文章主要為大家展示了“WebSocket如何實現(xiàn)服務(wù)器消息推送客戶端”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“WebSocket如何實現(xiàn)服務(wù)器消息推送客戶端”這篇文章吧。

創(chuàng)新互聯(lián)建站是專業(yè)的玉溪網(wǎng)站建設(shè)公司，玉溪接單;提供成都網(wǎng)站制作、網(wǎng)站設(shè)計,網(wǎng)頁設(shè)計,網(wǎng)站設(shè)計,建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進行玉溪網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團隊,希望更多企業(yè)前來合作!

一、背景

項目需要做一個消息能夠?qū)崟r獲取的功能，系統(tǒng)日活躍量達到10000，產(chǎn)生的消息是活躍量的數(shù)倍，如果采用 Http 的方式輪詢后端服務(wù)，會使得后端服務(wù)壓力過大而奔潰，因此需要一種新的技術(shù)方式來改變 “拉” 的方式。

二、解決方案

經(jīng)過各種 Google、百度 后發(fā)現(xiàn)可以使用 html5 的新技術(shù) WebSocket ，將現(xiàn)有 “拉”消息的方式改變成 “推” 的模式，大大的減少服務(wù)器壓力。

三、具體實現(xiàn)

實例采用 Spring Boot 框架，

引入 pom 依賴

org.springframework.boot

spring-boot-starter-websocket

org.springframework.boot

spring-boot-starter-undertow

org.springframework.boot

spring-boot-starter-web

org.springframework.boot

spring-boot-starter-tomcat

WebSocket 服務(wù)可采用 websocket-api 或 spring-websocket 開發(fā)，我們采用 websocket-api 的注解開發(fā)方式：

package com.gridsum.techpub.systemhistory.api.server;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.stereotype.Service;

import javax.websocket.*;

import javax.websocket.server.PathParam;

import javax.websocket.server.ServerEndpoint;

import java.io.IOException;

import java.util.Objects;

import java.util.Set;

import java.util.concurrent.CopyOnWriteArraySet;

/**

* @author ouyangrongtao

* @version 1.0

* @description WebSocketServer

* @date 2019/12/23 10:16

**/

@ServerEndpoint("/websocket/{sid}")

@Service

public class WebSocketServer {

private static final Logger logger = LoggerFactory.getLogger(WebSocketServer.class);

private ClientInfo clientInfo;

/**

* 存放每個客戶端對應(yīng)的 ClientInfo 對象。

*/

private static final Set WEB_SOCKET_SET = new CopyOnWriteArraySet<>();

/**

* 連接建立成功調(diào)用的方法

*

* @param session 會話

* @param sid 客戶端

*/

@OnOpen

public void onOpen(Session session, @PathParam("sid") String sid) {

//加入set中

this.clientInfo = new ClientInfo(sid, session);

WEB_SOCKET_SET.add(clientInfo);

logger.info("有新窗口開始監(jiān)聽:[{}],當(dāng)前在線人數(shù)為[{}]", sid, WEB_SOCKET_SET.size());

try {

this.sendMessage(session, "連接成功");

} catch (IOException e) {

logger.error("websocket IO異常");

}

}

/**

* 連接關(guān)閉調(diào)用的方法

*/

@OnClose

public void onClose() {

//從set中刪除

WEB_SOCKET_SET.remove(this.clientInfo);

logger.info("有一連接關(guān)閉!當(dāng)前在線人數(shù)為：[{}]", WEB_SOCKET_SET.size());

}

/**

* 

* @param message 客戶端發(fā)送過來的消息

*/

@OnMessage

public void onMessage(String message) {

logger.info("收到來自窗口[{}]的信息:[{}]", this.clientInfo.getSid(), message);

//發(fā)消息

for (ClientInfo item : WEB_SOCKET_SET) {

try {

this.sendMessage(item.getSession(), message);

} catch (IOException ignored) {

}

}

}

/**

* 錯誤時調(diào)用

* @param session 會話

* @param error 錯誤信息

*/

@OnError

public void onError(Session session, Throwable error) {

logger.error("發(fā)生錯誤", error);

}

/**

* 給 sid 發(fā)送消息

* @param message 消息

* @param sid sid

*/

public void sendMessage(String message, String sid) {

logger.info("推送消息到窗口[{}]，推送內(nèi)容:[{}]", sid, message);

ClientInfo client = WEB_SOCKET_SET.parallelStream()

.filter(item -> item.getSid().equals(sid)).findFirst().orElse(null);

if (client != null) {

try {

this.sendMessage(client.getSession(), message);

} catch (IOException ignored) {

}

}

}

/**

* 實現(xiàn)服務(wù)器主動推送

* @param session session

* @param message message

* @throws IOException IOException

*/鄭州哪個婦科醫(yī)院好 http://www.sptdfk.com/

private void sendMessage(Session session, String message) throws IOException {

session.getBasicRemote().sendText(message);

}

class ClientInfo {

/**

* 接收sid

*/

private String sid = "";

/**

* 客戶端

*/

private Session session;

public ClientInfo() { }

private ClientInfo(String sid, Session session) {

this.sid = sid;

this.session = session;

}

private String getSid() {

return sid;

}

private Session getSession() {

return session;

}

@Override

public boolean equals(Object o) {

if (this == o) {

return true;

}

if (o == null || getClass() != o.getClass()) {

return false;

}

ClientInfo that = (ClientInfo) o;

return Objects.equals(sid, that.sid);

}

@Override

public int hashCode() {

return Objects.hash(sid);

}

}

}

前端代碼

運行 WebSocketClient1000001

來一個發(fā)消息的接口

/**

* 發(fā)送消息給客戶端

* @author ouyangrongtao

*/

@RestController

public class WebSocketController {

private WebSocketServer webSocketServer;

@Autowired

public WebSocketController(WebSocketServer webSocketServer) {

this.webSocketServer = webSocketServer;

}

@PostMapping("/socket/push")

public boolean pushToWeb(@RequestBody Map content) {

webSocketServer.sendMessage(content.get("message"), content.get("cid"));

return true;

}

}

到此已經(jīng)基本寫完。使用 Postman 調(diào)用發(fā)消息的接口，發(fā)現(xiàn)客戶端可以收到發(fā)送的消息。

四、問題記錄

在做的時候，因為項目用的 Tomcat 容器，導(dǎo)致 Tomcat 相關(guān)包與 WebSocket 依賴有沖突，最終項目不能啟動，解決方式只需要將 Tomcat 容器改為 Undertow 。

org.springframework.boot

spring-boot-starter-undertow

org.springframework.boot

spring-boot-starter-web

org.springframework.boot

spring-boot-starter-tomcat

異常信息：

Caused by: java.lang.IllegalStateException: javax.websocket.server.ServerContainer not available

at org.springframework.util.Assert.state(Assert.java:73)

at org.springframework.web.socket.server.standard.ServerEndpointExporter.afterPropertiesSet(ServerEndpointExporter.java:106)

at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1753)

at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1690)

... 16 common frames omitted

以上是“WebSocket如何實現(xiàn)服務(wù)器消息推送客戶端”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

網(wǎng)站題目：WebSocket如何實現(xiàn)服務(wù)器消息推送客戶端
當(dāng)前網(wǎng)址：http://muchs.cn/article38/pdjisp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供App設(shè)計、網(wǎng)站排名、標(biāo)簽優(yōu)化、微信小程序、ChatGPT、外貿(mào)建站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)

成都app開發(fā)公司