# 基于amqp实现的golang消息队列 MaxQ 2017-07-01 张培培 饿了么－基础框架组 ## 内容 1. 队列 2. IPC消息队列 3. AMQP协议 4. MaxQ架构模型 5. MaxQ相关特性 6. 使用场景和案例 ### 1. 队列  跟消息队列相比，有哪些共性？ • 生产者消费者 • 通信方式 • 存储方式 • 堆积能力 消息可靠性 • 生产消费关系 • Pull/Push ### 2. IPC消息队列  跟消息队列相比，有哪些共性？ ###

## 现代编程思想 队列：可变数据结构实现 Hongbo Zhang ## 队列 - 我们曾经介绍过队列这个数据结构 - 先进先出 ☐ 利用两个堆栈进行实现 - 我们利用可变数据结构进行实现 - 基于数组的循环队列 ☐ 单向链表 ## 队列 • 我们实现以下函数（以整数队列为例） 1. struct Queue { ... } 2. 3. fn make() -> self，为了方便起见，我们将本身作为返回值传回 1. make().push(1).push(2).push(3).pop().pop().length() // 1 ## 循环队列 - 我们可以利用一个数组来代表队列 - 数组是一个连续的存储空间，每一个字段均可被修改 ☐ 数组被分配后长度不变 1. let a: Array[Int] = Array::make(5, 0) 2. a[1] = 2 4. println(a) // [1, 2, 0, 0, 0] - 我们记录当前的开始和结束，每当添加新的元素的时候，结束向后移一位。如果超出数组长度，则绕回开头 ## 循环队列 make() End  Start

基础服务 支撑系统 消息PaaS平台 ## 存储和中间件 账号/认证 接入管理 基础API 事件输出 逻辑回调 UI DB 淘友关系 打点输出 消息形态 消息队列 消息业务逻辑层 群/群成员 基础监控 单聊 群聊 消息号 分布式缓存 数据模型层 定义模型 关注关系 全链路 消息 收件箱 会话 Redis 会话视图 消息模型 客户端 ## 电商消息核心技术和挑战 ## 电商消息多端同步设计 同步技术核心要求： 1. 客户端和服务端消息最终一致 2，不一致后增量补偿机制 3. 端侧维护syncId 消息IM 消息队列 sync可靠同步 补偿机制 在线推送 在线通道 同步/补偿机制 通道不持久化消息 消息SDK 补偿：客户端冷启动、后台切换到前台以及syncId不连续请求服务器 网络SDK 分页拉取 按业务多端同步 群活动推送 营销推送 群成员关系 syncId序列号 消息SaaS Agoo离线通道 发送消息 单聊 分发模块 号关注关系 RDB缓存队列 消息发送 客户端 持久化消息 消息队列 单聊关系 消息队列 推送消息 ACK 追加写入 消息表 更新 会话视图表 收件箱表 增量补偿根据同步位点获取 sync\_inbox表 客户端SyncSDK

rate|缓存命中率|快取命中率| |stack|栈|堆疊| |top of the stack|栈顶|堆疊頂| |bottom of the stack|栈底|堆疊底| |queue|队列|佇列| |double-ended queue|双向队列|雙向佇列| |front of the queue|队首|佇列首| |rear of the queue|队尾|佇列尾| |hash table|哈希表|雜湊表| |hash |heap|堆|堆積| |English|簡體中文|繁體中文| |---|---|---| |max heap|大顶堆|大頂堆積| |min heap|小頂堆|小頂堆積| |priority queue|优先队列|優先行列| |heapify|堆化|堆積化| |top-k problem|Top-k 问题|Top-k 問題| |graph|图|圖| |vertex|顶点|頂點| |undirected graph|无向图|無向圖|