function WSConnecter_Huobi (method, symbol) {
// wss : wss://api.huobi.pro/ws
/* Subscribe
{
"sub": "market.btcusdt.detail",
}
*/
/* Subscribe string
'{"sub": "market.btcusdt.detail"}'
*/
var strSubscribe = ""
if (method == "GetTicker") {
symbol = symbol.toLowerCase()
symbol = symbol.replace("_", "")
strSubscribe = '{"sub": "market.' + symbol + '.detail"}' // symbol : btcusdt
} else {
throw "未实现：" + method + "方法！"
}
var self = {}
self.method = method
self.pingCount = 0
Log("Dial函数链接：", "wss://api.huobi.pro/ws|compress=gzip&mode=recv&reconnect=true&payload=" + strSubscribe)
Log("订阅信息：", strSubscribe)
self.client = Dial("wss://api.huobi.pro/ws|compress=gzip&mode=recv&reconnect=true&payload=" + strSubscribe)
self.client.write(strSubscribe)
self.Read = function () {
try {
var ret = self.client.read()
var objRet = JSON.parse(ret)
if (objRet.ping) {
var pong = {"pong" : objRet.ping}
// Log("huobiConn 收到心跳包，发送pong:", JSON.stringify(pong))
self.client.write(JSON.stringify(pong))
self.pingCount++
return null
} else {
/* 封装成FMZ的ticker结构
{
"ch":"market.btcusdt.detail",
"ts":1569477791639,
"tick":{
"id":205028275148,
"low":8217,
"high":8624.87,
"open":8517.89,
"close":8386.36,
"vol":361804831.52344716,
"amount":43197.45945060976,
"version":205028275148,
"count":335763
}
}
*/
var ticker = {}
if (!objRet.tick) {
return null
}
ticker.Info = objRet.tick
ticker.High = objRet.tick.high
ticker.Low = objRet.tick.low
ticker.Last = objRet.tick.close
ticker.Volume = objRet.tick.vol
ticker.Buy = objRet.tick.close
ticker.Sell = objRet.tick.close
ticker.Time = objRet.ts
return ticker
}
} catch (e) {
Log("error:", e)
return null
}
}
self.Close = function () {
self.client.close()
Log("method:", self.method, "断开ws链接")
}
return self
}
function WSConnecter_Binance (method, symbol) {
// wss : wss://stream.binance.com:9443
// /ws/<streamName>
// Stream 名称: <symbol>@ticker
// /ws/btcusdt@ticker
var strSubscribe = ""
if (method == "GetTicker") {
symbol = symbol.toLowerCase()
symbol = symbol.replace("_", "")
strSubscribe = "/ws/" + symbol + "@ticker"
} else {
throw "未实现：" + method + "方法！"
}
var self = {}
self.pingCount = 0
self.method = method
Log("Dial函数链接：", "wss://stream.binance.com:9443" + strSubscribe + "|reconnect=true")
self.client = Dial("wss://stream.binance.com:9443" + strSubscribe + "|reconnect=true")
self.Read = function () {
try {
var ret = self.client.read()
var objRet = JSON.parse(ret)
if (objRet.ping) {
var pong = {"pong" : objRet.ping}
Log("binanceConn 收到心跳包，发送pong:", JSON.stringify(pong))
self.client.write(JSON.stringify(pong))
self.pingCount++
return null
} else {
/*
{
"e":"24hrTicker",
"E":1569479950378,
"s":"BTCUSDT",
"p":"-72.67000000",
"P":"-0.855",
"w":"8380.87678669",
"x":"8504.99000000",
"c":"8430.98000000",
"Q":"0.10865300",
"b":"8430.02000000", // Buy1
"B":"2.00000000",
"a":"8431.00000000",
"A":"0.24020700",
"o":"8503.65000000",
"h":"8629.96000000",
"l":"8215.64000000",
"v":"52091.18312400",
"q":"436569787.43499342",
"O":1569393550372,
"C":1569479950372,
"F":182689950,
"L":183168699,
"n":478750
}
*/
var ticker = {}
ticker.Info = objRet
ticker.Buy = objRet.b
ticker.Sell = objRet.a
ticker.High = objRet.h
ticker.Low = objRet.l
ticker.Volume = objRet.v
ticker.Last = objRet.c
ticker.Time = objRet.E
Log("推送行情：", ticker) // 测试
return ticker
}
} catch (e) {
Log("error:", e)
return null
}
}
self.Close = function () {
self.client.close()
Log("断开ws链接")
}
return self
}
var _DictConnectCreater = {
"Huobi" : WSConnecter_Huobi,
"Binance" : WSConnecter_Binance,
}
var _ConnMap = {}
function init () {
if (IsUsedWebSocket) {
var connectCreater = null
if (exchanges.length != 1) {
Log("切换为ws接口只针对 exchange 交易所对象（即第一个添加的交易所对象）")
}
var isFound = false
for (var name in _DictConnectCreater) {
if (exchange.GetName() == name) {
connectCreater = _DictConnectCreater[name]
isFound = true
}
}
if (!isFound) {
throw "没有找到实现"
}
if (Hook_GetTicker) {
var symbol = exchange.GetCurrency()
_ConnMap.GetTicker = connectCreater("GetTicker", symbol)
exchange.GetTicker = function () {
return _C(_ConnMap.GetTicker.Read)
}
}
// ...
}
}
/* 不会触发
function onexit(){
for (var method in _ConnMap) {
_ConnMap[method].Close()
}
}
*/
// 测试
function main () {
}
冰糖葫芦娃 这个返回的不是最新的数据吧，read(-2)会不会好点
小小梦 可以 ，可以根据需求，调整。