我的Node.js应用程序使用bitfinex-api-node npm包建立WebSocket连接,以接收来自Bitfinex加密货币交易所的数据。
不幸的是,几个小时后连接会默默中断,应用程序停止通过WebSocket接收数据。这似乎是一个已知的问题,可能是bitfinex-api-module的一个bug。
现在,我正在尝试“手动”重新连接,首先连接WebSocket并订阅一些蜡烛数据。然后调用websocket.close()函数模拟运行时连接错误。在关闭函数中,我设置另一个超时并尝试创建一个新的BFX()对象并打开它,但.on(open)从未被调用。
=> 我一定做错了什么。我的逻辑有误吗?有更好的重新连接方法吗?
以下代码有效,只需复制粘贴并运行即可查看。非常感谢任何提示或建议。
不幸的是,几个小时后连接会默默中断,应用程序停止通过WebSocket接收数据。这似乎是一个已知的问题,可能是bitfinex-api-module的一个bug。
现在,我正在尝试“手动”重新连接,首先连接WebSocket并订阅一些蜡烛数据。然后调用websocket.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);