## Apache RocketMQ 事务消息 王强 (辽天) 阿里巴巴 中间件技术专家 ## QCon 全球软件开发大会 北京·2019 更多技术干货分享，北京站精彩继续 提前参与，还能享受更多优惠 识别二维码 查看了解更多 2019.qconbeijing.com  - 高性能，分布式 · 高并发 消息堆积 • Apache顶级项目 ## 典型应用场景  金融交易 分布式事务  电子商务 异步解耦 ![Im

## 使用gRPC go实现 基于Topic的高效消息订阅发布模型  姓名：___ 张凯 中国电子云  gRPC go 介绍 01 gRPC 四种通信模式及落地场景 02 根据 proto 生成 go 桩代码 03 订阅者动态注册 04 发布者消息推送 05 现场案例演示 06 ## gRPC go介绍 ## gRPC是什么？ 1. 什么是gRPC？gRPC go与gRPC的关系是什么？ 2. gRPC与HTTP相比优势是什么？能否使用HTTP平替gRPC的实现？ {} } // 定义一个Response Person的消息类型 message Person { required string name = 1; required int32 id = 2; optional string email = 3; } // 定义一个Request GetPersonRequest的消息类型 message GetPersonRequest

## 电商消息系统架构演进 李历岷 阿里巴巴-淘宝高级技术专家 ## SPEAKER INTRODUCE ## 李历岷 淘宝高级技术专家 ## - 当前： 电商消息核心系统架构以及Team Leader ## 阿里： • 主导电商内容平台架构以及构建招选搭投一体化内容导购 - 阿里巴巴第四届中间件ServiceMesh性能挑战赛冠军 - 基于Facebook–GraphQL规范打造数据聚合产品TQL TABLE OF CONTENTS 大纲 电商消息业务场景 电商消息系统架构 电商消息核心技术和挑战 电商消息全链路稳定性保障 电商消息系统未来展望 • Q&A  ## 电商消息业务场景 场景：社交互动、生意沟通、交易提醒、优惠通知、品牌资讯 目标：打造新零售业务商业连接，帮助消费者进行消费决策 ## 活动 9月会员日来袭 U 童装上新，网红爆款玩具等你来玩 >>> 95公益周，以你之名助力公益！ ## 电商消息业务场景 社交互动 淘友 电商 客服交易 亲情关系 线下导购 游戏互动 专属客服 轻店铺 业务特点 业务形态 · 多端同步 · 多样场景 业务定制 临时沟通 ##

# 基于amqp实现的golang消息队列 MaxQ 2017-07-01 张培培 饿了么－基础框架组 ## 内容 1. 队列 2. IPC消息队列 3. AMQP协议 4. MaxQ架构模型 5. MaxQ相关特性 6. 使用场景和案例 ### 1. 队列  跟消息队列相比，有哪些共性？ • 生产者消费者 • 通信方式 • 存储方式 • 堆积能力 消息可靠性 • 生产消费关系 • Pull/Push ### 2. IPC消息队列  跟消息队列相比，有哪些共性？ ### Message Queuing Protocol)协议 • 七层应用协议 • 定义Broker实现 • 生产消费轻耦合 • 生产消费状态记录 • Push/Pull消费模型 • 消费者流控 • 事务支持  ## 一 些基本概念 • Broker

## TiDB: HBase分布式事务与SQL实现 ## About me • TiDB & Codis founder • Golang expert • Distributed database developer • Currently, CEO and co-founder of PingCAP liuqi@pingcap.com https://github.com/pingcap/tidb

[Image](/uploads/documents/b/c/4/2/bc4201e3191543d1cf3ac91f91e8ea10/p1_2.jpg) ## 微信号： ## scottlewis ## 分布式事务框架 Seata-Golang  刘晓敏 & QA 05 目录 ## 什么是分布式事务问题？ 分布式事务就是指事务的参与者、支持事务的服务器、资源服务器以及事务管理器分别位于不同的分布式系统的不同节点之上。简单的说，就是一次大的操作由不同的小操作组成，这些小的操作分布在不同的服务器上，且属于不同的应用，分布式事务需要保证这些小操作要么全部成功，要么全部失败。本质上来说，分布式事务就是为了保证不同数据库的数据一致性。 ## Demo Demo 演示 1997-1998 1 ## Seata 原理 ## 整体机制： • 一阶段：业务数据和回滚日志记录在同一个本地事务中提交，释放本地锁和连接资源。 • 二阶段: • 提交异步化，非常快速地完成。 • 回滚通过一阶段的回滚日志进行反向补偿。 BranchSession Lock BranchSession Lock ![Image](/uploads/document

