跳至主要內容

XTP行情服务接入前指引

xtp_master大约 35 分钟

XTP行情服务接入前指引

一、XTP行情接入要点概述

  1. XQuote是XTP自主开发的行情解码、数据推送的服务器。
  2. 支持的行情源包括SHL1,SHL2,SZL1,SZL2行情及北交所行情。
  3. 用户可以通过API获取股票、基金、债券、指数、期权行情。
  4. 目前XQuote只提供实时行情,不提供历史行情。
  5. 行情推送方式有两种:TCP推送和UDP(组播)推送(生产环境使用UDP推送)。
  6. 推送的数据包括:行情快照、买一卖一委托队列、逐笔、订单薄。
  7. XQuote提供按市场订阅和按股票代码订阅两种模式。
  8. 因为实盘的数据量,比公网测试环境的数据量大得多,所以用户在接入实盘前,一定要在实盘上做接入测试。
  9. 接入前请下载最新的API,网址为https://xtp.zts.com.cn/service/download/info?id=1&type=downloadProducts 请勿下载1.1.14.x版本的API,该版本不能用来登陆行情服务器。

二、基础操作

1、登陆


(1)API使用Login函数进行登陆。Login函数的sock_type参数,决定了API 接收更新数据的方式。请务必与行情服务器一致,否则会收不到行情更新数据。
///用户登录请求
///@return 登录是否成功,“0”表示登录成功,“-1”表示连接服务器出错,此时用户可以调用GetApiLastError()来获取错误代码,“-2”表示已存在连接,不允许重复登录,如果需要重连,请先logout,“-3”表示输入有错误
///@param ip 服务器ip地址,类似“127.0.0.1”
///@param port 服务器端口号
///@param user 登陆用户名
///@param password 登陆密码
///@param sock_type “1”代表TCP,“2”代表UDP
///@param local_ip 本地网卡地址,类似“127.0.0.1”
///@remark 此函数为同步阻塞式,不需要异步等待登录成功,当函数返回即可进行后续操作,此api只能有一个连接
virtual int Login(const char* ip, int port, const char* user, const char* password, XTP_PROTOCOL_TYPE sock_type, const char* local_ip = NULL) = 0;

(2)API日志级别
///创建QuoteApi
///@param client_id (必须输入)用于区分同一用户的不同客户端,由用户自定义
///@param save_file_path (必须输入)存贮订阅信息文件的目录,请设定一个有可写权限的真实存在的路径,如果路径不存在的话,可能会因为写冲突而造成断线
///@param log_level 日志输出级别
///@return 创建出的UserApi
///@remark 如果一个账户需要在多个客户端登录,请使用不同的client_id,系统允许一个账户同时登录多个客户端,但是对于同一账户,相同的client_id只能保持一个session连接,后面的登录在前一个session存续期间,无法连接
static QuoteApi *CreateQuoteApi(uint8_t client_id, const char *save_file_path, XTP_LOG_LEVEL log_level=XTP_LOG_LEVEL_DEBUG);

可以通过CreateQuoteApi的log_level参数来调整API的日志级别,默认为DEBUG。但DEBUG级别的日志会非常多,请慎重使用。


(3)一个账号在多个客户端登陆

XTP的行情是允许一个账号在多个客户端同时登陆的。只需要将CreateQuoteApi的第client_id参数设置为不同的值即可。

2、查询


(1)查询可交易合约信息
///获取当前交易日合约部分静态信息
///@return 发送查询请求是否成功,“0”表示发送查询请求成功,非“0”表示发送查询请求不成功
///@param exchange_id 交易所代码,必须提供 1-上海 2-深圳
virtual int QueryAllTickers(XTP_EXCHANGE_TYPE exchange_id) = 0;
///查询合约部分静态信息的应答
///@param ticker_info 合约部分静态信息
///@param error_info 查询合约部分静态信息时发生错误时返回的错误信息,当error_info为空,或者error_info.error_id为0时,表明没有错误
///@param is_last 是否此次查询合约部分静态信息的最后一个应答,当为最后一个的时候为true,如果为false,表示还有其他后续消息响应
virtual void OnQueryAllTickers(XTPQSI* ticker_info, XTPRI *error_info, bool is_last) {};

调用QueryAllTickers,查询对应市场可交易合约(股票/基金/债券/期权)基本信息。
行情服务器内部对从数据库查询的到ticker进行过滤,过滤条件为(trade_status=0),所以该接口,查询不到指数的信息。
当行情服务器返回数据时,OnQueryAllTickers函数被调用(异步接口)。
注意:目前(2018-12)生产环境,把停牌股票的trade_status配置成了0,即该接口也返回停牌股票。

返回的数据类型列表:

返回类型含义备注
XTP_TICKER_TYPE_STOCK(0)股票主板/中小板/创业板
XTP_TICKER_TYPE_TECH_STOCK(5)科创版科创版(上海)
XTP_TICKER_TYPE_BOND(3)债券国债/企业债/公司债/转换债券/国债逆回购
XTP_TICKER_TYPE_FUND(2)基金ETF/分级基金子基金/深交所仅申赎基金/上交所货币基金/深交所货币基金
XTP_TICKER_TYPE_OPTION(4)期权个股期权/ETF期权
XTP_TICKER_TYPE_UNKNOWN(6)客户应该过滤掉返回类型为6的ticker
XTP_TICKER_TYPE_INDEX(1)指数本接口不返回指数

