WebSocketConfig.java package com.yizhen.config;import org.springframework.context.annotation.Bean; import org.springframework.stereotype.Component; import org.springframework.web.socket.server.standard.ServerEndpointExporter;/*** Created by 廖師兄* 2017-07-30 23:17*/ @Component public class WebSocketConfig {@Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();} }

WebSocket.java

package com.yizhen.service;import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component;import javax.websocket.OnClose; import javax.websocket.OnMessage; import javax.websocket.OnOpen; import javax.websocket.Session; import javax.websocket.server.ServerEndpoint; import java.util.concurrent.CopyOnWriteArraySet;/*** Created by 廖師兄* 2017-07-30 23:19*/ @Component @ServerEndpoint("/webSocket") @Slf4j public class WebSocket {private Session session;private static CopyOnWriteArraySet<WebSocket> webSocketSet = new CopyOnWriteArraySet<>();@OnOpenpublic void onOpen(Session session) {this.session = session;webSocketSet.add(this);log.info("【websocket消息】有新的連接, 總數:{}", webSocketSet.size());}@OnClosepublic void onClose() {webSocketSet.remove(this);log.info("【websocket消息】連接斷開, 總數:{}", webSocketSet.size());}@OnMessagepublic void onMessage(String message) {log.info("【websocket消息】收到客戶端發來的消息:{}", message);}public void sendMessage(String message) {for (WebSocket webSocket: webSocketSet) {log.info("【websocket消息】廣播消息, message={}", message);try {webSocket.session.getBasicRemote().sendText(message);} catch (Exception e) {e.printStackTrace();}}}}

需要消息提示的界面：

<script type="text/javascript">var websocket = null;if('WebSocket' in window) {websocket = new WebSocket('ws://bgyzuishuai.s1.natapp.cc/webSocket');}else {alert('該瀏覽器不支持訂單提醒!');}websocket.onopen = function (event) {console.log('建立連接');}websocket.onclose = function (event) {console.log('連接關閉');}websocket.onmessage = function (event) {console.log('收到消息:' + event.data)//彈窗提醒, 播放音樂$('#dingdanxiaoxi').modal('show');document.getElementById('notice').play();}websocket.onerror = function () {alert('websocket通信發生錯誤！');}window.onbeforeunload = function () {websocket.close();}</script>

pom：

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

最后@autowired?? Websocket

使用websocket.sendMessage()發送消息

原文更多：http://blog.maptoface.com/post/156

總結

以上是生活随笔為你收集整理的springboot websocket订单消息提醒的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。