rabbitmq学习——spring集成rabbitmq实现简单的消息发送和接收

一、准备

创建一个spring项目，引入spring-amqp依赖pom信息。

<dependencies>
		<dependency>
			<groupId>com.rabbitmq</groupId>
			<artifactId>amqp-client</artifactId>
			<version>4.0.2</version>
		</dependency>

		<dependency>
			<groupId>org.slf4j</groupId>
			<artifactId>slf4j-api</artifactId>
			<version>1.7.10</version>
		</dependency>

		<dependency>
			<groupId>org.slf4j</groupId>
			<artifactId>slf4j-log4j12</artifactId>
			<version>1.7.5</version>
		</dependency>

		<dependency>
			<groupId>log4j</groupId>
			<artifactId>log4j</artifactId>
			<version>1.2.17</version>
		</dependency>

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

二、编写demo

先看看整体的项目结构样式。

这些待会大家可以去我的github中下载或克隆使用。

回到主题，我们来完成一个简单的发送和接收消息的操作。

2.1、编写rabbitmq配置文件

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:rabbit="http://www.springframework.org/schema/rabbit" xsi:schemaLocation="http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.7.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd">
	
	<!-- 1.定义RabbitMQ的连接工厂 -->
	<rabbit:connection-factory id="connectionFactory" host="127.0.0.1" port="5672" username="xiangjiao" password="bunana" virtual-host="/xiangjiao" />
		
	
	<!-- 2.定义Rabbit模板，指定连接工厂以及定义exchange -->
	<rabbit:template id="amqpTemplate" connection-factory="connectionFactory" exchange="fanoutExchange" />
	
	<!-- MQ的管理，包括队列、交换器 声明等 -->
	<rabbit:admin connection-factory="connectionFactory" />

	<!-- 定义队列，自动声明 -->
	<rabbit:queue name="myQueue" auto-declare="true" durable="true"/>
	
	<!-- 定义交换器，自动声明 -->
	<rabbit:fanout-exchange name="fanoutExchange" auto-declare="true">
		<rabbit:bindings>
			<rabbit:binding queue="myQueue"/>
		</rabbit:bindings>
	</rabbit:fanout-exchange>
	
	
	<!-- 队列监听 -->
	<rabbit:listener-container connection-factory="connectionFactory">
		<rabbit:listener ref="foo" method="listen" queue-names="myQueue" />
	</rabbit:listener-container>

	<!-- 消费者 -->
	<bean id="foo" class="cn.linkpower.spring.MyConsumer" />

</beans>

后面会用到上面的配置信息。

2.2、编写消息发送类

消息发送类，作为消息发送至消息队列上，需要使用到信道、连接信息等。
这些信息在配置文件中都有申明，所以我们此处需要引入配置文件信息，创建rabbitmq模板。

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

/** * 消息生产者 * @author 765199214 * */
public class SpringSend {
    
	public static void main(String[] args) throws InterruptedException {
    
		//加载配置文件
		AbstractApplicationContext ctx = new ClassPathXmlApplicationContext("classpath:context.xml");
		//RabbitMQ模板
		RabbitTemplate template = ctx.getBean(RabbitTemplate.class);
		//发送消息
		template.convertAndSend("Hello, world!");
		Thread.sleep(1000);// 休眠1秒
		ctx.destroy(); //容器销毁
	}
}

2.3、消息消费者的创建

因为消息消费者在项目启动时，就已经创建好了监听，所以，我们只需要按照配置好的监听处理的类，实现具体的操作即可。
在配置文件中，我们进行了如下的配置操作。

上面的配置顾名思义，类的全路径为 cn.linkpower.spring.MyConsumer，他其中有一个监听的触发处理方法，叫听，所以我们编写一个消息处理类：

public class MyConsumer {
    
	   //具体执行业务的方法
    public void listen(String foo) {
    
        System.out.println("消费者： " + foo);
    }
}

三、尝试运行

运行SpringSend.java类，观察日志：

此时的消费者能够获取消息，并能对消息进行相关的处理操作。

四、源码

rabbitmq java代码和centos7安装包以及spring集成rabbitmq源码