(2)查询最新价接口
///获取合约的最新价格信息
///@return 发送查询请求是否成功,“0”表示发送查询请求成功,非“0”表示发送查询请求不成功
///@param ticker 合约ID数组,注意合约代码必须以'\0'结尾,不包含空格  
///@param count 要查询的合约个数
///@param exchange_id 交易所代码
virtual int QueryTickersPriceInfo(char *ticker[], int count, XTP_EXCHANGE_TYPE exchange_id) = 0;
///获取所有合约的最新价格信息
///@return 发送查询请求是否成功,“0”表示发送查询请求成功,非“0”表示发送查询请求不成功
virtual int QueryAllTickersPriceInfo() = 0;
///查询合约的最新价格信息应答
///@param ticker_info 合约的最新价格信息
///@param error_info 查询合约的最新价格信息时发生错误时返回的错误信息,当error_info为空,或者error_info.error_id为0时,表明没有错误
///@param is_last 是否此次查询的最后一个应答,当为最后一个的时候为true,如果为false,表示还有其他后续消息响应
virtual void OnQueryTickersPriceInfo(XTPTPI* ticker_info, XTPRI *error_info, bool is_last) {};

该接口可以返回股票/基金/债券/期权等最新价格。

需要注意的是:

(1)请使用“订阅/推送”的方式来获取行情最新价格,不要频繁调用查询接口。
(2)服务器对“全查询或超过3000只股票的查询”频率做了限制。

3、订阅

目前我们支持按股票代码和按市场进行订阅。快照、逐笔、订单薄(OB)使用不同的订阅接口。
生产环境使用UDP组播,推荐客户按市场进行订阅。
SubscribeAllMarketData、SubscribeAllOptionMarketData、SubscribeAllTickByTick、SubscribeAllOrderBook
SubscribeMarketData、SubscribeTickByTick、SubscribeOrderBook
例如:使用SubscribeMarketData订阅快照行情:

///订阅行情,包括股票、指数和期权。
///@return 订阅接口调用是否成功,“0”表示接口调用成功,非“0”表示接口调用出错
///@param ticker 合约ID数组,注意合约代码必须以'\0'结尾,不包含空格 
///@param count 要订阅/退订行情的合约个数
///@param exchange_id 交易所代码
///@remark 可以一次性订阅同一证券交易所的多个合约,无论用户因为何种问题需要重新登录行情服务器,都需要重新订阅行情
virtual int SubscribeMarketData(char *ticker[], int count, XTP_EXCHANGE_TYPE exchange_id) = 0;

订阅函数,传入需要订阅的股票代码,订阅股票的个数,以及市场。注意市场不要写错误。如股票代码同样是“000001”,深交所表示平安银行,上交所表示上证指数。
OnSubMarektData返回订阅结果。

///订阅行情应答,包括股票、指数和期权
///@param ticker 详细的合约订阅情况
///@param error_info 订阅合约发生错误时的错误信息,当error_info为空,或者error_info.error_id为0时,表明没有错误
///@param is_last 是否此次订阅的最后一个应答,当为最后一个的时候为true,如果为false,表示还有其他后续消息响应
///@remark 每条订阅的合约均对应一条订阅应答,需要快速返回,否则会堵塞后续消息,当堵塞严重时,会触发断线
virtual void OnSubMarketData(XTPST *ticker, XTPRI *error_info, bool is_last) {};

注意:
(1)生产环境L1/L2行情服务器均使用UDP推送模式,生产环境推荐使用全市场订阅接口。
(2)测试环境使用TCP的方式推送行情。由于带宽的限制,请客户只订阅少量股票,否则会出现推送延时、断线等问题。

4、推送

订阅成功后,当有行情服务器有数据推过来时,OnDepthMarketData、OnSubOrderBook、OnTickByTick会被回调。用户就可以从该函数中取数据了。
在这些回调函数中,请不要使用耗时操作,需尽快返回。否则会造成API来不及接收数据而丢行情。

///深度行情通知,包含买一卖一队列
///@param market_data 行情数据
///@param bid1_qty 买一队列数据
///@param bid1_count 买一队列的有效委托笔数
///@param max_bid1_count 买一队列总委托笔数
///@param ask1_qty 卖一队列数据
///@param ask1_count 卖一队列的有效委托笔数
///@param max_ask1_count 卖一队列总委托笔数
///@remark 需要快速返回,否则会堵塞后续消息,当堵塞严重时,会触发断线
virtual void OnDepthMarketData(XTPMD *market_data, int64_t bid1_qty[], int32_t bid1_count, int32_t max_bid1_count, int64_t ask1_qty[], int32_t ask1_count, int32_t max_ask1_count) {};

三、数据结构及字段含义

1、行情快照(XTPMD)赋值字段及含义

有关ticker代码及其含义的说明:
http://www.sse.com.cn/market/price/report/ http://www.szse.cn/market/trend/

从API 2.2.32.2开始,XTPMarketDataStruct结构体,增加XTP_MARKETDATA_TYPE_V2 data_type_v2 字段,来表明是哪种数据类型。

(1)指数字段说明

data_type_v2 = XTP_MARKETDATA_V2_INDEX;

  • exchange_id,交易所ID,枚举值
  • ticker,股票代码,6位
  • last_price,最新
  • pre_close_price,昨日收盘
  • open_price,今日开盘
  • high_price,最高
  • low_price,最低
  • close_price,今收。上交所有该字段(大于0该值有效)。深交所无该字段,xquote将其赋值为- last_price。
  • data_time
    • SHL1取自每行的时戳
    • SHL2取自FAST层的时戳(非STEP层)
    • SZ直接由深交所给出
  • qty,成交量,上交所单位手,深交所单位股
  • turnover,成交金额,单位元
  • trades_count,成交笔数,SH无意义(填0),SZ有值

