当前位置 主页 > 服务器问题 > Linux/apache问题 > 最大化 缩小

    SpringBoot整合Lettuce redis过程解析

    栏目:Linux/apache问题 时间:2019-11-08 01:40

    首先解释一下Lettuce客户端:

    Lettuce 和 Jedis 的都是连接Redis Server的客户端程序。Jedis在实现上是直连redis server,多线程环境下非线程安全,除非使用连接池,为每个Jedis实例增加物理连接。Lettuce基于Netty的连接实例(StatefulRedisConnection),可以在多个线程间并发访问,且线程安全,满足多线程环境下的并发访问,同时它是可伸缩的设计,一个连接实例不够的情况也可以按需增加连接实例。

    1、添加依赖

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

    2、添加redis配置

    spring:
     redis:
       host: ****
       password:****
       port: 6379
     # 连接超时时间(毫秒)
       timeout: 1000
     # Redis默认情况下有16个分片,这里配置具体使用的分片,默认是0
       database: 0
     # 连接池配置
       lettuce:
        pool:
     # 连接池最大连接数(使用负值表示没有限制) 默认 8
         max-active: 8
     # 连接池最大阻塞等待时间(使用负值表示没有限制) 默认 -1
         max-wait: -1
     # 连接池中的最大空闲连接 默认 8
         max-idle: 8
     # 连接池中的最小空闲连接 默认 0
         min-idle: 0

    3、实现逻辑

    @Autowired
      private StringRedisTemplate stringRedisTemplate;
      @Override
      public String testRedis(){
        ExecutorService executorService = Executors.newFixedThreadPool(1000);
        IntStream.range(0, 1000).forEach(i -> executorService.execute(() -> stringRedisTemplate.opsForValue().increment("lcl",1)));
        System.out.println("lcl1=============" + stringRedisTemplate.opsForValue().get("lcl"));
        stringRedisTemplate.opsForValue().set("lcl1","val1");
        String val1 = stringRedisTemplate.opsForValue().get("lcl1");
        System.out.println("lcl1=============" + val1);
        String key = "redis:test:demo1";
        User user = new User();
        user.setId(100L);
        user.setUsername("u2");
        user.setPassword("p2");
        stringRedisTemplate.opsForValue().set(key, JSON.toJSONString(user));
        String valUser = stringRedisTemplate.opsForValue().get(key);
        System.out.println("redis:test:demo1=============" + valUser);
        User getUser = JSON.parseObject(valUser, User.class);
        System.out.println("redis:test:demo1=============" + getUser.getUsername()+ "========" + getUser.getPassword());
        return null;
      }

    测试结果:

    由于redis有String、list、set、zset、hash、geo等类型,因此使用时不止使用opsForValue()方法,具体的对应方法如下:

    opsForValue: 对应 String(字符串) opsForZSet: 对应 ZSet(有序集合) opsForHash: 对应 Hash(哈希) opsForList: 对应 List(列表) opsForSet: 对应 Set(集合) opsForGeo: 对应 GEO(地理位置)

    以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持IIS7站长之家。

    下一篇:没有了