Spring整合RabbitMQ

在訂閱模式消息通訊中，需要配置交換機，交換機有三種模式：fanout廣播、direct定向、topic通配符。我們這里使用topic通配符模式，這種在企業應用中最為廣泛。

（一）消息生產者

 1. 創建消息生產者項目：spring_rabbitmq_producer

 2. 添加依賴　

<dependency>
　　<groupId>org.springframework.amqp</groupId>
　　<artifactId>spring-rabbit</artifactId>
　　<version>2.0.1.RELEASE</version>
</dependency>

 

 

 3.編寫spring整合rabbitmq配置文件：spring-rabbitmq-producer.xml 

<!-- 1. 配置連接 -->
<rabbit:connection-factory
　　id="connectionFactory"
 4　　 host="127.0.0.1"
　　port="5672"
　　username="pomelo"
　　password="pomelo"
　　virtual-host="/pomelo"
/>
<!-- 2. 配置隊列 -->
<rabbit:queue name="myQueue"/>
<!-- 3.配置rabbitAdmin -->
<rabbit:admin connection-factory="connectionFactory"/>
<!-- 4. 配置topic類型exchange；隊列綁定到交換機 -->
<rabbit:topic-exchange name="myExchange">
　　<rabbit:bindings>
　　　　<rabbit:binding queue="myQueue" pattern="msg.#"></rabbit:binding>
　　</rabbit:bindings>
</rabbit:topic-exchange>
<!-- 5. 配置消息對象json轉換類 -->
<bean id="jsonMessageConverter" class="org.springframework.amqp.support.converter.Jackson2JsonMessageConverter" />
<!-- 6. 配置RabbitTemplate -->
<rabbit:template
　　id="rabbitTemplate"
　　connection-factory="connectionFactory"
　　exchange="myExchange"
27　　 message-converter="jsonMessageConverter"
/>

 

 

 4. 發消息測試

 

package com.pomelo.producer;


import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.HashMap;
import java.util.Map;

public class Send {

　　public static void main(String[] args) {
　　　　//創建spring容器
　　　　ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring-rabbitmq-producer.xml");
　　　　//從容器中獲取對象
　　　　RabbitTemplate template = context.getBean(RabbitTemplate.class);
　　　　// 發送消息
　　　　Map<String,String> map = new HashMap<>();
　　　　map.put("email","[e-mail]");
　　　　template.convertAndSend("msg.email",map);
　　　　context.close();
　　}
}

 

(二)消息消費者

 1.創建消費者項目：spring_rabbitmq_consumer

 2.添加依賴

 

<dependencies>
　　<dependency>
　　　　<groupId>org.springframework.amqp</groupId>
　　　　<artifactId>spring-rabbit</artifactId>
　　　　<version>2.0.1.RELEASE</version>
　　</dependency>
</dependencies>

 

 

 3.編寫消息監聽器

 

package com.pomelo.listener;

import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;

import java.io.IOException;
@Component
public class EmailMessageListener implements MessageListener {

　　private static final ObjectMapper MAPPER = new ObjectMapper();

　　@Override
　　public void onMessage(Message message) {

　　　　try {
　　　　　　JsonNode jsonNode = MAPPER.readTree(message.getBody());
　　　　　　String email = jsonNode.get("email").asText();
　　　　　　System.out.println("獲取隊列中消息：" + email);
　　　　} catch (IOException e) {
　　　　　　e.printStackTrace();
　　　　}
　　}
}

 

 

 4.編寫spring整合rabbitmq配置文件：spring-rabbitmq-consumer.xml

 

<!-- 1. springIOC注解掃描-->
<context:component-scan base-package="com.pomelo.listener"/>
<!-- 2. 配置連接工廠 -->
<rabbit:connection-factory
　　id="connectionFactory"
　　host="127.0.0.1"
　　port="5672"
　　username="pomelo"
　　password="pomelo"
　　virtual-host="/pomelo"
/>
<!-- 3. 配置隊列名 -->
<rabbit:queue name="myQueue"/>
<!-- 4.配置rabbitAdmin -->
<rabbit:admin connection-factory="connectionFactory"/>
<!-- 5.配置監聽 -->
<rabbit:listener-container connection-factory="connectionFactory">
　　<rabbit:listener ref="emailMessageListener" queue-names="myQueue" />
</rabbit:listener-container>

 

 

 5.運行項目

 

package com.pomelo.consumer;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.io.IOException;

public class Consumer {
　　public static void main(String[] args) throws IOException {
　　　　ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring-rabbitmq-consumer.xml");
　　　　System.in.read();
　　}
}