(2)股票/基金字段说明

股票的价格精度为0.01元,债券为0.001元
data_type_v2 = XTP_MARKETDATA_V2_ACTUAL;

  • exchange_id,交易所ID,枚举值
  • ticker,股票代码,6位
  • last_price,最新
  • pre_close_price,昨收
  • open_price,今开
  • high_price,最高
  • low_price,最低
  • close_price,今收。上交所有该字段(大于0该值有效)。深交所无该字段,xquote将其赋值为last_price。

深交所的今收,是在收盘后,通过文件( cashsecurityclosemd _*.xml )的形式下发的。

  • data_time
    • SHL1取自每行的时戳(非第一行header的时戳),含义为最近一次的成交时间
    • SHL2取自FAST层的时戳(非STEP层),含义为“最新委托、最新成交、最新状态”的最新时间,全市场行情时间,会持续更新
    • SZ直接由深交所给出
  • upper_limit_price/lower_limit_price,涨/跌停价。SZ该值由深交所实时给出;SH来源于初始化文件(上交所没有实时给出该值)。
  • qty,成交量,单位股
  • turnover,成交金额,单位元
  • avg_price,无意义
  • bid[10]/ask[10],买/卖价
    • L1数据源,只显示5档。L2数据源,显示10档。
    • 单位元。
  • bid_qty[10]/ask_qty[10],买/卖量
    • L1数据源,只显示5档。L2数据源,显示10档。
    • 单位股。
  • trades_count,成交笔数。SHL1无意义(填0),SHL2/SZL1/SZL2有值。
  • ticker_status,当前交易状态及标志,8字节。

第 0 位:

  • ‘S’,启动(开市前)时段(SH/SZ)
  • ‘C’,集合竞价(SH/SZ)
  • ‘T’,连续竞价(SH/SZ)
  • ‘B’,休市(SZ)
  • ‘E’,闭市(SH/SZ)
  • ‘P’,产品停牌(SH/SZ)
  • ‘M’,表示可恢复交易的熔断时段(盘中集合竞价)(SH)
  • ‘N’,表示不可恢复交易的熔断时段(暂停交易至闭市)(SH)
  • ‘U’,表示收盘集合竞价时段(SH)
  • ‘D’,开盘结合竞价结束到连续竞价开始前(SH)
  • ‘A’,盘后交易(SZ)
  • ‘V’,波动性中断(SZ,SH期权)

第 1 位:

  • ‘0’,此产品不可正常交易
  • ‘1’,此产品可以正常交易
  • 无意义填空格

第 2 位:

  • ‘0’,未上市
  • ‘1’,已上市

第 3 位:

  • ‘0’,此产品在当前时段,不接受进行新订单申报
  • ‘1’,此产品在当前时段,可接受进行新订单申报
  • 无意义填空格

深交所只有第0、1位,没有第2、3位

上海市场0-9:159:15-9:259:25-9:309:30-11:3011:30-13:0013:00-14:5714:57-15:0015:00-
非停牌S 11C111T111T111T111T111U111E111
停牌P011P011P011P011P011P011P011P011
上海市场0-9:259:259:25-9:309:30-11:3011:30-13:0013:00-14:5714:57-15:0015:00-
SH603192
2018.08.28
[9:30-10:00]
盘中停牌
---C111T111P011T111T111U111E111

注意:从2018-12月份开始,上交所停止发送开盘集合竞价消息(UA3107)。开盘/收盘集合竞价消息,直接从UA3202发出。

深圳市场0-9:159:15-9:259:25-9:309:30-11:3011:30-13:0013:00-14:5714:57-15:0015:00-
非停牌S1C1B1T1B1T1C1E1
停牌S0C0B0T0B0T0C0E0
深圳市场0-9:159:15-9:259:25-9:309:309:30-10:0010:00-11:3011:30-13:0013:00-14:5714:57-15:0015:00-
SZ300747
2018.05.25
[9:30-10:00]
盘中停牌
S1C1B1T1V1T1B1T1C1E1
  • data_type,股票时为0。
  • stk,股票扩展字段。
    • total_bid_qty,委托买入总量,SHL2/SZ有值。
    • total_ask_qty,委托卖出总量,SHL2/SZ有值。
    • ma_bid_price,加权平均委买价格,SHL2/SZ有值。
    • ma_ask_price,加权平均委卖价格,SHL2/SZ有值。
    • ma_bond_bid_price,债券加权平均委买价格,SHL2有值。
    • ma_bond_ask_price,债券加权平均委卖价格,SHL2有值。
    • yield_to_maturity,债券到期收益率,SHL2有值。
    • iopv,基金实时参考净值,SH/SZ有值。
    • etf_buy_count,ETF申购笔数,SHL2有值。
    • etf_sell_count,ETF赎回笔数,SHL2有值。
    • etf_buy_qty,ETF申购数量,SHL2有值。
    • etf_buy_money,ETF申购数量,SHL2有值。
    • etf_sell_qty,ETF赎回数量,SHL2有值。
    • etf_sell_money,ETF赎回金额,SHL2有值。
    • total_warrant_exec_qty,权证执行的总数量,SHL2有值。
    • warrant_lower_price,权证跌停价格,SHL2有值。
    • warrant_upper_price,权证涨停价格,SHL2有值。
    • cancel_buy_count,买入撤单笔数,SHL2有值。
    • cancel_sell_count,卖出撤单笔数,SHL2有值。
    • cancel_buy_qty,买入撤单数量,SHL2有值。
    • cancel_sell_qty,卖出撤单数量,SHL2有值。
    • cancel_buy_money,买入撤单金额,SHL2有值。
    • cancel_sell_money,卖出撤单金额,SHL2有值。
    • total_buy_count,买入总笔数,SHL2有值。
    • total_sell_count,卖出总笔数,SHL2有值。
    • duration_after_buy,买入委托成交最大等待时间,SHL2有值。
    • duration_after_sell,卖出委托成交最大等待时间,SHL2有值。
    • num_bid_orders,买方委托价位数,SHL2有值。
    • num_ask_orders,卖方委托价位数,SHL2有值。
    • pre_iopv,基金T-1日净值。SZ有值。

