标签 redis 下的文章

2024-09-05

在Redis 7.x中，访问控制列表（ACL）功能提供了一种基于用户和权限的安全模型，以保护Redis服务器不受未授权访问的影响。

以下是一些使用Redis ACL功能的示例命令：

添加用户：




# 添加一个新用户
ACL SETUSER newuser on >password ~* +@all

给用户授权：




# 给用户授予所有权限
ACL SETUSER newuser on >password allcommands

查看用户列表：




# 查看当前的用户列表
ACL LIST

查看用户权限：




# 查看特定用户的权限
ACL LIST newuser

删除用户：




# 删除一个用户
ACL DELUSER newuser

更改用户密码：




# 更改用户密码
ACL SETUSER newuser on >newpassword

为用户添加特定权限：




# 为用户添加特定权限
ACL SETUSER newuser +set

移除用户的特定权限：




# 移除用户的特定权限
ACL SETUSER newuser -set

使用用户登录：




# 使用新用户登录
redis-cli -u newuser -p newpassword

在实际应用中，你需要根据自己的需求和环境来调整这些命令。记得在生产环境中使用复杂的密码来保障用户安全。

- 阅读更多 -

史上最全保姆级教程Centos7从安装redis到卸载redis

System

2024-09-05

所有,redis

要在CentOS 7上安装和卸载Redis，可以按照以下步骤操作：

安装Redis

添加EPEL仓库：
```
sudo yum install epel-release
```
安装Redis：
```
sudo yum install redis
```
启动Redis服务：
```
sudo systemctl start redis
```
设置Redis开机自启：
```
sudo systemctl enable redis
```
检查Redis是否正在运行：
```
sudo systemctl status redis
```

卸载Redis

停止Redis服务：
```
sudo systemctl stop redis
```
禁用Redis开机自启：
```
sudo systemctl disable redis
```
卸载Redis：
```
sudo yum remove redis
```
（可选）如果不再需要，可以删除配置文件和数据目录：
```
sudo rm -rf /etc/redis /var/lib/redis /var/log/redis
```

以上步骤提供了在CentOS 7上安装和卸载Redis的详细过程。

- 阅读更多 -

使用SpringBoot+Redis做一个排行榜【推荐】

System

2024-09-05

所有,redis

在Spring Boot中使用Redis做排行榜，你可以使用Spring Data Redis或Jedis。以下是一个简单的例子，使用Spring Data Redis操作ZSet（有序集合）。

添加依赖到你的pom.xml：




<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

配置Redis。在application.properties或application.yml中设置Redis连接信息：




spring.redis.host=localhost
spring.redis.port=6379

在你的服务中使用RedisTemplate操作ZSet：




import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.stereotype.Service;
 
@Service
public class LeaderboardService {
 
    @Autowired
    private RedisTemplate<String, String> redisTemplate;
 
    private ZSetOperations<String, String> zSetOps;
 
    public LeaderboardService() {
        this.zSetOps = redisTemplate.opsForZSet();
    }
 
    public void addScoreToLeaderboard(String userId, double score) {
        zSetOps.add(getLeaderboardKey(), userId, score);
    }
 
    public List<String> fetchTopUsers(int limit) {
        Set<String> userIds = zSetOps.reverseRange(getLeaderboardKey(), 0, limit - 1);
        return new ArrayList<>(userIds);
    }
 
    private String getLeaderboardKey() {
        return "leaderboard";
    }
}

在这个例子中，addScoreToLeaderboard方法将用户的分数添加到排行榜中，而fetchTopUsers方法则用于获取前N名用户的列表。

确保你的应用程序配置了Redis，并且有一个定时任务或者某种触发机制来调用addScoreToLeaderboard方法，以更新用户的分数。

- 阅读更多 -

国产操作系统离线部署MYSQL、NGINX、redis、JDK1.8

System

2024-09-05

所有,redis

由于您要在离线环境下部署这些应用，所以需要提前下载好对应的安装包或者是可执行文件。以下是在Linux环境下进行部署的基本步骤：

下载MySQL的压缩包，解压后手动安装。
下载NGINX的源码包，编译安装。
下载Redis的压缩包，解压后编译安装。
下载JDK的压缩包，解压后设置环境变量。

以下是具体的命令和步骤：

步骤1: 下载MySQL压缩包，并解压。




wget https://dev.mysql.com/get/Downloads/MySQL-8.0/mysql-8.0.xx-linux-glibc2.12-x86_64.tar.xz
tar -xvf mysql-8.0.xx-linux-glibc2.12-x86_64.tar.xz
mv mysql-8.0.xx-linux-glibc2.12-x86_64 /usr/local/mysql

步骤2: 下载NGINX源码包，并编译安装。




wget http://nginx.org/download/nginx-1.xx.x.tar.gz
tar -xvf nginx-1.xx.x.tar.gz
cd nginx-1.xx.x
./configure
make
make install

