基礎功能

• Python
• C#
• Java
• C++
• JavaScript
• 裸協議

協議 ID	Protobuf 文件	説明
1001	InitConnect	初始化連線
1002	GetGlobalState	取得全域狀態
1003	Notify	事件通知推送
1004	KeepAlive	保持連線

設定 API 資訊

• Python
• C#
• Java
• C++
• JavaScript
• 裸協議

set_client_info(client_id, client_ver)

• 介紹

  設定呼叫 API 的資訊（非必須）。

• 參數

  • client_id: client 的標識
  • client_ver: client 的版本號

• Example

from futu import *
SysConfig.set_client_info("MyFutuAPI", 0)
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
quote_ctx.close()

• Example

from moomoo import *
SysConfig.set_client_info("MymoomooAPI", 0)
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
quote_ctx.close()

void SetClientInfo(String clientID, int clientVer);

• 介紹

  設定呼叫 API 的資訊（非必須）。

• 參數

  • clientID: client 的標識
  • clientVer: client 的版本號

• Example

FTAPI_Qot qot = new FTAPI_Qot();
qot.SetClientInfo("FTAPI4NET_Sample", 1);  //設置客户端信息

• Example

MMAPI_Qot qot = new MMAPI_Qot();
qot.SetClientInfo("MMAPI4NET_Sample", 1);  //設置客户端信息

void setClientInfo(String clientID, int clientVer);

• 介紹

  設定呼叫 API 的資訊（非必須）。

• 參數

  • clientID: client 的標識
  • clientVer: client 的版本號

• Example

FTAPI_Conn_Qot qot = new FTAPI_Conn_Qot();
qot.setClientInfo("javaclient", 1);  //設置客户端信息

MMAPI_Conn_Qot qot = new MMAPI_Conn_Qot();
qot.setClientInfo("javaclient", 1);  //設置客户端信息

void SetClientInfo(const char* szClientID, Futu::i32_t nClientVer);

• 介紹

  設定呼叫 API 的資訊（非必須）。

• 參數

  • szClientID: client 的標識
  • nClientVer: client 的版本號

• Example

FTAPI_Qot *m_pQotApi = FTAPI::CreateQotApi();
m_pQotApi->SetClientInfo('cpp', 1);
FTAPI::ReleaseQotApi(m_pQotApi);

void SetClientInfo(const char* szClientID, moomoo::i32_t nClientVer);

• 介紹

  設定呼叫 API 的資訊（非必須）。

• 參數

  • szClientID: client 的標識
  • nClientVer: client 的版本號

MMAPI_Qot *m_pQotApi = MMAPI::CreateQotApi();
m_pQotApi->SetClientInfo('cpp', 1);
MMAPI::ReleaseQotApi(m_pQotApi);

InitConnect.proto

message C2S
{
    required int32 clientVer = 1; //客户端版本號，clientVer = "."以前的數 * 100 + "."以後的，舉例：1.1版本的 clientVer 為1 * 100 + 1 = 101，2.21版本為2 * 100 + 21 = 221
    required string clientID = 2; //客户端唯一標識，無生具體生成規則，客户端自己保證唯一性即可
    optional bool recvNotify = 3; //此連接是否接收市場狀態、交易需要重新解鎖等等事件通知，true 代表接收，OpenD 就會向此連接推送這些通知，反之 false 代表不接收不推送
    //如果通信要加密，首先得在 OpenD 和客户端都配置 RSA 密鑰，不配置始終不加密
    //如果配置了 RSA 密鑰且指定的加密算法不為 PacketEncAlgo_None 則加密(即便這裏不設置，配置了 RSA 密鑰，也會採用默認加密方式)，默認採用 FTAES_ECB 算法
    optional int32 packetEncAlgo = 4; //指定包加密算法，參見 Common.PacketEncAlgo 的枚舉定義
    optional int32 pushProtoFmt = 5; //指定這條連接上的推送協議格式，若不指定則使用 push_proto_type 配置項
}

message C2S
{
    required int32 clientVer = 1; //客户端版本號，clientVer = "."以前的數 * 100 + "."以後的，舉例：1.1版本的 clientVer 為1 * 100 + 1 = 101，2.21版本為2 * 100 + 21 = 221
    required string clientID = 2; //客户端唯一標識，無生具體生成規則，客户端自己保證唯一性即可
    optional bool recvNotify = 3; //此連接是否接收市場狀態、交易需要重新解鎖等等事件通知，true 代表接收，OpenD 就會向此連接推送這些通知，反之 false 代表不接收不推送
    //如果通信要加密，首先得在 OpenD 和客户端都配置 RSA 密鑰，不配置始終不加密
    //如果配置了 RSA 密鑰且指定的加密算法不為 PacketEncAlgo_None 則加密(即便這裏不設置，配置了 RSA 密鑰，也會採用默認加密方式)，默認採用 FTAES_ECB 算法
    optional int32 packetEncAlgo = 4; //指定包加密算法，參見 Common.PacketEncAlgo 的枚舉定義
    optional int32 pushProtoFmt = 5; //指定這條連接上的推送協議格式，若不指定則使用 push_proto_type 配置項
}

• 介紹

  在初始化連線協議的 clientVer 及 clientID 欄位中設定相關資訊。

設置協議格式

• Python
• C#
• Java
• C++
• JavaScript
• 裸協議

set_proto_fmt(proto_fmt)

• 介紹

  設定通訊協議 Body 格式（非必須）　目前支援 Protobuf 或 Json 兩種格式，預設為 Protobuf。

• 參數

  • proto_fmt: 協議格式，參見ProtoFMT

from futu import *
SysConfig.set_proto_fmt(ProtoFMT.Protobuf)
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
quote_ctx.close()

from moomoo import *
SysConfig.set_proto_fmt(ProtoFMT.Protobuf)
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
quote_ctx.close()

• Example

InitConnect.proto

message C2S
{
    required int32 clientVer = 1; //客户端版本號，clientVer = "."以前的數 * 100 + "."以後的，舉例：1.1版本的 clientVer 為1 * 100 + 1 = 101，2.21版本為2 * 100 + 21 = 221
    required string clientID = 2; //客户端唯一標識，無生具體生成規則，客户端自己保證唯一性即可
    optional bool recvNotify = 3; //此連接是否接收市場狀態、交易需要重新解鎖等等事件通知，true 代表接收，OpenD 就會向此連接推送這些通知，反之 false 代表不接收不推送
    //如果通信要加密，首先得在 OpenD 和客户端都配置 RSA 密鑰，不配置始終不加密
    //如果配置了 RSA 密鑰且指定的加密算法不為 PacketEncAlgo_None 則加密(即便這裏不設置，配置了 RSA 密鑰，也會採用默認加密方式)，默認採用 FTAES_ECB 算法
    optional int32 packetEncAlgo = 4; //指定包加密算法，參見 Common.PacketEncAlgo 的枚舉定義
    optional int32 pushProtoFmt = 5; //指定這條連接上的推送協議格式，若不指定則使用 push_proto_type 配置項
}