(3)期权字段说明

期权的价格精度为0.0001元
data_type_v2 = XTP_MARKETDATA_V2_OPTION;

  • exchange_id,交易所ID,枚举值
  • ticker,股票代码,8位
  • last_price,最新成交价
  • pre_close_price,昨日收盘价
    • SH mktdt数据源,在行情文件中不提供,初始化时从reff03MMDD.txt取;
    • SH LDDS数据源,在流式行情中提供该字段(PrevClosePx);
    • SZ 数据源,在流式行情中提供该字段(PrevClosePx).
  • open_price,今开
  • high_price,当日最高价
  • low_price,当日最低价
  • close_price,今收价,SH mktdt总为0。SH LDDS大于0该值有效(观察到盘中为0,收盘后大于0)。SZ 该值总等于last_price。
  • pre_total_long_positon,SH和SZ市场,该值总为0
  • total_long_positon,未平仓合约数量(张或股)
  • pre_settl_price,昨日结算价
  • settl_price,今日结算价,SH mktdt该值为0,SH LDDS数据源有值;SZ数据源该值为0
  • upper_limit_price/lower_limit_price,涨/跌停价。SH来源于初始化文件(上交所没有实时给出该值)。
  • data_time
    • SH mktdt数据源,取自每行的时戳(观察到为上交所最近一次的成交时间,若委托发生变化,该值不变)
    • SH LDDS数据源,取自FAST层最里面的时戳(观察到为上交所最近一次的成交时间,若委托发生变化,该值不变)
  • qty,当日累计成交量
  • turnover,当日累计成交金额
  • avg_price,均价,计算方法为turnover/qty,无意义
  • bid[10]/ask[10],买/卖价,SH/SZ均只有5档
  • bid_qty[10]/ask_qty[10],买卖量,SH/SZ均只有5档
  • trades_count,成交笔数,SH mktdt数据源为0,SH LDDS数据源有值
  • ticker_status,当前交易状态及标志,8字节

上交所标志含义

第 0 位:

  • ‘S’,启动(开市前)阶段
  • ‘C’,集合竞价
  • ‘T’,连续交易
  • ‘B’,休市
  • ‘E’,闭市
  • ‘V’,波动性中断
  • ‘P’,临时停牌
  • ‘U’,收盘集合竞价
  • ‘M’,可恢复交易的熔断(盘中集合竞价)
  • ‘N’,不可恢复交易的熔断(暂停交易至闭市)

第 1 位:

  • ‘0’,未连续停牌
  • ‘1’,连续停牌
  • 预留则填空格

第 2 位:

  • ‘0’,不限制开仓
  • ‘1’,限制备兑开仓
  • ‘2’,卖出开仓
  • ‘3’,限制卖出开仓、备兑开仓
  • ‘4’,限制买入开仓
  • ‘5’,限制买入开仓、备兑开仓
  • ‘6’,限制买入开仓、卖出开仓
  • ‘7’,限制买入开仓、卖出开仓、备兑开仓

第 3 位:

  • ‘0’,此产品在当前时段不接受进行新订单申报
  • ‘1’,此产品在当前时段可接受进行新订单申报

深交所标志含义

同股票字段说明

  • data_type,期权为1
  • opt,期权扩展字段(仅SH市场有意义,SZ市场值均无意义)
    • auction_price,波段性中断参考价
    • auction_qty,波段性中断集合竞价虚拟匹配量
    • last_enquiry_time,最近询价时间,格式为YYYYMMDDHHMMSSsss,若无询价时,HHMMSSsss部分为0。总为0。

(4)债券字段说明

data_type_v2 = XTP_MARKETDATA_V2_BOND;
从2021.10.25后,上交所启用新的债券交易系统,修改了债券行情的协议。
上交所L1时,ticker_status有值;
上交所L2时,ticker_status无意义;bond.instrument_status有值;
深交所L1/L2时,ticker_status有值。
SHL2的债券的加权平均价,要用ma_bond_bid_price和ma_bond_ask_price。
SZ的债券加权平均价,则用ma_bid_price和ma_ask_price。


(5)北交所字段说明

A. 实时行情字段说明
快照行情发布使用和沪深一样的结构体(XTPMarketDataStruct)中的一部分字段,如下所示:

  • exchange_id,交易所 ID,枚举值:XTP_EXCHANGE_NQ
  • ticker,股票代码,6 位
  • last_price,最新
  • pre_close_price,昨收
  • open_price,今开
  • high_price,最高
  • low_price,最低
  • close_price,今收盘
  • total_long_position,持仓量
  • data_time,DBF 行情,取的是 DBF 文件更新时间
  • qty,成交量
  • turnover,成交额
  • bid[10]/ask[10],买/卖价
    • 北交所数据源,只显示 5 档。
    • 单位元。
  • bid_qty[10]/ask_qty[10],买/卖量
    • 北交所数据源,只显示 5 档。
    • 单位股。

