基本機能

• 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呼び出し情報の設定。任意呼び出しAPI

• パラメータ

  • client_id: クライアントの識別子
  • client_ver: クライアントのバージョン番号

• 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呼び出し情報の設定。任意呼び出しAPI

• パラメータ

  • clientID: クライアントの識別子
  • clientVer: クライアントのバージョン番号

• 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呼び出し情報の設定。任意呼び出しAPI

• パラメータ

  • clientID: クライアントの識別子
  • clientVer: クライアントのバージョン番号

• 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呼び出し情報の設定。任意呼び出しAPI

• パラメータ

  • szClientID: クライアントの識別子
  • nClientVer: クライアントのバージョン番号

• 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呼び出し情報の設定。任意呼び出しAPI

• パラメータ

  • szClientID: クライアントの識別子
  • nClientVer: クライアントのバージョン番号

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 の2形式をサポート。デフォルトは ProtoBuf。任意呼び出しAPI

• パラメータ

  • 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)

• 概要

  内部で作成されるすべてのスレッドを daemon スレッドに設定するかどうか。

  • daemon スレッドに設定した場合：メインスレッド終了後、プロセスも終了します。
    例：リアルタイムコールバックAPIを使用する場合、メインスレッドの存続を自分で保証する必要があります。メインスレッド終了後はプロセスも終了し、プッシュデータを受信できなくなります。
  • 非 daemon スレッドに設定した場合：メインスレッド終了後も、プロセスは終了しません。
    例：相場または取引オブジェクト作成後、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	リアルタイムローソク足処理基底クラス
    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	API呼び出し結果
  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());
        }
    }
}

</template>
</FtDocSwitcher>
</template>
</FtSwitcher>

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;
}