代码如下,huobi在大概五六秒之后,会收到服务器的ping,然后我会发出一个pong,但是一直好像服务器收不到Pong似的,还在一直给我发ping,请教了大神说是给read加-1,但加了还是没用
function main() {
var ws_hbdm = Dial("wss://www.hbdm.com/ws?compress=true|compress=gzip&mode=recv")
var ws_ok= Dial("wss://real.okex.com:10440/ws/v1?compress=true|compress=gzip_raw&mode=recv")
var pingCyc = 1000 * 120
var lastPingTime = new Date().getTime()
if(ws_hbdm && ws_ok){
ws_hbdm.write('{"sub": "market.EOS_CW.depth.step6","id": "id2"}')
ws_ok.write("{'event':'addChannel','channel':'ok_sub_futureusd_eos_depth_this_week_5'}")
while(1){
//读取huobi数据
var ret = ws_hbdm.read(-1)
if(ret){
var ret1=JSON.parse(ret)
if("tick" in ret1){
Log("huobi",ret1.tick)
}else if("ping" in ret1){
ws_hbdm.write('{"pong":'+parseInt(ret1.ping)+'}')
Log("pong")
}
}
//读取ok数据
var nowTime = new Date().getTime()
var ret2 = ws_ok.read(-1)
if(ret2){
if(nowTime - lastPingTime > pingCyc){
ws_ok.write("{'event':'ping'}")
lastPingTime = nowTime
}
var ret3=JSON.parse(ret2)
if(ret3.length>0){
if("data" in ret3[0]){
Log("ok",ret3[0].data)
}
}
}
}
//ws_hbdm.close()
}
}
日志如下: (一直给huobi发pong值,就是没反应) 2019-03-21 00:30:25 信息 ok {“asks”:[[3.687,18。。。。 2019-03-21 00:30:24 信息 ok {“asks”:[[3.687,1684。。。。 2019-03-21 00:30:24 信息 pong 2019-03-21 00:30:23 信息 ok {“asks”:[[3.687,1684。。。。 2019-03-21 00:30:23 信息 ok {“asks”:[[3.687,1711,4640。。。
小草 看看是不是服务器位置的原因,另外更新一下托管者
小草 /upload/asset/292ead2ae2ccd91659e.jpg 复制你的代码试了下,没问题
小草 有些交易所服务器每隔一段时间就发一个ping检查链接
小草 额,你这托管者太老了,ws解压各种模式都是后来加的
guangtianxia 谢谢! 更新了托管者,好了
guangtianxia 如代码,我想同时获取OK和火币的行情数据,OK可以一直收到行情数据,但火币过了5秒之后就收不到了(我也回应了ping),所以想让帮忙看看代码,找找原因,我找了两天了
小草 还是没明白你有什么问题
guangtianxia 是的,我收到Ping的检查之后,马上回复pong,xxx.read() 这样读到之后返回pong是可以的,xxx.read(-1)这样就不可以了,不知道原因