Redis經(jīng)常被用在服務器來存儲一些需要頻繁調(diào)用的數(shù)據(jù),極大地提高計算機的性能。本篇文章將為大家介紹關于Java中一門操作Redis數(shù)據(jù)庫的工具,Jedis。
在前面我們已經(jīng)學習了Redis命令行客戶端redis-cli的使用,接下來我們了解一下Redis基于Java編程語言的客戶端。
在Java語言體系下,有三個常用的Redis客戶端Jedis
、Redisson
、Lettuce
。三者各有特點,各有適用的場景。
Jedis
:Redis的Java實現(xiàn)的客戶端,其API提供了比較全面的Redis命令的支持;- Jedis中的方法調(diào)用是比較底層的暴露的Redis的API,也即Jedis中的Java方法基本和Redis的API保持著一致,了解Redis的API,也就能熟練的使用Jedis。
Redisson
:實現(xiàn)了分布式和可擴展的Java數(shù)據(jù)結構,提供很多分布式相關操作服務,例如,分布式鎖,分布式集合,可通過Redis支持延遲隊列。和Jedis相比,功能較為簡單,不支持字符串操作,不支持排序、事務、管道、分區(qū)等Redis特性。Redisson的宗旨是促進使用者對Redis的關注分離,從而讓使用者能夠將精力更集中地放在處理業(yè)務邏輯上。- Redisson中的方法則是進行比較高的抽象,每個方法調(diào)用可能進行了一個或多個Redis方法調(diào)用。
Lettuce
:高級Redis客戶端,用于線程安全同步,異步和響應使用,支持集群,Sentinel,管道和編碼器。是SpringBoot2.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對象,這個對象負責和指定Redis實例進行通信
Jedis jedis = new Jedis("127.0.0.1", 6379);
// 2.jedis執(zhí)行set操作
jedis.set("hello", "world");
//3.jedis執(zhí)行get操作,value="world"
String value = jedis.get("hello");
初始化Jedis需要兩個參數(shù):Redis實例的IP和端口,除了這兩個參數(shù)外,還有一個包含了四個參數(shù)的構造函數(shù)是比較常用的:
Jedis(final String host, final int port, final int connectionTimeout, final int soTimeout)
參數(shù)說明:
- host:Redis實例的所在機器的IP
- port:Redis實例的端口
- connectionTimeout:客戶端連接超時
- soTimeout:客戶端讀寫超時
可以打印輸出一下上面程序的結果:
和JDBC類似,一般涉及到這種網(wǎng)絡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");
//結果 world
System.out.println(jedis.get("hello"));
//結果 1
System.out.println(jedis.incr("counter"));
hash
jedis.hset("myhash", "f1", "v1");
jedis.hset("myhash", "f2", "v2");
//運行結果 {f2=v2, f1=v1}
System.out.println(jedis.hgetAll("myhash"));
list
jedis.rpush("mylist", "1");
jedis.rpush("mylist", "2");
jedis.rpush("mylist", "3");
//運行結果 [1, 2, 3]
System.out.println(jedis.lrange("mylist",0,-1));
set
jedis.sadd("myset", "a");
jedis.sadd("myset", "b");
jedis.sadd("myset", "a");
//運行結果 [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");
//運行結果 james 33.0 peter 66.0 tom 99.0
jedis.zrangeWithScores("thezset",0,-1).stream().forEach(s->{
System.out.print(s.getElement()+" "+s.getScore()+" ");
});
2、序列化
在Java中,存儲對象一般會進行序列化和反序列化,Jedis本身并不支持序列化??梢砸胗螒蝾~第三方的序列化工具,例如XML、Json、谷歌的Protobuf、Facebook的Thrift等等。
我們以protostuff(Protobuf的Java客戶端)為例來進行學習:
引入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);
//結果 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 連接,使用后再斷開連接。
這種頻繁的連接/斷開連接的過程顯然是對資源的一種浪費。
和數(shù)據(jù)庫連接池一樣,同樣可以引入池化技術,將Jedis連接存在池子(JedisPool)里,每次去池子里取,而不用重新創(chuàng)建。
連接池的方式是可以預先初始化好Jedis連接,所以每次只需要從 Jedis連接池借用即可,而借用和歸還操作是在本地進行的,只有少量的并發(fā)同步開銷,遠遠小于新建TCP連接的開銷。
Jedis提供了JedisPool這個類作為對Jedis的連接池,同時使用了Apache的通用對象池工具common-pool作為資源的管理工具。
使用JedisPool操 作Redis示例如下:
1)Jedis連接池(通常JedisPool是單例的):
// common-pool連接池配置,這里使用默認配置
GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
// 初始化Jedis連接池
JedisPool jedisPool = new JedisPool(poolConfig, "127.0.0.1", 6379);
2)獲取Jedis對象不再是直接生成一個Jedis對象進行直連,而是從連接池直接獲?。?/p>
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操作不是關閉連接,代表歸還連接池
jedis.close();
}
}
面GenericObjectPoolConfig使用的是默認配置,實際它提供有很多參數(shù),例如池子中最大連接數(shù)、最大空閑連接數(shù)、最小空閑連接數(shù)、連接活性檢測,等等。
到此這篇關于 Java 中操作 Redis 數(shù)據(jù)的工具 Jedis 的基本使用的文章就介紹到這了,想要了解更多相關 Java Jedis 使用內(nèi)容請搜索W3Cschool以前的文章或繼續(xù)瀏覽下面的相關文章,也希望大家以后多多支持!