简单的股票行情演示(一) - 实时标的数据

这篇具有很好参考价值的文章主要介绍了简单的股票行情演示(一) - 实时标的数据。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

    • 一、概述
    • 二、效果展示
    • 三、实现代码
      • 1、行情数据中心
      • 2、数据拉取模块
      • 3、基础服务模块
      • 4、UI展示
    • 四、相关文章

原文链接:简单的股票行情演示(一) - 实时标的数据

一、概述

很长一段时间都有一个想法,使用QCP去做一个行情展示小事例,一直没有着手开发的原因主要是行情数据源的问题,毕竟稳定的数据才是核心,加上今年5月份有了小宝宝也一直比较忙。

最近得空研究了下用C++实现股票行情展示相关内容,主要策略是通过拉取网上一些免费的开源接口数据,然后存储到本地,在通过代码读取需要的日期数据进行展示。互联网拉取行情数据方法网上随手百度后会发现有一大堆,调取个别接口进行获取数据也是很方便的,比如通过新浪开源获取A股股票接口获取实时行情数据就很简单,浏览器url输入框中输入http://hq.sinajs.cn/list=sz002208,sh601318这段测试连接,按下回车,就会拿到list指定的两支股票数据,效果如下图所示。

需要特别注意:该接口拉取频繁后,会被后台403,所以本地需要做一些策略,尽可能减少无效拉取

简单的股票行情演示(一) - 实时标的数据
尝到了简单的甜头之后,接下来就是疯狂百度、google,尽可能全面的整理开源的行情数据源,网上虽然文章很多,但是重复的内容特别多,讲的比较好的文章有新浪股票 api、股票数据 API 接口合集、实时行情API,通过看这几篇文章能大概了解到一些皮毛,简单使用不成问题。总的来说提供了一个可操作的入口,数据源的问题算是暂时得到一部分解决,至于其他更完善的数据后续文章会有介绍,是由开源软件提供,而且文档比较详细,之后更多的数据将会使用开源程序进行获取

实时行情数据有了之后,接下来就是C++侧代码实现,主要分为异步数据拉取、数据写入本地文件、数据层读取,回调给UI展示,本篇文章接下来的主要内容将会讲解怎么拉取数据、回调给UI等流程。

二、效果展示

如下效果图所示,是一个简单的多窗口程序,支持同时拉取多支股票实时行情数据并回调给UI。拿其中一个行情数据展示窗口为例来说明,数据源是来自新浪行情API接口,测试程序UI展示总共分上中下三段,上半部分主要是股票盘口数据,展示开收盘价格、实时成交量等,中段是股票买卖五档数据,最底下白色框中是数据源内容,也就是从互联网接口拉取后的数据。

正常情况下测试程序只会跑一个窗口,图示中多个窗口主要是为了观察方便。

简单的股票行情演示(一) - 实时标的数据

三、实现代码

1、行情数据中心

要想实现数据复用,并减少Server压力,数据中心是必不可少的模块,举一个简单例子,当UI界面上展示的两支股票相同时,那么数据中心只会维护一支股票数据,并实时更新然后同步给两份UI界面。

如下代码所示,为行情中心接口类,其中展示了如何去订阅股票详情数据和取消订阅,IQuoteCall这是订阅者唯一标识,每一个想要获取数据的对象都应该是一个IQuoteCall、或者持有一个IQuoteCall

struct QUOTECENTER_EXPORT IQuoteCenter
{
public:
 virtual ~IQuoteCenter(){}

public:
 //订阅detail
 virtual void SubscribeDetail(IQuoteCall * observer, const SecurityInfo & security) = 0;
 virtual void UnSubscribeDetail(IQuoteCall * observer) = 0;

    .
    .
    .

 //取消所有数据订阅
 virtual void UnSubscribe(IQuoteCall * observer) = 0;

 .
 .
 .
};

IQuoteCall接口类中有一个UpdateDetail接口,通过重写该接口即可获取订阅的标的行情数据,切换标的时从新订阅即可,之前订阅的标的会被自动取消。

