【数据库】 - Redis, MemCache 核心

内存缓存

磁盘缓存

Redis缓存

Memcached缓存

其他分布式缓存

MapReduce中间结果

Spark中间结果

数据清洗缓存

数据转换缓存

用户数据缓存

商品数据缓存

静态页面缓存

动态页面缓存

强一致性

弱一致性

Redis的应用场景

Redis的安装

Redis的集群架构

Redis数据类型

Redis数据持久化

Redis中的数据查询

MemCache的应用场景

MemCache的安装

MemCache的配置

MemCache的使用

Memcached的持久化特性

Memcache的内存管理机制

主动预热

被动预热

互斥锁

布隆过滤器

随机过期时间

二级缓存

读降级

写降级

Redis 是基于内存的数据存储，所有的数据都保存在内存中，读写操作非常迅速，能够在纳秒级别处理请求。

设计来避免并发锁的问题。多线程通常会引入上下文切换的开销;

单线程模型的另一个优点是 避免了锁竞争。

Redis 提供多种高效的数据结构（如 字符串、哈希、列表、集合、有序集合等）；
这些数据结构都经过精心设计，优化了内存访问速度。特别是在处理大数据量时，Redis 的表现仍然非常出色。

Redis 使用 I/O 多路复用 技术（如 epoll 或 select），它能在单线程中同时处理多个客户端请求。这种方式能够充分利用 CPU 时间片，实现高效的并发处理。通过事件循环，Redis 可以在收到大量请求时，尽量减少等待 I/O 操作的时间，保持高吞吐量和低延迟。

class AsyncRedisWrapper:
    def __init__(self, cluster: t.Optional[bool], host: t.Optional[str], port: t.Optional[int],
                 password: t.Optional[str], db: t.Optional[int] = None, *,
                 timeout: t.Union[int, float] = 3, max_connections: int = 2000):
        self.is_cluster = cluster
        self._host = '127.0.0.1' if host is None else host
        self._port = 6379 if port is None else port
        self._password = password if password else None
        self._db = 0 if db is None else db
        self.timeout = timeout
        self.max_connections = max_connections

        if self.is_cluster:
            self._redis = AsyncRedisCluster(
                host=self._host, port=self._port, password=self._password,
                socket_timeout=timeout, socket_connect_timeout=timeout,
                max_connections=max_connections
            )
        else:
            self._redis = AsyncRedis(
                host=self._host, port=self._port, password=self._password, db=self._db,
                socket_timeout=timeout, socket_connect_timeout=timeout,
                max_connections=max_connections
            )

    def __repr__(self) -> str:
        return 'redis://%s:%d/#%d)' % (self._host, self._port, 0 if self.is_cluster else self._db)

    def __str__(self) -> str:
        return self.__repr__()

    def __getattr__(self, item):
        if hasattr(self._redis, item) and callable(getattr(self._redis, item)):
            return functools.partial(self._execute, item)
        else:
            raise AttributeError('Unknown attribute : %s' % item)

redis-clust://:passwd@RedisHostName1:6379

redis-clust://:passwd@15.10.179.11:7000,15.10.179.11:7001,15.10.179.11:7002

只能查询该node的数据，其他node的数据查询不到。

连接实例会找寻其他node，从而成功交互数据。