Spring Boot Redis客戶端遠程操作實現(xiàn)過程解析
在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中的操作數(shù)據(jù)的命令一致,所以使用起來很方便。
在實際應用中,Jedis實例一般用連接池獲取,因為java本來就是多線程的,而jedis對象不是線程安全的,所以要使用連接池,從連接池中獲取Jedis,用完之后再還給連接池。保證他的線程是安全的。
如何創(chuàng)建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();
如果第三步,也就是我們的業(yè)務代碼出問題的話,是無法進行到第四步的,我們可以做一個優(yōu)化,在業(yè)務代碼塊中try catch給close加一個finally,并在finally中判斷jedis不為空的情況下給他歸還。這樣的話,就可以保證每次都歸還jedis對象了。
但是這種的明顯感覺很臃腫,而且約束性不強,因此可以再優(yōu)化,就是以接口和接口實現(xiàn)的形式去處理,需要調用的時候再去實現(xiàn)這個接口:
創(chuàng)建接口:
public interface CallJedis { void call(Jedis jedis);}
創(chuàng)建接口的實現(xiàn)
public class Redis { private JedisPool pool; public Redis() { GenericObjectPoolConfig config = new GenericObjectPoolConfig(); //連接池最大空閑數(shù) config.setMaxIdle(300); //最大連接數(shù) 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在實現(xiàn)過程中是直接連接redis的,在多個線程之間共享一個jedis實例,是線程不安全的,如果想在多線程場景下使用jedis,就得使用連接池,這樣,每個線程都有自己的jedis實例,但是有一個弊端,就是會消耗過多的物理資源。
Lettuce是線程安全的,因為使用了Netty NIO框架構建。支持同步,異步,以及響應調用,多個線程可以共享一個Lettuce實例,不用擔心多線程的并發(fā)問題。
在java中如何使用:
1.添加依賴。
2.測試
//創(chuàng)建連接root是密碼,127.0.0.1是服務端地址 RedisClient redisClient =RedisClient.create('redis://root@127.0.0.1'); //創(chuàng)建連接通道 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); }
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關文章:
1. IntelliJ IDEA設置背景圖片的方法步驟2. JAMon(Java Application Monitor)備忘記3. Python OpenCV去除字母后面的雜線操作4. Java類加載機制實現(xiàn)步驟解析5. docker /var/lib/docker/aufs/mnt 目錄清理方法6. Spring security 自定義過濾器實現(xiàn)Json參數(shù)傳遞并兼容表單參數(shù)(實例代碼)7. Python TestSuite生成測試報告過程解析8. IntelliJ IDEA設置默認瀏覽器的方法9. 教你用Java Swing做一個定時提醒工具10. 增大python字體的方法步驟
