訂閱/發布管理器 ~~~ //訂閱/發布管理器接口 private IPubSubManager pubSubManager; ~~~ 訂閱/發布管理器 ~~~ public interface IPubSubManager { /** * 支持消息發布到一個頻道或多個頻道 * * @param messageBody * @param channels */ void publish(Object messageBody, String... channels); /** * 支持訂閱一個頻道或多個頻道，但非pattern模式 * * @param listener * @param channels */ void subscribe(IMessageListener listener, String... channels); /** * 支持訂閱一個頻道或多個頻道，pattern模式 * * @param listener * @param channels */ void pSubscribe(IMessageListener listener, String... channels); /** * 支持取消訂閱一個頻道或多個頻道，但非pattern模式 * * @param listener * @param channels */ void unsubscribe(IMessageListener listener, String... channels); /** * 支持取消訂閱一個頻道或多個頻道，pattern模式 * * @param listener * @param channels */ void punsubscribe(IMessageListener listener, String... channels); /** * 返回當前的活躍頻道 * 活躍頻道指的是那些至少有一個訂閱者的頻道， 訂閱模式的客戶端不計算在內 * * @param pattern 可選參數 * 如果不給出 pattern 參數，那么列出訂閱與發布系統中的所有活躍頻道。 * 如果給出 pattern 參數，那么只列出和給定模式 pattern 相匹配的那些活躍頻道。 * @return */ List<String> pubsubChannels(final String pattern); /** * 返回給定頻道的訂閱者數量，訂閱模式的客戶端不計算在內 * * @param channels * @return key為頻道，value為該頻道訂閱者數量 */ Map<String, String> pubsubNumSub(final String... channels); /** * 返回訂閱模式的數量 * * 注意， 這個命令返回的不是訂閱模式的客戶端的數量，而是客戶端訂閱的所有模式的數量總和。 * @return */ Long pubsubNumPat(); /** * 獲取所有監聽器 * * @return */ Map<IMessageListener, MessageListener> getListeners(); } ~~~