股票实时行情数据需要启动一个轮训任务,每隔3秒去请求一次当前订阅的所有标的数据,有了时间服务后,我们只需要抛一个任务对象和时间间隔,之后的定时触发操作则会自动被执行。

QuoteCenter::QuoteCenter()
{
 qRegisterMetaType<DetailCNItem>("DetailCNItem");
 qRegisterMetaType<QList<DetailCNItem>>("QList<DetailCNItem>");
 m_strTaskID = Services::TimerServiceInstance()->AddTask(&DoRequests, 3000);
    .
    .
    .
}

DoRequests函数比较重要,可谓之承上启下,关键桥梁作用,因此这里单独做下说明。

首先DoRequests是一个C函数,被行情模块注册到时间管理器中,该函数会在指定时间间隔后触发一次,每次任务触发我们都需要在主线程中构造一个任务请求工作者,并把任务执行完成后的触发信号与行情对象的接收槽函数绑定,之后把任务对象抛给网络请求服务即可。任务对象后续还会有更加详细的说明,具体参看对detail请求对象说明。

void DoRequests(long long mseconds)
{
 .
 .
 .
 DetailWorker * detail = new DetailWorker(securitys);
 QObject::connect(detail, &DetailWorker::Response
  , static_cast<QuoteCenter *>(Quote::QuoteCenterInstance()), &QuoteCenter::OnDetailResponse);
 RLNet::NetworkInstance()->AddTask(detail);
}

2、数据拉取模块

本地数据的唯一来源就是从网络拉取,为了程序运行流程起见,必须要运行在工作线程中,防止阻塞UI,我们开发此演示程序是基于Qt开发框架下,所以线程创建、线程交互将会变的很简单,具体细节接下来一步一步讲解。

线程池

既然用到Qt,那么线程池肯定也要用Qt的,这样我们开发起来会省很多力气,如下代码所示,简单的几行代码我们就搞出来一个线程池,我们只管往池子里丢任务,当池子中有空闲线程时就会帮我们处理任务,是不是非常nice。

void RLNetwork::AddTask(CommonWorker * task)
{
 // 添加任务
 QThreadPool::globalInstance()->start(task);
}

RLNetwork::RLNetwork()
{
 curl_global_init(CURL_GLOBAL_DEFAULT);
 // 线程池初始化,设置最大线程池数
 QThreadPool::globalInstance()->setMaxThreadCount(8);
}

RLNetwork::~RLNetwork()
{
 curl_global_cleanup();
}

任务对象

有了线程池后,我们只管创建需要的task,然后丢到池子中,任务的触发时机将交给Qt线程池进行管理,我们只需要关心任务中要干什么、任务结束后怎么通知给外部即可。

任务基类

为了减少大量重复代码,这里我们定义一个任务基类,基类中完成每个请求任务都需要操作的内容,然后把请求体和写入内容封装成接口,供子类重写。

抽象内容包括:

  1. libcurl请求初始化、参数配置和清理
  2. 回调函数取到返回数据后整理标准字符串转发给子类Write函数
class RLNETWORK_EXPORT CommonWorker : public QObject, public QRunnable
{
public:
 CommonWorker();
 ~CommonWorker();

public:
 virtual void run() override;

 virtual void Write(char * data, std::size_t len) = 0;
 virtual void DoRequest(CURL * curl) = 0;

 static size_t  CurlWriteCb(char *ptr, size_t size, size_t nmemb, void *userdata);

private:
};

Detail请求

说了这么多,终于到了最关键的detail请求环节,如下StockListWorker代码所示,当Detail请求完成后,通过Response信号通知外部任务已完成,标的detail存放在了filePath指定的文件中。

对于StockListWorker对象有以下几点需要注意:

  1. 构造于主线程中,并且请求完成信号与主线程中槽函数所绑定
  2. DoRequest、Write和信号函数均运行于工作线程中
  3. 任务基类中我们设置了setAutoDelete为true,因此所有的请求对象在执行完任务后都会析构
  4. 析构函数运行于工作线程中,与run函数所在线程一致
