使用 RabbitMq

如何使用

  • 安装RabbitMq服务

安装 Eralng OTP ,安装 Rabbit MQ Server,具体可以到网上搜教程。

  • spring 集成 RabbitMq

spring配置文件:

<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/rabbit
    http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd" >
    <description>rabbitmq 连接服务配置</description>
    <!-- 连接配置 -->
    <rabbit:connection-factory id="connectionFactory" host="${mq.host}"
        username="${mq.username}" password="${mq.password}" port="${mq.port}"/>
    <!--
        通过指定下面的admin信息,
        当前producer中的exchange和queue会在rabbitmq服务器上自动生成
    -->
    <rabbit:admin connection-factory="connectionFactory"/>
    <!-- spring template声明-->
    <rabbit:template id="amqpTemplate" exchange="sms_exchange"
        connection-factory="connectionFactory" message-converter="jsonMessageConverter" />
    <!-- 消息对象json转换类 -->
    <bean id="jsonMessageConverter"
        class="org.springframework.amqp.support.converter.Jackson2JsonMessageConverter" />
    <!-- 申明一个消息队列Queue ;
        durable:是否持久化 ;
        exclusive: 仅创建者可以使用的私有队列,断开后自动删除;
        auto_delete: 当所有消费客户端连接断开后,是否自动删除队列;
    -->
    <rabbit:queue name="sms_code_queue" durable="true" auto-delete="false"
        exclusive="false" />
    <!-- 交换机定义 (
        rabbit:direct-exchange:
            定义exchange模式为direct,意思就是消息与一个特定的路由键完全匹配,才会转发。
        rabbit:binding:设置消息queue匹配的key)
    -->
    <rabbit:direct-exchange  name="sms_exchange" durable="true" auto-delete="false" >
        <rabbit:bindings>
            <rabbit:binding queue="sms_code_queue" key="sms_code_queue_key"/>
        </rabbit:bindings>
    </rabbit:direct-exchange>
    <!-- 监听配置 (queues:监听的队列,多个的话用逗号(,)分隔ref:监听器) -->
    <rabbit:listener-container connection-factory="connectionFactory" acknowledge="auto">
        <rabbit:listener queues="sms_code_queue" ref="smsCodeQueueListenter"/>
    </rabbit:listener-container>
</beans>

消息推送:

@Service
public class SmsMQProducerImpl implements MQProducer{
    @Autowired
    private AmqpTemplate amqpTemplate;
    private final static Logger logger = Logger.getLogger(SmsMQProducerImpl.class);
    @Override
    public void sendDataToQueue(String key, Object object) {
        try {
            amqpTemplate.convertAndSend("sms_code_queue_key", object);
        } catch (Exception e) {
            logger.error(e);
        }
    }
}

消息监听:

@Component
public class SmsCodeQueueListenter implements MessageListener {
    @Override
    public void onMessage(Message message) {

    }
}

简单解释

<rabbit:connection-factory />:连接RabbitMq服务

<rabbit:queue />:定义队列

<rabbit:direct-exchange />:定义交换机,关联队列,消息将直接推送给交换机,交换机将消息转发至队列

<rabbit:listener-container />:指定队列的listener

<rabbit:template/>:负责向队列推送消息的bean,关联交换机

<rabbit:admin/>:自动在RabbitMq服务器上生成定义的队列和交换机

时间: 2024-10-10 15:33:20

使用 RabbitMq的相关文章

windows上部署rabbitmq遇到的一些问题及解决方法

在目前这家公司,刚进公司的时候接手了一个服务,算是个比较完备的服务,其中几台电脑之间通信用到了rabbitmq,一开始没出什么问题,然后后来勒索病毒wanner cry来的时候,系服把所有服务器装了一个什么杀毒软件,重启之后rabibtmq集群就出现了一些问题,经过一番学习,把这些问题都搞定了,现在做一个总结. 一开始,我按照官网的描述,把四台服务器加入了一个集群,但是不知道为什么,除了主节点外,另外三台都看不了集群状态,由于并不影响什么,就先放在那没管,其实想起来,是因为之前集群的配置文件没删

Spring rabbitMq 中 correlationId或CorrelationIdString 消费者获取为null的问题

问题 在用Spring boot 的 spring-boot-starter-amqp   快速启动 rabbitMq 是遇到了个坑 消费者端获取不到:correlationId或CorrelationIdString 问题产生的原因 correlationId 的在 spring rabbitmq 2.0 以后 byte方式会被放弃,所以 目前 代码中有些地方没有改过来,应该算一个BUG @SuppressWarnings("deprecation") public class De

