spring rabbitmq 环境搭建详细说明
2016-05-26 00:11
459 查看
先装 Erlang 18.3 然后安装server RabbitMQ 3.6.2maven 依赖 <!-- rabbitmq --><dependency><groupId>org.springframework.amqp</groupId><artifactId>spring-rabbit</artifactId><version>1.3.5.RELEASE</version> 版本可以自己调高</dependency>
</pre>mq.xml 配置文件如下 <p></p><p></p><p></p><pre code_snippet_id="1697099" snippet_file_name="blog_20160525_3_3153463" name="code" class="html"><?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:rabbit="http://www.springframework.org/schema/rabbit" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd"> <!--配置connection-factory,指定连接rabbit server参数 --> <rabbit:connection-factory id="connectionFactory" port="5672" username="guest" password="guest" host="127.0.0.1" /> <!--通过指定下面的admin信息,当前producer中的exchange和queue会在rabbitmq服务器上自动生成 --> <rabbit:admin connection-factory="connectionFactory" /> <!--定义queue --> <rabbit:queue name="queueTest" durable="true" auto-delete="false" exclusive="false" /> <!-- 定义direct exchange,绑定queueTest --> <rabbit:direct-exchange name="exchangeTest" durable="true" auto-delete="false"> <rabbit:bindings> <rabbit:binding queue="queueTest" key="queueTestKey"></rabbit:binding> </rabbit:bindings> </rabbit:direct-exchange> <bean id="jsonMessageConverter" class="org.springframework.amqp.support.converter.Jackson2JsonMessageConverter"></bean> <!--定义rabbit template用于数据的接收和发送 --> <rabbit:template id="amqpTemplate" connection-factory="connectionFactory" exchange="exchangeTest" message-converter="jsonMessageConverter" /> <!-- 消息接收者 --> <bean id="messageReceiver" class="com.bimatrix.revit.mq.MessageConsumer"></bean> <!-- queue litener 观察 监听模式 当有消息到达时会通知监听在对应的队列上的监听对象--> <rabbit:listener-container connection-factory="connectionFactory"> <rabbit:listener queues="queueTest" ref="messageReceiver"/> </rabbit:listener-container> </beans>
ps: 这里注意下
<pre code_snippet_id="1697099" snippet_file_name="blog_20160525_3_3153463" name="code" class="html"> <rabbit:direct-exchange name="exchangeTest" durable="true" auto-delete="false"><rabbit:bindings><rabbit:binding queue="queueTest" key="queueTestKey"></rabbit:binding></rabbit:bindings></rabbit:direct-exchange>binding queue 有个name queueTest 后面senddata 用到的key 值 queueTestKeyamqpTemplate.convertAndSend("queueTestKey", message); 测试代码还会说明消费者代码:
package com.***.revit.mq;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.amqp.core.Message;import org.springframework.amqp.core.MessageListener;import org.springframework.stereotype.Component;/*** 功能概要:消费接收** @author flyer* @since 2016年5月25日*///@Service@Componentpublic class MessageConsumer implements MessageListener {private Logger logger = LoggerFactory.getLogger(MessageConsumer.class);@Overridepublic void onMessage(Message message) {//logger.info("receive message:{}",message);System.out.println("receive message:{}"+message);}}生产者代码/*** 功能概要:消息产生,提交到队列中去** @author flyer* @since 2016年5月15日*/@Servicepublic class MessageProducer {private Logger logger = LoggerFactory.getLogger(MessageProducer.class);@Resourceprivate AmqpTemplate amqpTemplate;public void sendMessage(Object message) {logger.info("to send message:{}", message);amqpTemplate.convertAndSend("queueTestKey", message);}}测试代码import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.amqp.core.AmqpTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.test.context.ContextConfiguration;import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;//TestQueue.java@RunWith(value = SpringJUnit4ClassRunner.class)@ContextConfiguration(locations = { "classpath*:config/applicationContext.xml" })public class TestQueue {@AutowiredAmqpTemplate amqpTemplate;final String queue_key = "queueTestKey";@Testpublic void send() {try {System.out.println("-----------------------------------------");amqpTemplate.convertAndSend(queue_key, "NIHAO..............");System.out.println("-----------------------------------------");} catch (Exception e) {// LOGGER.error(e);}}}启动tomcat 然后运行test 代码服务端打印receive message:{}(Body:'"NIHAO.............."'MessageProperties [headers={__TypeId__=java.lang.String}, timestamp=null,
messageId=null, userId=null, appId=null, clusterId=null, type=null, correlationId=null, replyTo=null,
contentType=application/json, contentEncoding=UTF-8, contentLength=0, deliveryMode=PERSISTENT, expiration=null,
priority=0, redelivered=false, receivedExchange=exchangeTest, receivedRoutingKey=queueTestKey, deliveryTag=1, messageCount=0])
相关文章推荐
- java日期操作工具类(获取指定日期、日期转换、相隔天数)
- Spring in action 00
- java知识图解
- Eclipse中project项目转web项目
- Java JDBC
- SpringMVC 4 解决406问题
- java监视和管理控制台
- java 内存泄露
- Netbeans中文字体乱码问题解决方法
- SpringMVC+Mybatis框架整合源码 项目SSM
- eclipse创建android项目,无法正常预览布局文件
- Spring-bean的属性-2
- Java开发有前景吗?学Java需要多久?
- SpringMVC---HelloWorld程序的创建步骤
- Java中的异常 Exception
- Eclipse Project Build Automatically、Build Project
- [Java入门笔记] Java语言基础(一):注释、标识符与关键字
- [Java入门笔记] Java语言基础(二):常量、变量与数据类型
- [Java入门笔记] Java语言基础(二):常量、变量与数据类型
- [Java入门笔记] Java语言基础(三):运算符