rocketmq有2種常見的消費模式,分別是defaultmqpushconsumer和defaultmqpullconsumer模式。兩種模式其本質都是拉取訊息,只是實現機制不一樣。
defaultmqpushconsumer(推薦使用):consumer向broker發出請求,保持了一種長鏈結,broker會每5秒會檢測一次是否有訊息,如果有訊息,則將訊息推送給consumer。broker會主動記錄訊息消費的偏移量。
defaultmqpullconsumer:consumer通過本地定時任務主動去broker拉取資料,訊息的及時性差,而且需要手動記錄訊息消費的偏移量資訊 ,所以在工作中多數情況推薦使用push模式。
rocketmq傳送的訊息缺省會儲存到4個佇列中,當然建立幾個佇列儲存資料,可以自己定義。
public class producer
}
public class consumer catch (unsupportedencodingexception e)
//訊息消費成功
return consumeconcurrentlystatus.consume_success;
}});
//啟動消費監聽
consumer.start();
}}
微信接受普通資訊
請注意 1 關於重試的訊息排重,推薦使用msgid排重。各訊息型別的推送xml資料報結構如下 1348831860 1234567890123456 引數 描述tousername fromusername 傳送方帳號 乙個openid createtime 訊息建立時間 整型 msgtype te...
微信 接收普通資訊
請注意 1 關於重試的訊息排重,推薦使用msgid排重。各訊息型別的推送xml資料報結構如下 1348831860 1234567890123456 引數描述 tousername fromusername 傳送方帳號 乙個openid createtime 訊息建立時間 整型 msgtype te...
微信公眾平台開發 接收訊息 接收普通資訊
1348831860 1234567890123456 引數 描述 fromusername 傳送方帳號 乙個openid createtime 訊息建立時間 整型 msgtype text content 文字訊息內容 msgid 訊息id,64位整型 那麼這些引數該如何獲取呢,示例 如下 定義 ...