其余字段北交所快照均未使用。

B. 请求接口XTPQuoteNQFullInfo静态数据字段说明:

  • “layer_type” 分层信息:用于过滤北交所的证券代码,layer_type为2时,是北交所证券,其中有一个指数899050是北证50指数,交易所给的layer_type是8,若需要指数,需按照代码过滤899050。
    • 2 - 北交所
    • 1 - 创新层
    • 0 - 基础层
    • 8 - 其他
  • “security_type” 合约详细类型,目前该字段没有定义,取值是255-其他。

若需要判断证券类型,请根据交易所证券代码前三位字符进行判断:

类型\合约代码第一位第一位第三位
现货43
83
87
指数899

注意:目前北交所上线的证券只有现货股票和一个指数899050。


(6)买一卖一委托队列字段及含义

L1没有委托队列,L2有委托队列。
在订阅行情快照后,若有行情数据推过来,OnDepthMarketData函数就会被回调。

///深度行情通知,包含买一卖一队列
///@param market_data 行情数据
///@param bid1_qty 买一队列数据
///@param bid1_count 买一队列的有效委托笔数
///@param max_bid1_count 买一队列总委托笔数
///@param ask1_qty 卖一队列数据
///@param ask1_count 卖一队列的有效委托笔数
///@param max_ask1_count 卖一队列总委托笔数
///@remark 需要快速返回,否则会堵塞后续消息,当堵塞严重时,会触发断线
virtual void OnDepthMarketData(XTPMD *market_data, int64_t bid1_qty[], int32_t bid1_count, int32_t max_bid1_count, int64_t ask1_qty[], int32_t ask1_count, int32_t max_ask1_count) {};
avatar
avatar

2、逐笔(XTPTBT)赋值字段及含义


(1) 深交所逐笔

深交所只有逐笔委托和逐笔成交,没有逐笔状态。

  • exchange_id,交易所ID
  • ticker,股票代码,6字节
  • seq,无意义,预留
  • data_time,委托时间或成交时间,格式YYYYMMDDHHMMSSsss
  • type,委托或成交标识
  • entrust,逐笔委托
    • channel_no,频道代码
    • seq,在该channel_no内的委托序号
    • price,委托价格
    • qty,委托数量
    • side,买卖方向。'1':买; '2':卖; 'G':借入; 'F':出借。
    • ord_type,订单类别。'1': 市价; '2': 限价; 'U': 本方最优。注:交易所没有给出转限、转撤等更加详细的信息
  • trade,逐笔成交
    • channel_no,频道代码
    • seq,在该channel_no内的成交序号
    • price,成交价格
    • qty,成交数量
    • money,成交金额,无意义
    • bid_no,买方订单号,可以追溯到entrust中的seq
    • ask_no,卖方订单号,可以追溯到entrust中的seq
    • trade_flag,成交标志。SZL2,成交标识('4':撤; 'F':成交)

(2) 上交所逐笔

跟深交所相比,上交所增加了逐笔状态消息。

  • exchange_id,交易所ID
  • ticker,股票代码,6字节
  • seq,对应上交所bizIndex字段,在同一个channel内唯一
  • data_time,委托时间或成交时间,格式YYYYMMDDHHMMSSsss
  • type,委托或成交标识
  • entrust,逐笔委托
    • channel_no,频道代码
    • seq,在该channel_no内的委托序号,单调递增
    • price,委托价格
    • qty,委托数量
    • side,买卖方向。'B':买; 'S':卖
    • ord_type,订单类别。'A':增加; 'D':删除
    • order_no,原始订单编号
  • trade,逐笔成交
    • channel_no,频道代码
    • seq,在该channel_no内的成交序号,单调递增
    • price,成交价格
    • qty,成交数量
    • money,成交金额,SHL2有该值,SZL2没有该值(总为0)
    • bid_no,买方订单号,可以追溯到entrust中的order_no
    • ask_no,卖方订单号,可以追溯到entrust中的order_no
    • trade_flag,成交标志。SHL2,内外盘标识('B':主动买; 'S':主动卖; 'N':未知)
  • state,状态订单
    • channel_no,频道代码
    • seq,在该channel_no内的序号,单调递增
    • flag,状态

(3) 对数据的解释

SHL1、SZL1没有逐笔。
SHL2的撤单信息在逐笔委托中(order_type=’D’);SZL2的撤单信息在逐笔成交中(trade_flag=’4’)。
channel_no,频道代码。同一只股票的逐笔委托和逐笔成交行情数据中,channel_no都相同。不同股票的逐笔委托和逐笔成交,channel_no可能不同。同一个channel_no会有多只股票的逐笔委托和逐笔成交数据。
SZL2的逐笔委托和逐笔成交,放到一起编号。可通过逐笔成交里的订单号(bid_no或ask_no)追溯到对应的委托逐笔(XTPTickByTickEntrust.seq)。
SHL2的逐笔委托&逐笔成交&逐笔状态,放到一起编号。可通过逐笔成交里的订单号(bid_no或ask_no)追溯到对应的委托逐笔(XTPTickByTickEntrust.order_no)。
注意:
上交所逐笔委托和成交消息合并之前,SHL2股票/基金,逐笔委托单独编号(entrust.seq),逐笔成交单独编号(trade.seq)。逐笔委托&逐笔成交一起有编号(tbt.seq)。


