netty-socketio整合springboot訊息推送
阿新 • • 發佈：2018-11-29
netty-socketio整合springboot訊息推送
1.netty-socketio訊息推送
1）在專案中常常涉及到訊息推送的情況，訊息推送要求的實時性，使用傳統的方式已經不能滿足需求了；
2）使用netty-socketio做訊息推送，實現步驟，加入jar包----->寫啟動，新增，通知，關閉工具類 -----> 設定依靠監聽器啟動 ----->頁面引入js----->編寫請求獲取訊息；
2.實現
1）pom依賴與js檔案：socket.io.js (見文章末尾附件包中)
<dependencies> <dependency> <groupId>com.corundumstudio.socketio</groupId> <artifactId>netty-socketio</artifactId> <version>1.7.7</version> </dependency> </dependencies>
2）實現工具類
/** * @author liudongyang * @ClassName: Socketio * @Description: netty-socketio工具類 建立、新增和啟動客戶端 訊息推送 關閉服務 * @date 2018年11月27日 下午4:57:59 */ public class Socketio { private static SocketIOServer socketIOServer; /** * @Title: startSocketio * @Description: 建立服務新增客戶端 */ public void startSocketio() { // 配置 Configuration conf = new Configuration(); // 指定要主機ip地址，這個和頁面請求ip地址一致 conf.setHostname( "localhost" ); // 指定埠號 conf.setPort( 9092 ); // 設定最大的WebSocket幀內容長度限制 conf.setMaxFramePayloadLength( 1024 * 1024 ); // 設定最大HTTP內容長度限制 conf.setMaxHttpContentLength( 1024 * 1024 ); socketIOServer = new SocketIOServer( conf ); ConnectListener connect = new ConnectListener() { @Override public void onConnect( SocketIOClient client ) {} }; // 新增客戶端 socketIOServer.addConnectListener( connect ); socketIOServer.start(); } /** * @Title: pushArr * @Description: 全體訊息推送 * @param type * 前臺根據型別接收訊息，所以接收的訊息型別不同，收到的通知就不同 推送的事件型別 * @param content * 推送的內容 */ public void pushArr( String type, Object content ) { // 獲取全部客戶端 Collection<SocketIOClient> allClients = socketIOServer.getAllClients(); for( SocketIOClient socket : allClients ) { socket.sendEvent( type, content ); } } /** * @Title: startServer * @Description: 啟動服務 */ public void startServer() { if( socketIOServer == null ) { new Thread( new Runnable() { @Override public void run() { startSocketio(); } } ).start(); } } /** * @Title: stopSocketio * @Description: 停止服務 */ public void stopSocketio() { if( socketIOServer != null ) { socketIOServer.stop(); socketIOServer = null; } } }
3）監聽器啟動(運行於整個專案執行時週期:init-destoryed)
@Configuration @WebListener public class SocketioLisener implements ServletContextListener { @Override public void contextInitialized(ServletContextEvent sce) { //啟動Socketio服務 Socketio socketio = new Socketio(); socketio.startServer(); } @Override public void contextDestroyed(ServletContextEvent sce) { //關閉Socketio服務 Socketio socketio = new Socketio(); socketio.stopSocketio(); } }
3.頁面監聽
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>訊息推送</title>
</head>
<body>
</body>
<script src="https://code.jquery.com/jquery-3.2.1.min.js"></script>
<script type="text/javascript" src="./js/socket.io/socket.io.js"></script>
<script type="text/javascript">
<!-- 實時從指定檢視是否有訊息 -->
var socket = io.connect('localhost:9092');
socket.on('connect_msg',function(data){
alert(data);
// var personInfo = JSON.parse(data);
// console.log(personInfo);
});
</script>
</html>4.訊息釋出呼叫方式
…
/**
* 測試報警推送服務:主要應用一個方法pushArr
*/
@GetMapping("/pushMessage")
@ApiOperation( "測試訊息推送" )
public void pushMessage(){
Socketio socketio = new Socketio();
//這裡傳送的訊息內容可以結合具體場景自定義物件
socketio.pushArr("connect_msg", "今天下午2點開會");
}
…5.效果
通過訪問測試服務請求 可看到如下效果：
6.附件
客戶端相關js程式碼：client.rar