文档章节

spring rabbitmq 配置文件简单介绍

巡山
 巡山
发布于 2016/07/12 19:13
字数 685
阅读 860
收藏 5

        rabbitmq  一个java 开源的消息中间件,可以用来对应用之间的调用解耦,比如说,我要对登陆事件进行多种操作(记录日志、更新某些信息)。这些应用依赖登陆事件,但登陆本身并不对这些应用有依赖,可以通过消息中间件的方式进行解耦。

        由对登陆事件感兴趣的应用系统订阅消息,对消息处理,完成业务需求,同时对各系统解耦。

        rabbitmq 的介绍以及教程网上有,需要的可以百度,这里仅上两端带注释的代码

//生产者

//创建连接工厂
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("192.168.22.111");
factory.setUsername("guest");
factory.setPassword("guest");
//创建连接
Connection connection = factory.newConnection();
//创建channel 所有的消息操作基于channel
Channel channel = connection.createChannel(10);
//声明一个exchange topic 类型
channel.exchangeDeclare("crm.topic", "topic",true,false,false,null);
//声明一个队列
channel.queueDeclare("app.login.user", true, false, false, null);
//将queue 与exchange 绑定
channel.queueBind("app.login.user", "crm.topic", "app.login.user");
//发送消息,指定与exchange & routingKey 
channel.basicPublish("crm.topic", "app.login.user", null, "sxxxxxxxxxx".getBytes());
 
channel.close();
connection.close();

消费者

//创建连接工厂
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("192.168.22.111");
factory.setUsername("guest");
factory.setPassword("guest");
//创建连接
Connection connection = factory.newConnection();
Channel channel = connection.createChannel(10);

//声明一个队列
channel.queueDeclare("crmcommon.login.user", true, false, false, null);
//将queue 与exchange 绑定
channel.queueBind("crmcommon.login.user", "crm.topic", "crmcommon.login.user");
//消费
GetResponse r = channel.basicGet("crmcommon.login.user", true);
System.out.println(new String(r.getBody()));
channel.close();
connection.close(); 

以上是一个简单的生产者,一个简单的消费者。

下面是使用spring整合的配置

<!-- 登陆事件 -->
<!-- 连接工厂 bean -->
<rabbit:connection-factory id="connectionFactory" host="${amqp.rabbit.host}" 
 username="${amqp.rabbit.username}"
 password="${amqp.rabbit.password}" 
 />
 
 <!-- RabbitAdmin 用于管理exchange,queue -->
 <rabbit:admin id="rabbitAdmin" connection-factory="connectionFactory"/>
 
 <!-- 声明一个队列 -->
 <rabbit:queue name="crmcommon.login.user" id="loginQuene" ></rabbit:queue>
     
 <!-- 声明一个exchange -->
 <rabbit:topic-exchange  id="crmTopic" name="crm.topic" auto-delete="false" durable="true" auto-declare="true">
     <rabbit:bindings>
        <rabbit:binding pattern="crmcommon.login.#" queue="crmcommon.login.user"  ></rabbit:binding>
     </rabbit:bindings>
 </rabbit:topic-exchange>

 <!-- 消息转换器 pojo ==> json  提供了 JsonMessageConverter SimpleMessageConverter 
     Jackson2JsonMessageConverter SerializerMessageConverter 这几种转换器 -->
     
 <bean id="messageConverter" class="org.springframework.amqp.support.converter.JsonMessageConverter" />
 
 <!-- 操作的模板,和jdbc 一样spring 提供了一个封装的模板类 -->
 <rabbit:template id="rabbitTamplate" exchange="crm.topic" routing-key="crmcommon.login.user"
 connection-factory="connectionFactory"
 message-converter="messageConverter"></rabbit:template> 
 
  
 <!--异步执行线程池,对jdk 线程池的封装,暴露部分参数 -->
 <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
      <property name="corePoolSize" value="2"></property>
      <property name="maxPoolSize" value="5"></property>
 </bean> 
     
 
 <!-- 消费者 需要实现 ChannelAwareMessageListener 或 MessageListener -->
 <bean id="listener" class="com.xx.xx.xx.rabbit.LoginListener" />
 
 <!-- listener 容器 可以绑定多个消费者,一个消费者可以绑定多个queue  -->
 <rabbit:listener-container connection-factory="connectionFactory"  acknowledge="manual" message-converter="messageConverter"  task-executor="taskExecutor" >
 <rabbit:listener ref="listener" queues="loginQuene"/>
 </rabbit:listener-container>