步骤3: 下载Redis压缩包，并编译安装。




wget http://download.redis.io/releases/redis-x.x.x.tar.gz
tar xzf redis-x.x.x.tar.gz
cd redis-x.x.x
make
make install

步骤4: 下载JDK压缩包，并解压。




wget --no-check-certificate -c --header "Cookie: oraclelicense=accept-securebackup-cookie" \
http://download.oracle.com/otn-pub/java/jdk/8uxx-bxx/jdk-8uxx-linux-x64.tar.gz
tar -xvf jdk-8uxx-linux-x64.tar.gz

设置环境变量：




echo 'export JAVA_HOME=/path/to/jdk1.8.0_xx' >> ~/.bashrc
echo 'export PATH=$PATH:$JAVA_HOME/bin' >> ~/.bashrc
source ~/.bashrc

请将上述命令中的xx替换为实际的版本号，并将/path/to/jdk1.8.0_xx替换为JDK解压后的实际路径。

注意：由于离线环境下可能没有网络连接，所以您需要提前将所有需要的安装包准备好，并通过USB设备或其他方式传输到目标机器上。另外，由于版本更新，上述链接和命令中的版本号可能会变化，请根据实际情况选择合适的版本。

- 阅读更多 -

redis 哨兵

System

2024-09-05

所有,redis

Redis 哨兵（Redis sentinel）是一个分布式系统，用于监控Redis主服务器和其他哨兵，主要目的是实现Redis的高可用性。

以下是一个基本的Redis哨兵配置示例：




# 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: 监控一个名为 mymaster 的主服务器，后面跟着主服务器的IP和端口，以及最少需要有多少个哨兵同意才进行故障转移。
sentinel down-after-milliseconds: 如果一个服务器在指定的毫秒数内没有响应，则认为它是主观下线。
sentinel parallel-syncs: 在故障转移期间，可以有几个从服务器同时进行同步。
sentinel failover-timeout: 故障转移超时时间。

启动Redis哨兵：




redis-sentinel /path/to/sentinel.conf

确保替换 /path/to/sentinel.conf 为你的哨兵配置文件的实际路径。

- 阅读更多 -

redis批量删除指定前缀key四种方法(收藏)

System

2024-09-05

所有,redis

在Redis中，我们可以使用不同的方法来批量删除具有特定前缀的键。以下是四种方法：

使用shell命令
使用redis-cli的--eval选项
使用Python的redis库
使用redis-cli的pipeline

方法1：使用shell命令

这种方法的前提是你有权限访问Redis服务器的shell。你可以使用以下命令：




redis-cli keys "prefix*" | xargs redis-cli del

这个命令会找到所有以"prefix"开头的键，然后将它们传递给xargs，后者会将它们作为参数传递给redis-cli del命令以删除它们。

方法2：使用redis-cli的--eval选项

Redis CLI提供了一个eval参数，允许你在服务器端运行一小段Lua脚本。你可以使用以下命令：




redis-cli --eval myscript.lua prefix*

myscript.lua的内容可能如下：




local keys = redis.call('keys', ARGV[1])
for i=1,#keys do
   redis.call('del', keys[i])
end

方法3：使用Python的redis库

如果你正在使用Python，那么你可以使用redis库来完成这个任务。以下是一个例子：




import redis
 
r = redis.Redis()
for key in r.scan_iter("prefix*"):
    r.delete(key)

方法4：使用redis-cli的pipeline

Redis-cli提供了一种方法，可以通过pipeline将多个命令一次性发送到服务器。以下是一个例子：




redis-cli keys "prefix*" | xargs -L 1 echo | xargs -I {} redis-cli del {}

这个命令会找到所有以"prefix"开头的键，然后将它们一行一行地传递给xargs，后者将它们作为参数传递给echo，然后传递给另一个xargs，后者将它们作为参数传递给redis-cli del命令以删除它们。

注意：以上所有方法都可能对Redis性能产生负面影响，因为它们都会阻塞服务器直到操作完成。在生产环境中，应该谨慎使用，并考虑在负载低的时段进行此类操作。

- 阅读更多 -

探索分布式锁的高效解决方案：Redis-Semaphore

System

2024-09-05

所有,redis




import redis
from redis_semaphore import RedisSemaphore
 
# 假设已经有一个Redis连接对象
redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)
 
# 创建一个Redis-Semaphore实例，并指定资源名称和最大同时访问数
semaphore = RedisSemaphore('my_resource', max_leases=5, redis_client=redis_client)
 
# 尝试获取锁
with semaphore:
    # 在这个区块内的代码将在获得锁的情况下执行
    # 可以放置需要互斥访问的代码
    print("已获取锁，执行操作...")

