redis简介

  1. redis是一个key-value存储系统。和Memcached类似,它支持存储的value类型相对更多

  2. 包括string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash(哈希类型)

  3. 这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作,且这些操作都是原子性的

  4. 与memcached一样,为了保证效率,数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件,并且在此基础上实现了master-slave(主从)同步

redis事务

  1. redis事务介绍

    1. redis事务是可以一次执行多个命令,本质是一组命令的集合。

    2. 一个事务中的所有命令都会序列化,按顺序串行的执行而不会被其他命令插入

      作用:一个队列中,一次性、顺序性、排他性的执行一系列命令

  2. multi 指令基本使用

    1. 下面指令演示了一个完整的事物过程,所有指令在exec前不执行,而是缓存在服务器的一个事物队列中

    2. 服务器一旦收到exec指令才开始执行事物队列,执行完毕后一次性返回所有结果

    3. 因为redis是单线程的,所以不必担心自己在执行队列是被打断,可以保证这样的“原子性”

     注:redis事物在遇到指令失败后,后面的指令会继续执行

 # Multi 命令用于标记一个事务块的开始事务块内的多条命令会按照先后顺序被放进一个队列当中,最后由 EXEC 命令原子性( atomic )地执行
> multi(开始一个redis事物)
incr books
incr books
> exec (执行事物)
> discard (丢弃事物)

注:myl的rollback与redis的discard的区别

  1. mysql回滚为sql全部成功才执行,一条sql失败则全部失败,执行rollback后所有语句造成的影响消失

  2. redis的discard只是结束本次事务,正确命令造成的影响仍然还在.

    1)如果在一个事务中的命令出现错误,那么所有的命令都不会执行

    2)如果在一个事务中出现运行错误,那么正确的命令会被执行

watch 指令作用

实质:WATCH 只会在数据被其他客户端抢先修改了的情况下通知执行命令的这个客户端(通过 WatchError 异常)但不会阻止其他客户端对数据的修改

  1. watch其实就是redis提供的一种乐观锁,可以解决并发修改问题

  2. watch会在事物开始前盯住一个或多个关键变量,当服务器收到exec指令要顺序执行缓存中的事物队列时,redis会检查关键变量自watch后是否被修改

  3. WATCH 只会在数据被其他客户端抢先修改了的情况下通知执行命令的这个客户端(通过 WatchError 异常)但不会阻止其他客户端对数据的修改

分布式锁

  1. 分布式锁本质是占一个坑,当别的进程也要来占坑时发现已经被占,就会放弃或者稍后重试

  2. 占坑一般使用 setnx(set if not exists)指令,只允许一个客户端占坑

  3. 先来先占,用完了在调用del指令释放

  setnx lock:codehole true
.... do something critical ....
> del lock:codehole
  1. 但是这样有一个问题,如果逻辑执行到中间出现异常,可能导致del指令没有被调用,这样就会陷入死锁,锁永远无法释放

  2. 为了解决死锁问题,我们拿到锁时可以加上一个expire过期时间,这样即使出现异常,当到达过期时间也会自动释放锁

 > setnx lock:codehole true
> expire lock:codehole 5
.... do something critical ....
> del lock:codehole
  1. 这样又有一个问题,setnx和expire是两条指令而不是原子指令,如果两条指令之间进程挂掉依然会出现死锁

  2. 为了治理上面乱象,在redis 2.8中加入了set指令的扩展参数,使setnx和expire指令可以一起执行

 > set lock:codehole true ex 5 nx
''' do something '''
> del lock:codehole

redis操作

 import redis

 # r = redis.Redis(host='1.1.1.3', port=6379)    # 操作模式

 pool = redis.ConnectionPool(host='1.1.1.3', port=6379)
r = redis.Redis(connection_pool=pool) # 连接池 r.set('foo', 'Bar')
print(r.get('foo'))

最新文章

  1. WPF DataGrid 鼠标双击选中的DataGridRow及Row数据
  2. u-boot移植初步尝试-tiny4412
  3. linux下vim如何配置markdown插件
  4. ECMAScript数据类型
  5. Java String字符串补0或空格
  6. 蓝牙的L2CAP协议
  7. Android中向SD卡读写数据,读SD卡和手机内存
  8. jquery控制按钮的禁用与启用
  9. .NET分布式事务处理总结【下】 - 包含MSMQ的分布式事务处理
  10. 【Android】关于pix,dip,dip,sp等相关概念
  11. SQLserver中的常量与变量、判断循环语句
  12. 利用github for windows 工具将本地的内容同步到github上
  13. cssline-height行高 全解
  14. HEX文件合并方法
  15. 升级python2.7, 实现python2.7与python3并存
  16. Java代码一行一行读取txt的内容
  17. OKHttpUtil工具类
  18. IO流中File文件最常用和直接的用法
  19. Luogu P1983 车站分级
  20. NSAttributedString 上下标---!!!!!

热门文章

  1. [转]cookie 和 session
  2. unittest(20)- 自动更新表格中的测试数据(1)
  3. Holer一款局域网服务器代理到公网的内网映射工具
  4. 序列化模块ModelSerializer上补充及ListSerializer
  5. Ionic3学习笔记(六)存储之使用 SQLite
  6. 用 20 行 python 代码实现人脸识别!
  7. JAVA:初识Java · Xer97
  8. 11. 无数人难办事? - 迪米特法则(LoD)
  9. WEB端缓存机制
  10. AAAI |如何保证人工智能系统的准确性?