国外期货程序化交易之行情获取讲解

2024-08-28 14:08

本文主要是介绍国外期货程序化交易之行情获取讲解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

       本来是做图像算法,后来稀里糊涂的被拉进期货程序化交易这个方向。刚接触时真是一头雾水,什么合约、保证金、开仓、平仓、看多、看空等等完全不懂,对期货的了解仅仅停留在新闻报道里,各种期货知识一顿恶补后,思路渐渐清晰。于是开始着手开发期货行情程序、交易程序等等。目前,开发的行情程序及交易程序,主要还是和郑州易盛的交易系统对接,基于易盛的sdk做二次开发,通过调用易盛的行情api获取期货合约行情,调用易盛的交易api完成交易报单。当然也可以申请美国盈透的账号,然后使用盈透的行情及交易api。

       为了方便开发,易盛官方(http://www.esunny.com.cn/)提供了文档以及示例demo,不过还是建议按照自己的理解和思路设计程序,官方提供的demo仅供参考。实时获取行情数据使用socket协议,需要长连接易盛提供的行情服务器,不过易盛提供的sdk内部会维护长连接,开发者可以不做太多处理,但断线重连逻辑需要开发者编写。编写代码时需要处理两方面内容,一个是调用方,即发出请求,另一个是回调方,即响应请求。发出请求时,只要自己的应用直接调用易盛的api即可,而响应请求,这个需要自己的应用继承、重写易盛提供的相应方法,然后作为回调供易盛的sdk调用。同时需要注意回调函数内不要做比较耗时的操作,即不要堵塞易盛的回调线程。整体上讲,开发过程还是容易的,下面是流程图及一些代码示例:

                                                                   

       1. 创建易盛TapAPI实例:
TapAPIApplicationInfo tapAppInfo;
strcpy(tapAppInfo.AuthCode, authcode.c_str());
strcpy(tapAppInfo.KeyOperationLogPath, username.c_str());
ITapQuoteAPI *pTapQuote = CreateTapQuoteAPI(&tapAppInfo, result);
       即通过调用CreateTapQuoteAPI()创建api实例——pTapQuote,随后调用该实例发起各种请求,比如连接服务器、用户登录、订阅合约、退订合约等。
       2. 创建TapAPI回调实例:
MarketDataSource *pDataSource = new MarketDataSource(pTapQuote, this);
       这个需要自己编写相应实现类,需要继承易盛提供的ITapQuoteAPINotify类。重写该类里面的方法,以处理易盛服务器发过来的各类数据。
       3. 将上述两个实例关联起来,并发起连接服务器及用户登录:
pTapQuote->SetAPINotify(pDataSource);
pDataSource->connect(serverAddr, port, username, password);
      连接服务器及用户登录部分代码:
void MarketDataSource::connect(string serverAddr, uint16_t port, string username, string password)
{TAPIINT32 result = TAPIERROR_SUCCEED;// 保存登录信息serverAddr_ = serverAddr;port_ = port;username_ = username;password_ = password;// 设置服务器IP、端口result = (pTapQuote_ != NULL) ? pTapQuote_->SetHostAddress(serverAddr.c_str(), port) : -999;if (result != TAPIERROR_SUCCEED){LOG_INFO << username_ << " 请求: 设置服务器IP/端口出错 " << result;return;}// 登录服务器TapAPIQuoteLoginAuth loginAuth;memset(&loginAuth, 0, sizeof(TapAPIQuoteLoginAuth));strcpy(loginAuth.UserNo, username.c_str());strcpy(loginAuth.Password, password.c_str());loginAuth.ISModifyPassword = APIYNFLAG_NO;loginAuth.ISDDA = APIYNFLAG_NO;result = (pTapQuote_ != NULL) ? pTapQuote_->Login(&loginAuth) : -999;if (result != TAPIERROR_SUCCEED){LOG_INFO << username_ << " 请求: 登录服务器出错 " << result;}
}
       登录请求发出后,OnRspLogin()及OnAPIReady()会响应请求,根据返回的信息,可以确定是否登录完成,以及API是否初始化完成,并在响应函数内做一些与主体程序有关的初始化工作。
void TAP_CDECL MarketDataSource::OnRspLogin(TAPIINT32 errorCode, const TapAPIQuotLoginRspInfo *info)
{}void TAP_CDECL MarketDataSource::OnAPIReady()
{}
       4. 订阅期货合约:
void MarketDataSource::subscribeContract(const ContractInfo &contract)
{TapAPIContract tapContract;memset(&tapContract, 0, sizeof(TapAPIContract));tapContract.Commodity.CommodityType = TAPI_COMMODITY_TYPE_FUTURES;strcpy(tapContract.Commodity.ExchangeNo, contract.ExchangeNo.c_str());strcpy(tapContract.Commodity.CommodityNo, contract.CommodityNo.c_str());strcpy(tapContract.ContractNo1, contract.ContractNo.c_str());tapContract.CallOrPutFlag1 = TAPI_CALLPUT_FLAG_NONE;tapContract.CallOrPutFlag2 = TAPI_CALLPUT_FLAG_NONE;sessionId_ = 0;TAPIINT32 result = pTapQuote_->SubscribeQuote(&sessionId_, &tapContract);if (result == TAPIERROR_SUCCEED){LOG_INFO << username_ << " "<< "请求: 合约订阅成功" << " "<< contract.CommodityNo << contract.ContractNo;}else{LOG_INFO << username_ << " "<< "请求: 合约订阅失败" << " "<< contract.CommodityNo << contract.ContractNo << " "<< "错误码: " << result;}
}
       上述代码主要参考易盛文档编写,比较简单,按照文档说明,填写正确参数,然后调用SubscribeQuote()函数即可。
       5. 接收行情数据:
void TAP_CDECL MarketDataSource::OnRtnQuote(const TapAPIQuoteWhole *info)
{if (info != NULL){TapAPIQuoteWhole marketData;memcpy(&marketData, info, sizeof(TapAPIQuoteWhole));LOG_INFO << "行情更新:"<< marketData.DateTimeStamp << " "<< marketData.Contract.Commodity.CommodityType << " "<< marketData.Contract.Commodity.ExchangeNo << " "<< marketData.Contract.Commodity.CommodityNo << " "<< marketData.Contract.ContractNo1 << " "<< marketData.QLastPrice << " "<< username_;}
}
       该方法属于易盛的回调函数,需要自己重写,易盛的sdk会自动调用。一旦合约订阅成功,在交易时间段内,就会有行情数据源源不断的推送过来,行情信息还是很丰富的,字段较多,需要按照项目需求,摘录一些重要字段然后整理使用,比较常用的主要有昨收盘价,昨结算价,开盘价,最新价,买一价,卖一价,买一量,卖一量,涨幅等等。易盛文档中提到行情是每秒2条数据,实际测试时发现,有的期货品种有时每秒会多于2条数据。注意,这里并不是一次把所订阅的合约全推送过来,而是一次推一个合约的行情,所以这个函数调用的非常频繁,一定不能阻塞。
       上面只是大体流程,具体如何写出高效、健壮、稳定的程序,以美原油合约为例,工作日全天23小时交易,那么程序怎么着也得5*24小时运行,并做到高效分发数据,还是需要时间慢慢调试完善的 。


       参考资料:
       http://www.esunny.com.cn/
       https://esunnyapi.gitbooks.io/esunnyapi_faq/content/EsunnyAPI.html



这篇关于国外期货程序化交易之行情获取讲解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1114977

相关文章

Python使用OpenCV实现获取视频时长的小工具

《Python使用OpenCV实现获取视频时长的小工具》在处理视频数据时,获取视频的时长是一项常见且基础的需求,本文将详细介绍如何使用Python和OpenCV获取视频时长,并对每一行代码进行深入解析... 目录一、代码实现二、代码解析1. 导入 OpenCV 库2. 定义获取视频时长的函数3. 打开视频文

嵌入式数据库SQLite 3配置使用讲解

《嵌入式数据库SQLite3配置使用讲解》本文强调嵌入式项目中SQLite3数据库的重要性,因其零配置、轻量级、跨平台及事务处理特性,可保障数据溯源与责任明确,详细讲解安装配置、基础语法及SQLit... 目录0、惨痛教训1、SQLite3环境配置(1)、下载安装SQLite库(2)、解压下载的文件(3)、

MySQL 获取字符串长度及注意事项

《MySQL获取字符串长度及注意事项》本文通过实例代码给大家介绍MySQL获取字符串长度及注意事项,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录mysql 获取字符串长度详解 核心长度函数对比⚠️ 六大关键注意事项1. 字符编码决定字节长度2

python3如何找到字典的下标index、获取list中指定元素的位置索引

《python3如何找到字典的下标index、获取list中指定元素的位置索引》:本文主要介绍python3如何找到字典的下标index、获取list中指定元素的位置索引问题,具有很好的参考价值,... 目录enumerate()找到字典的下标 index获取list中指定元素的位置索引总结enumerat

SpringMVC高效获取JavaBean对象指南

《SpringMVC高效获取JavaBean对象指南》SpringMVC通过数据绑定自动将请求参数映射到JavaBean,支持表单、URL及JSON数据,需用@ModelAttribute、@Requ... 目录Spring MVC 获取 JavaBean 对象指南核心机制:数据绑定实现步骤1. 定义 Ja

C++中RAII资源获取即初始化

《C++中RAII资源获取即初始化》RAII通过构造/析构自动管理资源生命周期,确保安全释放,本文就来介绍一下C++中的RAII技术及其应用,具有一定的参考价值,感兴趣的可以了解一下... 目录一、核心原理与机制二、标准库中的RAII实现三、自定义RAII类设计原则四、常见应用场景1. 内存管理2. 文件操

SpringBoot服务获取Pod当前IP的两种方案

《SpringBoot服务获取Pod当前IP的两种方案》在Kubernetes集群中,SpringBoot服务获取Pod当前IP的方案主要有两种,通过环境变量注入或通过Java代码动态获取网络接口IP... 目录方案一:通过 Kubernetes Downward API 注入环境变量原理步骤方案二:通过

使用Python实现获取屏幕像素颜色值

《使用Python实现获取屏幕像素颜色值》这篇文章主要为大家详细介绍了如何使用Python实现获取屏幕像素颜色值,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 一、一个小工具,按住F10键,颜色值会跟着显示。完整代码import tkinter as tkimport pyau

Java进程CPU使用率过高排查步骤详细讲解

《Java进程CPU使用率过高排查步骤详细讲解》:本文主要介绍Java进程CPU使用率过高排查的相关资料,针对Java进程CPU使用率高的问题,我们可以遵循以下步骤进行排查和优化,文中通过代码介绍... 目录前言一、初步定位问题1.1 确认进程状态1.2 确定Java进程ID1.3 快速生成线程堆栈二、分析

python获取cmd环境变量值的实现代码

《python获取cmd环境变量值的实现代码》:本文主要介绍在Python中获取命令行(cmd)环境变量的值,可以使用标准库中的os模块,需要的朋友可以参考下... 前言全局说明在执行py过程中,总要使用到系统环境变量一、说明1.1 环境:Windows 11 家庭版 24H2 26100.4061