InitConnect.proto

message C2S
{
    required int32 clientVer = 1; //客户端版本號，clientVer = "."以前的數 * 100 + "."以後的，舉例：1.1版本的 clientVer 為1 * 100 + 1 = 101，2.21版本為2 * 100 + 21 = 221
    required string clientID = 2; //客户端唯一標識，無生具體生成規則，客户端自己保證唯一性即可
    optional bool recvNotify = 3; //此連接是否接收市場狀態、交易需要重新解鎖等等事件通知，true 代表接收，OpenD 就會向此連接推送這些通知，反之 false 代表不接收不推送
    //如果通信要加密，首先得在 OpenD 和客户端都配置 RSA 密鑰，不配置始終不加密
    //如果配置了 RSA 密鑰且指定的加密算法不為 PacketEncAlgo_None 則加密(即便這裏不設置，配置了 RSA 密鑰，也會採用默認加密方式)，默認採用 FTAES_ECB 算法
    optional int32 packetEncAlgo = 4; //指定包加密算法，參見 Common.PacketEncAlgo 的枚舉定義
    optional int32 pushProtoFmt = 5; //指定這條連接上的推送協議格式，若不指定則使用 push_proto_type 配置項
}

• 介紹

  可在初始化連線協議的 pushProtoFmt 欄位中，指定該連線的推送數據格式。 請求的數據格式，請參考協議頭 中的 nProtoFmtType 欄位。

對所有連接設置協議加密

• Python
• C#
• Java
• C++
• JavaScript
• 裸協議

enable_proto_encrypt(is_encrypt)

• 介紹

  數據加密　對所有連線的請求及回傳內容進行加密。如需了解協議的加密流程，請詳見這裡。

• 參數

  參數	類型	説明
  is_encrypt	bool	是否啟用加密

• Example

  from futu import *
  SysConfig.enable_proto_encrypt(is_encrypt = True)
  SysConfig.set_init_rsa_file("conn_key.txt")   # rsa 私鑰文件路徑
  quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
  quote_ctx.close()
  

• Example

  from moomoo import *
  SysConfig.enable_proto_encrypt(is_encrypt = True)
  SysConfig.set_init_rsa_file("conn_key.txt")   # rsa 私鑰文件路徑
  quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
  quote_ctx.close()
  

start(ip, port, ssl, key)

• 介紹

  初始化連線，連接並初始化

• 參數

  • ip: OpenD 監聽的 WebSocket 地址
  • port: OpenD 監聽的 WebSocket 端口
  • ssl: 是否啟用 SSL 加密，參見 WebSocket 相關
  • key：連線密鑰必須提供密鑰，否則連線會超時。密鑰可在 OpenD 內設定；如使用 UI 版本且未有指定，系統將會隨機產生

• Example

import ftWebSocket from "@/components/ft-websocket/main.js";
class Example {
    example() {
        this.websocket = new ftWebSocket();
        this.websocket.start("127.0.0.1", 33333, true, '123456');
    }
}

• 介紹

  初始化連線，連接並初始化

• 參數

  • ip: OpenD 監聽的 WebSocket 地址
  • port: OpenD 監聽的 WebSocket 端口
  • ssl: 是否啟用 SSL 加密，參見 WebSocket 相關
  • key：連接的密鑰，否則會連接超時，密鑰在在 OpenD 可配置，UI 版本在不指定的情況下會隨機指定

import mmWebSocket from "@/components/mm-websocket/main.js";
class Example {
    example() {
        this.websocket = new mmWebSocket();
        this.websocket.start("127.0.0.1", 33333, true, '123456');
    }
}

設置私鑰路徑

• Python
• C#
• Java
• C++
• JavaScript
• 裸協議

set_init_rsa_file(file)

• 介紹

  設置 RSA 私鑰文件路徑。如需瞭解協議加密流程，詳見 這裏。

• 參數

  參數	類型	説明
  file	str	私鑰文件路徑

• Example

from futu import *
SysConfig.enable_proto_encrypt(is_encrypt = True)
SysConfig.set_init_rsa_file("conn_key.txt")   # rsa 私鑰文件路徑
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
quote_ctx.close()

from moomoo import *
SysConfig.enable_proto_encrypt(is_encrypt = True)
SysConfig.set_init_rsa_file("conn_key.txt")   # rsa 私鑰文件路徑
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
quote_ctx.close()

void SetRSAPrivateKey(string key)

• 介紹

  設置私鑰

• 參數

  • key: 私鑰內容

• Example

public class Program : FTSPI_Qot, FTSPI_Conn {
    FTAPI_Qot qot = new FTAPI_Qot();

    public Program() {
        qot.SetClientInfo("csharp", 1);  //設置客户端信息
        qot.SetConnCallback(this);  //設置連接回調
        qot.SetQotCallback(this);   //設置交易回調
        qot.SetRSAPrivateKey(System.IO.File.ReadAllText(@"d:\rsa1024", Encoding.UTF8)); //設置 rsa 密鑰
    }

    public void Start() {
        qot.InitConnect("127.0.0.1", (ushort)11111, true); //連接加密
    }

    
    public void OnInitConnect(FTAPI_Conn client, long errCode, String desc)
    {
        Console.Write("Qot onInitConnect: ret={0} desc={1} connID={2}\n", errCode, desc, client.GetConnectID());
        if (errCode != 0)
            return;

        QotCommon.Security sec = QotCommon.Security.CreateBuilder()
                .SetMarket((int)QotCommon.QotMarket.QotMarket_HK_Security)
                .SetCode("00700")
                .Build();
        QotSub.C2S c2s = QotSub.C2S.CreateBuilder()
                .AddSecurityList(sec)
                .AddSubTypeList((int)QotCommon.SubType.SubType_Basic)
                .SetIsSubOrUnSub(true)
                .Build();
        QotSub.Request req = QotSub.Request.CreateBuilder().SetC2S(c2s).Build();
        uint seqNo = qot.Sub(req);
        Console.Write("Send QotSub: {0}\n", seqNo);
    }

    
    public void OnDisconnect(FTAPI_Conn client, long errCode) {
        Console.Write("Qot onDisConnect: {0}\n", errCode);
    }

    
    public void OnReply_Sub(FTAPI_Conn client, uint nSerialNo, QotSub.Response rsp) {
        Console.Write("Reply: QotSub: {0}  {1}\n", nSerialNo, rsp.ToString());
    }

