當(dāng)前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

springboot 之 webscoket 服务端推送

發(fā)布時(shí)間：2023/12/15 编程问答 24 豆豆

生活随笔收集整理的這篇文章主要介紹了 springboot 之 webscoket 服务端推送小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

因?yàn)樽罱泻蠖藢?shí)時(shí)推送數(shù)據(jù)的需求，所以想到了websocket組件，在此寫一下springboot集成使用websocket的方法，供各位童鞋參考。

注：基于test項(xiàng)目。

1.首先打開pom.xml引入相關(guān)依賴

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websocket</artifactId> </dependency>  <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-thymeleaf</artifactId> </dependency>

2.編寫websocket配置文件：

@Configuration @EnableWebSocketMessageBroker public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {@Override public void registerStompEndpoints(StompEndpointRegistry registry) {//注冊STOMP協(xié)議的節(jié)點(diǎn)(endpoint),并映射指定的url //注冊一個STOMP的endpoint,并指定使用SockJS協(xié)議 // 允許使用socketJs方式訪問，訪問點(diǎn)為webSocketServer，允許跨域 // 在網(wǎng)頁上我們就可以通過這個鏈接來和服務(wù)器的WebSocket連接 registry.addEndpoint("/endpointTest").setAllowedOrigins("*").withSockJS(); }@Override public void configureMessageBroker(MessageBrokerRegistry registry) {//配置消息代理(Message Broker) //廣播式應(yīng)配置一個/topic消息代理 //queue 點(diǎn)對點(diǎn) registry.enableSimpleBroker("/queue","/topic"); } }

3.webmvc配置

/** * @author xiaofeng * @version V1.0 * @title: WebMvcConfig.java * @package: com.yingda.xsignal.test * @description: 配置viewController, 為頁面提供路徑映射 * @date 2018/3/30 0030 下午 7:05 */ @Controller public class WebMvcConfig extends WebMvcConfigurerAdapter {/** * 配置viewController,提供映射路徑 */ @Override public void addViewControllers(ViewControllerRegistry registry) {registry.addViewController("/webSocket").setViewName("/webSocket"); } }

4.websocket控制器

/** * @author xiaofeng * @version V1.0 * @title: WebSocketController.java * @package: com.yingda.xsignal.test * @description: webSocket控制器 * @date 2018/3/30 0030 下午 7:04 */ @RestController @EnableScheduling public class WebSocketController {private Logger logger = LoggerFactory.getLogger(getClass()); /** * 當(dāng)瀏覽器向服務(wù)端發(fā)送請求時(shí),通過@MessageMapping映射/sendTest這個地址,類似于@ResponseMapping * 當(dāng)服務(wù)器有消息時(shí),會對訂閱了@SendTo中的路徑的瀏覽器發(fā)送消息 * * @param message * @return */ @MessageMapping("/sendTest")@SendTo("/topic/responseTest")public String say(String message) {try {//睡眠1秒 Thread.sleep(1000); } catch (InterruptedException e) {e.printStackTrace(); }return message; } @SubscribeMapping("/topic/responseTest")public String sub() {logger.info("X用戶訂閱了"); return "thanks for your subscribe!"; }@Autowired WebSocketTemplate webSocketTemplate; /** * 模擬服務(wù)端推送數(shù)據(jù)（注：必須在同一個服務(wù)內(nèi)，否則無法進(jìn)行訂閱推送） */ @Scheduled(fixedRate = 2000)public void task() {webSocketTemplate.sendMessage("服務(wù)器端推送~" + UUID.randomUUID()); }}

WebSocketTemplate:

/** * @author xiaofeng * @version V1.0 * @title: WebSocketTemplate.java * @package: com.yingda.xsignal.test.websocket.send * @description: webSocket發(fā)送模板 * @date 2018/3/30 0030 下午 3:57 */ @Component public class WebSocketTemplate {private SimpMessagingTemplate messagingTemplate; @Autowired public WebSocketTemplate(SimpMessagingTemplate messagingTemplate) {this.messagingTemplate = messagingTemplate; }/** * 向訂閱了 /topic/responseTest 客戶端websocket實(shí)例發(fā)送數(shù)據(jù) * * @param message */ public void sendMessage(String message) {AricMessage aricMessage = new AricMessage(); aricMessage.setName(message); messagingTemplate.convertAndSend("/topic/responseTest", aricMessage); } }

5.在resources -> templates中創(chuàng)建html文件

<!DOCTYPE html> <html xmlns:th="http://www.thymeleaf.org"> <head> <meta charset="UTF-8" /> <title>SpringBoot 服務(wù)端推送消息</title> <script src="http://cdn.bootcss.com/sockjs-client/1.1.1/sockjs.min.js"></script> <script src="http://cdn.bootcss.com/stomp.js/2.3.3/stomp.js"></script> <script src="http://cdn.bootcss.com/jquery/3.1.1/jquery.min.js"></script> </head> <body> <div> <div> <button id="connect" οnclick="connect();">connect</button> <button id="disconnect" disabled="disabled" οnclick="disconnect();">disconnect</button> </div> <div id="conversationDiv"> <div id="response"></div> </div> </div> </body> <script type="text/javascript"> var stompClient = null; function setConnected(connected){document.getElementById('connect').disabled = connected; document.getElementById('disconnect').disabled = !connected; document.getElementById('conversationDiv').style.visibility = connected ? 'visible' : 'hidden'; $("#response").html(); }function connect(){var socket = new SockJS('/endpointTest'); //連接SockJS的endpoint名稱為"endpointTest" stompClient = Stomp.over(socket);//使用STMOP子協(xié)議的WebSocket客戶端 stompClient.connect({},function(frame){//連接WebSocket服務(wù)端 setConnected(true); console.log('Connected:' + frame); //通過stompClient.subscribe訂閱/topic/responseTest 目標(biāo)(destination)發(fā)送的消息,這個是在控制器的@SentTo中定義的 stompClient.subscribe('/topic/responseTest',function(response){showResponse(JSON.parse(response.body).name); }); }); }function disconnect(){if(stompClient != null) {stompClient.disconnect(); }setConnected(false); console.log("Disconnected"); }function showResponse(message){var response = $("#response"); response.html(message); } </script> </html>

啟動服務(wù)，測試，點(diǎn)擊connect,發(fā)現(xiàn)每隔幾秒隨機(jī)字符串都會發(fā)生變化，說明后臺服務(wù)一直在向前端推送數(shù)據(jù)

ok，至此我們的springboot集成websocket并向前端推送數(shù)據(jù)成功，congratulation！

總結(jié)

以上是生活随笔為你收集整理的springboot 之 webscoket 服务端推送的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。