可以看到spring 配置也是要配置上面代码的基本元素,spring 同时提供了一下封装类,对消息的转换,操作模板等。 

© 著作权归作者所有

共有 人打赏支持
巡山
粉丝 2
博文 20
码字总数 12425
作品 0
深圳
私信 提问
RabbitMQ 入门 与 RabbitMQ 在 Spring Boot 中的使用

Message Broker与AMQP简介 Message Broker是一种消息验证、传输、路由的架构模式,其设计目标主要应用于下面这些场景: 消息路由到一个或多个目的地 消息转化为其他的表现方式 执行消息的聚集...

Anur
2018/09/13
0
0
RabbitMQ学习以及与Spring的集成(三)

本文介绍RabbitMQ与Spring的简单集成以及消息的发送和接收。 在RabbitMQ的Spring配置文件中,首先需要增加命名空间。 xmlns:rabbit="http://www.springframework.org/schema/rabbit" 其次是模...

onedotdot
2018/06/18
0
0
【Spring Cloud】分布式必学springcloud(十一)——消息驱动 SpringCloud Stream

一、前言 在前面的博客中,基本上已经把springcloud系列的大部分都介绍过了。如果有太明白的小白,还是建议从小编的第一篇博客进行学习。 在这篇博客中,小白向大家介绍一个消息事件驱动框架...

kisscatforever
2018/04/26
0
0
阿里云Kubernetes SpringCloud 实践进行时(2): 分布式配置管理

简介 为了更好地支撑日益增长的庞大业务量,我们常常需要把服务进行整合、拆分,使我们的服务不仅能通过集群部署抵挡流量的冲击,又能根据业务在其上进行灵活的扩展。随着分布式的普及、服务...

osswangxining
2018/05/25
0
0
SSM框架下配置rabbitMQ

一、准备工作: 第一步:下载erlang http://www.erlang.org/downloads/19.3 第二步:下载rabbitMQ http://www.rabbitmq.com/download.html rabbitMQ安装完成后,打开rabbitMQ控制台 输入:r...

嘴角轻扬30
2018/11/15
0
0

没有更多内容

加载失败,请刷新页面

加载更多

大数据教程(11.9)hive操作基础知识

上一篇博客分享了hive的简介和初体验,本节博主将继续分享一些hive的操作的基础知识。 DDL操作 (1)创建表 #建表语法CREATE [EXTERNAL] TABLE [IF NOT EXISTS] table_name [(col_name ...

em_aaron
今天
4
0
OSChina 周四乱弹 —— 我家猫真会后空翻

Osc乱弹歌单(2019)请戳(这里) 【今日歌曲】 @我没有抓狂 :#今天听这个# 我艇牛逼,百听不厌,太好听辣 分享 Led Zeppelin 的歌曲《Stairway To Heaven》 《Stairway To Heaven》- Led Z...

小小编辑
今天
26
3
node调用dll

先安装python2.7 安装node-gyp cnpm install node-gyp -g 新建一个Electron-vue项目(案例用Electron-vue) vue init simulatedgreg/electron-vue my-project 安装electron-rebuild cnpm ins......

Chason-洪
今天
3
0
scala学习(一)

学习Spark之前需要学习Scala。 参考学习的书籍:快学Scala

柠檬果过
今天
3
0
通俗易懂解释网络工程中的技术,如STP,HSRP等

导读 在面试时,比如被问到HSRP的主备切换时间时多久,STP几个状态的停留时间,自己知道有这些东西,但在工作中不会经常用到,就老是记不住,觉得可能还是自己基础不够牢固,知识掌握不够全面...

问题终结者
昨天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部