    public static void Main(String[] args) {
        FTAPI.Init();
        Program qot = new Program();
        qot.Start();


        while (true)
            Thread.Sleep(1000 * 600);
    }
}

public class Program : MMSPI_Qot, MMSPI_Conn {
    MMAPI_Qot qot = new MMAPI_Qot();

    public Program() {
        qot.SetClientInfo("csharp", 1);  //設置客户端信息
        qot.SetConnCallback(this);  //設置連接回調
        qot.SetQotCallback(this);   //設置交易回調
        qot.SetRSAPrivateKey(System.IO.File.ReadAllText(@"d:\rsa1024", Encoding.UTF8)); //設置 rsa 密鑰
    }

    public void Start() {
        qot.InitConnect("127.0.0.1", (ushort)11111, true); //連接加密
    }

    
    public void OnInitConnect(MMAPI_Conn client, long errCode, String desc)
    {
        Console.Write("Qot onInitConnect: ret={0} desc={1} connID={2}\n", errCode, desc, client.GetConnectID());
        if (errCode != 0)
            return;

        QotCommon.Security sec = QotCommon.Security.CreateBuilder()
                .SetMarket((int)QotCommon.QotMarket.QotMarket_HK_Security)
                .SetCode("00700")
                .Build();
        QotSub.C2S c2s = QotSub.C2S.CreateBuilder()
                .AddSecurityList(sec)
                .AddSubTypeList((int)QotCommon.SubType.SubType_Basic)
                .SetIsSubOrUnSub(true)
                .Build();
        QotSub.Request req = QotSub.Request.CreateBuilder().SetC2S(c2s).Build();
        uint seqNo = qot.Sub(req);
        Console.Write("Send QotSub: {0}\n", seqNo);
    }

    
    public void OnDisconnect(MMAPI_Conn client, long errCode) {
        Console.Write("Qot onDisConnect: {0}\n", errCode);
    }

    
    public void OnReply_Sub(MMAPI_Conn client, uint nSerialNo, QotSub.Response rsp) {
        Console.Write("Reply: QotSub: {0}  {1}\n", nSerialNo, rsp.ToString());
    }

    public static void Main(String[] args) {
        MMAPI.Init();
        Program qot = new Program();
        qot.Start();


        while (true)
            Thread.Sleep(1000 * 600);
    }
}

• Output

Qot onInitConnect: ret=0 desc= connID=6827935070720340213
Send QotSub: 3
Reply: QotSub: 3  retType: 0
retMsg: ""
errCode: 0

void setRSAPrivateKey(String key)

• 介紹

  設置私鑰

• 參數

  • key: 私鑰內容

• Example

public class QotDemo implements FTSPI_Qot, FTSPI_Conn {
    FTAPI_Conn_Qot qot = new FTAPI_Conn_Qot();

    public QotDemo() {
        qot.setClientInfo("javaclient", 1);  //設置客户端信息
        qot.setConnSpi(this);  //設置連接回調
    }

    public void start() throws IOException {
        String rsaKey = "";
        byte[] buf = java.nio.file.Files.readAllBytes(Paths.get("c:\\rsa1024"));
        rsaKey = new String(buf, Charset.forName("UTF-8"));
        qot.setRSAPrivateKey(rsaKey);
    }

    public static void main(String[] args) throws IOException {
        FTAPI.init();
        QotDemo qot = new QotDemo();
        qot.start();

        while (true) {
            try {
                Thread.sleep(1000 * 600);
            } catch (InterruptedException exc) {

            }
        }
    }
}

• Example

public class QotDemo implements MMSPI_Qot, MMSPI_Conn {
    MMAPI_Conn_Qot qot = new MMAPI_Conn_Qot();

    public QotDemo() {
        qot.setClientInfo("javaclient", 1);  //設置客户端信息
        qot.setConnSpi(this);  //設置連接回調
    }

    public void start() throws IOException {
        String rsaKey = "";
        byte[] buf = java.nio.file.Files.readAllBytes(Paths.get("c:\\rsa1024"));
        rsaKey = new String(buf, Charset.forName("UTF-8"));
        qot.setRSAPrivateKey(rsaKey);
    }

    public static void main(String[] args) throws IOException {
        MMTAPI.init();
        QotDemo qot = new QotDemo();
        qot.start();

        while (true) {
            try {
                Thread.sleep(1000 * 600);
            } catch (InterruptedException exc) {

            }
        }
    }
}

void SetRSAPrivateKey(const char* szRSAPrivateKey);

• 介紹

  設置私鑰

• 參數

  • strRSAPrivateKey: 私鑰內容

• Example

string strKey;
ifstream file("key");
file >> strKey;
file.close();
FTAPI_Qot *m_pQotApi = FTAPI::CreateQotApi();
m_pQotApi->SetRSAPrivateKey(strKey.c_str());
m_pQotApi->InitConnect("127.0.0.1", 11111, true);
FTAPI::ReleaseQotApi(m_pQotApi);

string strKey;
ifstream file("key");
file >> strKey;
file.close();
MMAPI_Qot *m_pQotApi = MMAPI::CreateQotApi();
m_pQotApi->SetRSAPrivateKey(strKey.c_str());
m_pQotApi->InitConnect("127.0.0.1", 11111, true);
MMAPI::ReleaseQotApi(m_pQotApi);

start(ip, port, ssl, key)

• 介紹

  初始化連線，連接並初始化

• 參數

  • ip: OpenD 監聽的 WebSocket 地址
  • port: OpenD 監聽的 WebSocket 端口
  • ssl: 是否啟用 SSL 加密，參見 WebSocket 相關
  • key：連接的密鑰，否則會連接超時，密鑰在在 OpenD 可配置，UI 版本在不指定的情況下會隨機指定

• Example

import ftWebSocket from "@/components/ft-websocket/main.js";
class Example {
    example() {
        this.websocket = new ftWebSocket();
        this.websocket.start("127.0.0.1", 33333, true, '123456');
    }
}

• 參數

  • ip: OpenD 監聽的 WebSocket 地址
  • port: OpenD 監聽的 WebSocket 端口
  • ssl: 是否啟用 SSL 加密，參見 WebSocket 相關
  • key：連接的密鑰，否則會連接超時，密鑰在在 OpenD 可配置，UI 版本在不指定的情況下會隨機指定

• Example

