建立网站有免费的吗,企业网站建设与管理试题,wordpress 4.0 关闭评论,重庆建设工程安全管理网查询Java脚好用的库很多#xff0c;开发效率一点不输Python。如果是日内策略#xff0c;需要更实时的行情数据#xff0c;不然策略滑点太大#xff0c;容易跑偏结果。
之前爬行情网站提供的level1行情接口#xff0c;实测平均更新延迟达到了6秒#xff0c;超过10只股票并发请…Java脚好用的库很多开发效率一点不输Python。如果是日内策略需要更实时的行情数据不然策略滑点太大容易跑偏结果。
之前爬行情网站提供的level1行情接口实测平均更新延迟达到了6秒超过10只股票并发请求频率过快很容易封IP。后面又尝试了买代理IP来请求成本太高而且不稳定。
在Github上看到一个行情包对接的是WebSocket协议找到了一个Java版本封装的包记录一下:
package com.client;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
import java.net.URI;
import java.net.URISyntaxException;
import java.nio.ByteBuffer;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.util.zip.Inflater;
import java.util.zip.DataFormatException;public class Client extends WebSocketClient {SimpleDateFormat sdf new SimpleDateFormat(HH:mm:ss);public Client(String url) throws URISyntaxException {super(new URI(url));}Overridepublic void onOpen(ServerHandshake shake) {//发送订阅命令this.send(addlv1_600519,lv2_600519);}/*** 命令返回文本消息*/Overridepublic void onMessage(String paramString) {System.out.println(sdf.format(new Date()) Text响应 paramString);}Overridepublic void onClose(int paramInt, String paramString, boolean paramBoolean) {System.out.println(连接关闭);}Overridepublic void onError(Exception e) {System.out.println(连接异常 e);}/*** 行情接收处理*/Overridepublic void onMessage(ByteBuffer bytes) {super.onMessage(bytes);String s;try {//二进制解压缩byte[] decdecompress(bytes.array());s new String(dec, UTF-8);}catch (IOException e){System.err.println(Binary解析IO异常:e.getMessage());return;}catch (DataFormatException e){System.err.println(Binary解析格式异常:e.getMessage());return;}System.out.println(sdf.format(new Date()) Binary响应 s);}/*** 解压缩方法*/public static byte[] decompress(byte[] compressedData) throws DataFormatException {Inflater inflater new Inflater(true);inflater.setInput(compressedData);ByteArrayOutputStream outputStream new ByteArrayOutputStream(compressedData.length);byte[] buffer new byte[1024];while (!inflater.finished()) {int count inflater.inflate(buffer);outputStream.write(buffer, 0, count);}inflater.end();return outputStream.toByteArray();}
}
使用:
package com.client;import java.net.URISyntaxException;public class Main {public static void main(String[] args) throws URISyntaxException {String wsUrl ws://服务器地址?tokentoken;Client fd new Client(wsUrl);fd.connect();}
} 引用地址:https://github.com/freevolunteer/bondTrader/blob/main/pyscript/jvUtil/HanqQing.py
订阅指令参考:JAVA量化之WebScoket行情接入