在Node.js中使用RabbitMQ系列二 任务队列

在上一篇文章在Node.js中使用RabbitMQ系列一 Hello world我有使用一个任务队列,不过当时的场景是将消息发送给一个消费者,本篇文章我将讨论有多个消费者的场景. 其实,任务队列最核心解决的问题是避免立即处理那些耗时的任务,也就是避免请求-响应的这种同步模式.取而代之的是我们通过调度算法,让这些耗时的任务之后再执行,也就是采用异步的模式.我们需要将一条消息封装成一个任务,并且将它添加到任务队列里面.后台会运行多个工作进程(worker process),通过调度算法,将队列里的任

RabbitMQ 很成熟 不是阿里的

简介 官网 http://www.rabbitmq.com RabbitMQ是一个由erlang开发的AMQP(Advanced Message Queue )的开源实现 RabbitMQ实现了AMQP标准 安装 参考 http://www.cnblogs.com/LipeiNet/p/5973061.html 安装 erlang 有安装C运行库,给 Erlang 用的  配置环境变量 ERLANG_HOME C:\Program Files\erl8.3 安装 MQ服务器软件 3.6.9  配

杂项之rabbitmq

杂项之rabbitmq 本节内容 rabbitmq简介 AMQP协议 rabbitmq使用 应用举例 rabbitmq简介 介绍rabbitmq之前,先介绍一下AMQP协议,因为rabbitmq就是基于AMQP协议实现的一个服务程序.(目前为止应该也是唯一实现了AMQP协议的服务) AMQP(高级消息队列协议)是一个网络协议.它支持符合要求的客户端应用(application)和消息中间件代理(messaging middleware broker)之间进行通信. arbbitmq使用erlan

RabbitMQ安装和使用(和Spring集成)

一.安装Rabbit MQ Rabbit MQ 是建立在强大的Erlang OTP平台上,因此安装Rabbit MQ的前提是安装Erlang.通过下面两个连接下载安装3.2.3 版本: 下载并安装 Eralng OTP For Windows (vR16B03) 运行安装 Rabbit MQ Server Windows Installer (v3.2.3) 具体操作步骤参考:在 Windows 上安装Rabbit MQ 指南 本人遇到的问题 当安装RabbitMQ后,使用rabbitmqctl

rabbitMQ、activeMQ、zeroMQ、Kafka、Redis 比较

Kafka作为时下最流行的开源消息系统,被广泛地应用在数据缓冲.异步通信.汇集日志.系统解耦等方面.相比较于RocketMQ等其他常见消息系统,Kafka在保障了大部分功能特性的同时,还提供了超一流的读写性能. 针对Kafka性能方面进行简单分析,相关数据请参考:https://segmentfault.com/a/1190000003985468,下面介绍一下Kafka的架构和涉及到的名词: Topic:用于划分Message的逻辑概念,一个Topic可以分布在多个Broker上. Parti

NET操作RabbitMQ组件EasyNetQ

NET操作RabbitMQ组件EasyNetQ使用中文简版文档. 本文出自EasyNetQ官方文档,内容为自己理解加翻译.文档地址:https://github.com/EasyNetQ/EasyNetQ/wiki/Quick-Start EasyNetQ简介 EasyNetQ是基于官方.NET组件RabbitMQ.Client 的又一层封装,使用起来更加方便,开发者不用关心具体队列声明,路由声明等细节,几句简单代码即可发送消息到队列,接收消息也很简单,下面将简单介绍EasyNetQ的使用方法.

Python之路【第九篇】:Python操作 RabbitMQ、Redis、Memcache、SQLAlchemy

Python之路[第九篇]:Python操作 RabbitMQ.Redis.Memcache.SQLAlchemy Memcached Memcached 是一个高性能的分布式内存对象缓存系统,用于动态Web应用以减轻数据库负载.它通过在内存中缓存数据和对象来减少读取数据库的次数,从而提高动态.数据库驱动网站的速度.Memcached基于一个存储键/值对的hashmap.其守护进程(daemon )是用C写的,但是客户端可以用任何语言来编写,并通过memcached协议与守护进程通信. Memc

Centos7安装rabbitmq server 3.6.0

###假设所有操作在opt目录下进行 cd /opt mkdir apps cd apps ### 下载 RabbitMQ Server wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.0/rabbitmq-server-generic-unix-3.6.0.tar.xz ### 解压 tar -xvJf rabbitmq-server-generic-unix-3.6.0.tar.xz ### 安装 Erlang yum i