import mmWebSocket from "@/components/mm-websocket/main.js";
class Example {
    example() {
        this.websocket = new mmWebSocket();
        this.websocket.start("127.0.0.1", 33333, true, '123456');
    }
}

InitConnect.proto

message C2S
{
        required int32 clientVer = 1; //客户端版本號，clientVer = "."以前的數 * 100 + "."以後的，舉例：1.1版本的 clientVer 為1 * 100 + 1 = 101，2.21版本為2 * 100 + 21 = 221
        required string clientID = 2; //客户端唯一標識，無生具體生成規則，客户端自己保證唯一性即可
        optional bool recvNotify = 3; //此連接是否接收市場狀態、交易需要重新解鎖等等事件通知，true 代表接收，OpenD 就會向此連接推送這些通知，反之 false 代表不接收不推送
        //如果通信要加密，首先得在 OpenD 和客户端都配置 RSA 密鑰，不配置始終不加密
        //如果配置了 RSA 密鑰且指定的加密算法不為 PacketEncAlgo_None 則加密(即便這裏不設置，配置了 RSA 密鑰，也會採用默認加密方式)，默認採用 FTAES_ECB 算法
        optional int32 packetEncAlgo = 4; //指定包加密算法，參見 Common.PacketEncAlgo 的枚舉定義
        optional int32 pushProtoFmt = 5; //指定這條連接上的推送協議格式，若不指定則使用 push_proto_type 配置項
}

InitConnect.proto

message C2S
{
        required int32 clientVer = 1; //客户端版本號，clientVer = "."以前的數 * 100 + "."以後的，舉例：1.1版本的 clientVer 為1 * 100 + 1 = 101，2.21版本為2 * 100 + 21 = 221
        required string clientID = 2; //客户端唯一標識，無生具體生成規則，客户端自己保證唯一性即可
        optional bool recvNotify = 3; //此連接是否接收市場狀態、交易需要重新解鎖等等事件通知，true 代表接收，OpenD 就會向此連接推送這些通知，反之 false 代表不接收不推送
        //如果通信要加密，首先得在 OpenD 和客户端都配置 RSA 密鑰，不配置始終不加密
        //如果配置了 RSA 密鑰且指定的加密算法不為 PacketEncAlgo_None 則加密(即便這裏不設置，配置了 RSA 密鑰，也會採用默認加密方式)，默認採用 FTAES_ECB 算法
        optional int32 packetEncAlgo = 4; //指定包加密算法，參見 Common.PacketEncAlgo 的枚舉定義
        optional int32 pushProtoFmt = 5; //指定這條連接上的推送協議格式，若不指定則使用 push_proto_type 配置項
}

• 介紹

  在初始化連線協議中 packetEncAlgo 字段指定該連接上加密算法。
  協議加密詳情，參見加密通信流程

設置線程模式

• Python
• C#
• Java
• C++
• JavaScript
• 裸協議

set_all_thread_daemon(all_daemon)

• 介紹

  執行緒 設定說明是否將所有內部建立的執行緒設定為背景執行緒：

  1. 若設定為背景執行緒：主執行緒結束後，整個程式也會隨之結束。 例如：使用實時回調 API 時，需自行確保主執行緒持續運作
  2. 若設定為非背景執行緒：主執行緒結束後，程式不會終止。 例如：建立行情或交易物件後，若未呼叫 close() 關閉連線...

• 參數

  參數	類型	説明
  all_daemon	bool	是否設置為 daemon 線程 True：設置為 daemon 線程 False：設置為非 daemon 線程 預設為 False

• Example

from futu import *
SysConfig.set_all_thread_daemon(True)
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
# 不調用 quote_ctx.close()，進程也會退出

from moomoo import *
SysConfig.set_all_thread_daemon(True)
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
# 不調用 quote_ctx.close()，進程也會退出

設置回調

• Python
• C#
• Java
• C++
• JavaScript
• 裸協議

set_handler(handler)

• 介紹

  設定非同步回調處理物件

• 參數

  • handler: 回調處理對象

    類	説明
    SysNotifyHandlerBase	OpenD 通知處理
    StockQuoteHandlerBase	報價處理
    OrderBookHandlerBase	買賣盤處理
    CurKlineHandlerBase	實時 K 線處理
    TickerHandlerBase	逐筆交易處理
    RTDataHandlerBase	分時數據處理
    BrokerHandlerBase	經紀排位處理
    PriceReminderHandlerBase	到價提醒處理
    TradeOrderHandlerBase	訂單處理
    TradeDealHandlerBase	成交處理

• Example

import time
from futu import *
class OrderBookTest(OrderBookHandlerBase):
    def on_recv_rsp(self, rsp_str):
        ret_code, data = super(OrderBookTest,self).on_recv_rsp(rsp_str)
        if ret_code != RET_OK:
            print("OrderBookTest: error, msg: %s" % data)
            return RET_ERROR, data
        print("OrderBookTest ", data) # OrderBookTest 自己的處理邏輯
        return RET_OK, data
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
handler = OrderBookTest()
quote_ctx.set_handler(handler)  # 設置實時擺盤迴調
quote_ctx.subscribe(['HK.00700'], [SubType.ORDER_BOOK])  # 訂閲買賣擺盤類型，OpenD 開始持續收到服務器的推送
time.sleep(15)  #  設置腳本接收 OpenD 的推送持續時間為15秒
quote_ctx.close()  # 關閉當條連接，OpenD 會在1分鐘後自動取消相應股票相應類型的訂閲

import time
from moomoo import *
class OrderBookTest(OrderBookHandlerBase):
    def on_recv_rsp(self, rsp_str):
        ret_code, data = super(OrderBookTest,self).on_recv_rsp(rsp_str)
        if ret_code != RET_OK:
            print("OrderBookTest: error, msg: %s" % data)
            return RET_ERROR, data
        print("OrderBookTest ", data) # OrderBookTest 自己的處理邏輯
        return RET_OK, data
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
handler = OrderBookTest()
quote_ctx.set_handler(handler)  # 設置實時擺盤迴調
quote_ctx.subscribe(['HK.00700'], [SubType.ORDER_BOOK])  # 訂閲買賣擺盤類型，OpenD 開始持續收到服務器的推送
time.sleep(15)  #  設置腳本接收 OpenD 的推送持續時間為15秒
quote_ctx.close()  # 關閉當條連接，OpenD 會在1分鐘後自動取消相應股票相應類型的訂閲

void SetConnCallback(FTSPI_Conn connCallback)
void SetQotCallback(FTSPI_Qot callback)
void SetTrdCallback(FTSPI_Trd callback)

