Java实现消息消费

接收消息

消息接收步骤:

1. 创建消息消费者, 指定消费者所属的组名

2. 指定Nameserver地址

3. 指定消费者订阅的主题和标签

4. 设置回调函数，编写处理消息的方

5. 启动消息消费者

package com.leon.test;import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.common.message.MessageExt;import java.util.List;public class RocketMQReceiveMessageTest {//接收消息public static void main(String[] args) throws Exception {//1 创建消费者,并且为其指定消费者组名DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("myconsumer-group");//2 为消费者设置NameServer的地址consumer.setNamesrvAddr("192.168.109.131:9876");//3 指定消费者订阅的主题和标签consumer.subscribe("myTopic", "*");//4 设置一个回调函数,并在函数中编写接收到消息之后的处理方法consumer.registerMessageListener(new MessageListenerConcurrently() {//处理获取到的消息@Overridepublic ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeConcurrentlyContext consumeConcurrentlyContext) {//消费逻辑System.out.println("Message===>" + list);//返回消费成功状态return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;}});//5 启动消费者consumer.start();System.out.println("启动消费者成功了");}
}

Java实现消息消费相关推荐

mq补偿机制java代码_RocketMQ源码分析之消息消费机制-消费端消息负载均衡机制与重新分布 - Java 技术驿站-Java 技术驿站...
1.消息消费需要解决的问题首先再次重复啰嗦一下RocketMQ消息消费的一些基本元素的关系主题 ---> 消息队列(MessageQueue) 1 对多主题 ----> 消息生产者, ...
Java常用消息队列原理介绍及性能对比
消息队列使用场景为什么会需要消息队列(MQ)? 解耦在项目启动之初来预测将来项目会碰到什么需求,是极其困难的.消息系统在处理过程中间插入了一个隐含的.基于数据的接口层,两边的处理过程都要实现这一 ...
kafka原理_P8架构师带你参透Kafka：设计原理、消息存储、消息消费原理等等
本文转载自: linkedkeeper.com,作者:张松然推荐阅读: 一个月面试了3家大厂Java岗,我发现这几个突破点目录 Kafka的基本介绍 Kafka的设计原理分析 Kafka数据传输的 ...
rocketmq 消息自定义_跟我学RocketMQ[1-4]之消息消费及支持spring
博客地址:朝·闻·道www.wuwenliang.net 本文我将继续讲解如何使用DefaultMQPushConsumer对RocketMQ中的消息进行消费,同时在文章的第二部分将继续带领读者朋友 ...
源码分析RocketMQ顺序消息消费实现原理
本节目录 1.消息队列负载 2.消息拉取 3.消息顺序消息消费 3.1核心属性与构造函数 3.2 start方法 3.3 submitConsumeRequest 3.4 ConsumeMessage ...
java activeMQ消息的发送与接收
java activeMQ消息的发送与接收 activemq是我们经常用到的消息队列之一,比如说速度快,对spring的很好的支持,支持多种协议等等,今天我们就来看一下activeMQ消息的发送与接收 ...
谈谈mq消息消费的几种方式
mq系列文章对mq了解不是很多的,可以看一下下面两篇文章: 聊聊mq的使用场景聊聊业务系统中投递消息到mq的几种方式聊聊消息消费的几种方式如何确保消息至少消费一次如何保证消息消费的幂等性本 ...
Java面试——消息队列
一.消息队列的使用场景 ☞ 以下介绍消息队列在实际应用常用的使用场景.异步处理.应用解耦.流量削锋和消息通讯四个场景. [1]异步处理:场景说明:用户注册后,需要发注册邮件和注册短信. 引入消息队 ...
我的架构梦：（九十九）消息中间件之RocketMQ的高可用机制——消息消费高可用
欢迎大家关注我的公众号[老周聊架构],Java后端主流技术栈的原理.源码分析.架构以及各种互联网高并发.高性能.高可用的解决方案. 一.前言在前两篇我们介绍了我的架构梦:(九十七)消息中间件之Ro ...

Java实现消息消费

接收消息

Java实现消息消费相关推荐

最新文章

热门文章