以下是一个使用Spring Cloud Stream与RabbitMQ的简单示例，演示了如何发送和接收消息。
// 生产者
@EnableBinding(Source.class)
public class ProducerApplication {
@Autowired
private SourceChannel output;
public static void main(String[] args) {
SpringApplication.run(ProducerApplication.class, args);
}
@Scheduled(fixedDelay = 1000)
public void sendMessage() {
String message = "Hello, RabbitMQ!";
output.send(MessageBuilder.withPayload(message).build());
System.out.println("Send: " + message);
}
}
// 消费者
@EnableBinding(Sink.class)
public class ConsumerApplication {
@StreamListener(Sink.INPUT)
public void receiveMessage(String payload) {
System.out.println("Received: " + payload);
}
public static void main(String[] args) {
SpringApplication.run(ConsumerApplication.class, args);
}
}在这个例子中，我们创建了一个生产者应用程序ProducerApplication，它定时发送消息到RabbitMQ。我们还创建了一个消费者应用程序ConsumerApplication，它监听队列并接收并打印出消息。
确保你的application.yml或application.properties文件包含正确的RabbitMQ配置，例如：
spring:
cloud:
stream:
bindings:
output:
destination: test-topic
input:
destination: test-topic
rabbit:
bindings:
input:
consumer:
bindingRoutingKey: test-topic
output:
producer:
routingKeyExpression: 'headers[topic]'在这个配置中，我们指定了输入（input）和输出（output）绑定的目的地（destination），以及RabbitMQ特定的配置。