掃二維碼與項(xiàng)目經(jīng)理溝通
我們?cè)谖⑿派?4小時(shí)期待你的聲音
解答本文疑問(wèn)/技術(shù)咨詢/運(yùn)營(yíng)咨詢/技術(shù)建議/互聯(lián)網(wǎng)交流
消息中間件在互聯(lián)網(wǎng)公司使用的越來(lái)越多，主要用于在分布式系統(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)心是誰(shuí)來(lái)消費(fèi)，消費(fèi)者不用關(guān)心誰(shuí)在生產(chǎn)消息，從而達(dá)到系統(tǒng)解耦的目的，也大大提高了系統(tǒng)的高可用性和高并發(fā)能力。
接下來(lái)介紹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提供了spring-boot-starter-amqp組件，只需要簡(jiǎn)單的配置即可與Spring Boot無(wú)縫集成。下面通過(guò)示例演示集成RabbitMQ實(shí)現(xiàn)消息的接收和發(fā)送。
第一步，配置pom包。
創(chuàng)建Spring Boot項(xiàng)目并在pom.xml文件中添加spring-bootstarter-amqp等相關(guān)組件依賴：
org.springframework.boot spring-boot-starter-amqp
在上面的示例中，引入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ī)，不過(guò)這個(gè)配置項(xiàng)不是必需的。
第三步，創(chuàng)建消費(fèi)者。
消費(fèi)者可以消費(fèi)生產(chǎn)者發(fā)送的消息。接下來(lái)創(chuàng)建消費(fèi)者類Consumer，并使用@RabbitListener注解來(lái)指定消息的處理方法。示例代碼如下：
- @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)者通過(guò)@RabbitListener注解創(chuàng)建偵聽器端點(diǎn)，綁定rabbitmq_queue隊(duì)列。
（1）@RabbitListener注解提供了@QueueBinding、@Queue、@Exchange等對(duì)象，通過(guò)這個(gè)組合注解配置交換機(jī)、綁定路由并且配置監(jiān)聽功能等。
（2）@RabbitHandler注解為具體接收的方法。
第四步，創(chuàng)建生產(chǎn)者。
生產(chǎn)者用來(lái)產(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必須一致，不然無(wú)法接收。
最后，測(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()方法來(lái)發(fā)送消息。
最后，單擊Run Test或在方法上右擊，選擇Run 'contextLoads()'，運(yùn)行單元測(cè)試程序，查看后臺(tái)輸出情況，結(jié)果如下圖所示。
通過(guò)上面的程序輸出日志可以看到，消費(fèi)者已經(jīng)收到了生產(chǎn)者發(fā)送的消息并進(jìn)行了處理。這是常用的簡(jiǎn)單使用示例。
Spring Boot支持對(duì)象的發(fā)送和接收，且不需要額外的配置。下面通過(guò)一個(gè)例子來(lái)演示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ù)無(wú)法序列化的錯(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)者類和消息處理方法和之前的類似，只不過(guò)將參數(shù)換成了實(shí)體對(duì)象，監(jiān)聽rabbitmq_queue_object隊(duì)列。
3. 定義生產(chǎn)者
修改Producer類，定義User實(shí)體對(duì)象，并通過(guò)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所示。
通過(guò)上面的示例成功實(shí)現(xiàn)了RabbitMQ發(fā)送和接收實(shí)體對(duì)象，使得消息的數(shù)據(jù)結(jié)構(gòu)更加清晰，也更加貼合面向?qū)ο蟮木幊趟枷搿?/p>
文章題目：三分鐘實(shí)現(xiàn)SpringBoot集成RabbitMQ，實(shí)現(xiàn)消息隊(duì)列服務(wù)
瀏覽地址：http://uogjgqi.cn/article/dpidche.html
我們?cè)谖⑿派?4小時(shí)期待你的聲音
解答本文疑問(wèn)/技術(shù)咨詢/運(yùn)營(yíng)咨詢/技術(shù)建議/互聯(lián)網(wǎng)交流
微信二維碼
微信二維碼
移動(dòng)版官網(wǎng)