void SetConnCallback(MMSPI_Conn connCallback)
void SetQotCallback(MMSPI_Qot callback)
void SetTrdCallback(MMSPI_Trd callback)

• 介紹

  設置回調

• 參數

  • callback: 回調函數

• Example

public class Program : FTSPI_Qot, FTSPI_Conn
    {
        FTAPI_Qot qot = new FTAPI_Qot();

        public Program()
        {
            qot.SetClientInfo("csharp", 1);  //設置客户端信息
            qot.SetConnCallback(this);  //設置連接回調
            qot.SetQotCallback(this);   //設置交易回調
        }

        public void Start()
        {
            qot.InitConnect("127.0.0.1", (ushort)11111, false); //連接加密
        }


        public void OnInitConnect(FTAPI_Conn client, long errCode, String desc)
        {
            Console.Write("Qot onInitConnect: ret={0} desc={1} connID={2}\n", errCode, desc, client.GetConnectID());
            if (errCode != 0)
                return;
        }


        public void OnDisconnect(FTAPI_Conn client, long errCode)
        {
            Console.Write("Qot onDisConnect: {0}\n", errCode);
        }


        public static void Main(String[] args)
        {
            FTAPI.Init();
            Program qot = new Program();
            qot.Start();


            while (true)
                Thread.Sleep(1000 * 600);
        }
    }

public class Program : MMSPI_Qot, MMSPI_Conn
    {
        MMAPI_Qot qot = new MMAPI_Qot();

        public Program()
        {
            qot.SetClientInfo("csharp", 1);  //設置客户端信息
            qot.SetConnCallback(this);  //設置連接回調
            qot.SetQotCallback(this);   //設置交易回調
        }

        public void Start()
        {
            qot.InitConnect("127.0.0.1", (ushort)11111, false); //連接加密
        }


        public void OnInitConnect(MMAPI_Conn client, long errCode, String desc)
        {
            Console.Write("Qot onInitConnect: ret={0} desc={1} connID={2}\n", errCode, desc, client.GetConnectID());
            if (errCode != 0)
                return;
        }


        public void OnDisconnect(MMAPI_Conn client, long errCode)
        {
            Console.Write("Qot onDisConnect: {0}\n", errCode);
        }


        public static void Main(String[] args)
        {
            MMAPI.Init();
            Program qot = new Program();
            qot.Start();


            while (true)
                Thread.Sleep(1000 * 600);
        }
    }

• Output

Qot onInitConnect: ret=0 desc= connID=6827937191858660334

setConnSpi(FTSPI_Conn callback);
void setQotSpi(FTSPI_Qot callback);
void setTrdSpi(FTSPI_Trd callback);

setConnSpi(MMSPI_Conn callback);
void setQotSpi(MMSPI_Qot callback);
void setTrdSpi(MMSPI_Trd callback);

• 介紹

  設置回調

• 參數

  • callback: 回調函數

• Example

public class QotDemo implements FTSPI_Qot, FTSPI_Conn {
    FTAPI_Conn_Qot qot = new FTAPI_Conn_Qot();

    public QotDemo() {
        qot.setClientInfo("javaclient", 1);  //設置客户端信息
        qot.setConnSpi(this);  //設置連接回調
        qot.setQotSpi(this);   //設置行情回調
    }

    public void start() throws IOException {
        qot.initConnect("127.0.0.1", (short)11111, false);
    }

    @Override
    public void onInitConnect(FTAPI_Conn client, long errCode, String desc)
    {
        System.out.printf("Qot onInitConnect: ret=%b desc=%s connID=%d\n", errCode, desc, client.getConnectID());
    }

    @Override
    public void onDisconnect(FTAPI_Conn client, long errCode) {
        System.out.printf("Qot onDisConnect: %d\n", errCode);
    }

    public static void main(String[] args) throws IOException {
        FTAPI.init();
        QotDemo qot = new QotDemo();
        qot.start();

        while (true) {
            try {
                Thread.sleep(1000 * 600);
            } catch (InterruptedException exc) {

            }
        }
    }
}

• Example

public class QotDemo implements MMSPI_Qot, MMSPI_Conn {
    MMAPI_Conn_Qot qot = new MMAPI_Conn_Qot();

    public QotDemo() {
        qot.setClientInfo("javaclient", 1);  //設置客户端信息
        qot.setConnSpi(this);  //設置連接回調
        qot.setQotSpi(this);   //設置行情回調
    }

    public void start() throws IOException {
        qot.initConnect("127.0.0.1", (short)11111, false);
    }

    @Override
    public void onInitConnect(MMAPI_Conn client, long errCode, String desc)
    {
        System.out.printf("Qot onInitConnect: ret=%b desc=%s connID=%d\n", errCode, desc, client.getConnectID());
    }

    @Override
    public void onDisconnect(MMAPI_Conn client, long errCode) {
        System.out.printf("Qot onDisConnect: %d\n", errCode);
    }

    public static void main(String[] args) throws IOException {
        MMAPI.init();
        QotDemo qot = new QotDemo();
        qot.start();

        while (true) {
            try {
                Thread.sleep(1000 * 600);
            } catch (InterruptedException exc) {

            }
        }
    }
}

void RegisterConnSpi(FTSPI_Qot* pSpi);
void RegisterQotSpi(FTSPI_Qot* pSpi);
void RegisterTrdSpi(FTSPI_Qot* pSpi);

void RegisterConnSpi(MMSPI_Qot* pSpi);
void RegisterQotSpi(MMSPI_Qot* pSpi);
void RegisterTrdSpi(MMSPI_Qot* pSpi);

• 介紹

  設置回調

• 參數

  • pSpi: 回調函數

• Example

FTAPI_Qot *m_pQotApi = FTAPI::CreateQotApi();
m_pQotApi->InitConnect("127.0.0.1", 11111, false);
m_pQotApi->RegisterQotSpi(this);
m_pQotApi->RegisterConnSpi(this);
FTAPI::ReleaseQotApi(m_pQotApi);

MMAPI_Qot *m_pQotApi = MMAPI::CreateQotApi();
m_pQotApi->InitConnect("127.0.0.1", 11111, false);
m_pQotApi->RegisterQotSpi(this);
m_pQotApi->RegisterConnSpi(this);
MMAPI::ReleaseQotApi(m_pQotApi);

onPush(cmd, res)
onlogin(ret, msg)

• 介紹

  登錄回調以及推送回調

• 返回

  • cmd: 推送協議 ID
  • res: 推送協議內容
  • ret: 是否成功初始化
  • msg: 失敗描述

• Example

