天天看點

client與broker斷開後重新連接配接

qpid的client端有可能會由于某種原因與broker斷開連接配接,如網絡連接配接斷開,broker的節點删除等等。

公司的項目需要用java編寫一個Service,用來監聽broker的消息。要求如果與broker斷開後,必須嘗試重新連接配接。

那應該完成以下一個步驟:

(1)檢測到client與伺服器斷開。

(2)如果斷開,嘗試重新連接配接。

對于(1),javax.jms.Connection對象可以設定一個ExceptionListener對象,用來監聽是否發生連接配接異常。

以下為client端的類

如果檢測到異常,就關閉用戶端。啟動Service時啟動一個線程,監視連接配接是否正常,如果被關閉,則重新連接配接。