标签 redis 下的文章

2024-09-06

在Redis中，RDB、AOF和混合持久化机制是用来保障数据持久化的三种方式。

RDB（Redis DataBase）：是Redis默认的持久化方式。在指定的时间间隔内将内存中的数据集快照写入磁盘，也就是Snapshot快照，它捕获的是某一时刻的数据。

# 在redis.conf中配置
save 900 1      # 900秒内至少1个键被修改则触发保存
save 300 10     # 300秒内至少10个键被修改则触发保存
save 60 10000   # 60秒内至少10000个键被修改则触发保存

dbfilename dump.rdb  # 指定RDB文件名
dir /path/to/your/redis/directory  # 指定RDB文件存储目录

AOF（Append Only File）：是另一种持久化方式。它记录每一个写操作，并在数据文件中追加记录这些写操作。

# 在redis.conf中配置
appendonly yes  # 开启AOF持久化存储
appendfilename "appendonly.aof"  # AOF文件名
dir /path/to/your/redis/directory  # 文件存储目录

# AOF文件的更新频率
appendfsync always  # 每次写入都同步，最慢但最安全
appendfsync everysec  # 每秒同步一次，折衷方案
appendfsync no  # 完全依赖操作系统，最快但不安全

混合持久化机制：是Redis 4.0以上版本提出的新概念。它结合了RDB快照和AOF日志，使用RDB来快速恢复数据，同时使用AOF来保证数据的完整性。

# 在redis.conf中配置
aof-use-rdb-preamble yes  # 开启混合持久化机制

混合持久化机制会在AOF文件中以RDB的格式存储一个快照，当Redis重启时，它会先加载AOF文件，如果检测到RDB的快照，就会直接加载RDB快照，然后再重放AOF文件中剩余的指令。这样既保证了恢复速度，也保证了数据的完整性。

- 阅读更多 -

揭秘Redis列表底层实现

System

2024-09-06

所有,redis

Redis的列表数据结构是使用双向链表实现的，这使得在列表的两端进行插入和删除操作都可以在常数时间内完成。

在Redis内部，列表的每个节点使用一个listNode结构表示：

typedef struct listNode {
    struct listNode *prev;
    struct listNode *next;
    void *value;
} listNode;

而整个列表由一个list结构体来维护：

typedef struct list {
    listNode *head;
    listNode *tail;
    void (*free)(void *ptr);
    unsigned long len;
} list;

其中：

head 指向列表的头节点。
tail 指向列表的尾节点。
free 是一个函数指针，用于释放列表节点的值所占用的内存。
len 记录了列表的长度。

以下是一个简单的Redis列表结构的实现示例：

#include <stdio.h>
#include <stdlib.h>

typedef struct listNode {
    struct listNode *prev;
    struct listNode *next;
    void *value;
} listNode;

typedef struct list {
    listNode *head;
    listNode *tail;
    void (*free)(void *ptr);
    unsigned long len;
} list;

list *listCreate() {
    list *l = malloc(sizeof(list));
    l->head = NULL;
    l->tail = NULL;
    l->len = 0;
    l->free = NULL;
    return l;
}

listNode *listNodeCreate(void *value) {
    listNode *node = malloc(sizeof(listNode));
    node->prev = NULL;
    node->next = NULL;
    node->value = value;
    return node;
}

int listAddNodeHead(list *l, void *value) {
    listNode *node = listNodeCreate(value);
    if (l->len == 0) {
        l->head = node;
        l->tail = node;
    } else {
        node->next = l->head;
        l->head->prev = node;
        l->head = node;
    }
    l->len++;
    return 1;
}

int listAddNodeTail(list *l, void *value) {
    listNode *node = listNodeCreate(value);
    if (l->len == 0) {
        l->head = node;
        l->tail = node;
    } else {
        node->prev = l->tail;
        l->tail->next = node;
        l->tail = node;
    }
    l->len++;
    return 1;
}

void listFree(list *l) {
    listNode *current = l->head;
    listNode *next = NULL;
    while(current != NULL) {
        next = current->next;
        if (l->free) l->free(current->value);
        free(current);
        current = next;
    }
    free(l);
}

