这是springboot里面的代码
这是生产者的
class SpringbootRabbitmqApplicationTests {
@Autowired
private RabbitTemplate rabbitTemplate;
@Test
void contextLoads() throws IOException {
CorrelationData messageID = new CorrelationData(UUID.randomUUID().toString());
rabbitTemplate.convertAndSend("boot-topic-exchange","slow.red.dog","红色大狼狗!!",messageID);
System.in.read();
}
}
这是消费者的
@Component
public class Consumer {
@RabbitListener(queues = "boot-queue")
public void getMessage(Object msg) {
System.out.println("接收到消息:" + msg);
}
}
这是一个整合exchange和queue的配置
@Configuration
public class RabbitMQConfig {
@Bean
public TopicExchange gteTopicExchange() {
return new TopicExchange("boot-topic-exchange", true, false);
}
@Bean
public Queue getQueue() {
return new Queue("boot-queue", true, false, false);
}
@Bean
public Binding getBinding(TopicExchange topicExchange, Queue queue) {
return BindingBuilder.bind(queue).to(topicExchange).with("quirky.*.*");
}
}
生产者发送成功
消费者也收到了消息