आदिम के लिएSocketपहुँच, समर्थनtcp, udp, tls, unixप्रोटोकॉल. 4 लोकप्रिय संचार प्रोटोकॉल का समर्थनःmqtt, nats, amqp, kafkaडेटाबेस से कनेक्ट करने के लिए समर्थनःsqlite3, mysql, postgres, clickhouse.
..Dial()function null लौटाता है यदि यह समय समाप्त हो जाता है। एक सामान्य कॉल एक कनेक्शन ऑब्जेक्ट लौटाता है जिसमें तीन विधियां होती हैंःread, writeऔरclose.readविधि का उपयोग डेटा को पढ़ने के लिए किया जाता है,writeविधि का उपयोग डेटा भेजने औरcloseविधि का उपयोग कनेक्शन को बंद करने के लिए किया जाता है।
दreadविधि निम्नलिखित मापदंडों का समर्थन करती हैः
ws.read().ws.read(2000)दो सेकंड (2000 मिलीसेकंड) का टाइमआउट निर्दिष्ट करता है।-1इसका मतलब है कि फ़ंक्शन तुरंत संदेशों की उपस्थिति या अनुपस्थिति के बावजूद वापस करता है, उदाहरण के लिएःws.read(-1).
पैरामीटर पास करना-2इसका अर्थ है कि फ़ंक्शन तुरंत संदेश के साथ या बिना संदेश लौटाता है, लेकिन केवल नवीनतम संदेश लौटाया जाता है, और बफर किया गया संदेश त्याग दिया जाता है। उदाहरण के लिए,ws.read(-2).read()फ़ंक्शन बफर का वर्णनः
वेबसॉकेट प्रोटोकॉल द्वारा पुश किए जाने वाले आने वाले डेटा डेटा संचय का कारण बन सकते हैं यदि रणनीति के बीच समय अंतरालread()फ़ंक्शन कॉल बहुत लंबा है. ये डेटा बफर में संग्रहीत होते हैं, जिसमें अधिकतम 2000 के साथ एक कतार की डेटा संरचना होती है। 2000 से अधिक होने के बाद, सबसे नया डेटा बफर में प्रवेश करता है और सबसे पुराना डेटा साफ़ किया जाता है।
| परिदृश्य | कोई पैरामीटर नहीं | पैरामीटरः -1 | पैरामीटरः -2 | पैरामीटरः 2000 मिलीसेकंड में |
|---|---|---|---|---|
| पहले से ही बफर में डेटा | सबसे पुराना डेटा तुरंत लौटाएँ | सबसे पुराना डेटा तुरंत लौटाएँ | नवीनतम डेटा तुरंत लौटाएं | सबसे पुराना डेटा तुरंत लौटाएँ |
| बफर में कोई डेटा नहीं | डेटा पर अवरुद्ध होने पर वापस लौटाएँ | तुरंत शून्य लौटाएँ | तुरंत शून्य लौटाएँ | 2000 एमएस प्रतीक्षा करें, यदि कोई डेटा नहीं है तो शून्य लौटाएं, यदि कोई डेटा है तो शून्य लौटाएं |
| WebSocket कनेक्शन डिस्कनेक्ट या अंतर्निहित द्वारा फिर से कनेक्ट किया जाता है | read() फ़ंक्शन रिक्त स्ट्रिंग देता है, अर्थातः |
वस्तु
डायल करें (पते) डायल (पता, टाइमआउट)
अनुरोध पता। पता सच स्ट्रिंग टाइमआउट सेकंड, टाइमआउट झूठी संख्या
function main(){
// Dial supports tcp://，udp://，tls://，unix://protocol, you can add a parameter to specify the number of seconds for the timeout
var client = Dial("tls://www.baidu.com:443")
if (client) {
// write can be followed by a numeric parameter to specify the timeout, write returns the number of bytes successfully sent
client.write("GET / HTTP/1.1\nConnection: Closed\n\n")
while (true) {
// read can be followed by a numeric parameter specifying the timeout in milliseconds. Returning null indicates an error or timeout or that the socket has been closed
var buf = client.read()
if (!buf) {
break
}
Log(buf)
}
client.close()
}
}
def main():
client = Dial("tls://www.baidu.com:443")
if client:
client.write("GET / HTTP/1.1\nConnection: Closed\n\n")
while True:
buf = client.read()
if not buf:
break
Log(buf)
client.close()
void main() {
auto client = Dial("tls://www.baidu.com:443");
if(client.Valid) {
client.write("GET / HTTP/1.1\nConnection: Closed\n\n");
while(true) {
auto buf = client.read();
if(buf == "") {
break;
}
Log(buf);
}
client.close();
}
}
डायल फ़ंक्शन कॉल का उदाहरणः
function main() {
LogStatus("Connecting...")
// Accessing WebSocket interface of Binance
var client = Dial("wss://stream.binance.com:9443/ws/!ticker@arr")
if (!client) {
Log("Connection failed, program exited")
return
}
while (true) {
// read returns only the data retrieved after the read call
var buf = client.read()
if (!buf) {
break
}
var table = {
type: 'table',
title: 'Ticker Chart',
cols: ['Currency', 'Highest', 'Lowest', 'Buy 1', 'Sell 1', 'Last traded price', 'Volume', 'Update time'],
rows: []
}
var obj = JSON.parse(buf)
_.each(obj, function(ticker) {
table.rows.push([ticker.s, ticker.h, ticker.l, ticker.b, ticker.a, ticker.c, ticker.q, _D(ticker.E)])
})
LogStatus('`' + JSON.stringify(table) + '`')
}
client.close()
}
import json
def main():
LogStatus("Connecting...")
client = Dial("wss://stream.binance.com:9443/ws/!ticker@arr")
if not client:
Log("Connection failed, program exited")
return
while True:
buf = client.read()
if not buf:
break
table = {
"type" : "table",
"title" : "Ticker Chart",
"cols" : ['Currency', 'Highest', 'Lowest', 'Buy 1', 'Sell 1', 'Last traded price', 'Volume', 'Update time'],
"rows" : []
}
obj = json.loads(buf)
for i in range(len(obj)):
table["rows"].append([obj[i]["s"], obj[i]["h"], obj[i]["l"], obj[i]["b"], obj[i]["a"], obj[i]["c"], obj[i]["q"], _D(int(obj[i]["E"]))])
LogStatus('`' + json.dumps(table) + '`')
client.close()
void main() {
LogStatus("Connecting...");
auto client = Dial("wss://stream.binance.com:9443/ws/!ticker@arr");
if(!client.Valid) {
Log("Connection failed, program exited");
return;
}
while(true) {
auto buf = client.read();
if(buf == "") {
break;
}
json table = R"({
"type" : "table",
"title" : "Ticker Chart",
"cols" : ["Currency", "Highest", "Lowest", "Buy 1", "Sell 1", "Last traded price", "Volume", "Update time"],
"rows" : []
})"_json;
json obj = json::parse(buf);
for(auto& ele : obj.items()) {
table["rows"].push_back({ele.value()["s"], ele.value()["h"], ele.value()["l"], ele.value()["b"], ele.value()["a"], ele.value()["c"],
ele.value()["q"], _D(ele.value()["E"])});
}
LogStatus("`" + table.dump() + "`");
}
client.close();
}
बिनेंस के वेबसॉकेट टिकर इंटरफ़ेस तक पहुँचने के लिएः
var ws = null
function main(){
var param = {
"op": "subscribe",
"args": [{
"channel": "tickers",
"instId": "BTC-USDT"
}]
}
// When calling Dial function, specify reconnect=true to set reconnection mode and payload to be the message sent when reconnecting. When the WebSocket connection is disconnected, it will reconnect and send messages automatically.
ws = Dial("wss://ws.okx.com:8443/ws/v5/public|compress=gzip_raw&mode=recv&reconnect=true&payload="+ JSON.stringify(param))
if(ws){
var pingCyc = 1000 * 20
var lastPingTime = new Date().getTime()
while(true){
var nowTime = new Date().getTime()
var ret = ws.read()
Log("ret:", ret)
if(nowTime - lastPingTime > pingCyc){
var retPing = ws.write("ping")
lastPingTime = nowTime
Log("Send : ping", "#FF0000")
}
LogStatus("Current time:", _D())
Sleep(1000)
}
}
}
function onexit() {
ws.close()
Log("exit")
}
import json
import time
ws = None
def main():
global ws
param = {
"op": "subscribe",
"args": [{
"channel": "tickers",
"instId": "BTC-USDT"
}]
}
ws = Dial("wss://ws.okx.com:8443/ws/v5/public|compress=gzip_raw&mode=recv&reconnect=true&payload=" + json.dumps(param))
if ws:
pingCyc = 1000 * 20
lastPingTime = time.time() * 1000
while True:
nowTime = time.time() * 1000
ret = ws.read()
Log("ret:", ret)
if nowTime - lastPingTime > pingCyc:
retPing = ws.write("ping")
lastPingTime = nowTime
Log("Send: ping", "#FF0000")
LogStatus("Current time:", _D())
Sleep(1000)
def onexit():
ws.close()
Log("exit")
auto objWS = Dial("wss://ws.okx.com:8443/ws/v5/public|compress=gzip_raw&mode=recv&reconnect=true");
void main() {
json param = R"({
"op": "subscribe",
"args": [{
"channel": "tickers",
"instId": "BTC-USDT"
}]
})"_json;
objWS.write(param.dump());
if(objWS.Valid) {
uint64_t pingCyc = 1000 * 20;
uint64_t lastPingTime = Unix() * 1000;
while(true) {
uint64_t nowTime = Unix() * 1000;
auto ret = objWS.read();
Log("ret:", ret);
if(nowTime - lastPingTime > pingCyc) {
auto retPing = objWS.write("ping");
lastPingTime = nowTime;
Log("Send: ping", "#FF0000");
}
LogStatus("Current time:", _D());
Sleep(1000);
}
}
}
void onexit() {
objWS.close();
Log("exit");
}
OKX
var ws = null
function main(){
var param = {"sub": "market.btcusdt.detail", "id": "id1"}
ws = Dial("wss://api.huobi.pro/ws|compress=gzip&mode=recv&reconnect=true&payload="+ JSON.stringify(param))
if(ws){
while(1){
var ret = ws.read()
Log("ret:", ret)
// Respond to heartbeat packet operations
try {
var jsonRet = JSON.parse(ret)
if(typeof(jsonRet.ping) == "number") {
var strPong = JSON.stringify({"pong" : jsonRet.ping})
ws.write(strPong)
Log("Respond to ping, send pong:", strPong, "#FF0000")
}
} catch(e) {
Log("e.name:", e.name, "e.stack:", e.stack, "e.message:", e.message)
}
LogStatus("Current time:", _D())
Sleep(1000)
}
}
}
function onexit() {
ws.close()
Log("Execute the ws.close() function")
}
import json
ws = None
def main():
global ws
param = {"sub" : "market.btcusdt.detail", "id" : "id1"}
ws = Dial("wss://api.huobi.pro/ws|compress=gzip&mode=recv&reconnect=true&payload=" + json.dumps(param))
if ws:
while True:
ret = ws.read()
Log("ret:", ret)
# Respond to heartbeat packet operations
try:
jsonRet = json.loads(ret)
if "ping" in jsonRet and type(jsonRet["ping"]) == int:
strPong = json.dumps({"pong" : jsonRet["ping"]})
ws.write(strPong)
Log("Respond to ping, send pong:", strPong, "#FF0000")
except Exception as e:
Log("e:", e)
LogStatus("Current time:", _D())
Sleep(1000)
def onexit():
ws.close()
Log("Execute the ws.close() function")
using namespace std;
void main() {
json param = R"({"sub" : "market.btcusdt.detail", "id" : "id1"})"_json;
auto ws = Dial("wss://api.huobi.pro/ws|compress=gzip&mode=recv&reconnect=true&payload=" + param.dump());
if(ws.Valid) {
while(true) {
auto ret = ws.read();
Log("ret:", ret);
// Respond to heartbeat packet operations
try
{
auto jsonRet = json::parse(ret);
if(jsonRet["ping"].is_number()) {
json pong = R"({"pong" : 0})"_json;
pong["pong"] = jsonRet["ping"];
auto strPong = pong.dump();
ws.write(strPong);
Log("Respond to ping, send pong:", strPong, "#FF0000");
}
} catch(exception &e)
{
Log("e:", e.what());
}
LogStatus("Current time:", _D());
Sleep(1000);
}
}
}
void onexit() {
// ws.close();
Log("Execute the ws.close() function");
}
Huobi
function getLogin(pAccessKey, pSecretKey, pPassphrase) {
// Signature function for login
var ts = (new Date().getTime() / 1000).toString()
var login = {
"op": "login",
"args":[{
"apiKey" : pAccessKey,
"passphrase" : pPassphrase,
"timestamp" : ts,
"sign" : exchange.HMAC("sha256", "base64", ts + "GET" + "/users/self/verify", pSecretKey) // exchange.HMAC has been deprecated and is temporarily supported. Please use the latest exchange.Encode function instead.
}]
}
return login
}
var client_private = null
function main() {
// Because the read function uses a timeout setting, filtering the timeout reports errors that would otherwise be output with redundant errors
SetErrorFilter("timeout")
// Position channel subscription information
var posSubscribe = {
"op": "subscribe",
"args": [{
"channel": "positions",
"instType": "ANY"
}]
}
var accessKey = "xxx"
var secretKey = "xxx"
var passphrase = "xxx"
client_private = Dial("wss://ws.okx.com:8443/ws/v5/private")
client_private.write(JSON.stringify(getLogin(accessKey, secretKey, passphrase)))
Sleep(3000) // When logging in, you cannot subscribe to private channels immediately, you need to wait for server response
client_private.write(JSON.stringify(posSubscribe))
if (client_private) {
var lastPingTS = new Date().getTime()
while (true) {
var buf = client_private.read(-1)
if (buf) {
Log(buf)
}
// Detect disconnection, reconnect
if (buf == "" && client_private.write(JSON.stringify(posSubscribe)) == 0) {
Log("Disconnection detected, close connection, reconnect")
client_private.close()
client_private = Dial("wss://ws.okx.com:8443/ws/v5/private")
client_private.write(JSON.stringify(getLogin(accessKey, secretKey, passphrase)))
Sleep(3000)
client_private.write(JSON.stringify(posSubscribe))
}
// Send heartbeat packets
var nowPingTS = new Date().getTime()
if (nowPingTS - lastPingTS > 10 * 1000) {
client_private.write("ping")
lastPingTS = nowPingTS
}
}
}
}
function onexit() {
var ret = client_private.close()
Log("Close the connection!", ret)
}
import json
import time
def getLogin(pAccessKey, pSecretKey, pPassphrase):
ts = str(time.time())
login = {
"op": "login",
"args":[{
"apiKey" : pAccessKey,
"passphrase" : pPassphrase,
"timestamp" : ts,
"sign" : exchange.HMAC("sha256", "base64", ts + "GET" + "/users/self/verify", pSecretKey)
}]
}
return login
client_private = None
def main():
global client_private
SetErrorFilter("timeout")
posSubscribe = {
"op": "subscribe",
"args": [{
"channel": "positions",
"instType": "ANY"
}]
}
accessKey = "xxx"
secretKey = "xxx"
passphrase = "xxx"
client_private = Dial("wss://ws.okx.com:8443/ws/v5/private")
client_private.write(json.dumps(getLogin(accessKey, secretKey, passphrase)))
Sleep(3000)
client_private.write(json.dumps(posSubscribe))
if client_private:
lastPingTS = time.time() * 1000
while True:
buf = client_private.read(-1)
if buf:
Log(buf)
if buf == "" and client_private.write(json.dumps(posSubscribe)) == 0:
Log("Disconnection detected, close connection, reconnect")
ret = client_private.close()
client_private = Dial("wss://ws.okx.com:8443/ws/v5/private")
client_private.write(json.dumps(getLogin(accessKey, secretKey, passphrase)))
Sleep(3000)
client_private.write(json.dumps(posSubscribe))
nowPingTS = time.time() * 1000
if nowPingTS - lastPingTS > 10 * 1000:
client_private.write("ping")
lastPingTS = nowPingTS
def onexit():
ret = client_private.close()
Log("Close the connection!", ret)
auto client_private = Dial("wss://ws.okx.com:8443/ws/v5/private");
json getLogin(string pAccessKey, string pSecretKey, string pPassphrase) {
auto ts = std::to_string(Unix());
json login = R"({
"op": "login",
"args": [{
"apiKey": "",
"passphrase": "",
"timestamp": "",
"sign": ""
}]
})"_json;
login["args"][0]["apiKey"] = pAccessKey;
login["args"][0]["passphrase"] = pPassphrase;
login["args"][0]["timestamp"] = ts;
login["args"][0]["sign"] = exchange.HMAC("sha256", "base64", ts + "GET" + "/users/self/verify", pSecretKey);
return login;
}
void main() {
SetErrorFilter("timeout");
json posSubscribe = R"({
"op": "subscribe",
"args": [{
"channel": "positions",
"instType": "ANY"
}]
})"_json;
auto accessKey = "xxx";
auto secretKey = "xxx";
auto passphrase = "xxx";
client_private.write(getLogin(accessKey, secretKey, passphrase).dump());
Sleep(3000);
client_private.write(posSubscribe.dump());
if (client_private.Valid) {
uint64_t lastPingTS = Unix() * 1000;
while (true) {
auto buf = client_private.read(-1);
if (buf != "") {
Log(buf);
}
if (buf == "") {
if (client_private.write(posSubscribe.dump()) == 0) {
Log("Disconnection detected, close connection, reconnect");
client_private.close();
client_private = Dial("wss://ws.okx.com:8443/ws/v5/private");
client_private.write(getLogin(accessKey, secretKey, passphrase).dump());
Sleep(3000);
client_private.write(posSubscribe.dump());
}
}
uint64_t nowPingTS = Unix() * 1000;
if (nowPingTS - lastPingTS > 10 * 1000) {
client_private.write("ping");
lastPingTS = nowPingTS;
}
}
}
}
void onexit() {
client_private.close();
Log("exit");
}
OKX
var client = null
function main() {
// client = Dial("sqlite3://:memory:") // Using an in-memory database
client = Dial("sqlite3://test1.db") // Open/connect to the database file in the docker's directory
// record handle
var sqlite3Handle = client.fd()
Log("sqlite3Handle:", sqlite3Handle)
// Querying tables in the database
var ret = client.exec("SELECT name FROM sqlite_master WHERE type='table'")
Log(ret)
}
function onexit() {
Log("Execute client.close()")
client.close()
}
// Not supported
// Not supported
एक डेटाबेस से कनेक्ट करते समय डायल फ़ंक्शन द्वारा लौटाए गए कनेक्शन ऑब्जेक्ट में दो विधि फ़ंक्शन होते हैं जो इसके लिए अद्वितीय होते हैंः
exec(sqlString): SQL कथन को निष्पादित करने के लिए उपयोग किया जाता हैDBExec() function.fd():fd()फ़ंक्शन एक हैंडल (जैसे, हैंडल चर हैडल है) वापस करता है जिसका उपयोग अन्य थ्रेडों द्वारा फिर से कनेक्ट करने के लिए किया जाएगा (भले ही डायल द्वारा बनाई गई ऑब्जेक्ट को पहले ही निष्पादन द्वारा बंद कर दिया गया हो)close()कनेक्शन को बंद करने के लिए कार्य) हैंडल कोDial()उदाहरण के लिए,Dial(handle)पुनः उपयोग कनेक्शन।
निम्नलिखित डायल फ़ंक्शन का एक उदाहरण है जो एकsqlite3 database.विवरणaddressपैरामीटर, द्वारा अलग|सामान्य पते के बाद प्रतीक:wss://ws.okx.com:8443/ws/v5/publicयदि कोई है।|पैरामीटर स्ट्रिंग में वर्ण, तो||विभाजक चिह्न के रूप में प्रयोग किया जाता है. इसके बाद का हिस्सा कुछ समारोह पैरामीटर सेटिंग्स है, और प्रत्येक पैरामीटर के साथ जुड़ा हुआ है&उदाहरण के लिए,ss5प्रॉक्सी और संपीड़न मापदंडों को एक साथ निम्नानुसार सेट किया जा सकता हैःDial("wss://ws.okx.com:8443/ws/v5/public|proxy=socks5://xxx:9999&compress=gzip_raw&mode=recv")
| डायल फ़ंक्शन के पते पैरामीटर द्वारा समर्थित फ़ंक्शन | पैरामीटर का वर्णन |
|---|---|
| वेबसॉकेट प्रोटोकॉल डेटा संपीड़न से संबंधित पैरामीटरः compress=parameter value | compress संपीड़न विधि है, संपीड़न पैरामीटर विकल्प हैंः gzip_raw, gzip, आदि यदि gzip विधि मानक gzip नहीं है, तो आप विस्तारित विधि का उपयोग कर सकते हैंः gzip_raw |
| वेबसॉकेट प्रोटोकॉल डेटा संपीड़न से संबंधित पैरामीटरः मोड=पैरामीटर मान | मोड संपीड़न मोड है, मोड पैरामीटर दोहरी हो सकती है, भेजें, recv. दोहरी दो तरफा संपीड़न है, संपीड़ित डेटा भेजें, संपीड़ित डेटा प्राप्त करें. send संपीड़ित डेटा भेजें है. recv संपीड़ित डेटा प्राप्त करें, स्थानीय decompression है. |
| वेबसॉकेट प्रोटोकॉल अंतर्निहित ऑटो-पुनः कनेक्ट संबंधित पैरामीटर सेट करता हैः reconnect=parameter value | reconnect reconnect सेट करना है, reconnect=true reconnect सक्षम करना है। डिफ़ॉल्ट रूप से यह पैरामीटर सेट नहीं होने पर कोई reconnect नहीं है. |
| वेबसॉकेट प्रोटोकॉल अंतर्निहित ऑटो-पुनः कनेक्ट संबंधित मापदंडों को सेट करता हैः अंतराल=पैरामीटर मान | अंतराल पुनः प्रयास अंतराल है, मिलीसेकंड में, अंतराल=10000 10 सेकंड का पुनः प्रयास अंतराल है, डिफ़ॉल्ट 1 सेकंड है जब यह सेट नहीं है, यानी अंतराल=1000. |
| वेबसॉकेट प्रोटोकॉल अंतर्निहित ऑटो-पुनः कनेक्ट संबंधित मापदंडों को सेट करता हैः पेलोड=पैरामीटर मान | पेलोड वह सब्सक्रिप्शन संदेश है जिसे वेबसॉकेट को फिर से कनेक्ट करने पर भेजना आवश्यक है, उदाहरण के लिएः पेलोड=ओकोकोक. |
| Socks5 प्रॉक्सी से संबंधित पैरामीटर: proxy=पैरामीटर मान | प्रॉक्सी ss5 प्रॉक्सी सेटिंग है, पैरामीटर मान प्रारूपः socks5://name:pwd@192.168.0.1:1080, नाम ss5 सर्वर उपयोगकर्ता नाम है, pwd ss5 सर्वर लॉगिन पासवर्ड है, 1080 ss5 सेवा पोर्ट है. |
..Dial()फ़ंक्शन केवल लाइव ट्रेडिंग के लिए समर्थित है.
डायल फ़ंक्शन का उपयोग करके डेटाबेस से कनेक्ट करते समय, कनेक्शन स्ट्रिंग प्रत्येक डेटाबेस के लिए go भाषा ड्राइवर प्रोजेक्ट के संदर्भ में लिखी जाती है.
| समर्थित डेटाबेस | ड्राइविंग परियोजनाएं | कनेक्शन स्ट्रिंग | टिप्पणी |
|---|---|---|---|
| स्क्लाइट3 | github.com/mattn/go-sqlite3 | sqlite3://file:test.db?cache=shared&mode=memory फ़ाइलःtest.db?cache=shared&mode=memory फ़ाइलःtest.db?cache=shared&mode=memory | ..sqlite3://उपसर्ग इंगित करता है कि एक sqlite3 डेटाबेस का उपयोग किया जा रहा है, उदाहरण कॉलःDial("sqlite3://test1.db") |
| mysql | github.com/go-sql-driver/mysql | mysql://username:yourpassword@tcp(localhost:3306) /आपका डेटाबेस?charset=utf8mb4 | – |
| उपजाऊ | github.com/lib/pq | postgres://user=postgres dbname=yourdatabase sslmode=disable password=yourpassword होस्ट=localhost पोर्ट=5432 | – |
| क्लिकहाउस | github.com/ClickHouse/clickhouse-go | क्लिकहाउस://tcp://host:9000?username=username&password=yourpassword&database=youdatabase | – |
कृपया ध्यान दें कि जबpayloadसामग्री में सेटaddressपैरामीटर में वर्ण होते हैं=या अन्य विशेष वर्ण, यह पार्सिंग को प्रभावित कर सकता हैaddressपैरामीटरDialकार्य, जैसे कि निम्नलिखित उदाहरण।
backPack Exchange वेबसॉकेट निजी इंटरफ़ेस कॉल उदाहरणः
var client = null
function main() {
// Base64-encoded public key of the key pair, i.e. the access key configured on FMZ
var base64ApiKey = "xxx"
var ts = String(new Date().getTime())
var data = "instruction=subscribe×tamp=" + ts + "&window=5000"
// Since signEd25519 returns a base64 encoding, it contains the character "="
var signature = signEd25519(data)
// The payload may contain the character "=" after being encoded by JSON
payload = {
"method": "SUBSCRIBE",
"params": ["account.orderUpdate"],
"signature": [base64ApiKey, signature, ts, "5000"]
}
client = Dial("wss://ws.backpack.exchange")
client.write(JSON.stringify(payload))
if (!client) {
Log("Connection failed, program exited")
return
}
while (true) {
var buf = client.read()
Log(buf)
}
}
function onexit() {
client.close()
}
function signEd25519(data) {
return exchange.Encode("ed25519.seed", "raw", "base64", data, "base64", "{{secretkey}}")
}
कोड में निम्नलिखित कॉल ठीक काम करता हैः
client = Dial("wss://ws.backpack.exchange")
client.write(JSON.stringify(payload))
यदि आप इसे सीधे में लिखते हैंpayload, यह ठीक से काम नहीं करेगा, उदाहरण के लिएः
client = Dial("wss://ws.backpack.exchange|payload=" + JSON.stringify(payload))
वर्तमान में, केवल जावास्क्रिप्ट का उपयोग करने का समर्थन करता हैmqtt, nats, amqp, औरkafkaडायल फ़ंक्शन में संचार प्रोटोकॉल। चार प्रोटोकॉल के उपयोग को दिखाने के लिए जावास्क्रिप्ट भाषा रणनीति कोड का उपयोग एक उदाहरण के रूप में किया जाता हैःmqtt, nats, amqp, औरkafka:
// We need to configure and deploy proxy servers for each protocol first.
// For the sake of demonstration, the subscription (read operation) and publishing (write operation) of the topic test_topic are all performed in the current strategy.
var arrConn = []
var arrName = []
function main() {
LogReset(1)
conn_nats = Dial("nats://admin@127.0.0.1:4222?topic=test_topic")
conn_mqtt = Dial("mqtt://127.0.0.1:1883?topic=test_topic")
conn_amqp = Dial("amqp://q:admin@127.0.0.1:5672/?queue=test_Queue")
conn_kafka = Dial("kafka://localhost:9092/test_topic")
arrConn = [conn_nats, conn_amqp, conn_mqtt, conn_kafka]
arrName = ["nats", "amqp", "mqtt", "kafka"]
while (true) {
for (var i in arrConn) {
var conn = arrConn[i]
var name = arrName[i]
// Write data
conn.write(name + ", time: " + _D() + ", test msg.")
// Read data
var readMsg = conn.read(1000)
Log(name + " readMsg: ", readMsg, "#FF0000")
}
Sleep(1000)
}
}
function onexit() {
for (var i in arrConn) {
arrConn[i].close()
Log("close", arrName[i], "connect")
}
}
विस्तृत प्रलेखन संदर्भःएफएमजेड का अन्वेषण: लाइव ट्रेडिंग रणनीतियों के बीच संचार प्रोटोकॉल का अभ्यास
मेटा प्राप्त करें HttpQuery