Java中Jedis基本使用
在前面我們已經(jīng)學(xué)習(xí)了Redis命令行客戶端redis-cli的使用,接下來我們了解一下Redis基于Java編程語言的客戶端。
在Java語言體系下,有三個常用的Redis客戶端Jedis、Redisson、Lettuce。三者各有特點(diǎn),各有適用的場景。
好了,我們開始學(xué)習(xí)Jedis的使用吧。
1、Jedis的基本使用創(chuàng)建Maven工程,在項目中添加Jedis依賴。
<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.8.2</version></dependency>
Jedis的使用方法非常簡單,只要三行代碼就可以實現(xiàn)基本的set/get功能:
//1.生成一個Jedis對象,這個對象負(fù)責(zé)和指定Redis實例進(jìn)行通信Jedis jedis = new Jedis('127.0.0.1', 6379);// 2.jedis執(zhí)行set操作jedis.set('hello', 'world');//3.jedis執(zhí)行g(shù)et操作,value='world'String value = jedis.get('hello');
初始化Jedis需要兩個參數(shù):Redis實例的IP和端口,除了這兩個參數(shù)外,還有一個包含了四個參數(shù)的構(gòu)造函數(shù)是比較常用的:
Jedis(final String host, final int port, final int connectionTimeout, final int soTimeout)
參數(shù)說明:
host:Redis實例的所在機(jī)器的IP port:Redis實例的端口 connectionTimeout:客戶端連接超時 soTimeout:客戶端讀寫超時可以打印輸出一下上面程序的結(jié)果:
和JDBC類似,一般涉及到這種網(wǎng)絡(luò)I/O的操作,最好使用try catch finally的形式,稍微修改一下上面的例子:
Jedis jedis = null;try { jedis = new Jedis('127.0.0.1', 6379); jedis.get('hello');} catch (Exception e) { e.printStackTrace();} finally { if (jedis != null) {jedis.close(); }}
接下來我們看一下Jedis對各種基本數(shù)據(jù)類型的操作:
字符串
jedis.set('hello', 'world');//結(jié)果 worldSystem.out.println(jedis.get('hello')); //結(jié)果 1System.out.println(jedis.incr('counter'));
hash
jedis.hset('myhash', 'f1', 'v1');jedis.hset('myhash', 'f2', 'v2');//運(yùn)行結(jié)果 {f2=v2, f1=v1}System.out.println(jedis.hgetAll('myhash'));
list
jedis.rpush('mylist', '1');jedis.rpush('mylist', '2');jedis.rpush('mylist', '3');//運(yùn)行結(jié)果 [1, 2, 3]System.out.println(jedis.lrange('mylist',0,-1));
set
jedis.sadd('myset', 'a');jedis.sadd('myset', 'b');jedis.sadd('myset', 'a');//運(yùn)行結(jié)果 [b, a]System.out.println(jedis.smembers('myset'));
zset
Jedis jedis = new Jedis('127.0.0.1', 6379);jedis.zadd('thezset', 99, 'tom');jedis.zadd('thezset', 66, 'peter');jedis.zadd('thezset', 33, 'james');//運(yùn)行結(jié)果 james 33.0 peter 66.0 tom 99.0jedis.zrangeWithScores('thezset',0,-1).stream().forEach(s->{ System.out.print(s.getElement()+' '+s.getScore()+' ');});2、序列化
在Java中,存儲對象一般會進(jìn)行序列化和反序列化,Jedis本身并不支持序列化。可以引入游戲額第三方的序列化工具,例如XML、Json、谷歌的Protobuf、Facebook的Thrift等等。
我們以protostuff(Protobuf的Java客戶端)為例來進(jìn)行學(xué)習(xí):
引入protostuff依賴
<properties><protostuff.version>1.0.11</protostuff.version> </properties> <dependency> <groupId>com.dyuproject.protostuff</groupId> <artifactId>protostuff-runtime</artifactId> <version>${protostuff.version}</version></dependency><dependency> <groupId>com.dyuproject.protostuff</groupId> <artifactId>protostuff-core</artifactId> <version>${protostuff.version}</version></dependency>
定義實體類
public class Club implements Serializable { private int id; // id private String name; // 名稱 private String info; // 描述 private Date createDate; // 創(chuàng)建日期 private int rank; // 排名 //省略getter/setter等}
測試序列化和反序列化
// 1.生成序列化工具類ProtostuffSerializer protostuffSerializer = new ProtostuffSerializer();// 2.生成Jedis對象Jedis jedis = new Jedis('127.0.0.1', 6379);// 3.序列化String key = 'club:1';// 定義實體對象Club club = new Club(1, 'AC', '米蘭', new Date(), 1);// 序列化byte[] clubBtyes = protostuffSerializer.serialize(club);jedis.set(key.getBytes(), clubBtyes);// 4.反序列化byte[] resultBtyes = jedis.get(key.getBytes());Club resultClub = protostuffSerializer.deserialize(resultBtyes);//結(jié)果 Club{id=1, name=’AC’, info=’米蘭’, createDate=Sat May 15 22:21:42 CST 2021, rank=1}System.out.println(resultClub.toString());3、Jedis連接池
在上面我們使用的是Jedis的直連方式,每次都會新建TCP 連接,使用后再斷開連接。
這種頻繁的連接/斷開連接的過程顯然是對資源的一種浪費(fèi)。
和數(shù)據(jù)庫連接池一樣,同樣可以引入池化技術(shù),將Jedis連接存在池子(JedisPool)里,每次去池子里取,而不用重新創(chuàng)建。
連接池的方式是可以預(yù)先初始化好Jedis連接,所以每次只需要從 Jedis連接池借用即可,而借用和歸還操作是在本地進(jìn)行的,只有少量的并發(fā)同步開銷,遠(yuǎn)遠(yuǎn)小于新建TCP連接的開銷。
Jedis提供了JedisPool這個類作為對Jedis的連接池,同時使用了Apache的通用對象池工具common-pool作為資源的管理工具。
使用JedisPool操 作Redis示例如下:
1)Jedis連接池(通常JedisPool是單例的):
// common-pool連接池配置,這里使用默認(rèn)配置GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();// 初始化Jedis連接池JedisPool jedisPool = new JedisPool(poolConfig, '127.0.0.1', 6379);
2)獲取Jedis對象不再是直接生成一個Jedis對象進(jìn)行直連,而是從連接池直接獲取:
Jedis jedis = null;try { // 1. 從連接池獲取jedis對象 jedis = jedisPool.getResource(); // 2. 執(zhí)行操作 jedis.get('hello');} catch (Exception e) { e.printStackTrace();} finally { if (jedis != null) {// 如果使用JedisPool,close操作不是關(guān)閉連接,代表歸還連接池 jedis.close(); }}
面GenericObjectPoolConfig使用的是默認(rèn)配置,實際它提供有很多參數(shù),例如池子中最大連接數(shù)、最大空閑連接數(shù)、最小空閑連接數(shù)、連接活性檢測,等等。
參考:【1】:《Redis開發(fā)與運(yùn)維》
【2】:redis幾種java客戶端比較
到此這篇關(guān)于Java中Jedis基本使用的文章就介紹到這了,更多相關(guān)Java Jedis使用內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)!
相關(guān)文章:
1. python中scrapy處理項目數(shù)據(jù)的實例分析2. Python中讀取文件名中的數(shù)字的實例詳解3. 在idea中為注釋標(biāo)記作者日期操作4. 通過Ajax方式綁定select選項數(shù)據(jù)的實例5. JSP頁面的靜態(tài)包含和動態(tài)包含使用方法6. ASP.Net Core對USB攝像頭進(jìn)行截圖7. ASP.NET MVC使用Boostrap實現(xiàn)產(chǎn)品展示、查詢、排序、分頁8. .net如何優(yōu)雅的使用EFCore實例詳解9. 使用AJAX(包含正則表達(dá)式)驗證用戶登錄的步驟10. ajax動態(tài)加載json數(shù)據(jù)并詳細(xì)解析
