llf
/
wss-pool
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
1 Commit
1 Branch
0 Tags
330 KiB
 
Branch: master
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'master'
${ noResults }
wss-pool/README.md

8.0 KiB
Raw Permalink Blame History

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

#现货-合约-股票静态服务调用规则

股票服务

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 &