溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

Spring Boot Redis如何實(shí)現(xiàn)客戶端遠(yuǎn)程操作

發(fā)布時(shí)間:2020-08-04 14:54:29 來源:億速云 閱讀:150 作者:小豬 欄目:編程語言

這篇文章主要講解了Spring Boot Redis如何實(shí)現(xiàn)客戶端遠(yuǎn)程操作,內(nèi)容清晰明了,對此有興趣的小伙伴可以學(xué)習(xí)一下,相信大家閱讀完之后會(huì)有幫助。

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

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

修改config文件:

注釋掉bind:127.0.0.1

開啟密碼校驗(yàn),去掉requireprass的注釋

使用jedis客戶端:

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

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

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

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

在實(shí)際應(yīng)用中,Jedis實(shí)例一般用連接池獲取,因?yàn)閖ava本來就是多線程的,而jedis對象不是線程安全的,所以要使用連接池,從連接池中獲取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.測試是否連接成功
String ping =jedis.ping();
//返回pong表示成功
System.out.println(ping);
//4.歸還連接
jedis.close();

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

但是這種的明顯感覺很臃腫,而且約束性不強(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 表示沒有限制
    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)過程中是直接連接redis的,在多個(gè)線程之間共享一個(gè)jedis實(shí)例,是線程不安全的,如果想在多線程場景下使用jedis,就得使用連接池,這樣,每個(gè)線程都有自己的jedis實(shí)例,但是有一個(gè)弊端,就是會(huì)消耗過多的物理資源。

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

在java中如何使用:

1.添加依賴。

2.測試

//創(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)用對象
   RedisCommands<String, String> sync = connect.sync();
   //賦值
   sync.set("name", "zl");
   //取值
    String name = sync.get("name");
   //測試
    System.out.println(name);
  }

看完上述內(nèi)容,是不是對Spring Boot Redis如何實(shí)現(xiàn)客戶端遠(yuǎn)程操作有進(jìn)一步的了解,如果還想學(xué)習(xí)更多內(nèi)容,歡迎關(guān)注億速云行業(yè)資訊頻道。

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI