aliyun 消息中间件

topic : 通信通道

producerId: 生产者id,用于查找消息的发送者

consumerId: 消费者Id

tag: 消息标志

message.setKey() :  消息的唯一标志,这个key 一般会加上时间戳,会根据这个key删除重复 的消息

流程:   1.生产者创建消息(tag和messageKey)决定向哪个topic发送消息。

      2.MQ会根据messageKey 去判断最新上传上来的消息是否是重复的,去重

      3.消费者决定向哪个topic获取消息,根据tag 决定是否是需要的消息进行接收

    

问题:云上的消息在被消费后会消失么?

   消息是不会消失的,会永远地存在云上

问题:consumer 怎样获得的消息?

   一个topic 中的所有消息会复制给不同的consumer ,consumer根据自己的需要进行获取。

问题: 既然所有的数据不会从云上消失,并且所有的消息都会复制给不同的consumer进行鉴别,那么一段时间前发送到云上的消息会不会在一段时间后再次被拿出来给consumer进行鉴别,这样会存在效率问题?

    得到的回答是这样的:当一个消息被consumer 消费后,这个消息会产生偏移量(即进入了不会再拿出来复制给consumer鉴别的区域)

问题:如果当一个消息被不同consumer 同时进行鉴别,假设两个consumer  A和B都需要消费该消息,A先于B 消费了该消息,那么B在此时还能消费该消息么?

问题:是否是一旦有consumer 将消息消费,还消息马上产生偏移量,在该消息产生偏移量后则不会再复制给其他consumer鉴别,但在产生偏移量前,是会复制给其他consumer 的?

 

时间: 2024-12-07 07:57:42

aliyun 消息中间件的相关文章

十次方项目第五天(消息中间件RabbitMQ)

学习目标: 能够说出消息队列的应用场景以及RabbitMQ的主要概念 完成RabbitMQ安装以及RabbitMQ三种模式的入门案例 完成用户注册,能够将消息发送给RabbitMQ 完成短信微服务,能够接收消息并调用阿里云通信完成短信发送 1 RabbitMQ简介 1.1消息队列中间件简介 消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量 削锋等问题实现高性能,高可用,可伸缩和最终一致性[架构] 使用较多的消息队列有 ActiveMQ,RabbitMQ,ZeroMQ,Ka

架构设计:系统间通信(32)——其他消息中间件及场景应用(下2)

(接上文<架构设计:系统间通信(31)--其他消息中间件及场景应用(下1)>) 5-3.解决方案二:改进半侵入式方案 5-3-1.解决方法一的问题所在 方案一并不是最好的半侵入式方案,却容易理解架构师的设计意图:至少做到业务级隔离.方案一最大的优点在于日志采集逻辑和业务处理逻辑彼此隔离,当业务逻辑发生变化的时候,并不会影响日志采集逻辑. 但是我们能为方案一列举的问题却可以远远多于方案一的优点: 需要为不同开发语言分别提供客户端API包.上文中我们介绍的示例使用JAVA语言,于是 事件/日志采集

消息中间件

一.什么是消息中间件 消息中间件是在分布式系统中完成消息的发送和接收的基础软件. 二.消息中间件的作用 通过消息中间件,应用程序或组件之间可以进行可靠的异步通讯,从而降低系统之间的耦合度,提高系统的可扩展性和可用性.          三.JMS(Java Message Service:JavaEE中的一个关于消息的规范,是一套与具体平台无关的API )消息模型 1.点对点或队列模型 JMS 点对点队列模型特点:(1).消息生产者生产消息发送到queue中,然后消息消费者从queue中取出并且

redhat6.4 安装epel源和aliyun的源

##下载阿里云的源 wget -O /etc/yum.repos.d/CentOS-Base.repo http://mirrors.aliyun.com/repo/Centos-6.repo 修改阿里云的系统版本 sed -i 's/$releasever/6/g' CentOS-Base.repo 然后就可以使用了阿里云的源了 ##下载epel的源 wget http://download.fedoraproject.org/pub/epel/6/i386/epel-release-6-8.

转:Kafka、RabbitMQ、RocketMQ消息中间件的对比 —— 消息发送性能 (阿里中间件团队博客)

from: http://jm.taobao.org/2016/04/01/kafka-vs-rabbitmq-vs-rocketmq-message-send-performance/ 引言 分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦.现在开源的消息中间件有很多,前段时间我们自家的产品 RocketMQ (MetaQ的内核) 也顺利开源,得到大家的关注. 那么,消息中间件性能究竟哪家强? 带着这个疑问,我们中间件测试组对常见的三类消息产品(Kafka.RabbitM

C++ 消息中间件(MQ4CPP)

MQ4CPP支持: MultiThreading Sockets Cluster Encription Compression Service lookup Message routing 看到MQ4CPP的源码,代码写的非常清晰,让人看起来赏心悦目,对于学习网络编程或者分布式编程的人来讲,这个代码应该是很好的教材. 作为消息服务器,必须能够完成以下功能: 消息存储和转发 消息的订阅和发布 消息的广播 消息的持久化 消息的路由 消息的加密和解密 消息的压缩和解压 消息服务器对外的接口: Broa

消息中间件的技术选型心得-RabbitMQ、ActiveMQ和ZeroMQ

RabbitMQ.ActiveMQ和ZeroMQ都是极好的消息中间件,但是我们在项目中该选择哪个更适合呢?很多开发者面临这个烦恼.下面我会对这三个消息中间件做一个比较,看了后你们就心中有数了. RabbitMQ是AMQP协议领先的一个实现,它实现了代理(Broker)架构,意味着消息在发送到客户端之前可以在中央节点上排队.此特性使得RabbitMQ易于使用和部署,适宜于很多场景如路由.负载均衡或消息持久化等,用消息队列只需几行代码即可搞定.但是,这使得它的可扩展性差,速度较慢,因为中央节点增加了

[转]分布式消息中间件 MetaQ 作者庄晓丹专访

MetaQ(全称Metamorphosis)是一个高性能.高可用.可扩展的分布式消息中间件,思路起源于LinkedIn的Kafka,但并不是Kafka的一个Copy.MetaQ具有消息存储顺序写.吞吐量大和支持本地和XA事务等特性,适用于大吞吐量.顺序消息.广播和日志数据传输等场景,目前在淘宝和支付宝有着广泛的应用.   Github地址:  链接地址 为了使大家对MetaQ有进一步的了解,本期我们采访了MetaQ的核心开发者庄晓丹.  欢迎大家推荐更多开源项目给我们,支持中国的开源项目发展,如

Outlook代收发其他邮箱(gmail, qqmail, aliyun, 163)

A. Outlook代收Gmail 1.首先设置Gmail邮箱 a.设置--->转发和POP/IMAP,保证勾选启用POP,启用IMAP.     b.在Gmail里点击"我的账号",开启"允许访问安全性更低的应用" c.并启用两步验证,设置"应用专用密码",使用此密码重新登陆Gmail 2.在outlook里进行相应设置 a. 添加账户--->手动设置或其他服务器类型(M)--->POP或IMAP(P) b.发送服务器里如图勾