這篇文章主要為大家展示了“微信小程序如何使用websocket通訊的demo”，內(nèi)容簡(jiǎn)而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“微信小程序如何使用websocket通訊的demo”這篇文章吧。

成都創(chuàng)新互聯(lián)公司專(zhuān)注于企業(yè)成都全網(wǎng)營(yíng)銷(xiāo)、網(wǎng)站重做改版、塔什庫(kù)爾干塔吉克網(wǎng)站定制設(shè)計(jì)、自適應(yīng)品牌網(wǎng)站建設(shè)、html5、商城網(wǎng)站開(kāi)發(fā)、集團(tuán)公司官網(wǎng)建設(shè)、外貿(mào)網(wǎng)站建設(shè)、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁(yè)設(shè)計(jì)等建站業(yè)務(wù)，價(jià)格優(yōu)惠性?xún)r(jià)比高，為塔什庫(kù)爾干塔吉克等各大城市提供網(wǎng)站開(kāi)發(fā)制作服務(wù)。

0、概述websocket

(1) 個(gè)人總結(jié)：后臺(tái)設(shè)置了websocket地址，服務(wù)器開(kāi)啟后等待有人去連接它。 一個(gè)客戶(hù)端一打開(kāi)就去連接websocket地址，同時(shí)傳遞某些識(shí)別參數(shù)。這樣一來(lái)后臺(tái)和客戶(hù)端連接成功了，然后后臺(tái)就可以發(fā)消息給客戶(hù)端了，（客戶(hù)端也可以再回話給后臺(tái)）。

(2) socket叫套接字，應(yīng)用程序用socket向網(wǎng)絡(luò)發(fā)出請(qǐng)求或者應(yīng)答網(wǎng)絡(luò)請(qǐng)求。

(3) 官方解釋的socket 建立連接四步驟：

服務(wù)器端開(kāi)啟socket，然后accep方法處于監(jiān)聽(tīng)狀態(tài)，等待客戶(hù)端的連接。

 客戶(hù)端開(kāi)啟，指定服務(wù)器名稱(chēng)和端口號(hào)來(lái)請(qǐng)求連接服務(wù)器端的socket。
 服務(wù)器端收到客戶(hù)端連接請(qǐng)求，返回連接確認(rèn)。在服務(wù)器端，accept() 方法返回服務(wù)器上一個(gè)新的 socket 引用，該 socket 連接到客戶(hù)端的 socket。
 客戶(hù)端收到連接確認(rèn)，兩個(gè)人就連接好了，雙方開(kāi)始通訊

（4）注意：

客戶(hù)端的輸出流連接到服務(wù)器端的輸入流，而客戶(hù)端的輸入流連接到服務(wù)器端的輸出流。
TCP 是一個(gè)雙向的通信協(xié)議，因此數(shù)據(jù)可以通過(guò)兩個(gè)數(shù)據(jù)流在同一時(shí)間發(fā)送.

1、app.js寫(xiě)法

在app.js下添加三個(gè)函數(shù)openSocket()， closeSocket()，sendMessage()，在app初始化的onLunch函數(shù)里面調(diào)用openSocket()，這樣子用戶(hù)一進(jìn)入小程序就會(huì)自動(dòng)連接websocket

App({
  globalData: {
  socketStatus: 'closed',
  },
 onLaunch: function() { 
  var that = this;
  if (that.globalData.socketStatus === 'closed') {
    that.openSocket();
  }
 }
 openSocket() {
  //打開(kāi)時(shí)的動(dòng)作
  wx.onSocketOpen(() => {
   console.log('WebSocket 已連接')
   this.globalData.socketStatus = 'connected';
   this.sendMessage();
  })
  //斷開(kāi)時(shí)的動(dòng)作
  wx.onSocketClose(() => {
   console.log('WebSocket 已斷開(kāi)')
   this.globalData.socketStatus = 'closed'
  })
  //報(bào)錯(cuò)時(shí)的動(dòng)作
  wx.onSocketError(error => {
   console.error('socket error:', error)
  })
  // 監(jiān)聽(tīng)服務(wù)器推送的消息
  wx.onSocketMessage(message => {
   //把JSONStr轉(zhuǎn)為JSON
   message = message.data.replace(" ", "");
   if (typeof message != 'object') {
   message = message.replace(/\ufeff/g, ""); //重點(diǎn)
   var jj = JSON.parse(message);
   message = jj;
   }
   console.log("【websocket監(jiān)聽(tīng)到消息】?jī)?nèi)容如下：");
   console.log(message);
  })
  // 打開(kāi)信道
  wx.connectSocket({
   url: "ws://" + "localhost" + ":8888",
  })
  },
 //關(guān)閉信道
  closeSocket() {
  if (this.globalData.socketStatus === 'connected') {
   wx.closeSocket({
   success: () => {
    this.globalData.socketStatus = 'closed'
   }
   })
  }
  },
  //發(fā)送消息函數(shù)
  sendMessage() {
  if (this.globalData.socketStatus === 'connected') {
  //自定義的發(fā)給后臺(tái)識(shí)別的參數(shù) ，我這里發(fā)送的是name
   wx.sendSocketMessage({
   data: "{\"name\":\"" + wx.getStorageSync('openid') + "\"}" 
   })
  }
  },
})