class RLNETWORK_EXPORT StockListWorker : public CommonWorker
{
 Q_OBJECT

public:
 StockListWorker(const QString & filePath);
 ~StockListWorker();

signals:
 void Response(const QString & filePath);

public:
 virtual void Write(char * data, std::size_t len) override;
 virtual void DoRequest(CURL * curl) override;

private:
 QString m_filePath;
 QFile m_file;
};

DoRequest函数是基类提供给我们重写发送请求使用,如下代码所示,展示了请求detail数据的过程,网络请求我们统一使用libcurl进行完成,不使用Qt网络库主要是觉着不好用。

void StockListWorker::DoRequest(CURL * curl)
{
 curl_easy_setopt(curl, CURLOPT_URL, StockListUrl);//准备发送request的url

 CURLcode res = curl_easy_perform(curl);
 if (res == CURLE_OK)
 {
  curl_off_t val = -1;
  curl_easy_getinfo(curl, CURLINFO_NAMELOOKUP_TIME_T, &val);

  emit Response(m_filePath);
 }
 else
 {
  std::cout << "curl_easy_perform() failed: " << curl_easy_strerror(res);
 }
}

3、基础服务模块

市场服务

市场服务主要提供市场相关接口,如下代码所示,IsTradingStatus接口获取当前标的所属市场是否属于交易状态,根据市场状态我们可以过滤一些无效操作,比如A股不开盘时,不需要请求detail等。

struct BASICSERVICES_EXPORT IMarketService
{
 virtual ~IMarketService(){}

 virtual bool IsTradingStatus(const SecurityInfo & security, long long mseconds) const = 0;
 virtual bool IsTradingStatus(const QList<SecurityInfo> & securitys, long long mseconds) const = 0;
 ·
 ·
 ·
};

时间服务

时间管理器对于数据中心是相当重要的,因为有了时间维度后,我们才能去定制一批时间相关的任务,比如轮训任务、获取当前时间等。

本文中的股票实时detail数据就需要添加了一个轮训任务,因为没有长连接的加持,很多数据都需要我们自己去跟服务器要,虽然这样会增大服务器的压力,但是目前除过长连接外没有其他更好的方式去完成这件事。

struct BASICSERVICES_EXPORT ITimerService
{
 virtual ~ITimerService(){}

 virtual QString AddTask(const std::function<void(long long)> & fun, long internal = 3000) = 0;
 virtual bool HasTask(const QString &) = 0;
 virtual void RemoveTask(const QString &) = 0;
 virtual void ImmediatelyTask(const QString &) = 0;
 virtual long long GetCurrentStamp() const = 0;
 ·
 ·
 ·
};

4、UI展示

订阅股票detail

如下代码所示,通过行情中心我们可以很简单的去订阅标的数据,之后通过重写UpdateDetail接口拿数据就行,其他的我们统一不用操心。

void HqSimple::on_pushButton_pull_clicked()
{
 const QString & name = ui.comboBox->currentText();
 const QString & id = ui.comboBox->currentData().toString();
 const QStringList & items = id.split('_');

 SecurityInfo info;
 info.market = items.at(0);
 info.symbol = items.at(1);
 info.secType = "STK";

 Quote::QuoteCenterInstance()->SubscribeDetail(this, info);
}

每一个需要订阅行情数据的对象目前都是继承自IQuoteCall,或者持有一个IQuoteCall,本篇文章包括后续系列文章都会采用第一种方案来实现数据订阅,关于继承和包含的优缺点及使用场景问题大家可以自行斟酌,本篇文章所讲述案列数据类型较少,使用继承足以完成目标。

struct QUOTECENTER_EXPORT IQuoteCall
{
	virtual ~IQuoteCall(){}

	virtual void UpdateDetail(const DetailCNItem &) = 0;
	.
	.
	.
};

A股Detail数据定义