int main() {
    list *myList = listCreate();
    listAddNodeHead(myList, "Hello");
    listAddNodeTail(myList, "World");
    // 现在myList包含两个节点，分别保存"Hello"和"World"

    // 清理资源
    listFree(myList);
    return 0;
}

这个示例展示了如何创建一个列表，如何添加节点到列表的头部和尾部，以及如何释放整个列表所占用的内存。这里的代码仅为示例，并未包含完整的错误检查和处理。

- 阅读更多 -

深入解析SSRF和Redis未授权访问

System

2024-09-06

所有,redis

SSRF（Server-Side Request Forgery，服务器端请求伪造）是一种攻击手段，攻击者通过引诱服务器发起请求到内部系统或者其他服务器上。当攻击目标是使用Redis服务的应用时，攻击者可以通过SSRF攻击内部的Redis服务，未授权访问敏感数据。

解决方法：

对于SSRF：
- 使用随机数生成Token来避免CSRF攻击。
- 限制请求的来源IP，只允许来自合法的域名或IP。
- 如果可能，使用安全的HTTP方法，如HEAD，GET进行请求，避免产生副作用。
对于Redis未授权访问：
- 配置Redis的访问控制，设置密码保护，通过requirepass指令设置密码。
- 使用最小权限原则，仅为Redis服务创建具有最少必要权限的用户。
- 如果Redis绑定在本地，确保它只监听本地接口（127.0.0.1），并通过防火墙进一步限制访问。

在实际操作中，还需要定期检查应用程序的更新和安全补丁，以及定期审计安全配置，确保系统的安全性。

- 阅读更多 -

RedisTemplate.opsForHash()用法简介并举例

System

2024-09-06

所有,redis

RedisTemplate.opsForHash() 是 Spring Data Redis 提供的一个用于操作 Redis 哈希表的方法。哈希表可以存储键值对集合，适用于存储对象。

以下是一些使用 RedisTemplate.opsForHash() 的常见方法及示例：

put：在哈希表中添加一个键值对。

redisTemplate.opsForHash().put("myHash", "key1", "value1");

values：获取哈希表中的所有值。

List<Object> values = redisTemplate.opsForHash().values("myHash");

entries：获取哈希表中的所有键值对。

Map<Object, Object> entries = redisTemplate.opsForHash().entries("myHash");

get：获取哈希表中的一个键对应的值。

Object value = redisTemplate.opsForHash().get("myHash", "key1");

hasKey：检查哈希表中是否存在指定的键。

boolean hasKey = redisTemplate.opsForHash().hasKey("myHash", "key1");

keys：获取哈希表中的所有键。

Set<Object> keys = redisTemplate.opsForHash().keys("myHash");

size：获取哈希表中键值对的数量。

long size = redisTemplate.opsForHash().size("myHash");

increment：使哈希表中的一个键对应的值自增。

double increment = redisTemplate.opsForHash().increment("myHash", "key2", 1);

putAll：在哈希表中添加多个键值对。

Map<String, String> map = new HashMap<>();
map.put("key1", "value1");
map.put("key2", "value2");
redisTemplate.opsForHash().putAll("myHash", map);

delete：删除哈希表中的一个或多个键。

redisTemplate.opsForHash().delete("myHash", "key1");

以上方法均是 RedisTemplate<K, V> 中的方法，K 是键的类型，V 是值的类型。在使用时需要指定键和值的类型。

System

2024-09-06

所有,redis

这个问题看起来是要求提供一个使用Lua语言和Redis数据库的网站源代码。然而，由于直接分享源代码可能侵犯版权或者隐私政策，我无法提供具体的源代码。

然而，我可以提供一个概念性的示例，说明如何使用Lua和Redis来创建一个简单的天气数据应用。

-- 假设已经有一个Redis连接
local redis = require 'redis'

-- 连接到Redis
local client = redis.connect('127.0.0.1', 6379)

-- 假设存储了每个城市的气温数据，例如：
-- "city:青岛:temperature" = "22"