2、后臺(tái)寫(xiě)法

主要有兩個(gè)類(lèi)，一個(gè)是websocket啟動(dòng)監(jiān)聽(tīng)交互類(lèi)，一個(gè)是存儲(chǔ)當(dāng)前所有已經(jīng)連接好的用戶(hù)池以及對(duì)這些用戶(hù)的操作封裝類(lèi)
 然后在項(xiàng)目啟動(dòng)類(lèi)里面調(diào)用websocke啟動(dòng)監(jiān)聽(tīng)交互類(lèi)的啟動(dòng)方法。（如果是springboot項(xiàng)目，就直接在主類(lèi)中調(diào)用）

(1)導(dǎo)入包

 org.java-websocket
 Java-WebSocket
 1.3.0

(2)啟動(dòng)websocket的方法，放在啟動(dòng)類(lèi)里面   

 /**
  * 啟動(dòng)websocket
  */
 public void startWebsocketInstantMsg() {
  WebSocketImpl.DEBUG = false;
  MyWebScoket s;
  s = new MyWebScoket(8888);
  s.start();
  System.out.println("websocket啟動(dòng)成功");
 }

(3)websocket監(jiān)聽(tīng)交互類(lèi)如下

 該類(lèi)涉及的監(jiān)聽(tīng)方法有：監(jiān)聽(tīng)用戶(hù)連入；監(jiān)聽(tīng)用戶(hù)斷開(kāi)；監(jiān)聽(tīng)消息發(fā)過(guò)來(lái)；監(jiān)聽(tīng)有錯(cuò)誤等

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連接的時(shí)候觸發(fā)的代碼，onOpen中我們不做任何操作
 }
 @Override
 public void onClose(WebSocket conn, int code, String reason, boolean remote) {
  //斷開(kāi)連接時(shí)候觸發(fā)代碼
  userLeave(conn);
  System.out.println(reason);
 }
 @Override
 public void onMessage(WebSocket conn, String message) {
  //有用戶(hù)連接進(jìn)來(lái)
  Map obj = (Map) JSONObject.parse(message);
  System.out.println(message);
  String username = obj.get("name");
  userJoin(conn, username);
 }
 @Override
 public void onError(WebSocket conn, Exception ex) {
  //錯(cuò)誤時(shí)候觸發(fā)的代碼
  System.out.println("on error");
  ex.printStackTrace();
 }
 /**
  * 去除掉失效的websocket鏈接
  */
 private void userLeave(WebSocket conn){
  WsPool.removeUser(conn);
 }
 /**
  * 將websocket加入用戶(hù)池
  * @param conn
  * @param userName
  */
 private void userJoin(WebSocket conn,String userName){
  WsPool.addUser(userName, conn);
 }
}

(4)用戶(hù)池類(lèi)如下

 該類(lèi)包含的方法有：從池中移除或添加用戶(hù)；獲取當(dāng)前在線的所有用戶(hù)；通過(guò)參數(shù)"name"獲取某個(gè)用戶(hù)的當(dāng)前WebSocket連接；給某個(gè)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 wsUserMap = new HashMap();
 /**
  * 通過(guò)websocket連接獲取其對(duì)應(yīng)的用戶(hù)
  */
 public static String getUserByWs(WebSocket conn) {
  return wsUserMap.get(conn);
 }
 /**
  * 根據(jù)userName獲取WebSocket,這是一個(gè)list,此處取第一個(gè)
  * 因?yàn)橛锌赡芏鄠€(gè)websocket對(duì)應(yīng)一個(gè)userName（但一般是只有一個(gè)，因?yàn)樵赾lose方法中，我們將失效的websocket連接去除了）
  */
 public static WebSocket getWsByUser(String userName) {
  Set 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); // 添加連接
 }
 /**
  * 獲取所有連接池中的用戶(hù)，因?yàn)閟et是不允許重復(fù)的，所以可以得到無(wú)重復(fù)的user數(shù)組
  */
 public static Collection getOnlineUser() {
  List setUsers = new ArrayList();
  Collection 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;
  }
 }
 /**
  * 向特定的用戶(hù)發(fā)送數(shù)據(jù)
  */
 public static void sendMessageToUser(WebSocket conn, String message) {
  if (null != conn && null != wsUserMap.get(conn)) {
   conn.send(message);
  }
 }
 /**
  * 向所有用戶(hù)名中包含某個(gè)特征得用戶(hù)發(fā)送消息
  */
 public static void sendMessageToSpecialUser(String message,String special) {
  Set 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);
    }
   }
  }
 }
 /**
  * 向所有的用戶(hù)發(fā)送消息
  */
 public static void sendMessageToAll(String message) {
  Set 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)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！