1. 该股票行情系统在股票交易时间具有实时推送股票最新数据的功能,主要功能有市场情 绪,展示股市大盘的涨跌数,A 股排行榜实时更新数据,股票 k 线数据,用户自选股等功能。 2. 主要负责行情数据订阅、处理、行情数据推送,技术指标算法实现,接口开发,参与各 模块功能的设计与开发;阅读官方文档重写 django channels 的 WebsocketConsumer 方法
2. 使用 django channels 开发,基于 websocket 协议,服务端向客户端主动推送行情数据, 数据实时性和稳定性提高 70%;使用 kafka 消息中间件和高吞吐和解耦的特性,解决行情登 录点个数限制问题;通过Redis技术缓存股票历史数据,缓解网站的访问压力和数据库的读 写压力;使用 celery 执行定时任务。
3. 技术栈:Django channels,Websocket,Celery,Redis,Kafka,Mysql