摘要：但，在這個期間，還有一個動作需要執(zhí)行，火幣服務(wù)器會每隔秒，向客戶端發(fā)送一條數(shù)據(jù)，客戶端接收到這種信息的時候，需要一條對應(yīng)的數(shù)據(jù)，內(nèi)容是的數(shù)據(jù)體相應(yīng)的數(shù)據(jù)格式如下，如果服務(wù)器在發(fā)送兩條數(shù)據(jù)后沒有收到客戶端返回的數(shù)據(jù)，火幣服務(wù)器就會關(guān)閉連接。

火幣官方文檔地址： https://huobiapi.github.io/do...
pako(解壓gzip)： https://github.com/nodeca/pako
參考鏈接(地址可能已過時，但內(nèi)容沒有)： https://www.cnblogs.com/zhumi...

坑死，接火幣 websocket 地址 wss://api.huobi.pro/ws 的時候接到懷疑人生，怎么都無法建立連接，一度以為自己沒有像其它 get/post 接口那樣傳入該傳的參數(shù)，又以為是 wss 走的是 SSL 通道，所以才沒能建立連接，還以為是需要服務(wù)端轉(zhuǎn)接一下。

但，最后的最后，竟然發(fā)現(xiàn)是因為地址的問題，這個地址根本接入不了，至少我這邊是接入不進去。

后來換這個地址： wss://api.hadax.com/ws就順利的接入了

先建立連接

客戶端發(fā)送訂閱請求，這個官方文檔有說明

火幣服務(wù)器返回訂閱成功與否的回饋信息

如果成功就定時發(fā)送 gzip 壓縮后的數(shù)據(jù)，解壓 gzip 你需要 pako https://github.com/nodeca/pako

我們自己客戶端這邊接收數(shù)據(jù)，并解壓數(shù)據(jù)，才能獲取到真正的 json 數(shù)據(jù)

自己做前端該做的相應(yīng)操作，壓入數(shù)據(jù)，展示數(shù)據(jù)什么的。

但，在這個期間，還有一個動作需要執(zhí)行，火幣服務(wù)器會每隔 5 秒，向客戶端發(fā)送一條 ping 數(shù)據(jù)，客戶端接收到這種信息的時候，需要 send 一條對應(yīng)的 pong 數(shù)據(jù)，內(nèi)容是 ping 的數(shù)據(jù)體（相應(yīng)的數(shù)據(jù)格式如下），如果服務(wù)器在發(fā)送兩條 ping 數(shù)據(jù)后沒有收到 客戶端返回的 pong 數(shù)據(jù)，火幣服務(wù)器就會關(guān)閉連接。

關(guān)于其它信息的獲取，查看官方文檔關(guān)于 websocket 的說明就可以了。

// 服務(wù)器發(fā)送的 ping 數(shù)據(jù)
{ ping: 1562741680416 }

// 客戶端返回服務(wù)器的 pong 數(shù)據(jù)
{ pong: 1562741680416 }

// K 線相關(guān)
let hburl = "wss://api.huobipro.com/ws";  // 實時幣種價格
let haurl = "wss://api.hadax.com/ws";


let requestK = { // 請求對應(yīng)信息的數(shù)據(jù)
    req: "market.bchusdt.kline.1min",
    id: "bchusdt",
    from: Math.round(new Date().getTime()/1000) - 60,
    to: Math.round(new Date().getTime()/1000)
};

let subK = { // 訂閱數(shù)據(jù)
    sub: "market.bchusdt.kline.1min",
    id: "bchusdt"
};

let socketK = new WebSocket(haurl);
socketK.onopen = function () {
    console.log("connection establish");
    socketK.send(JSON.stringify(subK));
    socketK.send(JSON.stringify(requestK));
};
socketK.onmessage = function (event) {
    let blob = event.data;
    let reader = new FileReader();
    reader.onload = function (e) {
        let ploydata = new Uint8Array(e.target.result);
        let msg = pako.inflate(ploydata, {to: "string"});
        handleData(msg);
    };
    reader.readAsArrayBuffer(blob, "utf-8");
};
socketK.onclose = function () {
    console.log("connection closed");
};

// 處理接收到的信息
function handleData(msg) {
    let data = JSON.parse(msg);
    if (data.ping) {
        // 如果是 ping 消息
        sendHeartMessage(data.ping);
    } else if (data.status === "ok") {
        // 響應(yīng)數(shù)據(jù)
        handleReponseData(data);
    } else {
        // 數(shù)據(jù)體
        console.log(data)
    }
}

// 發(fā)送響應(yīng)信息
function sendHeartMessage(ping) {
    socketK.send(JSON.stringify({"pong": ping}));
}

function handleReponseData(data) {
}