这段代码展示了如何使用redis_semaphore库来创建一个名为my_resource的分布式信号量，并且在获取锁的上下文管理器中执行一些需要互斥访问的操作。这是一个在分布式系统中实现锁定机制的高效方法。

- 阅读更多 -

使用RedissonClient的管道模式批量查询key

System

2024-09-05

所有,redis

在使用RedissonClient进行管道模式批量查询key时，可以利用RBatch对象来执行。以下是一个简单的示例代码：




import org.redisson.Redisson;
import org.redisson.api.RBatch;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
 
import java.util.concurrent.ExecutionException;
 
public class RedissonBatchExample {
    public static void main(String[] args) {
        // 配置RedissonClient
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        RedissonClient redisson = Redisson.create(config);
 
        // 创建批量操作对象
        RBatch batch = redisson.createBatch();
 
        // 将要查询的key添加到批量操作中
        batch.getMap("myMap").getAsync("key1");
        batch.getMap("myMap").getAsync("key2");
        batch.getMap("myMap").getAsync("key3");
 
        // 执行批量查询
        try {
            batch.execute();
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
 
        // 关闭RedissonClient
        redisson.shutdown();
    }
}

在这个例子中，我们首先配置了RedissonClient，然后创建了一个RBatch对象。我们使用getAsync方法将查询操作添加到批量处理中。最后，我们调用execute方法来执行批量查询。这种方式可以减少与Redis的通信开销，提高查询效率。记得在使用完毕后关闭RedissonClient以释放资源。

- 阅读更多 -

决胜高并发战场：Redis并发访问控制与实战解析

System

2024-09-05

所有,redis




-- 假设已经有了一个Redis连接对象 `redis_conn`
-- 设置商品库存
local function set_stock(redis_conn, product_id, stock_count)
    local key = "product:" .. product_id .. ":stock"
    return redis_conn:set(key, stock_count)
end
 
-- 扣减商品库存
local function decrement_stock(redis_conn, product_id)
    local key = "product:" .. product_id .. ":stock"
    -- 使用Lua脚本原子地减少库存
    local script = "local stock = redis.call('get', KEYS[1]) return redis.call('decr', KEYS[1])"
    return redis_conn:eval(script, 1, key)
end
 
-- 使用示例
local redis_conn = require('redis'):connect('127.0.0.1', 6379) -- 连接到Redis
set_stock(redis_conn, '12345', 100) -- 设置产品ID为'12345'的库存为100
local stock = decrement_stock(redis_conn, '12345') -- 将产品ID为'12345'的库存减1
print("当前库存:", stock)

这个示例代码展示了如何使用Lua脚本在Redis中原子地减少库存。这是非常重要的，因为它可以防止多个客户端同时修改同一个值而导致的数据不一致问题。此外，这段代码使用了get和decr命令，这是一个更为安全的方式来减少库存，因为它先检查了库存数量，然后才进行减少，确保库存不会超卖。

- 阅读更多 -

如何理解Redis中的缓存雪崩，缓存穿透，缓存击穿？

System

2024-09-05

所有,redis

缓存雪崩
缓存雪崩是指在同一时段大量的缓存失效，导致数据库负载过高，甚至宕机。为了避免这种情况，可以通过设置不同的过期时间，或者使用加锁或队列的方式保证缓存的线程安全。
缓存穿透
缓存穿透是指查询不存在的数据，缓存和数据库都不会命中，可能导致攻击请求直接打到数据库上。为了防止这种情况，可以使用布隆过滤器（Bloom Filter）或在应用层做校验，对不存在的数据也进行缓存，并设置一个较短的过期时间。
缓存击穿
缓存击穿是指一个热点key在失效的瞬间，大量请求直接打到数据库上。为了防止这种情况，可以设置热点key永不过期或者加大过期时间，同时实现互斥锁确保更新缓存的操作不会出现并发问题。

示例代码（伪代码）：




# 缓存雪崩：分散过期时间
keys = ['key1', 'key2', ...]
for key in keys:
    set(key, value, random_ttl)  # random_ttl是随机过期时间
 
# 缓存穿透：校验参数有效性
def get_data(key):
    if not is_valid(key):  # 检查key是否有效
        set(key, None, 5 minutes)  # 为不存在的数据设置短过期时间
        return None
    value = get(key)
    if value is None:
        value = db_query()
        set(key, value, 1 day)
    return value
 
# 缓存击穿：使用互斥锁
mutex = Lock()
def get_data(key):
    value = get(key)
    if value is None:  # 缓存未命中
        with mutex:
            value = get(key)  # 再次检查缓存
            if value is None:
                value = db_query()  # 从数据库加载数据
                set(key, value, 1 day)
    return value

注意：以上伪代码仅为示例，具体实现需要根据实际应用场景和框架选择合适的缓存和锁机制。

- 阅读更多 -