期权无逐笔数据。

SH现有逐笔channel:[1, 6] [20] [103][801] (共9个,20为B股,103为盘后固定价格交易,801为债券)
SZ现有逐笔channel:[2011, 2014] [2021, 2024] [2031, 2034] [2061][2071] (共14个,2061为国债逆回购,2071为债券)

3、订单薄(XTPOB)赋值字段及含义


(1) 结构字段说明
  • exchange_id,交易所ID
  • ticker,股票代码
  • last_price,最近成交价
  • qty,成交总量
  • turnover,成交总金额
  • trades_count,成交笔数
  • bid[10]/ask[10],十档买/卖价
  • bid_qty[10]/ask_qty[10],十档买/卖量
  • data_time,最近成交时间,格式YYYYMMDDHHMMSSsss

(2) 对数据的解释
订单薄,是根据交易所的逐笔委托和逐笔成交数据重建的。
在集合竞价阶段(包括开盘和收盘),不推送该数据,这个时间段的行情快照,可以从XTPMD结构中获取。
没有推送间隔限制,跟逐笔一样实时推送 使用该数据的用户,应该与行情快照(XTPMD)结合起来使用。最新的时间戳,便是最新的数据。
avatar
avatar

深交所债券:
债券上市首日开盘集合竞价的有效竞价范围为发行价的上下30%,连续竞价、收盘集合竞价的有效竞价范围为最近成交价的上下10%;
债券非上市首日开盘集合竞价的有效竞价范围为前收盘价的上下10%,连续竞价、收盘集合竞价的有效竞价范围为最近成交价的上下 10%。

四、FAQ

1、公网测试环境


公网测试环境是为了方便测试,在公网上搭建的一套测试环境。7*24小时提供行情服务。
公网测试环境仅供客户调试API接口,提供的L2测试数据包括:10档价/量、买一卖一委托队列、逐笔委托、逐笔成交,但是没有订单薄OB行情。
在公网测试环境,不建议全订阅。因为带宽有限。
所有用户在上实盘前,请务必在实盘上先做行情接入测试。
公网测试环境,使用TCP的方式推送数据。在该环境下测试时,API和客户端需要配置成TCP的方式接收行情,否则会收不到行情的更新数据。

(1) 若使用XTP官网上的测试用例,请按下图方式进行配置
"quote_ip": "120.27.164.138",
"quote_port": 6002,
"quote_user": "quoteusername",
"quote_password": "quotepw",
"quote_ticker": {
"instrument": [
  "600120"
 ],
"exchange": 1
},
"hb_interval":15,
"quote_buffer_size":128,
"quote_protocol":1

(2) 若使用XTP客户端,请按下图进行配置
[LOGIN]
MdProtocal=TCP
XTPLogLevel=4
GWName=上海网关, 深圳网关
GWIP=59.36.23.196, 59.36.23.196
GWPort=8016, 8017
QuoteIP=119.3.103.38
QuotePort=6002

(3) 若使用API,请按下图方式进行配置
///用户登录请求
///@return 登录是否成功,“0”表示登录成功,“-1”表示连接服务器出错,此时用户可以调用GetApiLastError()来获取错误代码,“-2”表示已存在连接,不允许重复登录,如果需要重连,请先logout,“-3”表示输入有错误
///@param ip 服务器ip地址,类似“127.0.0.1”
///@param port 服务器端口号
///@param user 登陆用户名
///@param password 登陆密码
///@param sock_type “1”代表TCP,“2”代表UDP
///@param local_ip 本地网卡地址,类似“127.0.0.1”
///@remark 此函数为同步阻塞式,不需要异步等待登录成功,当函数返回即可进行后续操作,此api只能有一个连接
virtual int Login(const char* ip, int port, const char* user, const char* password, XTP_PROTOCOL_TYPE sock_type, const char* local_ip = NULL) = 0;

(4) TCP推送方式及问题排查
TCP模式下,若用户收不到行情数据,请按以下方式排查。
(1) 启动API。
(2) 确保Login的sock_type参数使用的是XTP_PROTOCOL_TCP。
(3) 订阅股票,确保回调函数OnSubMarketData返回成功。
(4) 若还没有收到数据(OnDepthMarketData没有被回调),请使用抓包工具(如wireshark,tcpdump),看看数据有没有到达API所在的机器。
(5) tcpdump -i 网卡 tcp port 端口号(如 tcpdump -i p5p2 tcp port 6666),看看行情数据有没有到达主机.

2、生产环境


XTP在每个机房,都部署有L1行情服务器和L2行情服务器,均使用UDP方式对外推送行情。客户请勿跨机房连接行情服务器。
L1,只提供5档快照。
L2,提供10档快照、买一卖一委托队列、逐笔。
另外,在每个机房部署有OB服务器(不跨机房提供)。
期权(SH/SZ),无论哪个环境,交易所只提供5档快照,不提供逐笔。

买一卖一委托队列,跟行情快照是同时发过来的。
SHL2的逐笔数据,在开盘时间段,延时比较大。
SZL2的逐笔数据,深交所一般是实时发过来的。即交易下单后,行情马上可以看到逐笔委托。
每条行情快照加上买一卖一委托队列的大小为,约为1.5KB(按最大算)。
每条逐笔的大小约为112B。
在数据高峰时期(9:15,9:30,13:00,15:00),数据量非常大,约20W笔/秒。推送的带宽约为22MB/秒。

