Mine订阅流程

类 SubscribeClient入参：    BybitWsConfig: config方法：    subscribe；unsubscribe

继承

接口 WebSocketListener

类 RedisSinkService字段：BybitUsdcOptionOrderBookNotify         BybitUsdtPerpetualPublicNotify         BybitUsdcOptionTickerNotify

类 BybitUsdcOptionOrderBookNotify字段：     data: 本地缓存     workers = Array(7) 异步的7个Subscriber核心方法：     create方法：启动时创建7个worker【OrderBookSubscriber】     asSinkFlow : 从本地data里捞数据     sinkTo：data的数据sink进redis

抽象类 BaseWebSocket入参：    request：        url:    容量：默认1，mizar=100抽象方法：    decode；onFailure缓冲：Channel._message

类 SubscribeClientTemplate抽象方法：    initClient；initSubscribe，onConsumer核心方法：doSubscribe    initClient()    initSubscribe(client)    client.messages.consumeEach {            onConsumer(it)        }

分布式redis