-- 获取所有城市气温的函数
function get_all_cities_temperature()
    local cities = {'青岛', '其他城市名'} -- 这里应该是所有城市的列表
    local temperatures = {}

    for _, city in ipairs(cities) do
        local key = 'city:' .. city .. ':temperature'
        local temperature, err = client:get(key)
        if err then
            -- 错误处理
            print('Error:', err)
        else
            table.insert(temperatures, {city = city, temperature = temperature})
        end
    end

    return temperatures
end

-- 获取并打印所有城市气温
local temperatures = get_all_cities_temperature()
for _, temp in ipairs(temperatures) do
    print(temp.city .. ' 的气温为 ' .. temp.temperature .. ' 度')
end

这个示例展示了如何使用Lua和Redis来存储和检索天气数据。在实际应用中，你需要有一个方法来定期更新这些数据，并且需要一个前端界面来显示这些数据。

请注意，这个示例并不完整，它只是展示了如何从Redis获取数据的一个简单概念。在实际应用中，你需要处理错误、连接管理、数据验证等问题。

System

2024-09-06

所有,redis

import redis

# 连接Redis
r = redis.Redis(host='localhost', port=6379, db=0)

# 使用hscan_iter遍历哈希键中的键值对
for key, value in r.hscan_iter('your_hash_key', count=10):
    print(key, value)

# 注意：
# 1. 替换'your_hash_key'为你的实际哈希键名。
# 2. count参数可以根据需要调整，它表示每次迭代返回的元素数量。
# 3. 如果你需要处理大型的哈希键，考虑使用count参数来分批次获取键值对，以避免内存消耗过大。

这段代码演示了如何使用redis-py库中的hscan_iter方法来迭代哈希键中的键值对。它提供了一个简单的接口来处理大型的Redis哈希键，而不会消耗过多的内存。

- 阅读更多 -

Python操作redis系列--哈希(hash)--增查删改

System

2024-09-06

所有,redis

import redis

# 连接Redis
r = redis.Redis(host='localhost', port=6379, db=0)

# 操作Redis哈希表
hash_key = 'user:1'
field1 = 'name'
value1 = 'Alice'
field2 = 'age'
value2 = 25

# 增加或修改哈希表中的字段
r.hset(hash_key, field1, value1)
r.hset(hash_key, field2, value2)

# 查询哈希表中的字段
name = r.hget(hash_key, field1)
age = r.hget(hash_key, field2)
print(f"Name: {name.decode('utf-8')}, Age: {age.decode('utf-8')}")

# 删除哈希表中的字段
r.hdel(hash_key, field1)

# 修改哈希表中的字段值
r.hset(hash_key, field1, 'Bob')

# 查看哈希表的所有字段和值
user_info = r.hgetall(hash_key)
print(user_info)

这段代码演示了如何使用Python的redis模块来操作Redis中的哈希表。首先，我们连接到Redis服务器，然后通过hset方法添加或修改哈希表中的字段，使用hget查询字段的值，使用hdel删除字段，并使用hset重新设置字段值。最后，我们使用hgetall获取哈希表中的所有字段和值。

- 阅读更多 -

Redis系列之Redis Sentinel

System

2024-09-06

所有,redis

Redis Sentinel是Redis官方提供的一个高可用解决方案，它用于解决Redis单点故障的问题。Sentinel通过管理多个Redis服务实例，能够自动发现故障，进行故障转移，并通知应用程序。

以下是一个简单的Redis Sentinel配置实例：

# sentinel.conf
sentinel monitor mymaster 127.0.0.1 6379 2
sentinel down-after-milliseconds mymaster 30000
sentinel parallel-syncs mymaster 1
sentinel failover-timeout mymaster 180000

解释：

sentinel monitor mymaster: 这行指定Sentinel监控的Redis主服务器，其中mymaster是主服务器的名字，可以自定义。
127.0.0.1 6379: 主服务器的IP地址和端口号。
2: 最少有2个Sentinel同意认为主服务器宕机时，才进行故障转移。
sentinel down-after-milliseconds: 如果服务器在指定的毫秒数内没有响应，则认为它是主观下线。
sentinel parallel-syncs: 在故障转移期间，可以有几个从服务器同时进行同步。
sentinel failover-timeout: 故障转移超时时间。