请不要阻塞API行情接收线程。
若API使用TCP方式收行情数据:API接收线程收数据慢,行情服务器会断开与API的连接。
若API使用组播(UDP)方式收行情数据(生产L2):API接收线程收数据慢(接收线程阻塞,或者在接收线程处理完数据后再接收下一条数据),可能会丢数据。
为了避免丢数据的问题发生,建议用“生产者/消费者”的模式来处理行情数据。接收线程只管收数据,另启动一个线程处理数据。
提示:测试发现,格式化类的操作(如snprintf, printf)比较耗时,请勿在接收线程中使用。

用组播时,还需要确保API所在的机器,能够收到组播数据。防火墙开启时,组播数据可能会被过滤掉。请关闭防火墙,或允许行情的组播数据通过防火墙。
行情服务器一般在8:30至8:45就绪,交易所从9:15开始集合竞价。但在集合竞价前,交易所会发一些数据(只有行情快照,是为了测试),我们也会把这些数据发给用户。这些数据属于盘前数据。
假如API在9:10启动,可能会丢失一部分盘前数据(API日志中会提示WARNING),这个是没有关系的。
但若在盘中有大量提示丢数据的日志,需要查找原因。
所有用户在上实盘前,请务必在实盘做行情接入测试。

3、UDP(组播)推送方式及问题排查


生产环境Level-2、Level-1行情数据,都是通过组播的方式推送给API的,请使用UDP连接,请关闭防火墙。有些机器收不到组播数据,请按照以下步骤排查。
(1) 启动API。
(2) 确保Login的sock_type参数使用的是XTP_PROTOCOL_UDP。
(3) 订阅股票,确保回调函数OnSubMarketData返回成功。
(4) 进行socket参数优化,可登录xms至公共信息里查看优化说明。
(5) 若还没有收到数据(OnDepthMarketData没有被回调),请使用抓包工具(如wireshark,tcpdump),看看组播数据有没有到达API所在的机器。组播的地址与端口,请查看API的日志,也可以与XTP运维人员联系。

avatar

(6) tcpdump -i 网卡 udp port 端口号(如 tcpdump -i p5p2 udp port 17778),看看组播数据有没有到达主机。
(7) 若没有抓到行情组播数据,请调整系统参数。

windows系统:

  • 打开注册表编辑器regedit,
    路径:HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\services\Tcpip\Parameters,在该路径下新建两个DWORD变量,一个命名为IGMPVersion,
    值设定为3,第二个命名为IGMPLevel,值设定为2。
    路径: HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\Afd\Parameters,增加DefaultReceiveWindow字段,DWORD 类型,大小设置为 134217728(128M)。
  • 卸掉杀毒软件(或者杀毒软件放行组播数据)。
  • 重启系统。
  • 关掉防火墙(或允许组播使用的端口通过)

linux系统:

  • 确保组播地址绑定到了正确的网卡上,netstat -gn;

avatar

  • 关掉防火墙(或允许组播使用的端口通过):systemctl stop firewalld.service。

  • 下面命令是临时的,操作系统重启后会失效。需要写在操作系统的启动脚本中。
    sysctl -w net.core.rmem_default="134217728"
    sysctl -w net.core.rmem_max="134217728"
    sysctl -w net.core.wmem_default="134217728"
    sysctl -w net.core.wmem_max="134217728"
    sysctl -w net.ipv4.udp_mem="134217728 134217728 268435456"
    sysctl -w net.ipv4.udp_rmem_min="134217728"
    sysctl -w net.ipv4.udp_wmem_min="134217728"

如果设置 net.ipv4.udp_mem 时报错:Invalid argument,那就去掉引号再试下,因为不同的系统略有区别。

(8) 若还不能收到数据,添加临时路由: route add -net 组播地址 掩码 dev 设备, (如route add -net 230.1.1.0/24 dev p5p2)
(9) Windows下用SmartX客户端(Windows/macOS),订阅一整天行情,看API的quote.log日志,看看有没有丢包;若丢包,需要查找原因。
(10) API若发生频繁丢包,调用SetUDPBufferSize函数,调整参数到256MB或512MB。

///设置采用UDP方式连接时的单个队列接收缓冲区大小,目前可能最大使用4个缓冲区队列
///@remark 需要在Login之前调用,默认大小和最小设置均为64MB。此缓存大小单位为MB,请输入2的次方数,例如128MB请输入128。
virtual void SetUDPBufferSize(uint32_t buff_size) = 0;

(11) API的默认日志级别是DEBUG,需要调整到INFO(或ERROR),否则可能会导致丢包。CreateQuoteApi的log_level参数。

4、行情数据更新频率


逐笔和订单簿行情是实时更新的,快照行情更新频率如下:
种类集合竞价连续竞价午间休市
SH指数约5秒一次 (不准)约5秒一次(不准)60秒推一次 L2时间戳跟着变 (201901后,不准)
SH股票有变化3秒一次 无变化60秒一次有变化3秒一次 无变化60秒一次60秒推一次 L2时间戳跟着变 (201901后)
SH期权有变化15秒一次 无变化30秒一次有变化0.5秒一次 无变化30秒一次30秒一次
SZ指数60秒一次3秒一次60秒推一次 时间戳跟着变
SZ股票60秒一次有变化3秒一次 无变化60秒一次60秒推一次 时间戳跟着变
SZ期权6秒一次有变化0.5秒一次 无变化60秒一次6秒一次
NQEX有变化3秒一次 无变化60秒一次有变化3秒一次 无变化60秒一次60秒一次 时间戳跟着变