import ftWebSocket from "@/components/ft-websocket/main.js";
class Example {
    example() {
        this.websocket = new ftWebSocket();
        this.websocket.start("127.0.0.1", 33333, false, null);
        this.websocket.onPush = this.onPush.bind(this);
        this.websocket.onlogin = this.onLogin.bind(this);
    },
    onPush(cmd, res) {
    const obj = ftWebSocket.findCmdObj(cmd);
        if (obj && obj.description) {
            console.log(res);
        }
    },
    onLogin(ret, msg) {
        if (ret) {
            console.log(this.websocket.getConnID());
        }
    }
}

• Example

import mmWebSocket from "@/components/mm-websocket/main.js";
class Example {
    example() {
        this.websocket = new mmWebSocket();
        this.websocket.start("127.0.0.1", 33333, false, null);
        this.websocket.onPush = this.onPush.bind(this);
        this.websocket.onlogin = this.onLogin.bind(this);
    },
    onPush(cmd, res) {
    const obj = mmWebSocket.findCmdObj(cmd);
        if (obj && obj.description) {
            console.log(res);
        }
    },
    onLogin(ret, msg) {
        if (ret) {
            console.log(this.websocket.getConnID());
        }
    }
}

獲取連接 ID

• Python
• C#
• Java
• C++
• JavaScript
• 裸協議

get_sync_conn_id()

• 介紹

  取得連線 ID，連線成功初始化後才會產生數值

• 返回

  • conn_id: 連接 ID

• Example

from futu import *
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
quote_ctx.get_sync_conn_id()
quote_ctx.close() # 結束後記得關閉當條連接，防止連接條數用盡

• Example

from moomoo import *
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
quote_ctx.get_sync_conn_id()
quote_ctx.close() # 結束後記得關閉當條連接，防止連接條數用盡

uint GetConnectID();

• 介紹

  取得連線 ID，連線成功初始化後才會產生數值

• 返回

  • connID: 連接 ID

• Example

public class Program : FTSPI_Qot, FTSPI_Conn
    {
        FTAPI_Qot qot = new FTAPI_Qot();

        public Program()
        {
            qot.SetClientInfo("csharp", 1);  //設置客户端信息
            qot.SetConnCallback(this);  //設置連接回調
            qot.SetQotCallback(this);   //設置交易回調
        }

        public void Start()
        {
            qot.InitConnect("127.0.0.1", (ushort)11111, false); //連接加密
        }


        public void OnInitConnect(FTAPI_Conn client, long errCode, String desc)
        {
            Console.Write("Qot onInitConnect: ret={0} desc={1} connID={2}\n", errCode, desc, client.GetConnectID());
            if (errCode != 0)
                return;
        }


        public void OnDisconnect(FTAPI_Conn client, long errCode)
        {
            Console.Write("Qot onDisConnect: {0}\n", errCode);
        }

        public static void Main(String[] args)
        {
            FTAPI.Init();
            Program qot = new Program();
            qot.Start();


            while (true)
                Thread.Sleep(1000 * 600);
        }
    }

• Example

public class Program : MMSPI_Qot, MMSPI_Conn
    {
        MMAPI_Qot qot = new MMAPI_Qot();

        public Program()
        {
            qot.SetClientInfo("csharp", 1);  //設置客户端信息
            qot.SetConnCallback(this);  //設置連接回調
            qot.SetQotCallback(this);   //設置交易回調
        }

        public void Start()
        {
            qot.InitConnect("127.0.0.1", (ushort)11111, false); //連接加密
        }


        public void OnInitConnect(MMAPI_Conn client, long errCode, String desc)
        {
            Console.Write("Qot onInitConnect: ret={0} desc={1} connID={2}\n", errCode, desc, client.GetConnectID());
            if (errCode != 0)
                return;
        }


        public void OnDisconnect(MMAPI_Conn client, long errCode)
        {
            Console.Write("Qot onDisConnect: {0}\n", errCode);
        }

        public static void Main(String[] args)
        {
            MMAPI.Init();
            Program qot = new Program();
            qot.Start();


            while (true)
                Thread.Sleep(1000 * 600);
        }
    }

• Output

Qot onInitConnect: ret=0 desc= connID=6827937791149892052

long getConnectID();

• 介紹

  取得連線 ID，連線成功初始化後才會產生數值

• 返回

  • connID: 連接 ID

• Example

public class QotDemo implements FTSPI_Qot, FTSPI_Conn {
    FTAPI_Conn_Qot qot = new FTAPI_Conn_Qot();

    public QotDemo() {
        qot.setClientInfo("javaclient", 1);  //設置客户端信息
        qot.setConnSpi(this);  //設置連接回調
        qot.setQotSpi(this);   //設置行情回調
    }

    public void start() throws IOException {
        qot.initConnect("127.0.0.1", (short)11111, false);
    }

    @Override
    public void onInitConnect(FTAPI_Conn client, long errCode, String desc)
    {
        System.out.printf("Qot onInitConnect: ret=%b desc=%s connID=%d\n", errCode, desc, client.getConnectID());
    }

    @Override
    public void onDisconnect(FTAPI_Conn client, long errCode) {
        System.out.printf("Qot onDisConnect: %d\n", errCode);
    }

    public static void main(String[] args) throws IOException {
        FTAPI.init();
        QotDemo qot = new QotDemo();
        qot.start();

        while (true) {
            try {
                Thread.sleep(1000 * 60);
            } catch (InterruptedException exc) {

            }
        }
    }
}

• Example

public class QotDemo implements MMSPI_Qot, MMSPI_Conn {
    MMAPI_Conn_Qot qot = new MMAPI_Conn_Qot();

    public QotDemo() {
        qot.setClientInfo("javaclient", 1);  //設置客户端信息
        qot.setConnSpi(this);  //設置連接回調
        qot.setQotSpi(this);   //設置行情回調
    }

    public void start() throws IOException {
        qot.initConnect("127.0.0.1", (short)11111, false);
    }

    @Override
    public void onInitConnect(MMAPI_Conn client, long errCode, String desc)
    {
        System.out.printf("Qot onInitConnect: ret=%b desc=%s connID=%d\n", errCode, desc, client.getConnectID());
    }

    @Override
    public void onDisconnect(MMAPI_Conn client, long errCode) {
        System.out.printf("Qot onDisConnect: %d\n", errCode);
    }

    public static void main(String[] args) throws IOException {
        MMAPI.init();
        QotDemo qot = new QotDemo();
        qot.start();

        while (true) {
            try {
                Thread.sleep(1000 * 60);
            } catch (InterruptedException exc) {

            }
        }
    }
}

Futu::u64_t GetConnectID()

