请教各位大佬,目前正在使用火币的websocket行情api,众所周知火币没有一个完整的返回所有币实时行情的接口,所以只能用先用workerman作为客户端拿到火币网所有的实时行情后,经过自己的加工处理,再作为一个workerman的服务端将数据实时推送给自己的客户端供调用。
问题:
1、拿到火币网的数据后如将它保存下来,作为服务端的数据来源供客户端调用?
2、是否在一个文件中可以实现,开启两个worker,一个用来做客户端接火币的数据,另外一个做服务端,等待连接发数据。
workerman小白,希望大家能给予指导,感激不尽
先回答第二个问题:开启一个 Worker,用于接收客户端的连接。在 onWorkerStart 里面创建 AsyncTcpConnection 实例,连接到所需的服务器(火币)获取数据,需要几个就连接几个。
至于第一个问题,那得看你具体的数据处理逻辑了。
谢谢大佬的回答,目前可以实现拿到火币的数据并发送给客户端了,下面还有一个难点就是火币网的行情是有变化才会通知给我,而我这边也要拿到一个新的火币网行情消息时,去主动的推送给所有的客户端,这个应该如何实现呢?