种类集合竞价/连续竞价/午间休市
SH逐笔委托9:15-9:25,可以下单,但交易所不推逐笔委托 9:25,开始推送逐笔委托 9:25-9:30,无数据(开盘集合竞价结束到连续竞价开始前) 9:30,开始推(连续竞价)
SH逐笔成交9:25,有大量逐笔成交(集合竞价) 9:25-9:30,无数据(开盘集合竞价结束到连续竞价开始前) 9:30,开始推(连续竞价)
SH盘后固定价格(快照)参与盘后固定价格交易的股票,15:00开始发布 15:00 - 15:05,集中撮合 15:05 - 15:30,连续交易 15:30后,闭市
SZ逐笔委托9:15-9:25,推逐笔委托(期间可以下单,可以撤单) 9:25-9:30,无数据(开盘集合竞价结束到连续竞价开始前) 9:30,开始推(连续竞价)
SZ逐笔成交9:15-9:25,只有逐笔撤单,无逐笔成交单 9:25,有大量逐笔成交(集合竞价)9:25-9:30,无数据(开盘集合竞价结束到连续竞价开始前)9:30,开始推(连续竞价)

SH和SZ均无期权的逐笔

5、丢包问题API日志排查


udpseq0_0.YYYYMMDD 是普通股票的MarketData的Seq
udpseq0_1.YYYYMMDD 是普通股票的OrderBook的Seq
udpseq0_2.YYYYMMDD 是普通股票的TickByTick的Seq

udpseq1_0.YYYYMMDD 是期权的MarketData的Seq
udpseq1_1.YYYYMMDD 是期权的OrderBook的Seq
udpseq1_2.YYYYMMDD 是期权的TickByTick的Seq

udpseq2_0.YYYYMMDD 是新三板股票的MarketData的seq

udpseq3_0.YYYYMMDD 是接收buffer满的时候的错误代码
udpseq3_1.YYYYMMDD 是普通股票和期权TickByTick的来晚了、需要丢弃的Seq
udpseq3_2.YYYYMMDD 是普通股票和期权TickByTick的乱序Seq

如果tick丢包的话,quote.log.YYYYMMDD里会有discrete提示日志
如果tick乱序,udpseq3_2.YYYYMMDD里会有seq
如果接收buffer满,udpseq3_0.YYYYMMDD里会有错误码
看marketdata丢不丢包,可以看udpseq0_0.YYYYMMDD是否seq丢失(seq乱序没关系)
看OrderBook丢不丢包,可以看udpseq0_1.YYYYMMDD是否seq丢失(seq乱序没关系)

6、对seq is discrete N to M的解释


组播(UDP)推送行情模式下。
行情服务器启动后,若有数据需要推送,就会往外推数据(组播)。UDP包,是统一连续编号的。
若API启动前行情服务器已经往外推送了组播数据,API就会打印一条WARNIG日志。

avatar
avatar

上面的日志表明,丢失了逐笔数据(discrete 1-7516)。这种情况可以忽略,因为订阅晚了,交易所已经推送的包肯定是丢掉的。
但若在收行情的过程中,发现大量下图所示的日志,需要查找问题。

avatar
avatar

如果quote.log没有discrete关键字,可查看udpseq异步日志,判断seq行数跟seq最大值和最小值的差值是否一致,如果一致,就没有丢包。

普通股票的MarketData查看udpseq0_0.YYYYMMDD文件,TickByTick查看udpseq0_2.YYYYMMDD,OrderBook查看udpseq0_1.YYYYMMDD。

另外,快照数据MarketData、逐笔数据TickByTick、订单薄数据OrderBook,是分开编号的。

对日志”Tick by tick udp seq XXX is time out, discrete xxx-xxx”的解释:
行情服务器会对发出去的每个udp包按顺序编号(行情快照、逐笔、订单薄各自独立编号)。以逐笔行情(TickByTick)为例,API正常收到包的顺序应该为1,2,3,4,5,但若API收到1,2,3,然后收到5,就会去等4的包。若在一段时间内,API还没有收到4的包,就会打印上面的日志。并认为4丢掉了。

若发现丢包较多,可以把UDP的接收缓存开大点,内核参数从128MB增大到256MB。


**Windows:**
打开注册表的 “HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\Afd\Parameters”选项,增加“DefaultReceiveWindow”字段,DWORD类型,大小设置为113246208(128M)。

发送端(行情服务器),可以增加“DefaultSendWindow”字段,DWORD类型,大小设置为113246208(128M)。

7、其它问题


(1) SHL2的最新价和收盘价,分别是怎么计算得到的。发现收盘后,有些股票的收盘价和最新价不相同。
- 最新价 = 最新一支逐笔成交的价格
- 收盘价 = 证券的收盘价为当日该证券最后一笔交易前一分钟所有交易的成交量加权平均价(含最后一笔交易)。当日无成交的,以前收盘价为当日收盘价。
- 债券质押式回购的收盘价为当日该证券最后一笔交易前一小时所有交易的成交量加权平均价(含最后一笔交易)。当日无成交的,以前收盘价为当日收盘价。
- 收盘集合竞价阶段产生交易的,这两个价格相同;否则可能会不同。

(2)SHL1和SHL2每天的快照数量不一样。SHL1和SHL2分别在什么时候推出快照,所有档位,只要发生变化就推?
- SHL1,买卖 5档盘口发生变化时推。
- SHL2,买卖10档盘口发生变化时推。

(3)SHL2逐笔提速后,逐笔实时发送,逐笔约有250ms时间间隔。