RocketMQ 5.0

简介: RocketMQ 5.0 是一款分布式消息中间件,由阿里巴巴开源,提供了高性能、高可靠、高可扩展性的消息传递服务。它采用发布/订阅模式,支持多种消息协议,如 JMS、MQTT 等,可用于构建企业级应用的异步消息处理、系统解耦、流量削峰等场景。

RocketMQ 5.0 是一款分布式消息中间件,由阿里巴巴开源,提供了高性能、高可靠、高可扩展性的消息传递服务。它采用发布/订阅模式,支持多种消息协议,如 JMS、MQTT 等,可用于构建企业级应用的异步消息处理、系统解耦、流量削峰等场景。

  1. 下载并安装 RocketMQ
    在 RocketMQ 官网下载对应版本的二进制包,然后解压并启动 RocketMQ 服务。
  2. 生产者发送消息
    创建一个生产者实例,设置生产者组名、NameServer 地址等信息,然后通过 API 或客户端发送消息到 RocketMQ。
  3. 消费者接收消息
    创建一个消费者实例,设置消费者组名、NameServer 地址等信息,然后通过 API 或客户端接收消息。
  4. 监控 RocketMQ
    通过 RocketMQ 的监控系统,如 NameServer 的 Web 界面,查看 RocketMQ 的运行状态、消息队列等。
    推荐使用以下 demo 进行 RocketMQ 的入门学习:
  5. 创建一个简单的生产者

public class ProducerDemo {
public static void main(String[] args) throws Exception {
DefaultMQProducer producer = new DefaultMQProducer("producer_group");
producer.setNamesrvAddr("127.0.0.1:9876");
producer.start();

    Message msg = new Message("TopicTest", "TagA", "Hello RocketMQ " + System.currentTimeMillis());
    SendResult sendResult = producer.send(msg);
    System.out.println("SendResult: " + sendResult);

    producer.shutdown();
}

}

public class ConsumerDemo {
public static void main(String[] args) throws Exception {
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("consumer_group");
consumer.setNamesrvAddr("127.0.0.1:9876");
consumer.subscribe("TopicTest", "*");

    consumer.registerMessageListener(new MessageListenerConcurrently() {
        @Override
        public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
            System.out.println("Received messages: " + msgs);
            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
        }
    });

    consumer.start();
    System.out.println("Consumer started. Wait for messages...");
}

}

相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
12天前
|
消息中间件 存储 Cloud Native
RocketMQ的初步认识
RocketMQ的初步认识
23 0
|
4月前
|
消息中间件 监控 RocketMQ
RocketMQ
RocketMQ是一个开源的分布式消息中间件,由阿里巴巴集团开发和维护。
60 1
|
4月前
|
消息中间件 存储 负载均衡
RocketMQ
RocketMQ
45 0
|
5月前
|
消息中间件 存储 JSON
RocketMQ使用总结
RocketMQ使用总结
118 0
|
9月前
|
消息中间件 RocketMQ
对于RocketMQ的不同场景
对于RocketMQ的不同场景
69 2
|
9月前
|
消息中间件 负载均衡 Java
RocketMQ6
RocketMQ是一款分布式消息中间件,广泛应用于企业级架构中的异步消息传递、数据流处理、日志收集与传输等场景。RocketMQ 6是RocketMQ的最新版本,相比于旧版本,它具有更高的性能、更好的稳定性和更丰富的功能,支持更多的协议和特性。
79 0
|
10月前
|
消息中间件 存储 运维
RocketMq
RocketMq
98 0
|
消息中间件 存储 缓存
RocketMQ参数约束和建议
Apache RocketMQ 系统中存在很多自定义参数和资源命名,您在使用 Apache RocketMQ 时建议参考如下说明规范系统设置,避对某些具体参数设置不合理导致应用出现异常。
171 0
|
消息中间件 Kafka Linux
RocketMQ常备知识汇总
RocketMQ常备知识汇总
181 0
|
消息中间件 Java 中间件
rocketmq整合SpringCloudStream
rocketmq整合SpringCloudStream
441 0