Metamorphosis

分布式消息中间件
授权协议 Apache
开发语言 Java
所属分类 服务器软件、 JMS/消息中间件
软件类型 开源软件
地区 国产
投 递 者 吴腾
操作系统 跨平台
开源组织 阿里巴巴
适用人群 未知
 软件概览

Metamorphosis (MetaQ) 是一个高性能、高可用、可扩展的分布式消息中间件,类似于LinkedIn的Kafka,具有消息存储顺序写、吞吐量大和支持本地和XA事务等特性,适用于大吞吐量、顺序消息、广播和日志数据传输等场景,在淘宝和支付宝有着广泛的应用,现已开源。

总体结构:

内部结构:

主要特点:

 

  • 生产者、服务器和消费者都可分布

  • 消息存储顺序写

  • 性能极高,吞吐量大

  • 支持消息顺序

  • 支持本地和XA事务

  • 客户端pull,随机读,利用sendfile系统调用,zero-copy ,批量拉数据

  • 支持消费端事务

  • 支持消息广播模式

  • 支持异步发送消息

  • 支持http协议

  • 支持消息重试和recover

  • 数据迁移、扩容对用户透明

  • 消费状态保存在客户端

  • 支持同步和异步复制两种HA

  • 支持group commit

  • 更多……

  • PDF Metamorphosis .NET Crack,TXT 和 HTML 记录转换为 PDF   PDF Metamorphosis .NET Crack是一个易于访问且有用的应用程序,对于那些想要将其 RTF、DOC、TXT 和 HTML 记录转换为 PDF 的人来说非常方便。   PDF Metamorphosis .NET Crack无需事先安装即可运行   可移植性带来了一些优势,例

  • ABSTRACT My dissertation reevaluates medieval concepts of body and identity by analyzing literary depictions of metamorphosis in romance. Focusing on examples such as the hagturned- damsel in the Wife

  •   上周我在淘宝的同事开源了一个消息中间件 metamorphosis,放在了 淘蝌蚪上。我从淘蝌蚪的svn上fork了一个github的分支,放在了这里:  1.主体工程: https://github.com/killme2008/Metamorphosis  2.示例项目: https://github.com/killme2008/metamorphosis-example  3.Twit

  • 淘宝开源消息中间件-Metamorphosis。 Gecko随之一并开源。 Oschina主页: http://www.oschina.net/p/metamorphosis

  • zookeeper 和 metamorphosis 研究完成 目前搭建的环境是在 2台 ubuntu server 64下 简称 USA USB ...  USA下 安装了 server1 server3 目录 分别是两个 zookeeper   metamorphosis消息中间件 USB下 安装了 server2 目录 一个zookeeper     metamorphosis消息中间件 3个

  • Metamorphosis是一个高性能、高可用、可扩展的分布式消息中间件,类似于LinkedIn的Kafka,具有消息存储顺序写、吞吐量大和支持本地和XA事务等特性,适用于大吞吐量、顺序消息、广播和日志数据传输等场景,在淘宝和支付宝有着广泛的应用,现已开源.http://metaq.taobao.org/

  • Metamorphosis是一个高性能、高可用、可扩展的分布式消息中间件,思路起源于LinkedIn的Kafka,但并不是Kafka的一个Copy。具有消息存储顺序写、吞吐量大和支持本地和XA事务等特性,适用于大吞吐量、顺序消息、广播和日志数据传输等场景,目前在淘宝和支付宝有着广泛的应用。  Metamorphosis的特性如下:    生产者、服务器和消费者都可分布 消息存储顺序写 性能极高,吞

 相关资料
  • 发布确认原理 生产者将信道设置成 confirm 模式,一旦信道进入 confirm 模式,所有在该信道上的消息都会被指派一个唯一的 ID(从一开始),一旦消息被投递到所有匹配的队列后,broker 就会发送一个确认给生产者(包含消息的唯一ID),这就使得生产者知道消息已经正确到达目的队列了 如果消息和队列是持久化的,那么确认消息会在将消息写入磁盘后发出,broker 回传给生产者的确认消息中 ,

  • 主要内容:8. 发布高级确认,8.1 发布确认SpringBoot版本,8.2 回退消息,8.3 备份交换机8. 发布高级确认 在生产环境中由于一些不明原因,导致RabbitMQ重启,在RabbitMQ重启期间生产者消息投递失败,导致消息丢失,需要手动处理和恢复 于是,我们开始思考,如何才能进行RabbitMQ的消息可靠投递呢?特别是在这样比较极端的情况下,RabbitMQ集群不可用的时候,无法投递的消息该如何处理呢? 8.1 发布确认SpringBoot版本 8.1.1 发布确认方案 当交换机

  • 物联网有很多设备,通过这条指令可以向某个特定的物联网设备发送特定的消息内容。 请求方式: "|4|1|3|topic|message|" 参数: topic 设置订阅的topic,获取设备topic可参考教程 message 发布消息的内容 返回值: "|4|1|3|1|\r" 消息发送成功 "|4|1|3|2|\r" 消息发送失败 Arduino样例: softSerial.print("|4|

  • OpenStack使用消息传递(我想默认情况下是RabbitMQ?)用于节点之间的通信。另一方面,Kubernetes(谷歌内部博格的血统)使用RPC。Docker的swarm也使用了RPC。两者都是基于grpc/protofbuf的,在Google内部似乎也大量使用。

  • 开普勒消息分发 公告:由管理员在后台公告管理中,发布公告,可以选择接收对象(指定个人,指定业务线,全部) 通知:由项目操作事件时产生,如构建,回滚,删除应用等 告警:由prometheus发出,开普勒通过对外提供API,接收到告警信息,然后根据规则分发 消息流程: 消息产生后,先压到MQ对应的队列,消息中心定时分任务会时时从MQ队列取出消息,然后根据订阅配置和接收权限来分发给接收者。 接收终端:

  • 我有一个Kafka主题,目前有3个分区。我希望我的消费者从同一个分区读取,但每条消息都应该以循环方式发送给不同的消费者。有可能实现吗?