rabbitmq(七)与spring整合快速入门

添加依赖

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

使用普通方式

import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.amqp.rabbit.core.RabbitTemplate;

public class Plain {

private static final String QUEUE_NAME = "spring_queue_0";

public static void main(String[] args) {

ConnectionFactory connectionFactory = new CachingConnectionFactory("127.0.0.1");

AmqpAdmin admin = new RabbitAdmin(connectionFactory);
admin.declareQueue(new Queue(QUEUE_NAME));

AmqpTemplate template = new RabbitTemplate(connectionFactory);
//发送消息
template.convertAndSend(QUEUE_NAME, "hello world");

//接收消息
String message = (String) template.receiveAndConvert(QUEUE_NAME);
System.out.println(message);

}
}

使用spring方式

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.GenericXmlApplicationContext;

public class SpringWay {

private static final String QUEUE_NAME = "spring_queue_1";

public static void main(String[] args) {
ApplicationContext context = new GenericXmlApplicationContext("classpath:/spring/rabbit-context.xml");
AmqpTemplate template = context.getBean(AmqpTemplate.class);

//发布消息
template.convertAndSend(QUEUE_NAME, "hello word");

//接收消息
String message = (String) template.receiveAndConvert(QUEUE_NAME);
System.out.println(message);
}
}

<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.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> 
<rabbit:connection-factory id="connectionFactory" host="127.0.0.1"/>

<rabbit:template id="amqpTemplate" connection-factory="connectionFactory"/>

<rabbit:admin connection-factory="connectionFactory"/>

<rabbit:queue name="spring_queue_1"/>

</beans>