SpringBoot整合Lettuce redis過(guò)程解析

更新時(shí)間：2019年10月18日 09:38:09 作者：lcl-mm

這篇文章主要介紹了SpringBoot整合Lettuce redis過(guò)程解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

首先解釋一下Lettuce客戶端：

Lettuce 和 Jedis 的都是連接Redis Server的客戶端程序。Jedis在實(shí)現(xiàn)上是直連redis server，多線程環(huán)境下非線程安全，除非使用連接池，為每個(gè)Jedis實(shí)例增加物理連接。Lettuce基于Netty的連接實(shí)例（StatefulRedisConnection），可以在多個(gè)線程間并發(fā)訪問(wèn)，且線程安全，滿足多線程環(huán)境下的并發(fā)訪問(wèn)，同時(shí)它是可伸縮的設(shè)計(jì)，一個(gè)連接實(shí)例不夠的情況也可以按需增加連接實(shí)例。

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
 # 連接超時(shí)時(shí)間（毫秒）
   timeout: 1000
 # Redis默認(rèn)情況下有16個(gè)分片，這里配置具體使用的分片，默認(rèn)是0
   database: 0
 # 連接池配置
   lettuce:
    pool:
 # 連接池最大連接數(shù)（使用負(fù)值表示沒(méi)有限制） 默認(rèn) 8
     max-active: 8
 # 連接池最大阻塞等待時(shí)間（使用負(fù)值表示沒(méi)有限制） 默認(rèn) -1
     max-wait: -1
 # 連接池中的最大空閑連接 默認(rèn) 8
     max-idle: 8
 # 連接池中的最小空閑連接 默認(rèn) 0
     min-idle: 0

3、實(shí)現(xiàn)邏輯

@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;
  }

測(cè)試結(jié)果：