OpenMessaging概览

本文主要研究一下OpenMessaging

架构图

  • namespace,类似cgroup的namespace,用来进行安全隔离,每个namespace有自己的producer、consumer、topic、queue等
  • producer,消息生产者有两类,一类是Producer,一类是BatchMessageSender,前者提供多种发送方法发送消息到队列,后者主要是关注速度,批量发送一次提交
  • consumer,消息消费者有三类,一个是PullConsumer,一类是PushConsumer,还有一类是StreamingConsumer。PullConsumer从只能从固定一个队列拉取消息,PushConsumer可以从多个队列接收消息,通过MessageListener来接收,StreamingConsumer主要是用于流式处理
  • queue,用于接收来自producer或者routing的消息
  • routing,负责处理原生消息然后路由到其他队列

小结

OpenMessaging是阿里牵头发起的分布式消息模型标准,其api规范首先在rocketmq中落地实现。通过这个标准可以简化各种消息中间件的高复杂性和不兼容性,提升消息中间件服务的易用性。

doc

  • OPENMESSAGING DOMAIN ARCHITECTURE V0.3
  • 解读OpenMessaging开源项目,阿里巴巴发起首个分布式消息领域的国际标准

原文发布于微信公众号 - 码匠的流水账(geek_luandun)

原文发表时间:2018-07-23

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏匠心独运的博客

过来人的经验,谈谈一致性处理方案—分布式事务(DTS)

传统事务是使用数据库自身的事务属性(ACID),而数据库自身的事务属性是局限于当前实例,不能实现跨库。而对于大型分布式/微服务集群系统中,不仅存在着跨库的事务,...

44040
来自专栏Java后端技术栈

Kafka简介、基本原理、执行流程与使用场景

Apache Kafka是分布式发布-订阅消息系统,在 kafka官网上对 kafka 的定义:一个分布式发布-订阅消息传递系统。 它最初由LinkedIn公司...

13120
来自专栏java架构师

WCF学习笔记(一)

开篇,简单知识介绍: 最近开始用WCF,一直仅限于初级阶段,整理了下思路,深入研究一下。 开始时,在看一个叫Artech写的系列文章,结果。。。 1、长篇大作,...

28350
来自专栏BestSDK

一提交代码系统就崩溃? 给你8个避免此尴尬的技巧

当一群人作为一个整体同时进行一个程序的编写时,每个个体都会面临两方面的权衡: ●个人部分的实现——你需要保证你负责的代码部分可以正常运行; ● 整体部分的实现—...

37870
来自专栏美团技术团队

消息队列设计精要

消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能,成为异步RPC的主要手段之一。 当今市面上...

88350
来自专栏Java编程技术

分布式事务- 三阶段协议

前面我们介绍了为解决分布式事务而提出来的的二阶段协议,本文首先来讲解二阶段的不足,然后阐述三阶段协议,三阶段协议也是一个标准的协议,也并没有说具体如何实现。

7920
来自专栏皮振伟的专栏

[kvm][qemu]影响虚拟化热迁移的设备

前言 虚拟化场景下,热迁移、HA都会受到部分设备的影响。设备的实现上,包含“透传”、“直通”、“passthrough”,基本上就限制了虚拟机的迁移能力。 作...

53060
来自专栏battcn

为什么要前后端分离?有什么优缺点?

前后端分离已成为互联网项目开发的业界标准使用方式,通过nginx+tomcat的方式(也可以中间加一个nodejs)有效的进行解耦,并且前后端分离会为以后的大型...

46720
来自专栏架构师之路

集群信息管理,架构设计中最容易遗漏的一环

准备系统性介绍“技术体系规划”了,这是第一篇。 监控平台,服务治理,调用链跟踪,数据收集中心,自动化运维,自动化测试… 很多要讲,却没想好从哪里入手。 讲Z平台...

43760
来自专栏ytkah

测试了小程序的内嵌网页总结几点

  11月2日深夜微信团队宣布小程序内嵌页面开放了,很多开发者已经测试了小程序的内嵌网页,他们总结了以下几点: 1、内嵌网页的域名需要在小程序管理后台设置为业务...

34950

扫码关注云+社区

领取腾讯云代金券