沪深websocket level2/level1行情推送接入示例

行情接入包

golang packge:

package hangqingimport ("bufio""bytes""compress/flate""encoding/json""github.com/gorilla/websocket""io/ioutil""log""net/http""net/url""strings""sync""time"
)type ServerAddrRsp struct {Code   string `json:"code"`Server string `json:"server"`
}type Hq struct {token    string          //jvQuant Tokenserver   string          //websocket服务器地址conn     *websocket.Conn //websocket连接cmdChan  chan stringexitChan chan intlv1Deal  func(string string) //level1行情处理方法lv2Deal  func(string string) //level2行情处理方法wg       *sync.WaitGroup
}//实例初始化
func (hq *Hq) Construct(token, serAddr string, lv1Handle, lv2Handle func(string string)) {hq.token = tokenif serAddr == "" {hq.server = hq.initServer()}hq.lv1Deal = lv1Handlehq.lv2Deal = lv2Handlehq.conn = hq.connect()hq.wg = &sync.WaitGroup{}hq.cmdChan = make(chan string, 128)hq.exitChan = make(chan int)//接收协程hq.wg.Add(2)go func() {hq.receive()hq.wg.Done()}()//发送协程go func() {hq.cmd()hq.wg.Done()}()
}//获取行情服务器地址
func (hq *Hq) initServer() (server string) {params := url.Values{"market": []string{"ab"},"type":   []string{"websocket"},"token":  []string{hq.token},}req := "http://jvquant.com/query/server?" + params.Encode()rb, err := HttpOnce(req, nil, nil, 3000)if err != nil {log.Fatalln("获取行情服务器地址失败:", req, err)}rspMap := ServerAddrRsp{}err = json.Unmarshal(rb, &rspMap)if err != nil {log.Fatalln("解析行情服务器地址失败:", string(rb), err)}server = rspMap.Serverif rspMap.Code != "0" || server == "" {log.Fatalln("解析行情服务器地址失败:", string(rb))}log.Println("获取行情服务器地址成功:", server)return
}//连接行情服务器
func (hq Hq) connect() (conn *websocket.Conn) {wsUrl := hq.server + "?token=" + hq.tokenconn, _, err := websocket.DefaultDialer.Dial(wsUrl, nil)if err != nil {log.Fatalln("行情服务器连接错误:", err)}return
}//增加level1行情订阅
func (hq Hq) AddLv1(codeArr []string) {cmd := "add="cmdArr := []string{}for _, code := range codeArr {cmdArr = append(cmdArr, "lv1_"+code)}cmd = cmd + strings.Join(cmdArr, ",")hq.SendRawCmd(cmd)
}//增加level2行情订阅
func (hq Hq) AddLv2(codeArr []string) {cmd := "add="cmdArr := []string{}for _, code := range codeArr {cmdArr = append(cmdArr, "lv2_"+code)}cmd = cmd + strings.Join(cmdArr, ",")hq.SendRawCmd(cmd)
}//指令入队列
func (hq Hq) SendRawCmd(cmd string) {hq.cmdChan <- cmd
}//关闭行情连接
func (hq Hq) Close() {close(hq.cmdChan)hq.exitChan <- 1hq.conn.Close()
}//线程阻塞等待
func (hq Hq) Wait() {hq.wg.Wait()
}//websocket指令发送
func (hq Hq) cmd() {for cmd := range hq.cmdChan {log.Println("发送指令:" + cmd)err := hq.conn.WriteMessage(websocket.TextMessage, []byte(cmd))if err != nil {log.Println("指令发送错误:", err)}}
}//websocket行情接收处理
func (hq Hq) receive() {for {select {case <-hq.exitChan:log.Print("接收协程退出")returndefault://阻塞接收messageType, rb, err := hq.conn.ReadMessage()if err != nil {log.Print("接收错误:", err)}//文本消息if messageType == websocket.TextMessage {log.Println("Text响应:", string(rb))}//二进制消息if messageType == websocket.BinaryMessage {unZipByte := DeCompress(rb)text := string(unZipByte)ex1 := strings.Split(text, "\n")for _, ex1r := range ex1 {ex2 := strings.Split(ex1r, "=")if len(ex2) == 2 {code := ex2[0]hqs := ex2[1]if strings.HasPrefix(code, "lv1_") {hq.lv1Deal(hqs)}if strings.HasPrefix(code, "lv2_") {hq.lv2Deal(hqs)}}}}}}
}//二进制数据解压方法
func DeCompress(b []byte) []byte {var buffer bytes.Bufferbuffer.Write([]byte(b))reader := flate.NewReader(&buffer)var result bytes.Bufferresult.ReadFrom(reader)reader.Close()return result.Bytes()
}
//http请求封装
func HttpOnce(Url string, headers, postData map[string]string, msTimeOut int) (r []byte, err error) {client := &http.Client{Timeout: time.Duration(time.Duration(msTimeOut) * time.Millisecond),}method := http.MethodGetr = []byte{}err = nilif len(headers) == 0 {headers = map[string]string{}}if len(postData) != 0 {method = http.MethodPostheaders["Content-Type"] = "application/x-www-form-urlencoded"}postParam := url.Values{}for k, v := range postData {postParam.Set(k, v)}postParamBuff := bytes.NewBufferString(postParam.Encode())req, err := http.NewRequest(method, Url, postParamBuff)if err != nil {return r, err}for k, v := range headers {req.Header.Add(k, v)}resp, er := client.Do(req)if er != nil {err = erreturn}defer resp.Body.Close()if err != nil {return r, err}br := bufio.NewReader(resp.Body)r, err = ioutil.ReadAll(br)return r, err
}

参考地址:https://github.com/jvQuant/OpenAPIDemo

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/4233.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【方案解决思路】RPC服务器不可用

当在SCCM服务器上使用wmic /node:<客户端IP> process list命令时&#xff0c;如果遇到“RPC服务器不可用”的错误&#xff0c;这通常意味着SCCM服务器无法通过RPC协议与远程客户端通信。以下是一些可能的解决步骤&#xff1a; 检查远程客户端的RPC服务&#xff1a; 确保远…

C++下跨平台websocket库及使用示例

websocketpp库使用非常方便&#xff0c;开源&#xff0c;可跨平台&#xff0c;内部实现全部是head文件&#xff0c;无cpp&#xff0c;接口简单易用。源码路径比如 https://github.com/zaphoyd/websocketpp.git 使用方法是&#xff0c;先下载源码包并复制道工程的include目录下…

OpenResty 操作 Redis 和 MySQL

OpenResty 是一个基于 Nginx 的 Web 开发平台&#xff0c;它通过内置的方式集成了 LuaJIT&#xff0c;并内置了很多常用的第三方 Nginx 模块&#xff0c;使得开发人员可以使用 Lua 脚本来扩展 Nginx 的功能&#xff0c;这样就使得 OpenResty 可以非常方便地操作 Redis 和 MySQL…

springBoot加载配置文件

1. 说明 Spring Boot会自动加载application.properties或application.yml&#xff0c;所放置的位置如下表&#xff0c;所有位置的文件都会被加载&#xff08;互补配置&#xff09;&#xff0c;高优先级配置内容会覆盖低优先级配置内容。 自动加载配置文件的目录及优先级 位置优…

selenium 自动化测试课上实操指南1——百度搜索

1.环境准备 下面的所有资源可以从超星班级资料中下载&#xff0c;机房的同学在收到的文件夹中可以找到文件 非本校同学&#xff0c;免费加入学银在线课程&#xff0c;就可以在资料 根目录 > 02 课件新 > week09 web自动化测试02 里下载本次实操资料 1&#xff09;安…

【打工日常】云原生之搭建私有化web在线聊天软件LumenIM

一、LumenIM介绍 1.LumenIM简介 Lumen IM 是一个网页版在线聊天项目&#xff0c;前端使用 Naive UI Vue3&#xff0c;后端采用 GO 开发。 2.LumenIM功能 基于 WebSocket 服务做消息即时推送 支持私聊及群聊 支持多种聊天消息类型 例如:文本、代码块、图片及其它类型文件&…

JAVA对象的实例化内存布局与访问定位刨析

目录 1. 创建对象的方式 1.1 创建对象方式具体描述 2. 创建对象的步骤 2.1 判断对象对应的类是否加载、链接及初始化 2.2 为对象分配内存 2.3 处理并发安全问题

15.接口自动化学习-Mock(挡板/测试桩)

场景&#xff1a; 新需求还未开发时&#xff0c;使用mock提早介入测试&#xff0c;等后边开发后&#xff0c;进行调试 三方接口返回效率低&#xff0c;使用mock技术走通流程 1.mock方式 &#xff08;1&#xff09;如果会写django或flask,可以写简单对应的代码 &#xff08;…

lua编译器介绍

Lua编译器是将Lua语言编写的源代码转换为可执行代码的工具 一、实现原理 Lua编译器的核心任务是将Lua源代码&#xff08;纯文本文件&#xff09;转换为可执行的二进制代码&#xff08;字节码&#xff09;。这一过程通常包括词法分析、语法分析、语义分析、中间代码生成、优化以…

互联网摸鱼日报(2024-04-23)

互联网摸鱼日报(2024-04-23) 36氪新闻 重塑城市&#xff1a;AI驱动的城市模型如何改变治理 Windows将迎来第三方广告&#xff0c;微软终究还是“饿了” 加码内容化&#xff0c;或是京东攻占下沉市场的必由之路 同时押注两条路线&#xff0c;广汽智驾能领先华为和小鹏吗&…

为什么需要BigDecimal类

一、BigDecimal类介绍 BigDecimal 类在 Java 中主要用于提供高精度的浮点数运算。在 Java 中&#xff0c;float 和 double 类型并不适合进行高精度的金融计算&#xff0c;因为它们无法精确表示所有的小数。例如&#xff0c;0.1 的二进制表示是无限循环的&#xff0c;所以 floa…

MySQL 自建数据库慢日志分析

文章目录 前言1. 参数介绍1.1 慢日志参数1.2 慢日志切割 2. pt-query-digest2.1 离线分析2.2 在线分析2.3 常用参数 总结 前言 慢 SQL 是指 MySQL 中执行时间超过指定阈值的语句将被记录到 Slow log 文件中的查询。慢 SQL 的风险是可能随时都会因为某种原因而被触发&#xff0…

博客文章导航(实时更新)

一、计算机基础 链接&#xff1a;http://t.csdnimg.cn/ZtfmC 二、软件开发 链接&#xff1a;http://t.csdnimg.cn/cdT6H 三、数据结构与算法 链接&#xff1a;http://t.csdnimg.cn/XfoU0 四、计算机视觉 链接&#xff1a;http://t.csdnimg.cn/p21Y3 五、大语言模型 链…

Mysql--基础知识点--0.1--脏读、不可重复读、幻读

1 脏读、不可重复读、幻读 1.1 脏读 如果一个事务读到了另一个事务已修改且未提交的数据&#xff0c;则发生了脏读现象。 1.2 不可重复读 在一个事务里面多次读取同一个数据&#xff0c;若前后两次读到的数据不一致&#xff0c;则发生不可重复读现象。 1.3 幻读 在一个…

redis7 for windows的安装教程

本篇博客主要介绍redis7的windows版本下的安装教程 1.redis介绍 Redis&#xff08;Remote Dictionary Server&#xff09;是一个开源的&#xff0c;基于内存的数据结构存储系统&#xff0c;可用作数据库、缓存和消息代理。它支持多种数据结构&#xff0c;如字符串、哈希表、列…

【软考高项】二十六、范围管理基础内容

一、管理基础 产品范围和项目范围 产品范围强调结果&#xff0c;项目范围强调结果 管理的新实践 &#xff1a;需求一直是项目管理的关注重点&#xff0c;需求管理过程结束于需求关闭&#xff0c;即把产品、服务或成果移交给接收方&#xff0c;以便长期测量、监控、实现并维持收…

three.js 学习笔记 | 光线投射技术 - 包围盒(碰撞检测)

文章目录 three.js 学习笔记光线投射技术实现3D场景交互事件 THREE.Raycaster坐标系的转换案例&#xff1a;选中的模型变为红色 包围盒Box3 - 碰撞检测AABB包围盒辅助器Box3Helper案例1&#xff1a;创建AABB包围盒/包围球computeBoundingBox与boundingBox 搭配使用&#xff0c;…

PHP中的会话管理是如何工作的?

PHP中的会话管理是如何工作的&#xff1f; PHP中的会话管理是一个关键特性&#xff0c;它允许开发者跟踪和识别用户的活动&#xff0c;从而提供个性化的体验。会话管理主要依赖于会话ID、会话数据以及会话存储机制来实现。下面将详细解释PHP中会话管理的工作原理及其各个组成部…

vivado Aurora 8B/10B IP核(1)

Aurora 8B/10B IP 支持 Kintex -7, Virtex -7 FPGA GTP 和 GTH 收发器&#xff0c;Artix -7 FPGA GTP 收发器, Zynq -7000 GTP and GTP 收发器。Aurora 8B/10B IP core 可以工作于单工或者全双工模式。IP CODE的使用也非常简单&#xff0c;支持 AMBA总线的 AXI4-Stream 协议。…

字符串函数及其模拟实现

目录 strlen函数介绍模拟实现 strcpy函数介绍模拟实现 strcat函数介绍模拟实现 strcmp函数介绍模拟实现 strncpy函数介绍模拟实现 strncat函数介绍模拟实现 strncmp函数介绍模拟实现 strtokstrstr函数介绍模拟实现 strerrorperror strlen 函数介绍 函数介绍&#xff1a; 字符串…