快捷導(dǎo)航

Spring Boot Redis客戶端遠(yuǎn)程操作實(shí)現(xiàn)過(guò)程解析

更新時(shí)間：2020年04月09日 10:21:09 作者：繁華亂世

這篇文章主要介紹了Spring Boot Redis客戶端遠(yuǎn)程操作實(shí)現(xiàn)過(guò)程解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

在Spring Boot 1.x中默認(rèn)是Jedis作為客戶端，但是在Spring Boot2.x后，默認(rèn)就是Lettuce

Redis的遠(yuǎn)程連接，默認(rèn)是不支持的，需要手動(dòng)開(kāi)啟

修改config文件：

注釋掉bind：127.0.0.1

開(kāi)啟密碼校驗(yàn)，去掉requireprass的注釋

使用jedis客戶端：

jedis的GitHub地址：https://github.com/xetorthio/jedis

如何遠(yuǎn)程連接：

//構(gòu)造一個(gè)jedis對(duì)象
Jedis jedis=new Jedis("127.0.0.1")；
//有密碼的話要認(rèn)證
jedis.auth("root");
//測(cè)試是否連接成功
String ping =jedis.ping();
//返回pong表示成功
System.out.println(ping);

jedis中的方法API和redis中的操作數(shù)據(jù)的命令一致，所以使用起來(lái)很方便。

在實(shí)際應(yīng)用中，Jedis實(shí)例一般用連接池獲取，因?yàn)閖ava本來(lái)就是多線程的，而jedis對(duì)象不是線程安全的，所以要使用連接池，從連接池中獲取Jedis，用完之后再還給連接池。保證他的線程是安全的。

如何創(chuàng)建Jedis連接池

//1.構(gòu)造一個(gè)jedis連接池
JedisPool pool=new JedisPool("127.0.0.1"，6379)；
//2.從連接池中獲取一個(gè)jedis連接
Jedis jedis=pool.getResource();
//3.測(cè)試是否連接成功
String ping =jedis.ping();
//返回pong表示成功
System.out.println(ping);
//4.歸還連接
jedis.close();

如果第三步，也就是我們的業(yè)務(wù)代碼出問(wèn)題的話，是無(wú)法進(jìn)行到第四步的，我們可以做一個(gè)優(yōu)化，在業(yè)務(wù)代碼塊中try catch給close加一個(gè)finally，并在finally中判斷jedis不為空的情況下給他歸還。這樣的話，就可以保證每次都?xì)w還jedis對(duì)象了。

但是這種的明顯感覺(jué)很臃腫，而且約束性不強(qiáng)，因此可以再優(yōu)化，就是以接口和接口實(shí)現(xiàn)的形式去處理，需要調(diào)用的時(shí)候再去實(shí)現(xiàn)這個(gè)接口：

創(chuàng)建接口：

public interface CallJedis {
  void call(Jedis jedis);
}

創(chuàng)建接口的實(shí)現(xiàn)

public class Redis {
  private JedisPool pool;
  public Redis() {
    GenericObjectPoolConfig config = new GenericObjectPoolConfig();
    //連接池最大空閑數(shù)
    config.setMaxIdle(300);
    //最大連接數(shù)
    config.setMaxTotal(1000);
    //連接最大等待時(shí)間，如果是 -1 表示沒(méi)有限制
    config.setMaxWaitMillis(30000);
    //在空閑時(shí)檢查有效性
    config.setTestOnBorrow(true);
    /**
     * 1. Redis 地址
     * 2. Redis 端口
     * 3. 連接超時(shí)時(shí)間
     * 4. 密碼
     */
    pool = new JedisPool(config, "192.168.91.128", 6379, 30000, "root");
  }
  public void execute(CallJedis callJedis) {
    try (Jedis jedis = pool.getResource()) {
      callJedis.call(jedis);
    }
  }
}

調(diào)用接口：

Redis redis = new Redis();
redis.execute(jedis -> {
  System.out.println(jedis.ping());
});

使用Lettuce客戶端：

GitHub地址：https://github.com/lettuce-io/lettuce-core

Lettuce和Jedis比較

Jedis在實(shí)現(xiàn)過(guò)程中是直接連接redis的，在多個(gè)線程之間共享一個(gè)jedis實(shí)例，是線程不安全的，如果想在多線程場(chǎng)景下使用jedis，就得使用連接池，這樣，每個(gè)線程都有自己的jedis實(shí)例，但是有一個(gè)弊端，就是會(huì)消耗過(guò)多的物理資源。

Lettuce是線程安全的，因?yàn)槭褂昧薔etty NIO框架構(gòu)建。支持同步，異步，以及響應(yīng)調(diào)用，多個(gè)線程可以共享一個(gè)Lettuce實(shí)例，不用擔(dān)心多線程的并發(fā)問(wèn)題。

在java中如何使用：

1.添加依賴(lài)。

2.測(cè)試

//創(chuàng)建連接root是密碼，127.0.0.1是服務(wù)端地址
   RedisClient redisClient =RedisClient.create("redis://root@127.0.0.1");
   //創(chuàng)建連接通道
   StatefulRedisConnection<String, String> connect = redisClient.connect();
   //獲取同步調(diào)用對(duì)象
   RedisCommands<String, String> sync = connect.sync();
   //賦值
   sync.set("name", "zl");
   //取值
    String name = sync.get("name");
   //測(cè)試
    System.out.println(name);
  }

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: