做消息持久化 借助 jdbc, kahadb或 leveldb+zookeeper
首先將將消息發送設置為持久化發送(mq自帶的屬性),然后再借助jdbc kahadb leveldb+zookeeper等做消息的存儲來持久化。
思想都是發送者(消息生產者)將消息發送出去后,消息中心首先將消息存儲到本地數據文件、內存數據庫或者遠程數據庫等。再試圖將消息發給接收者,成功則將消息從存儲中刪除,失敗則繼續嘗試嘗試發送。消息中心啟動以后,要先檢查指定的存儲位置是否有未成功發送的消息,如果有,則會先把存儲位置中的消息發出去。