## 华为云分布式事务DTM最佳实践 王启军  王启军，华为云PaaS团队架构师，负责微服务框架的开发。曾任当当网架构师，主导电商平台架构设计；曾就职于搜狐负责手机微博的研发。《持续演进的Cloud Native》作者，微信公众号“奔跑中的蜗牛”博主。 [Image](/uploads/documents/4/f/c/1/4fc1dac86fed58e3630871012bbe2224/p5_1.jpg) |方案\\指标|2PC 传统事务|可靠事件|TCC 柔性事务|SAGA 补偿事务| |---|---|---|---|---| |数据一致性|强一致|最终一致|最终一致|最终一致| |总体性能|低|高|取决于实现|取决于实现| |业务侵入性|较低侵入|高侵入|高侵入|高侵入| |产品成熟度|高|高|一般|低|  ## 分布式事务管理中间件 (Distributed Transaction Management, DTM) ## DTM总体架构（TCC） 用户侧 系统侧 ![Image](/uploads/docume

## 万亿级数据洪峰下的消息引擎 Apache RocketMQ 誓嘉  ## 自我介绍 ●花名：誓嘉 ●真名：王小瑞 ●vintagewang@apache.org ●@阿里巴巴-中间件 ●Apache RocketMQ 创始人， PPMC Member, Committer ●Open-Messaging创始人 ## ☐ 扫一扫上面的二维码图案，加我微信 01/ 阿里消息中间件的演变历史 02 双11万亿级数据洪峰的挑战 03/ Apache RocketMQ 未来展望 ## 阿里消息中间件演变历史 Napoli ActiveMQ内核 B2B大规模使用 MetaQ v3.0 RocketMQ开源 Apache 五彩石项目 交易核心消息流转 MetaQ v1.0 顺序消息 海量堆积能力 2016 Aliware MQ v1.0 Notify v3.0 ## 阿里消息中间件现状  ## CONTENTS 01 阿里消息中间件的演变历史

## 万亿级数据洪峰下的消息引擎 Apache RocketMQ 誓嘉  ## 自我介绍 ●花名：誓嘉 ●真名：王小瑞 ●vintagewang@apache.org ●@阿里巴巴-中间件 ●Apache RocketMQ 创始人， PPMC Member, Committer ●Open-Messaging创始人 ## ☐ 扫一扫上面的二维码图案，加我微信 01/ 阿里消息中间件的演变历史 02 双11万亿级数据洪峰的挑战 03/ Apache RocketMQ 未来展望 ## 阿里消息中间件演变历史 Napoli ActiveMQ内核 B2B大规模使用 MetaQ v3.0 RocketMQ开源 Apache 五彩石项目 交易核心消息流转 MetaQ v1.0 顺序消息 海量堆积能力 2016 Aliware MQ v1.0 Notify v3.0 ## 阿里消息中间件现状  ## CONTENTS 01 阿里消息中间件的演变历史

...5 二：Producer 如何发送消息.....6 2.1 producer 发送普通消息.....7 2.2 顺序消息发送.....7 2.3 分布式事物消息.....9 三：Broker 落地消息.....11 2.1 普通消息落地.....11 2.2 分布式事物消息落地.....12 第二章 consumer 三：长轮询.....20 四：push 消息—并发消费消息.....24 五：push 消费-顺序消费消息.....26 六：pull 消息消费.....28 七：shutdown.....28 第三章：broker.....29 一：brker 的启动.....29 二：消息存储.....32 三：load&recover uments/2/1/4/a/214ac1a17f5807c7c62fd64499fff4da/p5_1.jpg) Producer 如何感知要发送消息的 broker 即 brokerAddrTable 中的值是怎么获得的， 1. 发送消息的时候指定会指定 topic，如果 producer 集合中没有会根据指定 topic 到 namesrv 获取 topic 发布信息 TopicPublishInfo，并放入本地集合