【redis】③ 数据淘汰策略、pipeline 管道命令、发布订阅

一、数据淘汰策略

Redis 之所以快最大的原因是：它把数据存储在内存之中。内存的容量和硬盘是无法比拟的，内存的容量总会达到最大值。当内存的容量达到某个值的时候需要对 Redis 存储在内存中的数据进行删除（淘汰）操作，删除那些数据呢？何时删除呢？

在 Redis 中，允许用户设置最大的内存大小（Redis 能够存储的数据的最大容量）【在 Redis 的配置文件中配置】
maxmemory 1G
maxmemory-policy noeviction # 没有淘汰策略，超出1G报错

lft：根据 key 的使用次数进行淘汰
lru：根据 key 的最近使用时间进行淘汰

• volatile-lru：设定超时时间的数据中，删除最不常用的数据
• allkeys-lru：所有 key 中最不常使用的数据进行删除
• volatile-random：在已经设定了超时的数据中随机删除
• allkeys-random：所有的 key 中随机删除
• volatile-ttl：查询全部设定超时时间的数据，随后马上排序，将马上要过期的数据删除掉
• noeviction：不会进行删除操作，如果内存溢出则报错
• volatile-lfu：从所有配置了过期的时间的键中驱逐使用频率最少的键
• allkeys-lfu：从所有键中驱逐使用频率最少的键

二、Java 基本使用 Redis（Jedis）

    <dependencies>
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>3.1.0</version>
        </dependency>  
    </dependencies> 

public class BasicTest {
    
    private Jedis jedis;

    @Before
    public void init() {
    
        jedis = new Jedis("192.168.80.130", 6379);
    }

    @Test
    public void test1() {
    
        jedis.flushAll();
        System.out.println(jedis.dbSize());
    }

    @After
    public void destroy() {
    
        if (jedis != null)
            jedis.close();
    }

}

三、pipeline

• 把命令放入管道之中，批量发送到 Redis 服务端，提高性能，大大减少网络消耗
• 批量执行的命令之间相互没有联系
• 并不是所有的数据结构能够使用 pipeline 命令
• pipeline 的操作并非原子性的
  

public class PipelineTest {
    
    private Jedis jedis;

    @Before
    public void init() {
    
        jedis = new Jedis("192.168.80.130", 6379);
    }

    @Test
    public void testPipeline() {
    
        Times.test("没有使用管道命令", this::noPipeline);
        Times.test("使用管道命令", this::pipeline);
    }

    private void noPipeline() {
    
        for (int i = 0; i < 66666; i++) {
    
            jedis.set("no" + i, String.valueOf(i));
        }
    }

    private void pipeline() {
    
        // 创建管道
        Pipeline pipeline = jedis.pipelined();
        for (int i = 0; i < 66666; i++) {
    
            // 往管道中添加命令
            pipeline.set("pipeline" + i, String.valueOf(i));
        }
        // 同步执行命令
        pipeline.sync();
    }

    @After
    public void destroy() {
    
        if (jedis != null)
            jedis.close();
    }

}

执行结果：

四、发布订阅