量化交易系统-接入网关设计-2

量化交易系统-接⼊⽹关设计-2客户端接⼊⽹关设计
384孔板
1.
客户端接⼊⽹关,上游对接PC客户端,下游对接消息总线和数据管理服务器,主要由如下功能:客户端连接会话管理。
客户端请求消息转发和服务端应答转发客户端。
订阅管理及消息推送。
客户端消息协议转换。
2. 体系结构
2.1 逻辑架构功能模块spi隔离芯片
2.2 功能模块
客户端接⼊⽹关由四个模块组成:
(a)客户端通讯消息处理模块。
(b)数据管理通讯消息处理模块。
(c)消息总线通讯消息处理模块。
(d)订阅管理推送模块。
1. 客户端消息处理模块
1. 功能说明
1. 负责客户端连接回话管理。
2. 客户端消息响应处理。
对消息进⾏协议转换(例如json协议转换成protobuf协议),转发到对应服务器处理。
DataPackConvertProtoUtils功能类负责将json协议转换成对应的protobuf协议格式。
1.
动力电池模拟电源1.
客户端消息处理器
客户端会话管理
1.
1.
//请求处理回调函数声明
using MsgHandlerCB = std::function<void(net::task_from_cli_sptr& task)>;
using MsgHandlerCBMap = std::map<int, MsgHandlerCB> ;
#define ON_MSG_CALLBACK(msg_id, cb) \
msg_id_cb_map_[msg_id] = std::bind(&cb, this, std::placeholders::_1)
每新增加⼀个消息,如果需要特殊处理,需要在RegisterMsgHandleCallback注册⼀个消息处理函数。否则,调⽤缺省消息处理函数onMsgCommonTask。
1. 数据管理消息处理模块
1.
⽬前所有数据查询直接⾛数据管理服务器,避免⼤流量查询占⽤消息总线的带宽,影响正常的交易,提交系统性能。
1.
增感油墨
1. 结构图
数据管理消息处理器
1.
1.
//请求处理回调函数声明
using MsgRspHandlerCB =  std::function<void(net::task_from_srv_sptr& task)>;
using MsgRspHandlerCBMap = std::map<int, MsgRspHandlerCB>;
#define ON_MSG_RSP_CALLBACK(msg_id, cb) \
msg_id_rsp_cb_map_[msg_id] = std::bind(&cb, this, std::placeholders::_1)
每新增加⼀个消息,如果需要特殊处理,需要在RegisterMsgHandleCallback注册⼀个消息处理函数。否则,调⽤缺省消息处理函数onMsgCommonTask。
1. 消息总线消息处理模块
1. 功能说明ir油墨
(1)消息总线消息响应处理。
对消息进⾏协议转换(例如protobuf协议转换成json协议格式)。如果是请求消息应答消息,根据会话管理信息,转发应答消息给客户端。如果是推送消息,调⽤订阅推送管理,将消息推送给订阅改消息的⽤户。
(2)ProtoConvertDataPackUtils功能类负责将protobuf协议转换成对应的json协议格式。
1.
1. 结构图
消息总线消息处理器
MsgPushMgr负责消息推送给订阅的⽤户
遥控器学习MsgSubMgr 负责管理消息的订阅
SessionMgr 负责客户端会话管理
1.
1. 接⼝
//请求处理回调函数声明
using MsgRspHandlerCB =  std::function<void(net::task_from_srv_sptr& task)>;
using MsgRspHandlerCBMap = std::map<int, MsgRspHandlerCB>;
#define ON_MSG_RSP_CALLBACK(msg_id, cb) \
msg_id_rsp_cb_map_[msg_id] = std::bind(&cb, this, std::placeholders::_1)每新增加⼀个消息,如果
需要特殊处理,需要在RegisterMsgHandleCallback注册⼀个消息处理函数。否则,调⽤缺省消息处理函数onMsgCommonTask。
1. 其他

本文发布于:2024-09-23 11:19:11,感谢您对本站的认可!

本文链接:https://www.17tex.com/tex/3/233544.html

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。

标签:消息   处理   客户端   协议   总线   模块
留言与评论(共有 0 条评论)
   
验证码:
Copyright ©2019-2024 Comsenz Inc.Powered by © 易纺专利技术学习网 豫ICP备2022007602号 豫公网安备41160202000603 站长QQ:729038198 关于我们 投诉建议