RocketMQ搭建并测试（windows）

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

brokerIP1=192.168.31.199
namesrvAddr=192.168.31.199:9876

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

start mqnamesrv.cmd

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

http://localhost:8080/#/

   <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!");
 
    }
}

   <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);
    }
}