websocket level2行情接口构建交易系统

http://jvQuant.com/server?market=ab&type=websocket&token=<token>

{
  "code": "0",
  "server": "xx.xx.x.xx:xxxx/xxx"
}

ws://xx.xx.x.xx:xxxx/xxx?token=<token>

http://jvQuant.com/server?market=ab&type=trade&token=<token>

{
  "code": "0",
  "server": "xx.xx.x.xx:xxxx"
}

http://xx.xx.x.xx:xxxx/login?&token=<token>&acc=<资金账号>&pass=<密码>

{
  "code": "0",
  "ticket": "xxxx",
  "expire": xxx
}

http://xx.xx.x.xx:xxxx/check_hold?&token=<token>&ticket=<交易凭证>

{
  "code": "0",
  "message": "",
  "total": "501527.77",
  "usable": "422977.27",
  "day_earn": "16325.27",
  "hold_earn": "18273.22",
  "hold_list": [
    {
      "code": "128079",
      "name": "英联转债",
      "hold_vol": "0",
      "usable_vol": "0",
      "hold_earn": "12242.69",
      "day_earn": "12242.32"
    },
    {
      "code": "111013",
      "name": "新港转债",
      "hold_vol": "0",
      "usable_vol": "0",
      "hold_earn": "-560.93",
      "day_earn": "-560.96"
    }
  ]
}

http://xx.xx.x.xx:xxxx/check_order?&token=<token>&ticket=<交易凭证>

{
  "code": "0",
  "message": "",
  "list": [
    {
      "order_id": "1334564",
      "day": "20180402",
      "time": "142423",
      "code": "110074",
      "name": "精达转债",
      "type": "证券卖出",
      "status": "已成",
      "order_price": "151.885",
      "order_volume": "8000",
      "deal_price": "151.927",
      "deal_volume": "8000"
    }
  ]
}

http://xx.xx.x.xx:xxxx/<trade>?&token=<token>&ticket=<交易凭证>&code=<证券代码>&name=<证券名称>&price=<委托价格>&volume=<委托数量>

{
  "code": "0",
  "message": "",
  "order_id":"4362316"
}

http://xx.xx.x.xx:xxxx/cancel?&token=<token>&ticket=<交易凭证>&order_id=<委托编号>

{
  "code": "0",
  "message": "",
  "order_id":"4362316"
}

http://jvquant.com/query/history?&token=<token>&year=<数据年份>

http://jvquant.com/query/industry?&token=<token>

http://jvquant.com/query/bond?&token=<token>

#!python3
# -*- coding:utf-8 -*-
import time
import websocket
import zlib
 
 
# 发送订阅
def on_open(ws):
    ws.send("all=lv2_600519,lv1_000001")
 
 
# 接收推送
def on_message(ws, message, type, flag):
    # 命令返回文本消息
    if type == websocket.ABNF.OPCODE_TEXT:
        print(time.strftime('%H:%M:%S', time.localtime(time.time())), "Text响应:", message)
        print(time.strftime('%H:%M:%S', time.localtime(time.time())), "Text响应:", message)
    # 行情推送压缩二进制消息，在此解压缩
    if type == websocket.ABNF.OPCODE_BINARY:
        rb = zlib.decompress(message, -zlib.MAX_WBITS)
        print(time.strftime('%H:%M:%S', time.localtime(time.time())), "Binary响应:", rb.decode("utf-8"))
 
 
def on_error(ws, error):
    print(error)
 
 
def on_close(ws, code, msg):
    print(time.strftime('%H:%M:%S', time.localtime(time.time())), "连接已断开")
 
 
wsUrl = "ws://<服务器地址>?token=<jvQuant token>"
ws = websocket.WebSocketApp(wsUrl,
                            on_open=on_open,
                            on_data=on_message,
                            on_error=on_error,
                            on_close=on_close)
ws.run_forever()

package main
 
import (
	"bytes"
	"compress/flate"
	"github.com/gorilla/websocket"
	"log"
	"time"
)
 
func main() {
	//连接地址
	wsUrl := "ws://<服务器地址>?token=<jvQuant token>"
	conn, _, err := websocket.DefaultDialer.Dial(wsUrl, nil)
	if err != nil {
		log.Fatalln("连接错误：", err)
	}
	//接收协程
	go func() {
		receive(conn)
	}()
 
	//发送订阅
	cmd := "all=lv2_600519,lv1_000001"
	err = conn.WriteMessage(websocket.TextMessage, []byte(cmd))
	if err != nil {
		log.Fatalln("发送指令错误：", err)
	}
	log.Println("发送指令成功，等待接收")
	for {
		time.Sleep(time.Second)
	}
}
 
func receive(conn *websocket.Conn) {
	for {
		//阻塞接收
		messageType, rb, err := conn.ReadMessage()
		if err != nil {
			log.Fatalln("接收错误：", err)
			return
		}
		//文本消息
		if messageType == websocket.TextMessage {
			log.Println("Text响应:", string(rb))
		}
		//二进制消息
		if messageType == websocket.BinaryMessage {
			unZipByte := DeCompress(rb)
			log.Println("Binary推送:", string(unZipByte))
		}
	}
}
 
//解压方法
func DeCompress(b []byte) []byte {
	var buffer bytes.Buffer
	buffer.Write([]byte(b))
	reader := flate.NewReader(&buffer)
	var result bytes.Buffer
	result.ReadFrom(reader)
	reader.Close()
	return result.Bytes()
}

<?php
 
//需安装swoole扩展
use Swoole\Coroutine\Http\Client;
use function Swoole\Coroutine\run;
 
run(function () {
    //服务器地址
    $host = '<服务器地址>';
    //服务器端口
    $port = <服务器端口>;
 
    //连接
    $conn = new Client($host, $port);
    $conn->upgrade("/?token=<jvQuant token>");
 
    //发送订阅
    $conn->push("add=lv2_600519,lv1_000001");
 
    //开启接收协程
    go("receive", $conn);
});
 
function receive($client)
{
    while (true) {
        $data = $client->recv();
        $time = date("H:i:s");
        //解压
        @$zipStr = gzinflate($data->data);
        if ($zipStr) {
            echo "{$time} Binary推送:{$zipStr}\n";
        } else {
            echo "{$time} Text响应:{$data->data}\n";
        }
    }
}