Spring Boot Redis客戶端遠程操作實現過程解析
在Spring Boot 1.x中默認是Jedis作為客戶端,但是在Spring Boot2.x后,默認就是Lettuce
Redis的遠程連接,默認是不支持的,需要手動開啟
修改config文件:
注釋掉bind:127.0.0.1
開啟密碼校驗,去掉requireprass的注釋
使用jedis客戶端:
jedis的GitHub地址:https://github.com/xetorthio/jedis
如何遠程連接:
//構造一個jedis對象Jedis jedis=new Jedis('127.0.0.1');//有密碼的話要認證jedis.auth('root');//測試是否連接成功String ping =jedis.ping();//返回pong表示成功System.out.println(ping);
jedis中的方法API和redis中的操作數據的命令一致,所以使用起來很方便。
在實際應用中,Jedis實例一般用連接池獲取,因為java本來就是多線程的,而jedis對象不是線程安全的,所以要使用連接池,從連接池中獲取Jedis,用完之后再還給連接池。保證他的線程是安全的。
如何創建Jedis連接池
//1.構造一個jedis連接池JedisPool pool=new JedisPool('127.0.0.1',6379);//2.從連接池中獲取一個jedis連接Jedis jedis=pool.getResource();//3.測試是否連接成功String ping =jedis.ping();//返回pong表示成功System.out.println(ping);//4.歸還連接jedis.close();
如果第三步,也就是我們的業務代碼出問題的話,是無法進行到第四步的,我們可以做一個優化,在業務代碼塊中try catch給close加一個finally,并在finally中判斷jedis不為空的情況下給他歸還。這樣的話,就可以保證每次都歸還jedis對象了。
但是這種的明顯感覺很臃腫,而且約束性不強,因此可以再優化,就是以接口和接口實現的形式去處理,需要調用的時候再去實現這個接口:
創建接口:
public interface CallJedis { void call(Jedis jedis);}
創建接口的實現
public class Redis { private JedisPool pool; public Redis() { GenericObjectPoolConfig config = new GenericObjectPoolConfig(); //連接池最大空閑數 config.setMaxIdle(300); //最大連接數 config.setMaxTotal(1000); //連接最大等待時間,如果是 -1 表示沒有限制 config.setMaxWaitMillis(30000); //在空閑時檢查有效性 config.setTestOnBorrow(true); /** * 1. Redis 地址 * 2. Redis 端口 * 3. 連接超時時間 * 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); } }}
調用接口:
Redis redis = new Redis();redis.execute(jedis -> { System.out.println(jedis.ping());});
使用Lettuce客戶端:
GitHub地址:https://github.com/lettuce-io/lettuce-core
Lettuce和Jedis比較
Jedis在實現過程中是直接連接redis的,在多個線程之間共享一個jedis實例,是線程不安全的,如果想在多線程場景下使用jedis,就得使用連接池,這樣,每個線程都有自己的jedis實例,但是有一個弊端,就是會消耗過多的物理資源。
Lettuce是線程安全的,因為使用了Netty NIO框架構建。支持同步,異步,以及響應調用,多個線程可以共享一個Lettuce實例,不用擔心多線程的并發問題。
在java中如何使用:
1.添加依賴。
2.測試
//創建連接root是密碼,127.0.0.1是服務端地址 RedisClient redisClient =RedisClient.create('redis://root@127.0.0.1'); //創建連接通道 StatefulRedisConnection<String, String> connect = redisClient.connect(); //獲取同步調用對象 RedisCommands<String, String> sync = connect.sync(); //賦值 sync.set('name', 'zl'); //取值 String name = sync.get('name'); //測試 System.out.println(name); }
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。
相關文章:
