# 基于amqp实现的golang消息队列 MaxQ 2017-07-01 张培培 饿了么－基础框架组 ## 内容 1. 队列 2. IPC消息队列 3. AMQP协议 4. MaxQ架构模型 5. MaxQ相关特性 6. 使用场景和案例 ### 1. 队列  - 按照协议spec自动生成frame encode/decode • Exchange接口化 • Queue接口化——MaxQ集群 ## MaxQ - 生产实现架构 ![ a1/p9_1.jpg) ## 满足生产环境的MaxQ集群： 1. 四层Proxy负载均衡 2. 集群中各Node通过grpc通信，publish、delivery、ack转发，HA消息同步 3. zookeeper存储元数据保证元数据一致性，Master queue选举 4. 集群管理维护所有 MaxQ 集群 ### 5. MaxQ相关特性 1. 消息可靠性 2. 容错性 3.

(MAX("facid") + 1) FROM "facilities") AS _, 'Spa', 20, 30, 100000, 800; maxq = Facility.select(fn.MAX(Facility.facid) + 1) subq = Select(columns=(maxq, 'Spa', 20, 30, 100000, 800)) query = Facility.insert_from(subq

(MAX("facid") + 1) FROM "facilities") AS _, 'Spa', 20, 30, 100000, 800; maxq = Facility.select(fn.MAX(Facility.facid) + 1) subq = Select(columns=(maxq, 'Spa', 20, 30, 100000, 800)) query = Facility.insert_from(subq

"facilities") AS _ 'Spa', 20, 30, 100000, 800; maxq = Facility.select(fn.MAX(Facility.facid) + 1) subq = Select(columns=(maxq, 'Spa', 20, 30, 100000, 800)) query = Facility.insert_from(subq

"facilities") AS _ 'Spa', 20, 30, 100000, 800; maxq = Facility.select(fn.MAX(Facility.facid) + 1) subq = Select(columns=(maxq, 'Spa', 20, 30, 100000, 800)) query = Facility.insert_from(subq

(MAX("facid") + 1) FROM "facilities") AS _, 'Spa', 20, 30, 100000, 800; maxq = Facility.select(fn.MAX(Facility.facid) + 1) subq = Select(columns=(maxq, 'Spa', 20, 30, 100000, 800)) query = Facility.insert_from(subq

"facilities") AS _ 'Spa', 20, 30, 100000, 800; maxq = Facility.select(fn.MAX(Facility.facid) + 1) subq = Select(columns=(maxq, 'Spa', 20, 30, 100000, 800)) query = Facility.insert_from(subq

"facilities") AS _ 'Spa', 20, 30, 100000, 800; maxq = Facility.select(fn.MAX(Facility.facid) + 1) subq = Select(columns=(maxq, 'Spa', 20, 30, 100000, 800)) query = Facility.insert_from(subq

(MAX("facid") + 1) FROM "facilities") AS _, 'Spa', 20, 30, 100000, 800; maxq = Facility.select(fn.MAX(Facility.facid) + 1) subq = Select(columns=(maxq, 'Spa', 20, 30, 100000, 800)) query = Facility.insert_from(subq

"facilities") AS _, 'Spa', 20, 30, 100000, 800; maxq = Facility.select(fn.MAX(Facility.facid) + 1) subq = Select(columns=(maxq, 'Spa', 20, 30, 100000, 800)) query = Facility.insert_from(subq