文章目錄

• 一、依賴配置引入
• • 1. 引入SpringBoot整合RabbitMQ依賴
  • 2. 生產者配置文件
  • 3. 主配置
• 二、代碼Conding
• • 2.1. 生產者代碼
  • 2.2. 實體對象
  • 2.3. 測試類

一、依賴配置引入

1. 引入SpringBoot整合RabbitMQ依賴

<!--springboot整合RabbitMQ依賴--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>

2. 生產者配置文件

#RabbitMQ 連接信息 spring:rabbitmq:addresses: 127.0.0.1port: 5672username: adminpassword: admin#虛擬主機virtual-host: /admin#連接超時時間connection-timeout: 15000##開啟 confirm 確認機制#發送確認 對應RabbitTemplate.ConfirmCallback接口#消息發送成功 有2個重要參數# ack 狀態為true correlationId 全局唯一ID用于標識每一支隊列publisher-confirms: true#開啟 return 確認機制publisher-returns: true#設置為 true 后 消費者在消息沒有被路由到合適隊列情況下會被return監聽，而不會自動刪除#發送失敗回退，對應RabbitTemplate.ReturnCallback接口template:mandatory: true

3. 主配置

package com.gblfy.springboot.config;import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration;@Configuration @ComponentScan({"com.gblfy.springboot.*"}) public class MainConfig { }

二、代碼Conding

2.1. 生產者代碼

package com.gblfy.springboot.producer;import com.gblfy.springboot.entity.Order; import org.springframework.amqp.rabbit.connection.CorrelationData; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback; import org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallback; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.messaging.Message; import org.springframework.messaging.MessageHeaders; import org.springframework.messaging.support.MessageBuilder; import org.springframework.stereotype.Component;import java.util.Map;@Component public class RabbitMQSender {//自動注入RabbitTemplate模板類@Autowiredprivate RabbitTemplate rabbitTemplate;/*** MQ發送 字符串類型消息+額外的屬性** @param message* @param properties* @throws Exception*///發送消息方法調用: 構建Message消息public void send(Object message, Map<String, Object> properties) throws Exception {//構造一個添加額外屬性的容器 儲存額外消息MessageHeaders mhs = new MessageHeaders(properties);Message msg = MessageBuilder.createMessage(message, mhs);//自動簽收rabbitTemplate.setConfirmCallback(confirmCallback);//消息確認rabbitTemplate.setReturnCallback(returnCallback);//id + 時間戳 全局唯一CorrelationData correlationData = new CorrelationData("1234567890");rabbitTemplate.convertAndSend("exchange-1", "springboot.abc", msg, correlationData);}/*** 發送MQ 對象類型消息** @param order* @throws Exception*///發送消息方法調用: 構建自定義對象消息public void sendOrder(Order order) throws Exception {rabbitTemplate.setConfirmCallback(confirmCallback);rabbitTemplate.setReturnCallback(returnCallback);//id + 時間戳 全局唯一CorrelationData correlationData = new CorrelationData("0987654321");rabbitTemplate.convertAndSend("exchange-2", "springboot.ff", order, correlationData);}//回調函數: confirm確認final ConfirmCallback confirmCallback = new RabbitTemplate.ConfirmCallback() {@Overridepublic void confirm(CorrelationData correlationData, boolean ack, String cause) {System.err.println("correlationData: " + correlationData);System.err.println("ack: " + ack);if (!ack) {System.err.println("異常處理....");}}};//回調函數: return返回final ReturnCallback returnCallback = new RabbitTemplate.ReturnCallback() {@Overridepublic void returnedMessage(org.springframework.amqp.core.Message message, int replyCode, String replyText,String exchange, String routingKey) {System.err.println("return exchange: " + exchange + ", routingKey: "+ routingKey + ", replyCode: " + replyCode + ", replyText: " + replyText);}}; }

2.2. 實體對象

package com.gblfy.springboot.entity;import lombok.AllArgsConstructor; import lombok.Builder; import lombok.Data; import lombok.NoArgsConstructor;import java.io.Serializable;@Data @AllArgsConstructor @NoArgsConstructor @Builder public class Order implements Serializable {private String id;private String name; }

2.3. 測試類

package com.gblfy.springboot;import com.gblfy.springboot.entity.Order; import com.gblfy.springboot.producer.RabbitMQSender; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner;import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import java.util.Map;@RunWith(SpringRunner.class) @SpringBootTest public class ProducerApplicationTests {@Testpublic void contextLoads() {}@Autowiredprivate RabbitMQSender rabbitMQSender;private static SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");@Testpublic void testSender1() throws Exception {Map<String, Object> properties = new HashMap<>();properties.put("number", "12345");properties.put("send_time", simpleDateFormat.format(new Date()));rabbitMQSender.send("Hello RabbitMQ For Spring Boot!", properties);}@Testpublic void testSender2() throws Exception {Order order = new Order("001", "第一個訂單");rabbitMQSender.sendOrder(order);} }

總結

以上是生活随笔為你收集整理的(需求实战_01) SpringBoot2.x 整合RabbitMQ_生产端的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。