并根据消息内容进⾏相应的处理⼯作。 下⾯的这段代码展示了⼀个简单的消息接收者， 在没有消息的时候， 这个程序将阻塞在 mq.get_message() 调⽤上 ⾯； 当有消息（邮件地址）出现时， 程序就会打印出该消息并发送邮件： >>> from redis import Redis >>> from message_queue import MessageQueue >>> client = Redis(decode_responses=True) .. email_address = mq.get_message() # 阻塞直到消息出现 ... send_email(email_address) # 打印出邮件地址并发送邮件 ... peter@exampl.com jack@spam.com tom@blahblah.com ⽽以下代码则展示了消息发送者是如何将消息推⼊到队列⾥⾯的： >>> from redis 使⽤消息队列实现实时提醒 消息队列除了可以在应⽤程序的内部中使⽤， 还可以⽤于实现⾯向⽤户的实时提醒系统。 ⽐如说， 如果我们在构建⼀个社交⽹站的话， 那么可以使⽤ JavaScript 脚本， 让客户端以异步的⽅式调⽤ MessageQueue 类的 get_message() ⽅法， 然后程序就可以在⽤户被关注的时候、收到了新回复的时候⼜或者收到 新私信的时候， 通过调⽤ add_message()

常访问的Value被保存在内存中，保证绝大部分访问请求的 最高性能。不常访问的Value（冷数据）则会被存储到磁盘上，以达到内存利用最高性价比。 云数据库 Redis 版 产品简介 7 数据异步交换 在内存将要跑满的时候，Redis混合存储型实例从最近访问时间、访问频率、Value大小这三个维度综 合考虑挑选出一些数据，通过后台线程将之存储到磁盘上。 当用户访问数据时，如果该数据对应的 Redis 原生复制的弊端。 Redis 原生复制弊端简要如下： Redis 复制中断后，Slave 会立即发起 psync，psync 尝试部署同步不成功，就会 全量同步 RDB 并发送至 Slave 节点。 如果 Redis 全量同步，会导致主节点执行全量备份，进程 Fork，可造成主节点达 到毫秒或秒级的卡顿。 Redis 进程 Fork 导致 Copy-On-Write Redis 读写分离实例 简介 针对读多写少的业务场景，云数据库 Redis 版推出了读写分离的产品形态，提供高可用、高性能、高灵活的读 写分离服务，解决热点数据集中及高并发读取的业务需求，最大化地节约用户运维成本。 组件 Redis 读写分离版本由 Proxy（路由）服务器、主-备节点及只读节点组成。 云数据库 Redis 版 产品简介 19 -

Redis 多数据中心双向同步 祝辰 • 携程框架架构部门 • 资深研发工程师 • 专注于 Redis 高可用系统的 研发工作 • 对分布式存储系统有所涉猎 讲师介绍 祝辰 1 开篇 2 3 4 5 目 录 CONTENTS 携程的Redis架构 分布式理论 双向/多向同步的问题 CRDT 19 世纪的通讯 “At 12:30 am on April 4th replicas, and where it is always mathematically possible to resolve inconsistencies which might result. 并发冲突 举个栗子: LWW(Last Writer Wins)-Register: 适用于 K/V 类型的存储 解决数据冲突的方式是通过使用 unix timestamp 或类似自然时间的计数 None 并发冲突的场景 Data Type: Strings Use Case: Concurrent SETs Conflict Resolution: Last Write Wins (LWW) Redis String 正常同步的场景 Data Type: Maps Use Case: Common HSET Conflict Resolution: None 并发冲突的场景 -

携程 Redis 多数据中心 双向同步实践 祝辰 祝辰 目前任职携程框架架构部门资深 研发工程师 负责框架Redis团队的开发工作 目录 1 业务背景 2 3 双向同步 4 CRDT 高可用 开篇 & 背景 Redis 在携程的规模 25,000,0 00 QPS 2000+Clust er 200TB + 跨公网同步 SHANGHAI CANADA

用JSON作为存储格式，JavaScript作为查询语言，MapReduce和HTTP作为API的NoSQL数据库。应用 广泛，如BBC用在其动态内容展示平台，Credit Suisse用在其内部的商品部门的市场框架，Meebo，用 在其社交平台（web和应用程序）,默认会在5984端口开放Restful的API接口，如果使用SSL的话就会监 听在6984端口，用于数据库的管理功能。其HTTP Server默认开启时没有进行验证，而且绑定在