redis协议与异步方式

本文涉及的产品
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
云数据库 Tair(兼容Redis),内存型 2GB
简介: redis协议与异步方式

redis协议图

 

redis网络

       微观抽象的redis网络,由io多路复用+非阻塞io组成,有io检测和io操作的职责,有异步事件处理流程,先注册事件,在事件循环中处理事件;

       宏观直接的redis网络,忽略其他流程,只关注数据包的处理流程;

       redis网络层中,假设有三个client与服务器建立连接,reactor会管理对应的连接,通过事件循环不断的处理连接给服务器发送的数据,现在只关注数据包处理的流程,这里有三个管道,车子比做网络线程,网络线程不断地从管道中取数据包,分割数据包,decode,compute,encode,最后发送到client端;哪一个队列中先构成完整的数据包,谁就最先处理;

       1)一个数据包可能是由多个读事件构成的;

       2)管道就是连接;

       3)人推车相当于网络线程;

 

redis pipeline

       redis pipeline是一个客户端提供的机制,而不是服务的提供的;和http1.1差不多;

       pipline不具备事务性;

       原来的是请求回应模式,即一个请求一个回应;

现在pipline模式,就算使用阻塞io,也可以同时发送多个请求,和同时接收多个回应;pipline模式主要是针对阻塞io使用;目的主要是节约网络传输事件;

 

redis事务

       事务,用户定义一些列数据库操作,这些操作视为一个完整的逻辑处理工作单元,要么全部执行,要么全部不执行,是不可分割的工作单元;探讨事务的前提是有并发连接的时候,有并发冲突的问题;乐观锁实现,所以失败需要重试,增加业务逻辑的复杂度;

       multi开启事务,事务执行过程中,单个命令是入队列操作,直到调用exec才会一起执行;

       acid,事务的特征分析;a是原子性,c是一致性,i是隔离性,d是持久性;

       lua,实现原子性;redis中加载了一个lua虚拟机,用来执行redis lua脚本,redis lua脚本的执行是原子性的;当某个脚本正在执行的时候,不会有其他命令或脚本被执行;

       lua脚本不具备一致性,具有隔离性,不具有持久性;

       lua脚本当中的命令会直接修改数据的状态;

       lua脚本mysql存储区别,mysql存储过程不具备事务性,所以也不具备原子性;

       注意:如果项目中使用了lua脚本,不需要使用上面的事务命令;

redis驱动

       后端都是采用reactor网络模型;

       驱动是指要构建一个模块,这个模块可以和redis进行交互;

       同步驱动是阻塞io实现的,效率低,异步驱动是非阻塞io实现的,融合到项目的reactor中;

       通过将redis连接融合到reactor进行管理来实现;

       构建事件对象,需要考虑hiredis事件对象,reactor事件对象;

       适配事件控制,添加读写事件,删除读写事件;复用项目中的reactor事件循环;

       hiredis封装规则中,所有io自己来做,提供了事件操作的接口,我们只需要适配这些事件操作接口;不同网络库,不同平台,对事件操作的接口不一致;因为reactor事件是异步处理的,异步连接处理逻辑需要提供函数来接收返回值;

 

自定义实现

       有时候,用户除了需要与项目网络层兼容,需要同时考虑与项目中数据结构契合;这个时候可以考虑自己实现redis协议,从解析协议开始转换成项目中的数据结构;

 

 

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
目录
相关文章
|
6月前
|
NoSQL Redis
Redis原理之网络通信协议笔记
1. RESP协议 ​2. 自定义Socket连接Redis
|
6月前
|
缓存 NoSQL 数据库
探秘Redis读写策略:CacheAside、读写穿透、异步写入
本文介绍了 Redis 的三种高可用性读写模式:CacheAside、Read/Write Through 和 Write Behind Caching。CacheAside 简单易用,但可能引发数据不一致;Read/Write Through 保证数据一致性,但性能可能受限于数据库;Write Behind Caching 提高写入性能,但有数据丢失风险。开发者应根据业务需求选择合适模式。
656 2
探秘Redis读写策略:CacheAside、读写穿透、异步写入
|
2月前
|
canal 缓存 NoSQL
Redis缓存与数据库如何保证一致性?同步删除+延时双删+异步监听+多重保障方案
根据对一致性的要求程度,提出多种解决方案:同步删除、同步删除+可靠消息、延时双删、异步监听+可靠消息、多重保障方案
Redis缓存与数据库如何保证一致性?同步删除+延时双删+异步监听+多重保障方案
|
9天前
|
设计模式 NoSQL Go
Redis 实现高效任务队列:异步队列与延迟队列详解
本文介绍了如何使用 Redis 实现异步队列和延迟队列。通过 Go 语言的 `github.com/go-redis/redis` 客户端,详细讲解了 Redis 客户端的初始化、异步队列的实现和测试、以及延迟队列的实现和测试。文章从基础连接开始,逐步构建了完整的队列系统,帮助读者更好地理解和应用这些概念,提升系统的响应速度和性能。
27 6
|
4月前
|
安全 NoSQL Java
网络安全-----Redis12的Java客户端----客户端对比12,Jedis介绍,使用简单安全性不足,lettuce(官方默认)是基于Netty,支持同步,异步和响应式,并且线程是安全的,支持R
网络安全-----Redis12的Java客户端----客户端对比12,Jedis介绍,使用简单安全性不足,lettuce(官方默认)是基于Netty,支持同步,异步和响应式,并且线程是安全的,支持R
|
6月前
|
监控 NoSQL 测试技术
python使用Flask,Redis和Celery的异步任务
python使用Flask,Redis和Celery的异步任务
|
6月前
|
消息中间件 NoSQL Kafka
Redis事务与异步方式
Redis事务与异步方式
86 0
|
6月前
|
NoSQL Java 关系型数据库
使用Kafka实现Java异步更新通知解决Redis与MySQL数据不一致
使用Kafka实现Java异步更新通知解决Redis与MySQL数据不一致
113 0
|
6月前
|
NoSQL 网络协议 关系型数据库
Redis(二)网络协议和异步方式(乐观锁&悲观锁、事务)
Redis(二)网络协议和异步方式(乐观锁&悲观锁、事务)
70 0
|
6月前
|
存储 NoSQL 关系型数据库
Redis协议与异步方式(redis网络层、pipeline、事务、lua脚本、ACID特性、发布订阅、hiredis实现同步连接与异步连接)
Redis协议与异步方式(redis网络层、pipeline、事务、lua脚本、ACID特性、发布订阅、hiredis实现同步连接与异步连接)
198 0