package com.xcong.excoin.modules.gateApi.wsHandler; import com.alibaba.fastjson.JSONObject; import org.java_websocket.client.WebSocketClient; /** * WebSocket 频道处理器接口。 * *

每个 Gate 频道对应一个实现类。新增频道只需实现此接口, * 然后通过 {@code GateKlineWebSocketClient.addChannelHandler()} 注册即可。 * *

实现类

* * *

路由机制

* {@code handleMessage()} 返回 {@code true} 表示消息已被该 handler 处理, * 路由循环会停止遍历。返回 {@code false} 表示不匹配(channel 名不相等)。 * * @author Administrator */ public interface GateChannelHandler { /** 频道名称,如 {@code "futures.candlesticks"} */ String getChannelName(); /** 发送订阅请求 */ void subscribe(WebSocketClient ws); /** 发送取消订阅请求 */ void unsubscribe(WebSocketClient ws); /** * 处理频道推送消息。 * * @param response WebSocket 推送的完整 JSON * @return true 表示已处理(循环停止),false 表示频道不匹配(继续遍历下一个 handler) */ boolean handleMessage(JSONObject response); }