### wss-pool ## 项目说明 根据撮合系统需求,实现一个广播分发的webSocket数据服务; * 对接第三方数据服务[火币,币安,OKX,股票...]. * 基于go-websocket提供高性能的、稳定的、时效性的数据服务. * 实现用户订阅功能 * 实现数据分发功能 ## Benchmarks #现货数据ws调用规则 *ws://127.0.0.1:端口/quotes-wss - (1)客户端ping： { "type":"ping", "symbol":"ping" } - (2)订阅： { "type":"subscribe", "symbol":"market.btcusdt.kline.1min" } - (3)取消订阅： { "type":"unSubscribe", "symbol":"market.btcusdt.kline.1min" } | Benchmark name | 服务端端口| | ------------------------------ | ---------:| | wssPool服务 | :8861| | 数采集服务 | :8852| *服务启动说明 - wssPool服务启动：./服务名称 --check=server --hostS 127.0.0.1 --addrS 服务端端口号 - 数采集服务端启动：./服务名称 --check=gather --hostG 127.0.0.1 --addrG 服务端端口号 #现货-合约-股票静态数据服务 | Static Services name | 服务名称 | | ------------------------------ | --------------------:| | 现货-K线数据（蜡烛图） | spots/kline| | 现货-聚合行情（Ticker） | spots/merged| | 现货-所有交易对的最新 | spots/tickers| | 现货-最近市场成交记录 | spots/trade| | 现货-市场深度数据 | spots/depth| | 现货-最近24小时行情数据 | spots/detail| | 现货-获得近期交易记录 | spots/history/trade| | 现货列表数据服务 | spots/merged/list| | 合约-获取行情深度数据 | contract/depth| | 合约-获取市场最优挂单 | contract/bbo| | 合约-K线数据获取 | contract/history/kline| | 合约-行情数据信息 | contract/merged | | 合约-获取标记价格的K线数据 | contract/history/price_kline | | 合约-批量获取聚合行情（V2) | contract/batch_merged | | 合约-获取市场最近成交记录 | contract/trade| | 合约-批量获取最近的交易记录 | contract/history/trade| | 合约-平台历史持仓量查询 | contract/swap_his_open_interest| | 合约-获取合约的溢价指数K线 | contract/history/linear_swap_premium_index_kline| | 合约-获取实时预测资金费率的K线数据 | contract/history/linear_swap_estimated_rate_kline| | 合约-获取基差数据 | contract/history/linear_swap_basis | *服务启动说明 - 服务端启动：./staticS --check=gin --hostC 127.0.0.1 --addrC :8851 *端口配置 - 静态服务端口：8851 #现货-合约-股票静态服务调用规则 - http://127.0.0.1:8851/服务名称 # 股票服务 ### supervisor 管理服务 ``` 1、http静态服务 WEB主服务端启动：服务名称 --check gin --hostS 0.0.0.0 --addrS :88 2、(美股|外汇[实时|买一卖一])行情服务 外汇分发服务：服务名称 --check collectForex --hostS 0.0.0.0 --addrS :7778 --config /home/ubuntu/wss-server/config/config.yaml 外汇采集服务：服务名称 --check gatherForex --hostS 0.0.0.0 --addrS :8965 --model forex --config /home/ubuntu/wss-server/config/config.yaml 美股分发服务：服务名称 --check collectUs --hostS 0.0.0.0 --addrS :7777 --config /home/ubuntu/wss-server/config/config.yaml 美股采集服务：服务名称 --check gatherUs --hostS 0.0.0.0 --addrS :8964 --model usShare --config /home/ubuntu/wss-server/config/config.yaml 3、股票采集和更新服务 印度期权股票服务端启动：服务名称 --check indiaOption --hostS 0.0.0.0 --addrS :95 指数股票服务端启动：服务名称 --check stockIndex --hostS 0.0.0.0 --addrS :92 日本股票服务端启动：服务名称 --check japanStock --hostS 0.0.0.0 --addrS :86 印尼股票服务端启动：服务名称 --check indonesiaStock --hostS 0.0.0.0 --addrS :89 泰国股票服务端启动：服务名称 --check thailandStock --hostS 0.0.0.0 --addrS :90 印度股票服务端启动：服务名称 --check indiaStock --hostS 0.0.0.0 --addrS :91 马来股票服务端启动：服务名称 --check malaysiaStock --hostS 0.0.0.0 --addrS :93 新加坡股票服务端启动：服务名称 --check singaporeStock --hostS 0.0.0.0 --addrS :94 港股票服务端启动：服务名称 --check hongkongStock --hostS 0.0.0.0 --addrS :96 英股票服务端启动：服务名称 --check ukStock --hostS 0.0.0.0 --addrS :97 德股票服务端启动：服务名称 --check germanyStock --hostS 0.0.0.0 --addrS :98 巴西股票服务端启动：服务名称 --check brazilStock --hostS 0.0.0.0 --addrS :103 美股票服务端启动：服务名称 --check usStock --hostS 0.0.0.0 --addrS :102 ``` ### cron 管理服务(行情报警、指数、泰股、马股、港股、印度股、印尼股、新加坡股、英股、德股、法股、巴西、日本) ``` */20 * * * 1-5 root /home/ubuntu/wss-server/checkStock --check tickDB --model checkStock --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/checkStock.log 2>&1 & */5 * * * 1-6 root /home/ubuntu/wss-server/stockIndex --check tickDB --model stockIndex --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/stockIndex.log 2>&1 & */5 * * * 1-5 root /home/ubuntu/wss-server/ukStock --check tickDB --model southAsiaStock --contract UK --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/ukStock.log 2>&1 & */5 * * * 1-5 root /home/ubuntu/wss-server/indiaStock --check tickDB --model southAsiaStock --contract India --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/indiaStock.log 2>&1 & */5 * * * 1-5 root /home/ubuntu/wss-server/thailandStock --check tickDB --model southAsiaStock --contract Thailand --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/thailandStock.log 2>&1 & */5 * * * 1-5 root /home/ubuntu/wss-server/malaysiaStock --check tickDB --model southAsiaStock --contract Malaysia --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/malaysiaStock.log 2>&1 */5 * * * 1-5 root /home/ubuntu/wss-server/hongkongStock --check tickDB --model southAsiaStock --contract HongKong --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/hongkongStock.log 2>&1 & */5 * * * 1-5 root /home/ubuntu/wss-server/indonesiaStock --check tickDB --model southAsiaStock --contract Indonesia --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/indonesiaStock.log 2>&1 & */5 * * * 1-5 root /home/ubuntu/wss-server/singaporeStock --check tickDB --model southAsiaStock --contract Singapore --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/singaporeStock.log 2>&1 & */5 * * * 1-5 root /home/ubuntu/wss-server/germanyStock --check tickDB --model southAsiaStock --contract Germany --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/germanyStock.log 2>&1 & */5 * * * 1-5 root /home/ubuntu/wss-server/franceStock --check tickDB --model southAsiaStock --contract France --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/franceStock.log 2>&1 & */5 * * * 1-5 root /home/ubuntu/wss-server/japanStock --check tickDB --model southAsiaStock --contract Japan --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/japanStock.log 2>&1 & ``` ### 更新美股上一次行情价格 ``` 8 9 * * * root /home/ubuntu/wss-server/preClose --check tickDB --model previousClose --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/preClose.log 2>&1 & ``` ### K线数据优化 ``` 12 22 * * 2-5 root /home/ubuntu/wss-server/deleteSpot --check tickDB --model deleteSpot --contract false --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/deleteSpot.log 2>&1 & ``` ### 插针数据推送 ``` */1 * * * * root /home/ubuntu/wss-server/stockCloseData --check tickDB --model stockCloseData --config /home/ubuntu/wss-server/config/config.yaml>>/var/log/stockCloseData.log 2>&1 & ```