要獲取RocketMQ中的消息列表,需要使用RocketMQ的客戶端API來進行操作。以下是一種常見的方法:
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("consumerGroup");
consumer.setNamesrvAddr("localhost:9876");
consumer.subscribe("topic", "*");
consumer.registerMessageListener(new MessageListenerConcurrently() {
@Override
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
// 處理消息的邏輯
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
});
consumer.start();
通過以上步驟,RocketMQ消費者就可以接收到消息并進行相應的處理。可以根據具體需求來自定義消息的處理邏輯,如將消息存儲到數據庫、打印消息內容等。