RocketMQ搭建并测试（windows）-阿里云开发者社区

RocketMQ搭建并测试（windows）

2024-06-25 7

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： RocketMQ搭建并测试（windows）

架构及组件说明

name server：注册中心

broker:消息处理

procucer:生成消息

consumer:消费消息

一、下载安装包

https://rocketmq.apache.org/zh/download

1、RocketMQ下载

2、RocketMQ仪表盘下载

二、修改RocketMQ配置参数

将 ocketmq-all-4.9.4-bin-release文件复制到合适的位置

1、修改conf/broker.conf配置

查询自己IP

添加如下配置（IP使用自己的），并保存。

brokerIP1=192.168.31.199
namesrvAddr=192.168.31.199:9876

2、设置ROCKETMQ_HOME环境变量

文件路径使用自己的

set ROCKETMQ_HOME=D:\ProgramFiles\rocketmq-all-4.9.4-bin-release

三、启动服务

1、启动Namesrv

在rocketmq文件的bin目录下，进入cmd

start mqnamesrv.cmd

2、启动Broker

start mqbroker.cmd -n 127.0.0.1:9876  autoCreateTopicEnable=true

三、启动仪表盘

1、修改配置文件

2、启动项目

3、打开仪表盘

http://localhost:8080/#/

按需修改为中文

查看消费者(非必须)

四、分别创建springboot生成者和消费者

1、生产者

创建普通springboot项目，添加依赖

   <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <version>2.0.1</version>
        </dependency>

修改配置文件

# 应用名称
spring:
  application:
    name: rocket-producer
# 应用服务 WEB 访问端口
server:
  port: 8002
rocketmq:
  name-server: localhost:9876
  producer:
    group: my-group

创建测试代码

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
 
import javax.annotation.Resource;
 
@Component
public class SendMessage {
    @Resource
    private RocketMQTemplate rocketMQTemplate;
 
 
    @Scheduled(fixedRate = 5000)
    public void run(){
        //发送消息
        rocketMQTemplate.convertAndSend("test-topic-1", "Hello, World!");
 
    }
}

启动类添加@EnableScheduling注解

项目目录

2、消费者

创建普通springboot项目，添加依赖

   <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <version>2.0.1</version>
        </dependency>

修改配置文件

# 应用名称
spring:
  application:
    name: rocket-consumer
server:
  port: 8001
 
rocketmq:
  name-server: localhost:9876

创建测试代码

 
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;
 
 
@Service
@RocketMQMessageListener(topic = "test-topic-1", consumerGroup = "my-consumer_test-topic-1")
class MyConsumer1 implements RocketMQListener<String> {
 
    /**
     *需要注意的是，onMessage（）封装了ACK机制，消费者往外抛异常时，RocketMQ认为消费失败，重新发送该条消息，否则默认消费成功
     */
 
    @Override
    public void onMessage(String s) {
        System.out.println(s);
    }
}