您好,登錄后才能下訂單哦!
這篇文章主要為大家展示了“微信小程序如何使用websocket通訊的demo”,內(nèi)容簡而易懂,條理清晰,希望能夠幫助大家解決疑惑,下面讓小編帶領大家一起研究并學習一下“微信小程序如何使用websocket通訊的demo”這篇文章吧。
0、概述websocket
(1) 個人總結:后臺設置了websocket地址,服務器開啟后等待有人去連接它。 一個客戶端一打開就去連接websocket地址,同時傳遞某些識別參數(shù)。這樣一來后臺和客戶端連接成功了,然后后臺就可以發(fā)消息給客戶端了,(客戶端也可以再回話給后臺)。
(2) socket叫套接字,應用程序用socket向網(wǎng)絡發(fā)出請求或者應答網(wǎng)絡請求。
(3) 官方解釋的socket 建立連接四步驟:
服務器端開啟socket,然后accep方法處于監(jiān)聽狀態(tài),等待客戶端的連接。
客戶端開啟,指定服務器名稱和端口號來請求連接服務器端的socket。
服務器端收到客戶端連接請求,返回連接確認。在服務器端,accept() 方法返回服務器上一個新的 socket 引用,該 socket 連接到客戶端的 socket。
客戶端收到連接確認,兩個人就連接好了,雙方開始通訊
(4)注意:
客戶端的輸出流連接到服務器端的輸入流,而客戶端的輸入流連接到服務器端的輸出流。
TCP 是一個雙向的通信協(xié)議,因此數(shù)據(jù)可以通過兩個數(shù)據(jù)流在同一時間發(fā)送.
1、app.js寫法
在app.js下添加三個函數(shù)openSocket(), closeSocket(),sendMessage(),在app初始化的onLunch函數(shù)里面調(diào)用openSocket(),這樣子用戶一進入小程序就會自動連接websocket
App({ globalData: { socketStatus: 'closed', }, onLaunch: function() { var that = this; if (that.globalData.socketStatus === 'closed') { that.openSocket(); } } openSocket() { //打開時的動作 wx.onSocketOpen(() => { console.log('WebSocket 已連接') this.globalData.socketStatus = 'connected'; this.sendMessage(); }) //斷開時的動作 wx.onSocketClose(() => { console.log('WebSocket 已斷開') this.globalData.socketStatus = 'closed' }) //報錯時的動作 wx.onSocketError(error => { console.error('socket error:', error) }) // 監(jiān)聽服務器推送的消息 wx.onSocketMessage(message => { //把JSONStr轉為JSON message = message.data.replace(" ", ""); if (typeof message != 'object') { message = message.replace(/\ufeff/g, ""); //重點 var jj = JSON.parse(message); message = jj; } console.log("【websocket監(jiān)聽到消息】內(nèi)容如下:"); console.log(message); }) // 打開信道 wx.connectSocket({ url: "ws://" + "localhost" + ":8888", }) }, //關閉信道 closeSocket() { if (this.globalData.socketStatus === 'connected') { wx.closeSocket({ success: () => { this.globalData.socketStatus = 'closed' } }) } }, //發(fā)送消息函數(shù) sendMessage() { if (this.globalData.socketStatus === 'connected') { //自定義的發(fā)給后臺識別的參數(shù) ,我這里發(fā)送的是name wx.sendSocketMessage({ data: "{\"name\":\"" + wx.getStorageSync('openid') + "\"}" }) } }, })
2、后臺寫法
主要有兩個類,一個是websocket啟動監(jiān)聽交互類,一個是存儲當前所有已經(jīng)連接好的用戶池以及對這些用戶的操作封裝類
然后在項目啟動類里面調(diào)用websocke啟動監(jiān)聽交互類的啟動方法。(如果是springboot項目,就直接在主類中調(diào)用)
(1)導入包
<dependency> <groupId>org.java-websocket</groupId> <artifactId>Java-WebSocket</artifactId> <version>1.3.0</version> </dependency>
(2)啟動websocket的方法,放在啟動類里面
/** * 啟動websocket */ public void startWebsocketInstantMsg() { WebSocketImpl.DEBUG = false; MyWebScoket s; s = new MyWebScoket(8888); s.start(); System.out.println("websocket啟動成功"); }
(3)websocket監(jiān)聽交互類如下
該類涉及的監(jiān)聽方法有:監(jiān)聽用戶連入;監(jiān)聽用戶斷開;監(jiān)聽消息發(fā)過來;監(jiān)聽有錯誤等
import com.alibaba.fastjson.JSONObject; import org.java_websocket.WebSocket; import org.java_websocket.handshake.ClientHandshake; import org.java_websocket.server.WebSocketServer; import java.net.InetSocketAddress; import java.net.UnknownHostException; import java.util.Map; public class MyWebScoket extends WebSocketServer { public MyWebScoket() throws UnknownHostException { super(); } public MyWebScoket(int port) { super(new InetSocketAddress(port)); } public MyWebScoket(InetSocketAddress address) { super(address); } @Override public void onOpen(WebSocket conn, ClientHandshake handshake) { // ws連接的時候觸發(fā)的代碼,onOpen中我們不做任何操作 } @Override public void onClose(WebSocket conn, int code, String reason, boolean remote) { //斷開連接時候觸發(fā)代碼 userLeave(conn); System.out.println(reason); } @Override public void onMessage(WebSocket conn, String message) { //有用戶連接進來 Map<String, String> obj = (Map<String,String>) JSONObject.parse(message); System.out.println(message); String username = obj.get("name"); userJoin(conn, username); } @Override public void onError(WebSocket conn, Exception ex) { //錯誤時候觸發(fā)的代碼 System.out.println("on error"); ex.printStackTrace(); } /** * 去除掉失效的websocket鏈接 */ private void userLeave(WebSocket conn){ WsPool.removeUser(conn); } /** * 將websocket加入用戶池 * @param conn * @param userName */ private void userJoin(WebSocket conn,String userName){ WsPool.addUser(userName, conn); } }
(4)用戶池類如下
該類包含的方法有:從池中移除或添加用戶;獲取當前在線的所有用戶;通過參數(shù)"name"獲取某個用戶的當前WebSocket連接;給某個WebSocket連接發(fā)送消息;為所有WebSocket連接發(fā)送消息等等
import com.td.yousan.util.StringUtils; import org.java_websocket.WebSocket; import java.util.*; public class WsPool { private static final Map<WebSocket, String> wsUserMap = new HashMap<WebSocket, String>(); /** * 通過websocket連接獲取其對應的用戶 */ public static String getUserByWs(WebSocket conn) { return wsUserMap.get(conn); } /** * 根據(jù)userName獲取WebSocket,這是一個list,此處取第一個 * 因為有可能多個websocket對應一個userName(但一般是只有一個,因為在close方法中,我們將失效的websocket連接去除了) */ public static WebSocket getWsByUser(String userName) { Set<WebSocket> keySet = wsUserMap.keySet(); synchronized (keySet) { for (WebSocket conn : keySet) { String cuser = wsUserMap.get(conn); if (cuser.equals(userName)) { return conn; } } } return null; } /** * 向連接池中添加連接 */ public static void addUser(String userName, WebSocket conn) { wsUserMap.put(conn, userName); // 添加連接 } /** * 獲取所有連接池中的用戶,因為set是不允許重復的,所以可以得到無重復的user數(shù)組 */ public static Collection<String> getOnlineUser() { List<String> setUsers = new ArrayList<String>(); Collection<String> setUser = wsUserMap.values(); for (String u : setUser) { setUsers.add(u); } return setUsers; } /** * 移除連接池中的連接 */ public static boolean removeUser(WebSocket conn) { if (wsUserMap.containsKey(conn)) { wsUserMap.remove(conn); // 移除連接 return true; } else { return false; } } /** * 向特定的用戶發(fā)送數(shù)據(jù) */ public static void sendMessageToUser(WebSocket conn, String message) { if (null != conn && null != wsUserMap.get(conn)) { conn.send(message); } } /** * 向所有用戶名中包含某個特征得用戶發(fā)送消息 */ public static void sendMessageToSpecialUser(String message,String special) { Set<WebSocket> keySet = wsUserMap.keySet(); if (special == null) { special = ""; } synchronized (keySet) { for (WebSocket conn:keySet) { String user = wsUserMap.get(conn); try { if (user != null) { String [] cus = user.split("_"); if (!StringUtils.isNullOrEmpty(cus[0])) { String cusDot = "," + cus[0] + ","; if (cusDot.contains(","+special+",")) { conn.send(message); } }else { conn.send(message); } } }catch (Exception e) { e.printStackTrace(); //wsUserMap.remove(conn); } } } } /** * 向所有的用戶發(fā)送消息 */ public static void sendMessageToAll(String message) { Set<WebSocket> keySet = wsUserMap.keySet(); synchronized (keySet) { for (WebSocket conn : keySet) { String user = wsUserMap.get(conn); if (user != null) { conn.send(message); } } } } }
以上是“微信小程序如何使用websocket通訊的demo”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對大家有所幫助,如果還想學習更多知識,歡迎關注億速云行業(yè)資訊頻道!
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權內(nèi)容。