Spring+RabbitMq简单例子

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

<?xml version="1.0" encoding="UTF-8" ?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xmlns:p="http://www.springframework.org/schema/p" xmlns:rabbit="http://www.springframework.org/schema/rabbit"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.5.xsd"> <rabbit:connection-factory id="connectionFactory"
host=ip port="5672" username="" password="" />
<!-- <property name="channelCacheSize" value="25"/> -->
<rabbit:template id="amqpTemplate" connection-factory="connectionFactory"
reply-timeout="2000" />
<rabbit:admin connection-factory="connectionFactory" />
</beans>

ApplicationContext acc = new ClassPathXmlApplicationContext("applicationContext.xml");
AmqpTemplate template = acc.getBean(AmqpTemplate.class);
RabbitAdmin rabbitAdmin = acc.getBean(RabbitAdmin.class);
//创建exchange, queue及binding, 如果不存在的话
rabbitAdmin.declareExchange(new FanoutExchange(name));  //name为要建立的queue名
rabbitAdmin.declareQueue(new Queue(name));
rabbitAdmin.declareBinding(new Binding(name, Binding.DestinationType.QUEUE, name, "", null));
//data要发往queue中的数据
template.convertAndSend(name, data);