启动Redis Sentinel：

redis-sentinel /path/to/sentinel.conf

这个例子展示了如何配置一个基本的Redis Sentinel，用于监控一个名为mymaster的Redis主服务器实例。当主服务器不可达时，Sentinel会开始一个故障转移过程，将一个从服务器提升为新的主服务器，并重新配置其他从服务器复制新的主服务器。

- 阅读更多 -

Redis修改密码方法

System

2024-09-06

所有,redis

在Redis中，修改密码的方法主要有两种：

通过配置文件修改
通过命令行动态修改

1. 通过配置文件修改

在Redis的配置文件redis.conf中，找到以下这行：

# requirepass foobared

将其修改为：

requirepass yournewpassword

然后重启Redis服务使配置生效。

2. 通过命令行动态修改

如果你想在不重启Redis服务的情况下修改密码，可以使用以下命令：

redis-cli -a current_password CONFIG SET requirepass "new_password"

执行上述命令后，Redis会立即使用新密码进行身份验证。

注意，使用命令行修改密码不会更改配置文件中的密码，如果重启Redis，还是会使用配置文件中的密码。

此外，如果Redis已经设置了密码，客户端连接Redis时也需要提供密码。例如，使用redis-cli连接时可以这样做：

redis-cli -a yournewpassword

或者在编程时，需要在连接字符串中指定密码：

import redis
r = redis.StrictRedis(host='localhost', port=6379, password='yournewpassword')

请根据实际情况选择合适的方法进行密码修改。

- 阅读更多 -

Java 实现基于Redis的分布式锁

System

2024-09-06

所有,redis

以下是一个使用Jedis库实现基于Redis的分布式锁的简单示例：

import redis.clients.jedis.Jedis;

public class RedisDistributedLock {

    private Jedis jedis;
    private String lockKey; // 锁的键值
    private int expireTime; // 锁的超时时间

    public RedisDistributedLock(Jedis jedis, String lockKey, int expireTime) {
        this.jedis = jedis;
        this.lockKey = lockKey;
        this.expireTime = expireTime;
    }

    public boolean lock() {
        long expires = System.currentTimeMillis() + expireTime + 1;
        String expiresStr = String.valueOf(expires); // 锁到期时间

        if (jedis.setnx(lockKey, expiresStr) == 1) {
            // 获取锁成功
            jedis.expire(lockKey, expireTime); // 设置锁的过期时间
            return true;
        }

        String currentValueStr = jedis.get(lockKey); // Redis里面的时间
        if (currentValueStr != null && Long.parseLong(currentValueStr) < System.currentTimeMillis()) {
            String oldValueStr = jedis.getSet(lockKey, expiresStr);
            if (oldValueStr != null && oldValueStr.equals(currentValueStr)) {
                // 锁已过期，获取锁成功
                jedis.expire(lockKey, expireTime); // 设置锁的过期时间
                return true;
            }
        }
        return false; // 获取锁失败
    }

    public void unlock() {
        // 确保是该线程获得的锁才能被释放
        String currentValueStr = jedis.get(lockKey);
        if (currentValueStr != null && Long.parseLong(currentValueStr) > System.currentTimeMillis()) {
            jedis.del(lockKey); // 删除锁
        }
    }
}

使用方法：

Jedis jedis = new Jedis("localhost", 6379);
RedisDistributedLock lock = new RedisDistributedLock(jedis, "my_lock", 1000);

try {
    if (lock.lock()) {
        // 业务逻辑
    } else {
        // 获取锁失败，执行其他逻辑或者等待重试
    }
} finally {
    lock.unlock(); // 释放锁
}

这个示例中的lock方法尝试获取锁，如果获取成功，则设置锁的过期时间；如果获取失败，则检查锁是否已过期，如果已过期，则尝试重新获取锁。unlock方法则确保只有获得锁的线程才能释放锁，防止释放其他线程持有的锁。

- 阅读更多 -