function main(){
var param = {
“op”: “subscribe”,
“args”: [
{
“channel” : “instruments”,
“instType”: “FUTURES”
}
]
}
// Chỉ định khi gọi hàm Dialreconnect=trueThiết lập để kết nối lại, chỉ địnhpayloadThông điệp được gửi khi kết nối lại. Sau khi kết nối websocket bị ngắt, nó sẽ tự động kết nối lại và tự động gửi thông điệp.
var ws = Dial(“wss://wsaws.okex.com:8443/ws/v5/public|compress=gzip_raw&mode=recv&reconnect=true&”+ JSON.stringify(param))
if(ws){
ws.write(JSON.stringify(param))
var pingCyc = 1000 * 20
var lastPingTime = new Date().getTime()
while(1){
var nowTime = new Date().getTime()
var ret = ws.read()
Log(“ret:”, ret)
if(nowTime - lastPingTime > pingCyc){
var retPing = ws.write(“ping”)
lastPingTime = nowTime
Log ((“được gửi bởi:ping”, “#FF0000”)
}
LogStatus_D())
Sleep(1000)
}
ws.close()
}
}
Ví dụ, có ai có thể cung cấp một mã chính xác cho các kênh sản phẩm trong giao diện websocket của okx, luôn luôn trễ thời gian, sử dụng mã trên để yêu cầu