• 介紹

  取得連線 ID，連線成功初始化後才會產生數值

• 返回

  • nConnID: 連接 ID

• Example

FTAPI_Qot *m_pQotApi = FTAPI::CreateQotApi();
m_pQotApi->InitConnect("127.0.0.1", 11111, false);
m_pQotApi->GetConnectID();
FTAPI::ReleaseQotApi(m_pQotApi);

moomoo::u64_t GetConnectID()

• 介紹

  取得連線 ID，連線成功初始化後才會產生數值

• 返回

  • nConnID: 連接 ID

MMAPI_Qot *m_pQotApi = MMAPI::CreateQotApi();
m_pQotApi->InitConnect("127.0.0.1", 11111, false);
m_pQotApi->GetConnectID();
MMAPI::ReleaseQotApi(m_pQotApi);

getConnID()

• 介紹

  取得連線 ID，連線成功初始化後才會產生數值

• 返回

  • connID: 連接 ID

• Example

import ftWebSocket from "@/components/ft-websocket/main.js";
class Example {
    example() {
        this.websocket = new ftWebSocket();
        this.websocket.start("127.0.0.1", 33333, false, null);
        this.websocket.onlogin = this.onLogin.bind(this);
    },
    onLogin(ret, msg) {
    if (ret) {
        this.websocket.getConnID();
    }
}

import mmWebSocket from "@/components/mm-websocket/main.js";
class Example {
    example() {
        this.websocket = new mmWebSocket();
        this.websocket.start("127.0.0.1", 33333, false, null);
        this.websocket.onlogin = this.onLogin.bind(this);
    },
    onLogin(ret, msg) {
    if (ret) {
        this.websocket.getConnID();
    }
}

InitConnect.proto

message S2C
{
	required int32 serverVer = 1; //OpenD 的版本號
	required uint64 loginUserID = 2; //OpenD 登錄的用户 ID
	required uint64 connID = 3; //此連接的連接 ID，連接的唯一標識
	required string connAESKey = 4; //此連接後續 AES 加密通信的 Key，固定為16字節長字符串
	required int32 keepAliveInterval = 5; //心跳保活間隔
	optional string aesCBCiv = 6; //AES 加密通信 CBC 加密模式的 iv，固定為16字節長字符串
}

• 介紹

  即 InitConnect 協議回傳資料中的 connID 欄位

事件通知回調

• Python
• C#
• Java
• C++
• JavaScript
• 裸協議

SysNotifyHandlerBase

• 介紹

  系統通知 通知 OpenD 重要訊息（例如連線中斷等）。

• 協議 ID

  1003

• 返回

  參數	類型	説明
  ret	RET_CODE	接口調用結果
  data	tuple	當 ret == RET_OK 時，返回 事件通知數據
  	str	當 ret != RET_OK，返回錯誤描述

  • 事件通知數據 的格式如下：

    
    

    參數	類型	説明
    notify_type	SysNotifyType	通知類型
    sub_type	ProgramStatusType	子類型。當 notify_type == SysNotifyType.PROGRAM_STATUS 時，sub_type 返回程式狀態類型
    	GtwEventType	子類型。當 notify_type == SysNotifyType.GTW_EVENT 時，sub_type 返回 OpenD 事件通知類型
    	0	當 notify_type != SysNotifyType.PROGRAM_STATUS 且 notify_type != SysNotifyType.GTW_EVENT 時，sub_type 返回 0
    msg	dict	事件資訊。當 notify_type == SysNotifyType.CONN_STATUS 時，msg 返回 連接狀態事件資訊 字典
    		事件資訊。當 notify_type == SysNotifyType.QOT_RIGHT 時，msg 返回 行情權限事件資訊 字典

    • 連接狀態事件資訊 字典結構如下（連接狀態類型為 bool，True 表示連接正常，False 表示連接斷開）:

      {
          'qot_logined': bool1, 
          'trd_logined': bool2,
      }
      

    • 行情權限事件資訊 字典結構如下（點擊瞭解 行情權限）:

