package com.xcong.excoin.modules.gateApi.wsHandler; import com.alibaba.fastjson.JSONObject; import org.java_websocket.client.WebSocketClient; /** * WebSocket 频道处理器接口。 * 每个 Gate 频道(K线/仓位/平仓)对应一个实现类, * 负责该频道的订阅、取消订阅、消息处理。 * * @author Administrator */ public interface GateChannelHandler { /** * 频道名称,如 "futures.candlesticks" */ String getChannelName(); /** * 发送订阅请求 */ void subscribe(WebSocketClient ws); /** * 发送取消订阅请求 */ void unsubscribe(WebSocketClient ws); /** * 处理频道推送消息 * * @param response WebSocket 推送的 JSON 消息 * @return true 表示已处理,false 表示不匹配(频道名不对) */ boolean handleMessage(JSONObject response); }