/*
0:  通用股份    // 名字;
1 : 5.050       // 今日开盘价
2 : 5.060       // 昨日收盘价
3 : 5.090       // 当前价格
4 : 5.110       // 今日最高价
5 : 5.030       // 今日最低价
6 : 5.090       // 竞买价,即 “买一” 报价;
7 : 5.100       // 竞卖价,即 “卖一” 报价;
8 : 3963000     // 成交的股票数,转手乘 100
9 : 20106078.000// 成交金额 (元),转万除 10000
10 : 52800       //“买一” 申请 52800 股
11 : 5.090       //“买一” 报价;
12 : 90600       //“买二” 申请 90600 股
13 : 5.080       //“买二” 报价;
14 : 98500       //..
15 : 5.070       //..
16 : 105200      //..
17 : 5.060       //..
18 : 127900      //..
19 : 5.050       //..
20 : 104400      //“卖一” 申报 104400 股
21 : 5.100       //“卖一” 报价;
22 : 99700       //“卖二” 申报 99700 股
23 : 5.110       //“卖二” 报价;
24 : 111800      //..
25 : 5.120       //..
26 : 87500       //..
27 : 5.130       //..
28 : 73300       //..
29 : 5.140       //..
30 : 2022 - 02 - 14  // 日期
31 : 11 : 18 : 56   // 时间
*/

struct STOCKDATA_EXPORT DetailCNItem : public SecurityInfo
{
 //0-9
 QString name;  //名字
 double open;  //今日开盘价
 double preClose; // 昨日收盘价
 double lastprice; // 当前价格
 double high;  // 今日最高价
 double low;   // 今日最低价
 double bid;   // 竞买价,即 “买一” 报价;
 double ask;   // 竞卖价,即 “卖一” 报价;
 double volumn;  // 成交的股票数,转手乘 100
 double amount;  // 成交金额 (元),转万除 10000
 
 struct AskBid
 {
  double price;//买/卖价
  double volumn;//买/卖量
 };

 QVector<AskBid> asks;//卖五档 //10-19
 QVector<AskBid> bids;//买五档 //20-29
 
 //30-31
 QString date; // 日期
 QString time; // 时间

 QString source; //原始数据

 DetailCNItem();
 DetailCNItem(const QString & str);
 DetailCNItem(DetailCNItem && other);

 void Clear();
};

刷新数据

UI数据刷新这里就比较简单了,文章最开始已经描述过UI数据分为上中下三部分,上部和下部就是简单文案设置,然后通过qss加了一些涨跌色配置,这里就简单展示下部分代码。

void HqSimple::UpdateDetail(const DetailCNItem & data)
{
 ui.label_open->setText(QString::number(data.open, 'f', 2));
 .
 .
 .
 ui.label_amount->setText(QString::number(data.amount, 'f', 2));

 m_pListmodel->SetAskBid(data);

 ui.textEdit->setText(QStringLiteral("原始数据:") + data.source);
}

盘口数据分为6列:买档、买价格、买数量、卖数量、卖价格和卖档。实现起来也比较简单,标准MVC即可搞定,代码中表现为QAbstractListModel+QListView+QStyledItemDelegate,其中M和V都比较简单,简单的进行绑定之后就可以,这里主要说下绘制界面用的QStyledItemDelegate,其中最为关键的就是paint函数,相信用过Qt一年半载的同学都比较熟悉,代码如下所示,绘制代码比较简单就不做说明了,不明白的同学进行留言或者私聊即可。

