[[424312]]

消息中間件在互聯(lián)網(wǎng)公司使用的越來越多，主要用于在分布式系統(tǒng)中存儲(chǔ)轉(zhuǎn)發(fā)消息，在易用性、擴(kuò)展性、高可用性等方面表現(xiàn)不俗。消息隊(duì)列實(shí)現(xiàn)系統(tǒng)之間的雙向解耦，生產(chǎn)者往消息隊(duì)列中發(fā)送消息，消費(fèi)者從隊(duì)列中拿取消息并處理，生產(chǎn)者不用關(guān)心是誰來消費(fèi)，消費(fèi)者不用關(guān)心誰在生產(chǎn)消息，從而達(dá)到系統(tǒng)解耦的目的，也大大提高了系統(tǒng)的高可用性和高并發(fā)能力。

接下來介紹Spring Boot對(duì)RabbitMQ的支持。如何在SpringBoot項(xiàng)目中使用RabbitMQ？

Spring Boot提供了spring-bootstarter-amqp組件對(duì)消息隊(duì)列進(jìn)行支持，使用非常簡(jiǎn)單，僅需要非常少的配置即可實(shí)現(xiàn)完整的消息隊(duì)列服務(wù)。

一、Spring Boot集成RabbitMQ

Spring Boot提供了spring-boot-starter-amqp組件，只需要簡(jiǎn)單的配置即可與Spring Boot無縫集成。下面通過示例演示集成RabbitMQ實(shí)現(xiàn)消息的接收和發(fā)送。

第一步，配置pom包。

創(chuàng)建Spring Boot項(xiàng)目并在pom.xml文件中添加spring-bootstarter-amqp等相關(guān)組件依賴：

<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服務(wù)的地址。RabbitMQ配置由spring.rabbitmq.*配置屬性控制。virtual-host配置項(xiàng)指定RabbitMQ服務(wù)創(chuàng)建的虛擬主機(jī)，不過這個(gè)配置項(xiàng)不是必需的。

第三步，創(chuàng)建消費(fèi)者。

消費(fèi)者可以消費(fèi)生產(chǎn)者發(fā)送的消息。接下來創(chuàng)建消費(fèi)者類Consumer，并使用@RabbitListener注解來指定消息的處理方法。示例代碼如下：

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

在上面的示例中，Consumer消費(fèi)者通過@RabbitListener注解創(chuàng)建偵聽器端點(diǎn)，綁定rabbitmq_queue隊(duì)列。

（1）@RabbitListener注解提供了@QueueBinding、@Queue、@Exchange等對(duì)象，通過這個(gè)組合注解配置交換機(jī)、綁定路由并且配置監(jiān)聽功能等。

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

第四步，創(chuàng)建生產(chǎn)者。

生產(chǎn)者用來產(chǎn)生消息并進(jìn)行發(fā)送，需要用到RabbitTemplate類。與之前的RedisTemplate類似，RabbitTemplate是實(shí)現(xiàn)發(fā)送消息的關(guān)鍵類。示例代碼如下：

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

如上面的示例所示，RabbitTemplate提供了 convertAndSend方法發(fā)送消息。convertAndSend方法有routingKey和message兩個(gè)參數(shù)：

（1）routingKey為要發(fā)送的路由地址。

（2）message為具體的消息內(nèi)容。發(fā)送者和接收者的queuename必須一致，不然無法接收。

最后，測(cè)試驗(yàn)證。

創(chuàng)建對(duì)應(yīng)的測(cè)試類ApplicationTests，驗(yàn)證消息發(fā)送和接收是否成功。

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

在上面的示例中，首先注入生產(chǎn)者對(duì)象，然后調(diào)用produce()方法來發(fā)送消息。

最后，單擊Run Test或在方法上右擊，選擇Run 'contextLoads()'，運(yùn)行單元測(cè)試程序，查看后臺(tái)輸出情況，結(jié)果如下圖所示。

通過上面的程序輸出日志可以看到，消費(fèi)者已經(jīng)收到了生產(chǎn)者發(fā)送的消息并進(jìn)行了處理。這是常用的簡(jiǎn)單使用示例。

二、發(fā)送和接收實(shí)體對(duì)象

Spring Boot支持對(duì)象的發(fā)送和接收，且不需要額外的配置。下面通過一個(gè)例子來演示RabbitMQ發(fā)送和接收實(shí)體對(duì)象。

1. 定義實(shí)體類

首先，定義發(fā)送與接收的對(duì)象實(shí)體User類，代碼如下：

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

在上面的示例中，定義了普通的User實(shí)體對(duì)象。需要注意的是，實(shí)體類對(duì)象必須繼承Serializable序列化接口，否則會(huì)報(bào)數(shù)據(jù)無法序列化的錯(cuò)誤。

2. 定義消費(fèi)者

修改Consumer類，將參數(shù)換成User對(duì)象。示例代碼如下：

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

其實(shí)，消費(fèi)者類和消息處理方法和之前的類似，只不過將參數(shù)換成了實(shí)體對(duì)象，監(jiān)聽rabbitmq_queue_object隊(duì)列。

3. 定義生產(chǎn)者

修改Producer類，定義User實(shí)體對(duì)象，并通過convertAndSend方法發(fā)送對(duì)象消息。示例代碼如下：

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

在上面的示例中，還是調(diào)用convertAndSend()方法發(fā)送實(shí)體對(duì)象。convertAndSend()方法支持String、Integer、Object等基礎(chǔ)的數(shù)據(jù)類型。

4. 驗(yàn)證測(cè)試

創(chuàng)建單元測(cè)試類，注入生產(chǎn)者對(duì)象，然后調(diào)用produceObj()方法發(fā)送實(shí)體對(duì)象消息，從而驗(yàn)證消息能否被成功接收。

@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()'，運(yùn)行單元測(cè)試程序，查看后臺(tái)輸出情況，運(yùn)行結(jié)果如圖12-8所示。

通過上面的示例成功實(shí)現(xiàn)了RabbitMQ發(fā)送和接收實(shí)體對(duì)象，使得消息的數(shù)據(jù)結(jié)構(gòu)更加清晰，也更加貼合面向?qū)ο蟮木幊趟枷搿?/p>