const app = getApp();
let url = 'wss://σ↓xxx.xxx.com/?xxx=xxx'
export$↓↔ const connect = function (cb) { // '✘≥定義一(yī)個(gè)方法
   wx.connectSocket({ //λ•© 創建一(yī)個(gè) WebSocket 連接
       ±✘βurl: url,
       fail (err) {γ∏
if (err) {
               console.log('%cΩ±€₩WebSocket連接失敗', 'color:red', err)
 ©≤              app.globalData.socketConnectFail = •∏$true // 定義一(yī)個(gè)全局變量，當鏈接失敗時(shí)改變變量的(d÷<e)值
}
}
})

   wx.onSo←£βφcketOpen(function (res) { // 監聽(tīng)We•™©bSocket連接打開(kāi)事(shì)件(jiàn)。
    ↑γ✔★   console.log('WebSocket打開(kāi)成功');
 δ≈'≠      wx.sendSocketMessage({ // 通( αtōng)過 WebSocket 連接發送數(shù)據，需™§要(yào)先 wx.connectSocket，并在 wx.onSoc‌↕ε•ketOpen 回調之後才能(néng)發送。
          ∏δ data: String2Base64(), // 用(yòng)于訂閱的(de)參數(sh<♦ù)，視(shì)具體(tǐ)情況而定
      ε±     success (data) {
               cons§¥αole.log('WebSocket發送消息:', data.errMsg)$ ©≈
},
           fail (err) {₽"♥
               console.log('Err', err)
≤♣♥α}
})

})

   wx.onSocketMessage(f£&←unction (res) { // 監聽(tīng)WebSocket接受到(dào)服£ "務器(qì)的(de)消息事(shì)件(jiàn)。
       console.log(₹γ♦''WebSocket接收到(dào)消息:', Ar↕×☆‌ryBuffer2Json(res.data));
       cb(Arry₹≠ Buffer2Json(res.data)); // ¥↑将接收到(dào)的(de)消息進行(xíng)回調，如(rú)果是(shì)ArryBu&✔αffer，需要(yào)進行(xíng)轉換
})

   wx.onSocketError♠ Ω✘(function (res) { // 監聽(tīng)WebSocket錯(cuò)誤。
 ∏>
       console.log('WebSocket連接打∏↕ε​開(kāi)失敗')
})

   wx.onSocketClose( π☆→function (res) { // 監聽(tīng)₽>✔WebSocket關閉。
       console.log('We$₹bSocket關閉');
})
};

function ArryBuffer2Js®€on (data) { // ArryBuffer轉換成Json
try {
var ←>₽encodedString = String.fromCharπ±Code.apply(null, new Uint8Array(data));
var deγ↓codedString = decodeURIComponent(atob(encodedS♣ ↑tring));
return JSON.parse(decodedString);
} 'σcatch (err) {
       console.log(err);
φ&♦return false;
}
}


fu↓÷nction String2Base64 () { // 用(yòng)于訂閱的(d¥♣εe)參數(shù)，視(shì)具體(tǐ)情況而定
var packet = {};
  σ∏↕σ packet["cmd"] = "subscribe";
   packet["¥$ ∑reqNo"] = "" + new Date().getTime();
  § ₹ packet["params"] = {token:♦Ω token, channelId: 'xcx', col₩ umnIds: "1"};
return stringTε±₩oUint(JSON.stringify(packet))
}★δ

function stringToUint σ€£(string) {
var string = base64_♣©encode(encodeURIComponent(string)),
 ±≠☆≤      charList = string.split('±©'),
       uintArray = [];
for (var i = 0; i &δ≤₽£lt; charList.length; i++) {
       uin★ tArray.push(charList[i].charCodeAt(0));
}
retur★↔n new Uint8Array(uintArray);
}

function b↑₩ase64_encode (str) { // bas♦Ω★'e64轉碼
var c1, c2, c3;
var base64EncodeChλ↔←ars = "ABCDEFGHIJKLMNOPQRSTUVWXY©σZabcdefghijklmnopqrstuvwxyz012Ω​♦₽3456789+/";
var i = 0, len = str.length, string ♥ γ™= '';

while (i < len) {
     ε↔←✘  c1 = str.charCodeAt(i++) & 0xff;
if (i β®== len) {
string += base64E↕σncodeChars.charAt(c1 >> 2);
string += ✔↕↓base64EncodeChars.charAt(( ↕β♥c1 & 0x3) << 4);
♦©✘
string += "==";
break;
•♠ }
       c2 = str.charCodeAt(i++);
if (i♦& == len) {
string += base64EncodeΩ©©Chars.charAt(c1 >> 2);
string += base64∏¶←₹EncodeChars.charAt(((c1 & 0x3) << 4) |∑↕ ((c2 & 0xF0) >> 4));
 "
string += base64EncodeChars.charAt((c2 &a Ω§mp; 0xF) << 2);
string += "=";
break;
×φ
}
       c3 = str.charCodeAt(i++);
string©∞✔ += base64EncodeChars.charAt(c1 >> 2↕&);
string += base64EncodeChaΩ§≠rs.charAt(((c1 & 0x3) << 4)α♠γ | ((c2 & 0xF0) >>↔<≈; 4));
string += base64EncodeChars.charAt(((c2 &÷™amp; 0xF) << 2) | ((c3 & 0x​&₩&C0) >> 6));
string += base64EncodeChar≈φ"s.charAt(c3 & 0x3F)
}
return strin&​g
}