javascript – Node-js：在websocket重新连接后没有收到事件

2023年3月15日 121次阅读

我的node-js应用程序使用bitfinex-api-node npm包建立websocket连接以从Bitfinex加密货币交换中接收数据.

不幸的是,连接在几个小时后无声地中断,应用程序停止通过websocket接收数据.这似乎是一个已知问题,也许是bitfinex-api-module的一个错误.

现在,我试图通过首先连接websocket并订阅一些蜡烛数据来“手动”重新连接.然后调用websocket.close()函数以在运行时模拟连接错误.在on close函数中,我设置了另一个超时并尝试创建一个新的BFX()对象并打开()但是.on(open)永远不会被调用.

=>我一定做错了什么.我的逻辑中有错误吗？有没有更好的重新连接方式？

以下代码有效,只需复制粘贴并运行即可查看.
我非常感谢任何提示或提示.

const BFX = require('bitfinex-api-node');

//websocket
const opts = {
  manageCandles: true, 
  transform: true,
  API_KEY: 'hidden',
  API_SECRET: 'hidden',
  ws: {
    autoReconnect: true,
    seqAudit: true,
    packetWDDelay: 10 * 1000
  }
};
var websocket = new BFX().ws(2, opts);

websocket.on('open', () => {
    //websocket.auth.bind(websocket)
    console.log('.on(open) called');
    websocket.subscribeCandles('trade:5m:tBTCUSD')
});

websocket.on('close', ()=>{
    console.log('.on(close) called');
    setTimeout(function() { 
        websocket = new BFX().ws(2, opts);
        websocket.open();
    }, 10000);
});

websocket.onCandle({key: 'trade:5m:tBTCUSD'},(candles) => { 
    console.log(candles[0]);
})

websocket.open();

// this closes the connection after 20 seconds 
//after start for debugging purposes:
setTimeout(function() {         
        websocket.close();
    }, 10000);

最佳答案 问题是当前一个websocket关闭时,你没有将任何监听器附加到websocket的新实例：

websocket.on('close', ()=>{
    console.log('.on(close) called');
    setTimeout(function() { 
        // this creates a new instance without listeners
        websocket = new BFX().ws(2, opts);
        websocket.open();
    }, 10000);
});

当您第一次初始化websocket时,添加它们：

websocket.on('open', /* code */);
websocket.onCandle(/* code */);

要解决此问题,我建议编写一个函数来创建和配置websocket的新实例：

function createWebsocket() {
    const websocket = new BFX().ws(2, opts);
    websocket.on('open', /* code */);
    websocket.onCandle(/* code */);
    websocket.open();
}

然后调用它(‘关闭’)：

websocket.on('close', ()=>{
    console.log('.on(close) called');
    setTimeout(createWebsocket, 10000);
});
点赞