[發明專利]一種JBM系統的消息處理方法及裝置

有效

• 申請號: 201210257118.3
• 申請日: 2012-07-23
• 公開（公告）號: CN102857406A
• 公開（公告）日: 2013-01-02
• 發明（設計）人: 賀治國;樊鑫
• 申請（專利權）人: 大唐移動通信設備有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L29/08
• 代理公司: 北京潤澤恒知識產權代理有限公司 11319
• 代理人: 趙娟

1.一種JBM系統的消息處理方法，其特征在于，包括：

獲取JBM系統當前連接的客戶端；

在所述客戶端中查找慢客戶端；

斷開JBM系統與所述慢客戶端的連接。

2.根據權利要求1所述的方法，其特征在于，所述獲取JBM系統當前連接的客戶端的步驟包括：

啟動監測線程；

由所述監測線程獲取JBM系統的活躍連接信息，并將所述JBM系統的活躍連接信息存儲于內存數據結構Map中；其中，所述活躍連接信息為與JBM系統的心跳連接正常的客戶端的信息；

遍歷所述內存數據結構Map，根據所述活躍連接信息確定JBM系統當前連接的客戶端。

3.根據權利要求1或2所述的方法，其特征在于，所述在客戶端中查找慢客戶端的步驟包括：

統計各個客戶端的消息積壓數；

當某個客戶端的消息積壓數大于或等于預設長度時，判定該客戶端為慢客戶端，其中，所述預設長度為JBM系統中發送消息的緩存隊列的最大長度與消息持久化的高速緩存長度之和。

4.根據權利要求1或2所述的方法，其特征在于，所述在客戶端中查找慢客戶端步驟包括：

獲取各個客戶端的socket連接狀態；

當所述socket連接狀態為斷開時，判定該客戶端為慢客戶端。

5.根據權利要求1所述的方法，其特征在于，所述斷開JBM系統與慢客戶端的連接的步驟包括：

觸發預置的斷鏈處理線程，由所述斷鏈處理線程

關閉所述JBM系統與慢客戶端的回調callback;

對所述JBM系統與慢客戶端的鏈接進行清理。

6.根據權利要求5所述的方法，其特征在于，所述對JBM系統與慢客戶端的鏈接進行清理的步驟包括：

關閉所述JBM系統與慢客戶端的連接會話Session；

和/或

關閉所述JBM系統與慢客戶端的會話訂閱Subscribe;

和/或

從所述JBM系統的郵局中注銷與慢客戶端的連接；

和/或

從所述JBM系統中清除被持久化到數據庫的消息。

7.根據權利要求1所述的方法，其特征在于，在斷開JBM系統與所述慢客戶端的連接步驟之后，還包括：

觸發斷開與所述慢客戶端的心跳連接的通知事件；

當慢客戶端獲得所述通知事件后，重新與JMS系統建立新的連接，或者，退出JBM系統。

8.一種JBM系統的消息處理裝置，其特征在于，包括：

客戶端獲取模塊，用于獲取JBM系統當前連接的客戶端；

慢客戶端查找模塊，用于在所述客戶端中查找慢客戶端；

連接處理斷開模塊，用于斷開JBM系統與所述慢客戶端的連接。

9.根據權利要求8所述的裝置，其特征在于，所述客戶端獲取模塊包括：

監測線程啟動子模塊，用于啟動監測線程，所述監測線程用于獲取JBM系統的活躍連接信息，并將所述JBM系統的活躍連接信息存儲于內存數據結構Map中；其中，所述活躍連接信息為與JBM系統的心跳連接正常的客戶端的信息；

數據結構遍歷子模塊，用于遍歷所述內存數據結構Map，根據所述活躍連接信息確定JBM系統當前連接的客戶端。

10.根據權利要求8或9所述的裝置，其特征在于，所述慢客戶端查找模塊包括：

消息積壓數統計子模塊，用于統計各個客戶端的消息積壓數；

第一判定子模塊，用于在某個客戶端的消息積壓數大于或等于預設長度時，判定該客戶端為慢客戶端，其中，所述預設長度為JBM系統中發送消息的緩存隊列的最大長度與消息持久化的高速緩存長度之和。

11.根據權利要求8或9所述的裝置，其特征在于，所述慢客戶端查找模塊包括：

Socket狀態獲取子模塊，用于獲取各個客戶端的Socket連接狀態；

第二判定子模塊，用于在所述Socket連接狀態為斷開時，判定該客戶端為慢客戶端。