转: RabbitMQ实现中AMQP与MQTT消息收发异同

转自:http://www.cnblogs.com/lucifer1997/p/9438186.html

实现了AMQP与MQTT(至多一次)后,用多个队列以topic exchange的方式用相同交换机监听同一个主题(topic),发现情况存在不同,觉得有点意思,所以记录了下来。

用2个MQTT(分别记作A、B)、2个AMQP(分别记作C、D)同时监听一个topic,

然后向这个topic先以MQTT的方式发送4条消息(分别记作1、2、3、4),

再以AMQP方式发送4条消息(分别记作5、6、7、8),

结果如下:

A:1、2、3、4、5、6、7、8;

B:1、2、3、4、5、6、7、8;

C:1、3、5、7;

D:2、4、6、8。

说明AMQP与MQTT发送封装后大致相同,而接收存在差异。

AMQP以轮询的方式接收消息,而MQTT则能全部接收。

当我继续探究两者之间是否存在相互影响时,我又发现了一些有趣的现象:

1、当AMQP与MQTT同时在线时,两边之间互不影响。

2、当仅有AMQP在线时收到消息,然后一个MQTT开始监听,MQTT收不到消息。

3、当仅有MQTT在线时收到消息,然后一个AMQP开始监听,AMQP能收到消息。

根据2、3我推出:MQTT无法读取队列中的离线消息,在线读取后不会删除队列消息;而AMQP能读取队列中的离线消息,读取消息后会删除消息。

然后根据1,我推测MQTT先于AMQP读取消息(不知道对不对)。

原文地址:https://www.cnblogs.com/saryli/p/9742733.html

时间: 2024-08-01 06:53:51

转: RabbitMQ实现中AMQP与MQTT消息收发异同的相关文章

golang rabbitmq实践 (二 实现简单的消息收发)

1:驱动 本来打算自己写一个驱动的,后来发现github上面已经有了,那我就直接拿现成的了, 驱动采用 github.com/streadway/amqp ,直接import就可以啦! 2:exchange and queue 在上一篇文章中,我们已经创建好virtualhost .exchange and queue,所以我们先定义这些常量 const ( queueName = "push.msg.q" exchange = "t.msg.ex" mqurl =

rabbitmq队列中消息过期配置

最近公司某个行情推送的rabbitmq服务器由于客户端异常导致rabbitmq队列中消息快速堆积,还曾导致过内存积压导致rabbitmq客户端被block的情况.考虑到行情信息从业务上来说可以丢失部分消息,并不要求完全可靠.为了尽量避免某个客户端未及时消费影响整个mq,故考虑对某些队列中的消息设置TTL.如下: rabbitmqctl set_policy TTL "ttl.*" '{"message-ttl":60000}' --apply-to queues具体

【Spring】使用Spring和AMQP发送接收消息(上)

讲AMQP之前,先讲下传统的JMS的消息模型,JMS中主要有三个参与者:消息的生产者.消费者.传递消息的通道(队列或者主题),两种消息模型如下:通道是队列: 通道是队列: 通道是主题: 在JMS中,虽然通道有助于解耦消息的生产者和消费者,但这两者依然会与通道相耦合.生产者会将消息发布到一个特定的队列或主题上,消费者从特定的队列或主题上接收这些消息,通道具有双重责任,就是传递数据和确定这些消息该发送到什么地方,队列的话会使用点对点算法发送,主题的话就使用发布-订阅方式.而使用AMQP的话,生产者并

RabbitMQ详解(二)------消息通信的概念

RabbitMQ详解(二)------消息通信的概念 消息通信,有很多种,邮箱 qq 微信 短信等,这些通信方式都有发送者,接受者,还有一个中间存储离线消息的容器.但是这些通信方式和RabbitMQ的通信模型是不一样的,比如邮件,邮件服务器基于POP3/SMTP协议,通信双方需要明确指定,并且发送的邮件内容有固定的结构.而RabbitMQ服务器基于AMQP协议,这个协议是不需要明确指定发送方和接受方的,而且发送的消息也没有固定的结构,甚至可直接存储二进制数据,并且和邮件服务器一样,也能存储离线消

[3] MQTT,mosquitto,Eclipse Paho---如何使用 Eclipse Paho MQTT工具来发送订阅MQTT消息?

在上两节,笔者主要介绍了 MQTT,mosquitto,Eclipse Paho的基本概念已经如何安装mosquitto. 在这个章节我们就来看看如何用 Eclipse Paho MQTT工具来发送接收MQTT消息.Eclipse Paho MQTT工具是一个基于Java的Eclipse桌面客户端程序,其底层的和MQTT服务器进行的交互的java类库就是Eclipse Paho java库.假设我们在本机(127.0.0.1)已经启动了一个mosquitto MQTT服务器,其端口为1883.如

EMQ 学习---MQTT消息QoS

MQTT发布消息QoS保证不是端到端的,是客户端与服务器之间的.订阅者收到MQTT消息的QoS级别,最终取决于发布消息的QoS和主题订阅的QoS. 客户端连接: 客户端完成TCP三次握手之后,还需要发起CONNECT命令 注意:如果客户端三次握手之后,不发起MQTT的CONNECT命令,30s之后会被服务器断掉. emqttd.config文件有定义这个时间间隔: %% Client {client, [ %% Socket is connected, but no 'CONNECT' pack

一个基于RabbitMQ的可复用的事务消息方案

原文:一个基于RabbitMQ的可复用的事务消息方案 前提# 分布式事务是微服务实践中一个比较棘手的问题,在笔者所实施的微服务实践方案中,都采用了折中或者规避强一致性的方案.参考Ebay多年前提出的本地消息表方案,基于RabbitMQ和MySQL(JDBC)做了轻量级的封装,实现了低入侵性的事务消息模块.本文的内容就是详细分析整个方案的设计思路和实施.环境依赖如下: JDK1.8+ spring-boot-start-web:2.x.x.spring-boot-start-jdbc:2.x.x.

Android中利用Handler实现消息的分发机制(三)

在第二篇文章<Android中利用Handler实现消息的分发机制(一)>中,我们讲到主线程的Looper是Android系统在启动App的时候,已经帮我们创建好了,而如果在子线程中需要去使用Handler的时候,我们就需要显式地去调用Looper的 prepare方法和loop方法,从而为子线程创建其唯一的Looper. 具体代码如下: class LooperThread extends Thread { public Handler mHandler; public void run()

freeswitch和sofia-sip中关于sip的消息机制

Sofia-sip内部使用消息队列的方式对sip协议进行处理,sofia-sip和application之间是通过reactor模式进行通信,即通过回调实现,本文主要关注sofia-sip内部消息队列的实现: 1. 需要了解sofia-sip使用到的一些oo(面向对象)技术,链接如下 http://sofia-sip.sourceforge.net/refdocs/programming.html 可惜这个咚咚比较久,以及使用范围不是很广,不然翻译一下,锻炼自己 2. 几个关键函数: 2.1 s