對于一個(gè)直接創(chuàng)建的springBoot項(xiàng)目工程來說，可以按照以下步驟使用rabbitmq文章來源：http://www.zghlxwxcb.cn/news/detail-485479.html
- 添加依賴：添加rabbitMQ的依賴。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
- 配置連接：在配置文件中配置虛擬主機(jī)、端口號、用戶名、密碼等信息。
spring:
rabbitmq:
host: localhost
port: 5672
virtual-host: {你的虛擬主機(jī)}
username: {你的用戶名}
password: {你的密碼}
- 創(chuàng)建生產(chǎn)者：導(dǎo)入對應(yīng)依賴后，使用rabbitTemplate，并調(diào)用convertAndSend來發(fā)送消息。
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String message) {
rabbitTemplate.convertAndSend("exchangeName", "routingKey", message);
}
來發(fā)送消息。文章來源地址http://www.zghlxwxcb.cn/news/detail-485479.html
- 創(chuàng)建消費(fèi)者：使用
@RabbitListener注解在消息處理方法上，指定監(jiān)聽的隊(duì)列名稱，并在方法參數(shù)中接收消息。
@RabbitListener(queues = "queueName")
public void receiveMessage(String message) {
// 處理接收到的消息
System.out.println("Received message: " + message);
}
- 編寫配置類，使用@Bean注解在對應(yīng)的方法上把方法的返回值（將隊(duì)列，交換機(jī)等信息）交由spring管理。
// 交換機(jī)名稱
public static final String ITEM_TOPIC_EXCHANGE = "item_topic_exchange";
// 隊(duì)列名稱
public static final String ITEM_QUEUE = "item_queue";
//聲明交換機(jī)
@Bean
public Exchange exchange(){
return ExchangeBuilder.topicExchange(ITEM_TOPIC_EXCHANGE).durable(true).build();
}
//聲明隊(duì)列
@Bean
public Queue queue(){
return QueueBuilder.durable(ITEM_QUEUE).build();
}
//隊(duì)列綁定到交換機(jī)
@Bean
public Binding binding(Queue queue,Exchange exchange){
return BindingBuilder.bind(queue).to(exchange).with("item.#").noargs();
}
- 啟動(dòng)應(yīng)用程序或者寫測試類。
@Autowired
RabbitTemplate rabbitTemplate;
@Test
public void testSendMessage(){
rabbitTemplate.convertAndSend(RabbitmqConfig.ITEM_TOPIC_EXCHANGE, "item.insert", "新增商品的消息~~");
System.out.println("消息發(fā)送成功");
}
到了這里，關(guān)于SpringBoot快速整合RabbitMq小案例的文章就介紹完了。如果您還想了解更多內(nèi)容，請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
