redis安装及其图形化界面安装以及与Python的交互

太阳不下山

　　
　　文章目录

• Redis数据库安装
  
• Redis可视化界面安装
  
• Redis与Python的交互
  
• 
  
  
  
  • Python连接Redis数据库的代码。
    
  • Python 实现一个 Reids 的分布式锁的功能的代码
    
  
  

　　redis是一个key-value存储系统。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash（哈希类型）。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。在此基础上，redis支持各种不同方式的排序。与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步。
Redis 是一个高性能的key-value数据库。 redis的出现，很大程度补偿了memcached这类key/value存储的不足，在部 分场合可以对关系数据库起到很好的补充作用。它提供了Java，C/C++，C#，PHP，JavaScript，Perl，Object-C，Python，Ruby，Erlang等客户端，使用很方便。
Redis数据库安装　　百度Redis
有一篇Redis菜鸟教程
https://www.runoob.com/redis/redis-tutorial.html
里面提供了Redis下载的GitHub地址
https://github.com/MSOpenTech/redis/releases
进入后找到适用于自己操作系统的版本的msi文件下载

然后自定义路径进行安装
直接傻瓜式安装就好了
Redis可视化界面安装　　在GitHub上搜索Redisdesktopmanager
点进去之后下拉到如下界面

点击0.8.8结尾的蓝字部分

下载其exe安装包
下载完成直接傻瓜式安装
打开后连接

步骤如上图
那么连接成功后如下：

Redis与Python的交互　　不多说，直接上代码

Python连接Redis数据库的代码。

from redis import StrictRedis, ConnectionPool
redis_url="redis://:xxxx@112.27.10.168:6379/15"
pool = ConnectionPool.from_url(redis_url, decode_responses=True)
r= StrictRedis(connection_pool=pool)

　　redis主要用来做分布式爬虫

Python 实现一个 Reids 的分布式锁的功能的代码

import time
import redis
from conf.config import REDIS_HOST, REDIS_PORT, REDIS_PASSWORD
class RedisLock:
  def __init__(self):
    self.conn = redis.Redis(host=REDIS_HOST, port=REDIS_PORT, password=REDIS_PASSWORD, db=1)
    self._lock = 0
    self.lock_key = ""
  @staticmethod
  def my_float(timestamp):
    """
    Args:
      timestamp:
    Returns:
      float或者0
      如果取出的是None，说明原本锁并没人用，getset已经写入，返回0，可以继续操作。
    """
    if timestamp:
      return float(timestamp)
    else:
      #防止取出的值为None，转换float报错
      return 0
@staticmethod
def get_lock(cls, key, timeout=10):
  cls.lock_key = f"{key}_dynamic_lock"
  while cls._lock != 1:
    timestamp = time.time() + timeout + 1
    cls._lock = cls.conn.setnx(cls.lock_key, timestamp)
    # if 条件中，可能在运行到or之后被释放，也可能在and之后被释放
    # 将导致 get到一个None，float失败。
    if cls._lock == 1 or (
            time.time() > cls.my_float(cls.conn.get(cls.lock_key)) and
            time.time() > cls.my_float(cls.conn.getset(cls.lock_key, timestamp))):
      break
    else:
      time.sleep(0.3)
@staticmethod
def release(cls):
  if cls.conn.get(cls.lock_key) and time.time() < cls.conn.get(cls.lock_key):
    cls.conn.delete(cls.lock_key)

def redis_lock_deco(cls):
  def _deco(func):
    def __deco(*args, **kwargs):
      cls.get_lock(cls, args[1])
      try:
        return func(*args, **kwargs)
      finally:
        cls.release(cls)
    return __deco
  return _deco

@redis_lock_deco(RedisLock())
def my_func():
  print("myfunc() called.")
  time.sleep(20)
if __name__ == "__main__":
  my_func()