      {
          'hk_qot_right': value1,
          'hk_option_qot_right': value2,
          'hk_future_qot_right': value3,
          'us_qot_right': value4,
          'us_option_qot_right': value5,
          'us_future_qot_right': value6,  // 已廢棄
          'cn_qot_right': value7,
      	'us_index_qot_right': value8,
      	'us_otc_qot_right': value9,
      	'sg_future_qot_right': value10,
      	'jp_future_qot_right': value11,
      	'us_future_qot_right_cme': value12,
      	'us_future_qot_right_cbot': value13,
      	'us_future_qot_right_nymex': value14,
      	'us_future_qot_right_comex': value15,
      	'us_future_qot_right_cboe': value16,
      }
      

• Example

import time
from futu import *


class SysNotifyTest(SysNotifyHandlerBase):
    def on_recv_rsp(self, rsp_str):
        ret_code, data = super(SysNotifyTest, self).on_recv_rsp(rsp_str)
        notify_type, sub_type, msg = data
        if ret_code != RET_OK:
            logger.debug("SysNotifyTest: error, msg: {}".format(msg))
            return RET_ERROR, data
        if notify_type == SysNotifyType.GTW_EVENT:  # OpenD 事件通知
            print("GTW_EVENT, type: {} msg: {}".format(sub_type, msg))
        elif notify_type == SysNotifyType.PROGRAM_STATUS:  # 程序狀態變化通知
            print("PROGRAM_STATUS, type: {} msg: {}".format(sub_type, msg))
        elif notify_type == SysNotifyType.CONN_STATUS:  ## 連接狀態變化通知
            print("CONN_STATUS, qot: {}".format(msg['qot_logined']))
            print("CONN_STATUS, trd: {}".format(msg['trd_logined']))
        elif notify_type == SysNotifyType.QOT_RIGHT:  # 行情權限變化通知
            print("QOT_RIGHT, hk: {}".format(msg['hk_qot_right']))
            print("QOT_RIGHT, hk_option: {}".format(msg['hk_option_qot_right']))
            print("QOT_RIGHT, hk_future: {}".format(msg['hk_future_qot_right']))
            print("QOT_RIGHT, us: {}".format(msg['us_qot_right']))
            print("QOT_RIGHT, us_option: {}".format(msg['us_option_qot_right']))
            print("QOT_RIGHT, cn: {}".format(msg['cn_qot_right']))
			print("QOT_RIGHT, us_index: {}".format(msg['us_index_qot_right']))
			print("QOT_RIGHT, us_otc: {}".format(msg['us_otc_qot_right']))
			print("QOT_RIGHT, sg_future: {}".format(msg['sg_future_qot_right']))
			print("QOT_RIGHT, jp_future: {}".format(msg['jp_future_qot_right']))
            print("QOT_RIGHT, us_future_cme: {}".format(msg['us_future_qot_right_cme']))
            print("QOT_RIGHT, us_future_cbot: {}".format(msg['us_future_qot_right_cbot']))
            print("QOT_RIGHT, us_future_nymex: {}".format(msg['us_future_qot_right_nymex']))
            print("QOT_RIGHT, us_future_comex: {}".format(msg['us_future_qot_right_comex']))
            print("QOT_RIGHT, us_future_cboe: {}".format(msg['us_future_qot_right_cboe']))
        return RET_OK, data


quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
handler = SysNotifyTest()
quote_ctx.set_handler(handler)  # 設置回調
time.sleep(15)  # 設置腳本接收 OpenD 的推送持續時間為15秒
quote_ctx.close()  # 結束後記得關閉當條連接，防止連接條數用盡`

• Example

import time
from moomoo import *


class SysNotifyTest(SysNotifyHandlerBase):
    def on_recv_rsp(self, rsp_str):
        ret_code, data = super(SysNotifyTest, self).on_recv_rsp(rsp_str)
        notify_type, sub_type, msg = data
        if ret_code != RET_OK:
            logger.debug("SysNotifyTest: error, msg: {}".format(msg))
            return RET_ERROR, data
        if notify_type == SysNotifyType.GTW_EVENT:  # OpenD 事件通知
            print("GTW_EVENT, type: {} msg: {}".format(sub_type, msg))
        elif notify_type == SysNotifyType.PROGRAM_STATUS:  # 程序狀態變化通知
            print("PROGRAM_STATUS, type: {} msg: {}".format(sub_type, msg))
        elif notify_type == SysNotifyType.CONN_STATUS:  ## 連接狀態變化通知
            print("CONN_STATUS, qot: {}".format(msg['qot_logined']))
            print("CONN_STATUS, trd: {}".format(msg['trd_logined']))
        elif notify_type == SysNotifyType.QOT_RIGHT:  # 行情權限變化通知
            print("QOT_RIGHT, hk: {}".format(msg['hk_qot_right']))
            print("QOT_RIGHT, hk_option: {}".format(msg['hk_option_qot_right']))
            print("QOT_RIGHT, hk_future: {}".format(msg['hk_future_qot_right']))
            print("QOT_RIGHT, us: {}".format(msg['us_qot_right']))
            print("QOT_RIGHT, us_option: {}".format(msg['us_option_qot_right']))
            print("QOT_RIGHT, cn: {}".format(msg['cn_qot_right']))
			print("QOT_RIGHT, us_index: {}".format(msg['us_index_qot_right']))
			print("QOT_RIGHT, us_otc: {}".format(msg['us_otc_qot_right']))
			print("QOT_RIGHT, sg_future: {}".format(msg['sg_future_qot_right']))
			print("QOT_RIGHT, jp_future: {}".format(msg['jp_future_qot_right']))
            print("QOT_RIGHT, us_future_cme: {}".format(msg['us_future_qot_right_cme']))
            print("QOT_RIGHT, us_future_cbot: {}".format(msg['us_future_qot_right_cbot']))
            print("QOT_RIGHT, us_future_nymex: {}".format(msg['us_future_qot_right_nymex']))
            print("QOT_RIGHT, us_future_comex: {}".format(msg['us_future_qot_right_comex']))
            print("QOT_RIGHT, us_future_cboe: {}".format(msg['us_future_qot_right_cboe']))
        return RET_OK, data


quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
handler = SysNotifyTest()
quote_ctx.set_handler(handler)  # 設置回調
time.sleep(15)  # 設置腳本接收 OpenD 的推送持續時間為15秒
quote_ctx.close()  # 結束後記得關閉當條連接，防止連接條數用盡`

void OnReply_Notify(FTAPI_Conn client, uint nSerialNo, Notify.Response rsp)

void OnReply_Notify(MMAPI_Conn client, uint nSerialNo, Notify.Response rsp)

• 介紹

  系統通知 通知 OpenD 重要訊息（例如連線中斷等）。

void onPush_Notify(FTAPI_Conn client, Notify.Response rsp)

void onPush_Notify(MMAPI_Conn client, Notify.Response rsp)

• 介紹

  系統通知 通知 OpenD 重要訊息（例如連線中斷等）。

virtual void OnPush_Notify(const Notify::Response &stRsp) = 0;

• 介紹

  系統通知 通知 OpenD 重要訊息（例如連線中斷等）。

onPush(cmd, res)

• 介紹

  系統通知 通知 OpenD 重要訊息（例如連線中斷等）。

• Example

import ftWebSocket from "@/components/ft-websocket/main.js";
class Example {
    example() {
        this.websocket = new ftWebSocket();
        this.websocket.start("127.0.0.1", 33333, false, null);
        this.websocket.onPush = this.onPush.bind(this);
        this.websocket.onlogin = this.onLogin.bind(this);
    },
    onPush(cmd, res) {
    const obj = ftWebSocket.findCmdObj(cmd);
        if (obj && obj.description && cmd == 1003) {
            console.log(res);
        }
    },
    onLogin(ret, msg) {
        if (ret) {
            console.log(this.websocket.getConnID());
        }
    }
}

• Example

import mmWebSocket from "@/components/mm-websocket/main.js";
class Example {
    example() {
        this.websocket = new mmWebSocket();
        this.websocket.start("127.0.0.1", 33333, false, null);
        this.websocket.onPush = this.onPush.bind(this);
        this.websocket.onlogin = this.onLogin.bind(this);
    },
    onPush(cmd, res) {
    const obj = mmWebSocket.findCmdObj(cmd);
        if (obj && obj.description && cmd == 1003) {
            console.log(res);
        }
    },
    onLogin(ret, msg) {
        if (ret) {
            console.log(this.websocket.getConnID());
        }
    }
}

Notify.proto

message S2C
{
	required int32 type = 1; //通知類型
	optional GtwEvent event = 2; //事件通息
	optional ProgramStatus programStatus = 3; //程序狀態
	optional ConnectStatus connectStatus = 4; //連接狀態
	optional QotRight qotRight = 5; //行情權限
	optional APILevel apiLevel = 6; //用户等級，已在2.10版本之後廢棄
	optional APIQuota apiQuota = 7; //API 額度
}

message Response
{
	required int32 retType = 1 [default = -400]; //RetType,返回結果
	optional string retMsg = 2;
	optional int32 errCode = 3;
	
	optional S2C s2c = 4;
}