SpringCloud实现基于RabbitMQ消息队列的详细步骤

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.messaging.support.MessageBuilder;
@EnableBinding(Source.class)
public class MessageProducer {
    private final Source source;
    public MessageProducer(Source source) {
        this.source = source;
    }
    public void sendMessage(String message) {
        source.output().send(MessageBuilder.withPayload(message).build());
        System.out.println("Sent message: " + message);
    }
}

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
@EnableBinding(Sink.class)
public class MessageConsumer {
    @StreamListener(Sink.INPUT)
    public void handleMessage(String message) {
        System.out.println("Received message: " + message);
        // 处理消息的业务逻辑
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class MessageController {
    private final MessageProducer messageProducer;
    @Autowired
    public MessageController(MessageProducer messageProducer) {
        this.messageProducer = messageProducer;
    }
    @GetMapping("/send/{message}")
    public String sendMessage(@PathVariable String message) {
        messageProducer.sendMessage(message);
        return "Message sent: " + message;
    }
}