void AskBidDelegate::paint(QPainter * painter, const QStyleOptionViewItem & option, const QModelIndex & index) const
{
 const DetailCNItem & detail = index.model()->data(index).value<DetailCNItem>();

 //left
 int y = 15;
 int lwidth = option.rect.width() / 2;

 const QPoint & gPos = QCursor::pos();
 const QPoint & lPos = option.widget->mapFromGlobal(gPos);
 int t = 0;
 if (lPos.x() >= 0 && lPos.x() <= lwidth)
 {
  t = 1;
 }
 else if (lPos.x() >= lwidth && lPos.x() <= lwidth * 2)
 {
  t = 2;
 }

 {
  painter->fillRect(option.rect.adjusted(0, 0, lwidth, 0)
   , t == 1 && option.state.testFlag(QStyle::State_MouseOver) ? QColor(28, 109, 83) : QColor(39, 67, 62));

  const DetailCNItem::AskBid & bid = detail.bids.at(index.row());
  const QString & bidName = QStringLiteral("买%1").arg(index.row() + 1);
  painter->setPen(QColor(Qt::white));
  painter->drawText(10, option.rect.top() + y, bidName);
  painter->setPen(QColor(Qt::red));
  painter->drawText(60, option.rect.top() + y, PriceText(bid.price));

  const QString & volumnName = PriceText(bid.volumn);
  int volumW = painter->fontMetrics().width(volumnName);
  painter->setPen(QColor(Qt::white));
  painter->drawText(lwidth - volumW, option.rect.top() + y, volumnName);
 }

 //right
 {
  painter->fillRect(option.rect.adjusted(option.rect.width() / 2, 0, 0, 0)
   , t == 2 && option.state.testFlag(QStyle::State_MouseOver) ? QColor(28, 109, 83) : QColor(68, 48, 58));
  const DetailCNItem::AskBid & ask = detail.asks.at(index.row());

  const QString & volumnName = PriceText(ask.volumn);
  painter->setPen(QColor(Qt::white));
  painter->drawText(lwidth + 10, option.rect.top() + y, volumnName);

  painter->setPen(QColor(Qt::green));
  painter->drawText(option.rect.width() - 98, option.rect.top() + y, PriceText(ask.price));

  const QString & askName = QStringLiteral("卖%1").arg(index.row() + 1);
  painter->setPen(QColor(Qt::white));
  painter->drawText(option.rect.width() - 28, option.rect.top() + y, askName);
 }
}

讲到这里,股票行情展示程序也差不都完成了,从数据订阅、数据求情、数据缓存、数据回调和数据刷新大致都说了一遍,最后贴上项目工程截图,大家可以参考。

简单的股票行情演示(一) - 实时标的数据

四、相关文章

  1. Qt 之股票组件 - 自选股 -- 列表可以拖拽、右键常用菜单
  2. Qt 之股票组件 - 股票检索 -- 支持搜索结果预览、鼠标、键盘操作
  3. QCustomplot使用分享(一) 能做什么事
  4. QCustomplot使用分享(二) 源码解读
  5. QCustomplot使用分享(三) 图
  6. QCustomplot使用分享(四) QCPAbstractItem
  7. QCustomplot使用分享(五) 布局
  8. QCustomplot使用分享(六) 坐标轴和网格线
  9. QCustomplot使用分享(七) 层(完结)

值得一看的优秀文章:

  1. 财联社-产品展示
  2. 广联达-产品展示
  3. Qt定制控件列表
  4. 牛逼哄哄的Qt库

如果您觉得文章不错,不妨给个打赏,写作不易,感谢各位的支持。您的支持是我最大的动力,谢谢!!!
 


很重要--转载声明

  1. 本站文章无特别说明,皆为原创,版权所有,转载时请用链接的方式,给出原文出处。同时写上原作者:朝十晚八 or Twowords

  2. 如要转载,请原文转载,如在转载时修改本文,请事先告知,谢绝在转载时通过修改本文达到有利于转载者的目的。文章来源地址https://www.toymoban.com/news/detail-506017.html


