RocketMQ与Springboot整合（rocketmq-spring-boot-starter）详细步骤

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rocketmq</artifactId>
    <!-- 根据需要指定版本号 -->
</dependency>

spring:
  cloud:
    stream:
      rocketmq:
        binder:
          name-server: localhost:9876 # RocketMQ NameServer地址
          access-key: your-access-key # 如果是阿里云服务，填写AccessKey
          secret-key: your-secret-key # 如果是阿里云服务，填写SecretKey
          enable-msg-trace: true # 是否开启消息轨迹功能，默认为true

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@EnableBinding(Source.class)
@RestController
public class MessageProducer {

    private final Source source;

    public MessageProducer(Source source) {
        this.source = source;
    }

    @PostMapping("/send")
    public String sendMessage(@RequestParam("message") String message) {
        source.output().send(MessageBuilder.withPayload(message).build());
        return "Message sent: " + message;
    }
}

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.stereotype.Component;

@Component
@EnableBinding(Sink.class)
public class MessageConsumer {

    @StreamListener(Sink.INPUT)
    public void handle(String message) {
        System.out.println("Received: " + message);
    }
}