El resto del API de okex es demasiado estricto para intentar obtener información de profundidad con una conexión dial websocket;
Debido a la gran cantidad de monedas que se suscriben al mismo tiempo (alrededor de 80), la lógica del proceso, los pedidos, las consultas, etc., son muy difíciles de realizar.
El intervalo de ejecución de la función w.s.read es un poco grande, y los datos se acumulan en exceso, por lo que cada ronda de lectura y mantenimiento en profundidad es más larga, pero la eficiencia no es alta.
Me pregunto si podría haber un programa separado que solo reciba información sobre el websocket en el ciclo, mantenga la profundidad y transmita la información de profundidad actualizada al robot a través del puerto local a cualquier hora.
想着能不能有一个单独的程序,只负责循环收取websocket信息、维护深度,并随时把更新后的深度信息通过本地端口传递给机器人
这个需求可以实现的。可以写个行情收集器,数据中心实盘。开启服务分发数据。
Dial函数用非阻塞的立即返回模式。
- 1