到了这里,关于简单的股票行情演示(一) - 实时标的数据的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 打通选股环节和行情显示链路!股票量化分析工具QTYX-V2.5.1

    目前股票量化分析工具QTYX已经打通了形态驱动选股和数据驱动选股之间的链路。比如双底选股、RPS选股、盘整平台突破选股得到的数据,可以叠加上财务数据、基本面数据、基金持仓数据,然后用条件表达式进行多因子综合排序,从而筛选出优质股票。 如果要更进一步提高

    2024年02月11日
    浏览(39)
  • python爬虫进阶篇:Scrapy中使用Selenium+Firefox浏览器爬取沪深A股股票行情

    上篇记录了Scrapy搭配selenium的使用方法,有了基本的了解后我们可以将这项技术落实到实际需求中。目前很多股票网站的行情信息都是动态数据,我们可以用Scrapy+selenium对股票进行实时采集并持久化,再进行数据分析、邮件通知等操作。 详情请看上篇笔记 items middlewares setti

    2024年02月04日
    浏览(65)
  • AI量化炒股是如何获取L2实时行情数据的呢?

    现在先说说证券行情吧。 1。国外的股票行情我就不谈了,这个我不是很了解,今天我来说说国内两大证券交易所,上交所和深交所两大交易所。 上交所的L1和深交所的L1行情,狭义的说就是五档行情,还是比较好获取,渠道很多,但是质量参差不齐。我说说质量稍微好点的,

    2024年01月20日
    浏览(42)
  • HTTP股票实时数据接口--沪深A股指数实时交易数据API接口

    沪深指数数据API文档 数据来源:必盈数据 请求方式:Get(直接在浏览器打开就可以看到返回的数据) 数据格式:标准Json格式[{},...{}] 数据时效:实时更新 API说明文档:接入指南 | 必盈API | 金融数据接口 指数列表数据 使用说明: 1、下方所有API接口连接均可直接点击打开,

    2024年02月03日
    浏览(42)
  • 如何用 python 获取实时的股票数据?

    Web爬取 Web爬取是指从网站上获取特定数据的过程。我们通常使用Python的Requests库来访问网站。网站会以HTML格式返回相应数据,我们需要使用Beautiful Soup库将HTML格式的数据转换为Python对象进行操作。 Python中,我们可以使用OpenPyXL库来读写Excel文件。使用OpenPyXL,我们可以创建、

    2024年02月20日
    浏览(88)
  • pytdx 调用实时行情

    pytdx 是一个 Python 库,可以用来调用通达信的实时行情。使用 pytdx 需要安装通达信软件,并且需要将 pytdx 和通达信的程序文件夹放在同一个目录下。 要调用 pytdx 获取实时行情,首先需要导入 pytdx 库并创建一个 TdxHq_API 对象。然后可以使用 get_security_quotes 函数获取实时行情。

    2024年02月11日
    浏览(43)
  • 4.3 Binance_interface APP 币本位合约行情-实时行情

    Github地址 PyTed量化交易研究院 方法 解释 get_bookTicker 获取一个产品的最优挂单 get_bookTickers 获取全部产品的最优挂单(列表格式) get_bookTickersMap 获取全部产品的最优挂单 (字典格式) get_tickerPrice 获取一个产品的最新价格 get_tickerPrices 获取全部产品的最新价格(列表格式)

    2024年02月19日
    浏览(41)
  • 伦敦金实时行情中的震荡

    不知道各位伦敦金投资者,曾经花过多长的时间来观察行情走势的表现,不知道大家是否有统计过,其实行情有60%-70%的时间,都会处于没有明显方向的震荡行情之中呢?面对长期的震荡行情,伦敦金投资者道理应该如何应对呢? 震荡行情事其实就是趋势的停顿,它与趋势行

    2024年02月07日
    浏览(40)
  • 简单的用Python采集股票数据,保存表格后分析历史数据

    字节跳动如果上市,那么钟老板将成为我国第一个世界首富 趁着现在还没上市,咱们提前学习一下用Python分析股票历史数据,抱住粗大腿坐等起飞~ 好了话不多说,我们直接开始正文 环境使用 Python 3.10 解释器 Pycharm 编辑器 模块使用 requests — 数据请求模块 csv - 保存csv表格

    2024年02月05日
    浏览(67)
  • QMT vs Ptrade 速度对比 (二)实时行情速度对比

    上一篇文章对了了QMT和Ptrade的获取历史行情速度,本篇文章继续对它俩的实时行情速度。 本文以获取市场所有可转债的实时行情为例子,比较二者的速度。 Ptrade获取所有可转债实时行情 目前市场上有480多只可转债,由于Ptrade内置的数据源不足以支撑可转债的大部分策略,所

    2024年02月07日
    浏览(81)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包