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

0国际(CC BY-SA 4.0) 之前博主的一篇读书笔记——《深入理解Java虚拟机》系列之回收对象算法与四种引用类型博客中为家介绍了Java中的四种引用类型，很多同学都希望能够对引用，还有不同类型引用的原理进行更深入了解。因此博主查看了抽象父类Reference和负责注册引用对象的引用队列ReferenceQueue的源码在此和大家一起分享，并做了一些分析，感兴趣的同学可以一起学习。 ## Reference源码分析 一个构造函数带需要注册到的引用队列，一个不带。`queue`的意义在于我们以吃从外部通过对queue的操作来了解到引用实例所指向的实际对象是否被回收了，同时我们也可以过queue对引用实例进行一些额外的操作；但如果我们的引用实例在创建时没有指定一个引用队列，我们要想知道实际对象是否被回收，就只能够不停地轮询引用实例的get()方法是否为空了。值得注意的是虚引用Phantom Reference，由于它的get()方法永远返回null，因此它的构造函数必须指定一个引队列。这两种查询实际对象是否被回收的方法都有应用，如weakHashMap中就选择去查询queue的据，来判定是否有对象将被回收；而ThreadLocalMap，则采用判断get()是否为null来作处理。`` 接下来是它的主要成员： private T referent; /* Treated

## 现代编程思想 队列：可变数据结构实现 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

University ## make & Makefile 程序的编写步骤 • 依赖关系图 工程管理与 make make 的工作原理 规则与依赖关系 通配符的使用 • 变量的定义和引用 • 自动变量 模式规则 • Makefile 的结构 make 命令参数与选项 • 常见的错误 • 依赖关系的自动生成 • Turbo C 的 make 与 make 相关的命令 o目标与lex.h相关。要实现这样的关联可以通过`Makefile`更强大的内置函数功能实现： $(subst .c,.o,*.c): lex.h 注意：.c，.o中间没有空格！ ## 变量的定义和引用 • Makefile支持强大的变量定义，并且提供许多内置变量，同时还具有宏定义和函数定义等功能，这些使得make能产生奇效； 变量的定义文法如下： $$ \begin{aligned}&a (Simply Expanded Variable), 两者的区别: 如果value中如果出现变量的引用, 该引用是在var_name定义时就展开 (simply), 还是在下文引用var_name时才展开 (recursively), 因此如果value中没有变量引用, 两者效果一样; • 变量的引用格式如下: $$ \begin{aligned}&\=\{var\_{n}ame\}\quad

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

C 语言有 int* 这种指针类型，C++ 中还新增了 int& 这种引用类型。引用和指针是一样的，只是包装了一层语法糖，唯二的区别是：他不需要手动写 & 和 * 运算符；他的拷贝是导致他指向的值拷贝，而不是对门牌号的拷贝。 • 但是 C++ 的 int&& 并不是二级指针，而是右值引用，之后的课里会讲到。 ## 实验：你的电脑是大端还是小端？ 如果说 p 是一个指向 [Image](/uploads/documents/0/9/6/3/0963fff64fa57377ee5925164d5ace9b/p60_1.jpg) ## C++ 的引用：无需手动 & 和 * • C++ 的引用类型 int& 本质无非是 int* 指针。 · 区别在于： - 他不需要手动 & 来创建。 • 他不需要手动 * 来创建。 - 他无法重新赋值，指向新的变量。 的）只需一个起始地址就能确定。 - 而动态长度的数组（通过 malloc 在堆上分配的）就需要起始地址和数组长度两个，才能确定下来，也就是 char* 和 int 两个。 - 所以要把动态数组的引用传给函数，需要有两个参数，一个指针加一个长度。 main.cpp #include #include #include void fillarr(char*