Spring Boot提供了spring-bootstarter-amqp組件對訊息佇列進行支持，使用非常簡單，僅需要非常少的配置即可實作完整的訊息佇列服務，
在這里插入圖片描述
訊息中間件在互聯網公司使用的越來越多，主要用于在分布式系統中存盤轉發訊息，在易用性、擴展性、高可用性等方面表現不俗，訊息佇列實作系統之間的雙向解耦，生產者往訊息佇列中發送訊息，消費者從佇列中拿取訊息并處理，生產者不用關心是誰來消費，消費者不用關心誰在生產訊息，從而達到系統解耦的目的，也大大提高了系統的高可用性和高并發能力，

接下來介紹Spring Boot對RabbitMQ的支持，如何在SpringBoot專案中使用RabbitMQ？

Spring Boot提供了spring-bootstarter-amqp組件對訊息佇列進行支持，使用非常簡單，僅需要非常少的配置即可實作完整的訊息佇列服務，

一、Spring Boot集成RabbitMQ

Spring Boot提供了spring-boot-starter-amqp組件，只需要簡單的配置即可與Spring Boot無縫集成，下面通過示例演示集成RabbitMQ實作訊息的接收和發送，

第一步，配置pom包，

創建Spring Boot專案并在pom.xml檔案中添加spring-bootstarter-amqp等相關組件依賴：

<dependency> 
	<groupId>org.springframework.boot</groupId> 
	<artifactId>spring-boot-starter-amqp</artifactId> 
</dependency>

在上面的示例中，引入Spring Boot自帶的amqp組件spring-bootstarter-amqp，

第二步，修改組態檔，

修改application.properties組態檔，配置rabbitmq的host地址、埠以及賬戶資訊，

spring.rabbitmq.host=10.2.1.231 
spring.rabbitmq.port=5672 
spring.rabbitmq.username=zhangweizhong 
spring.rabbitmq.password=weizhong1988 
spring.rabbitmq.virtualHost=order

在上面的示例中，主要配置RabbitMQ服務的地址，RabbitMQ配置由spring.rabbitmq.*配置屬性控制，virtual-host配置項指定RabbitMQ服務創建的虛擬主機，不過這個配置項不是必需的，

第三步，創建消費者，

消費者可以消費生產者發送的訊息，接下來創建消費者類Consumer，并使用@RabbitListener注解來指定訊息的處理方法，示例代碼如下：

@Component 
public class Consumer { 
    @RabbitHandler 
    @RabbitListener(queuesToDeclare = @Queue("rabbitmq_queue")) 
    public void process(String message) { 
        System.out.println("消費者消費訊息111=====" + message); 
    } 
 
}

在上面的示例中，Consumer消費者通過@RabbitListener注解創建偵聽器端點，系結rabbitmq_queue佇列，

（1）@RabbitListener注解提供了@QueueBinding、@Queue、@Exchange等物件，通過這個組合注解配置交換機、系結路由并且配置監聽功能等，

（2）@RabbitHandler注解為具體接收的方法，

第四步，創建生產者，

生產者用來產生訊息并進行發送，需要用到RabbitTemplate類，與之前的RedisTemplate類似，RabbitTemplate是實作發送訊息的關鍵類，示例代碼如下：

@Component 
public class Producer { 
 
    @Autowired 
    private RabbitTemplate rabbitTemplate; 
     
    public void produce() { 
        String message = new Date() + "Beijing"; 
        System.out.println("生產者產生訊息=====" + message); 
        rabbitTemplate.convertAndSend("rabbitmq_queue", message); 
    } 
}

如上面的示例所示，RabbitTemplate提供了 convertAndSend方法發送訊息，convertAndSend方法有routingKey和message兩個引數：

（1）routingKey為要發送的路由地址，

（2）message為具體的訊息內容，發送者和接收者的queuename必須一致，不然無法接收，

最后，測驗驗證，

創建對應的測驗類ApplicationTests，驗證訊息發送和接收是否成功，

@RunWith(SpringRunner.class) 
@SpringBootTest 
public class ApplicationTests { 
 
    @Autowired 
    Producer producer; 
 
    @Test 
    public void contextLoads() throws InterruptedException { 
        producer.produce();  
        Thread.sleep(1*1000); 
 
    } 
}

在上面的示例中，首先注入生產者物件，然后呼叫produce()方法來發送訊息，

最后，單擊Run Test或在方法上右擊，選擇Run ‘contextLoads()’，運行單元測驗程式，查看后臺輸出情況，結果如下圖所示，

在這里插入圖片描述
通過上面的程式輸出日志可以看到，消費者已經收到了生產者發送的訊息并進行了處理，這是常用的簡單使用示例，

二、發送和接收物體物件

Spring Boot支持物件的發送和接收，且不需要額外的配置，下面通過一個例子來演示RabbitMQ發送和接收物體物件，

1. 定義物體類

首先，定義發送與接收的物件物體User類，代碼如下：

public class User implements Serializable { 
 
    public String name; 
 
    public String password; 
 
    // 省略get和set方法 
 
}

在上面的示例中，定義了普通的User物體物件，需要注意的是，物體類物件必須繼承Serializable序列化介面，否則會報資料無法序列化的錯誤，

2. 定義消費者

修改Consumer類，將引數換成User物件，示例代碼如下：

@Component 
public class Consumer { 
 
    @RabbitHandler 
    @RabbitListener(queuesToDeclare = @Queue("rabbitmq_queue_object")) 
    public void process(User user) { 
        System.out.println("消費者消費訊息111user=====name：" + user.getName()+",password:"+user.getPassword()); 
     
    } 
}

其實，消費者類和訊息處理方法和之前的類似，只不過將引數換成了物體物件，監聽rabbitmq_queue_object佇列，

3. 定義生產者

修改Producer類，定義User物體物件，并通過convertAndSend方法發送物件訊息，示例代碼如下：

@Component 
public class Producer { 
 
    @Autowired 
    private RabbitTemplate rabbitTemplate; 
     
    public void produce() {  
        User user=new User(); 
        user.setName("weiz"); 
        user.setPassword("123456"); 
        System.out.println("生產者生產訊息111=====" + user); 
         
        rabbitTemplate.convertAndSend("rabbitmq_queue_object", user); 
    } 
 
}

在上面的示例中，還是呼叫convertAndSend()方法發送物體物件，convertAndSend()方法支持String、Integer、Object等基礎的資料型別，

4. 驗證測驗

創建單元測驗類，注入生產者物件，然后呼叫produceObj()方法發送物體物件訊息，從而驗證訊息能否被成功接收，

@RunWith(SpringRunner.class) 
@SpringBootTest 
public class ApplicationTests { 
 
    @Autowired 
    Producer producer; 
 
    @Test 
    public void testProduceObj() throws InterruptedException { 
        producer.produceObj(); 
        Thread.sleep(1*1000); 
    } 
}

最后，單擊Run Test或在方法上右擊，選擇Run ‘contextLoads()’，運行單元測驗程式，查看后臺輸出情況，運行結果如圖，
在這里插入圖片描述
通過上面的示例成功實作了RabbitMQ發送和接收物體物件，使得訊息的資料結構更加清晰，也更加貼合面向物件的編程思想，

轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/319661.html

標籤：其他

上一篇：大資料分析師實操練習（Hadoop完全分布式集群搭建）