jedis源碼

㈠ redis有哪些api

一、Redis Client介紹
1.1、簡介
Jedis Client是Redis官網推薦的一個面向java客戶端，庫文件實現了對各類API進行封裝調用。
Jedis源碼工程地址：https://github.com/xetorthio/jedis
1.2、使用
Redis Client最好選用與服務端對應的版本，本例中使用Redis 2.8.19客戶端使用jedis -2.6.3，Maven工程添加如下引用即可。
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.6.3</version>
<type>jar</type>
<scope>compile</scope>
</dependency>1.3、注意事項
Redis Client擁有眾多對接版本，本項目目前使用Jedis為官方推薦Java對接客戶端，是基於其對Redis良好的版本支持和API對接，另外編碼中盡量避免使用廢棄介面。
Redis目前正在新版過渡期，3.0版本暫未穩定，但是由於3.0版本提供了最新的集群功能，可能在日後穩定版發布以後升級到3.0，目前使用的Jedis支持3.0的目前版本API。
二、Redis Client常用API
2.1、環境要求
語言：Java
JDK：1.7
Redis : 2.8.19（穩定版）
2.2、系統使用
2.2.1、建立連接
普通連接
Jedis jedis = new Jedis("localhost");
jedis.set("foo", "bar");
String value = jedis.get("foo");
System.out.println(value);設置連接池配置
該方法用於得到redis連接池連接使用的連接池配置，該連接池配置也可以通過spring注入的方式來進行相對應的配置，連接池採用的是平時比較常用的org.apache.commons.pool2.impl.GenericObjectPoolConfig來進行的連接池管理
配置文件如下
#redis伺服器ip #
redis.ip=172.30.5.117

#redis伺服器埠號#
redis.port=6379

###jedis##pool##config###
#jedis的最大分配對象#
jedis.pool.maxActive=1024

#jedis最大保存idel狀態對象數 #
jedis.pool.maxIdle=200

#jedis池沒有對象返回時，最大等待時間 #
jedis.pool.maxWait=1000

#jedis調用borrowObject方法時，是否進行有效檢查#
jedis.pool.testOnBorrow=true

#jedis調用returnObject方法時，是否進行有效檢查 #
jedis.pool.testOnReturn=true連接池配置實例化代碼（也可通過spring注入進行配置）：
/**
* 獲取化連接池配置
* @return JedisPoolConfig
* */
private JedisPoolConfig getPoolConfig(){
if(config == null){
config = new JedisPoolConfig();
//最大連接數
config.setMaxTotal(Integer.valueOf(getResourceBundle().getString("redis.pool.maxTotal")));
//最大空閑連接數
config.setMaxIdle(Integer.valueOf(getResourceBundle().getString("redis.pool.maxIdle")));
//獲取連接時的最大等待毫秒數(如果設置為阻塞時BlockWhenExhausted),如果超時就拋異常, 小於零:阻塞不確定的時間, 默認-1
config.setMaxWaitMillis(Long.valueOf(getResourceBundle().getString("redis.pool.maxWaitMillis")));
//在獲取連接的時候檢查有效性, 默認false
config.setTestOnBorrow(Boolean.valueOf(getResourceBundle().getString("redis.pool.testOnBorrow")));
//在獲取返回結果的時候檢查有效性, 默認false
config.setTestOnReturn(Boolean.valueOf(getResourceBundle().getString("redis.pool.testOnReturn")));
}
return config;
}普通連接池連接
這里展示的是普通的連接池方式鏈接redis的方案，跟普通的資料庫連接池的操作方式類似；
/**
* 初始化JedisPool
* */
private void initJedisPool(){
if(pool == null){
//獲取伺服器IP地址
String ipStr = getResourceBundle().getString("redis.ip");
//獲取伺服器埠
int portStr = Integer.valueOf(getResourceBundle()
.getString("redis.port"));
//初始化連接池
pool = new JedisPool(getPoolConfig(), ipStr,portStr);
}
}Sentinel連接池連接
該連接池用於應對Redis的Sentinel的主從切換機制，能夠正確在伺服器宕機導致伺服器切換時得到正確的伺服器連接，當伺服器採用該部署策略的時候推薦使用該連接池進行操作；
private void initJedisSentinelPool(){
if(sentinelpool == null){
//監聽器列表
Set<String> sentinels = new HashSet<String>();
//監聽器1
sentinels.add(new HostAndPort("192.168.50.236",
26379).toString());
//監聽器2
sentinels.add(new HostAndPort("192.168.50.237",
26379).toString());
//實際使用的時候在properties里配置即可：redis.sentinel.hostandports
=192.168.50.236:26379,192.168.50.237:26379
getResourceBundle().getString("redis.sentinel.hostandports")
//mastername是伺服器上的master的名字，在master伺服器的sentinel.conf中配置:
//[sentinel monitor server-1M 192.168.50.236 6379 2]
//中間的server-1M即為這里的masterName
String masterName = getResourceBundle()
.getString("redis.sentinel.masterName");
//初始化連接池
sentinelpool = new JedisSentinelPool(masterName,
sentinels, getPoolConfig());
}
}ShardedJedisPool連接池分片連接
/**
* 初始化ShardedJedisPool
* Redis在容災處理方面可以通過伺服器端配置Master-Slave模式來實現。
* 而在分布式集群方面目前只能通過客戶端工具來實現一致性哈希分布存儲，即key分片存儲。
* Redis可能會在3.0版本支持伺服器端的分布存儲
* */
private void initShardedJedisPool() {
if (shardPool == null) {
// 創建多個redis共享服務
String redis1Ip = getResourceBundle().getString("redis1.ip");
int redis1Port = Integer.valueOf(bundle.getString("redis.port"));
JedisShardInfo jedisShardInfo1 = new JedisShardInfo(redis1Ip, redis1Port);
String redis2Ip = getResourceBundle().getString("redis2.ip");
int redis2Port = Integer.valueOf(bundle.getString("redis.port"));
JedisShardInfo jedisShardInfo2 = new JedisShardInfo(redis2Ip, redis2Port);

List<JedisShardInfo> serverlist = new LinkedList<JedisShardInfo>();
serverlist.add(jedisShardInfo1);
serverlist.add(jedisShardInfo2);
// 初始化連接池
shardPool = new ShardedJedisPool(getPoolConfig(),serverlist);
}
}讀寫刪除操作
// 從池中獲取一個Jedis對象
Jedis jedis = sentinelpool.getSentinelpoolResource();
String keys = "name";
// 刪除key-value對象，如果key不存在則忽略此操作
jedis.del(keys);
// 存數據
jedis.set(keys, "snowolf");
// 判斷key是否存在，不存在返回false存在返回true
jedis.exists(keys);
// 取數據
String value = jedis.get(keys);
// 釋放對象池（3.0將拋棄該方法）
sentinelpool.returnSentinelpoolResource(jedis);三、示例代碼
1. String的簡單追加
// 從池中獲取一個Jedis對象
JedisUtil.getInstance().STRINGS.append(key, value);2. 價格時間排序（前提是已經存儲了價格，時間的SortSet）
//執行2級排序操作（）
String stPriceSet = 「stPriceSet」;//stPriceSet價格的sortset列表名
String stTimeSet = 「stTimeSet」; // stTimeSet時間的sortset列表名
Set<Tuple> sumSet = JedisUtilEx.getInstance()
.(stPriceSet, stTimeSet);
//排序以後可以重復獲取上次排序結果(緩存時間10分鍾)
Set<Tuple> sumSet = JedisUtilEx.getInstance()
getLastPirceUpAndTimeDownSet();3. 價格時間排序（前提是已經存儲了價格，時間的SortSet）
//執行2級排序操作
String stPriceSet = 「stPriceSet」;//stPriceSet價格的sortset列表名
String stTimeSet = 「stTimeSet」; // stTimeSet時間的sortset列表名
Set<Tuple> sumSet = JedisUtilEx.getInstance()
. (stPriceSet, stTimeSet);
//排序以後可以重復獲取上次排序結果(緩存時間10分鍾)
Set<Tuple> sumSet = JedisUtilEx.getInstance()
();4. 保存JavaBean到hash表中
// bean繼承至RedisBean
JedisUtilEx.getInstance().setBeanToHash(bean);5. 從hash表中讀取JavaBean
//uuid為業務制定的唯一標識符規則（相當於主鍵）
String uuid = 「1」; //該ID是我們提前就知道的
//T繼承至RedisBean;
JedisUtilEx.getInstance().getBeanFromHash (uuid,Class<T> cls);6. 將JavaBean列表裝入hash中
//list中的bean繼承至RedisBean
List<T> beanList = ?;
JedisUtilEx.getInstance().setBeanListToHash(beanList);
//非同步版本的存儲列表到hash
JedisUtilEx.getInstance().setBeanListToHashSyn(beanList);7. 普通的操作流程示例
//獲取jedis引用
Jedis jedis = JedisUtil.getInstance().getJedis();
//執行業務以及調用jedis提供的介面功能
?
jedis.hset(?);
?
//執行完成以後務必釋放資源
JedisUtil.getInstance().returnJedis(jedis);
//若以後不會使用JEDIS，需要關閉所有鏈接池
RedisConnetcion.destroyAllPools();8. 事務執行流程
//獲取連接資源
Jedis jd = JedisUtil.getInstance().getJedis();
//開啟事務
Transaction ts = jd.multi();
//執行業務以及調用jedis提供的介面功能
?
jedis.hset(?);
?
//執行事務
List<Object> list = ts.exec();
//釋放資源
JedisUtil.getInstance().returnJedis(jd);9. 非同步執行
//獲取連接資源
Jedis jedis = JedisUtil.getInstance().getJedis();
//獲取管道
Pipeline pipeline = jedis.pipelined();
//執行業務以及調用jedis提供的介面功能
?
jedis.hset(?);
?
//提交並釋放管道
pipeline.syncAndReturnAll();
//釋放資源
JedisUtil.getInstance().returnJedis(jedis);10. 如何獲取Jedis命名規則的合成KEY
//獲取類的唯一鍵值key,例如：User:1(User為class,1為uuid)其中user繼承於Reidsbean
JedisUtilEx.getInstance().getBeanKey(user);
//另一種獲取類的唯一鍵值key的方法
JedisUtilEx.getInstance().getBeanKey(String uuid,Class<T> cls);
//獲取bean對應的KEY(對應列的唯一鍵值key)
JedisUtilEx.getInstance().getBeanKey(String uuid,Class<T> cls,String... fileds);
//獲取bean對應的KEY(集群key)
JedisUtilEx.getInstance().getBeanKey(Class<T> cls,String... fileds);四、jedis操作命令：
1.對value操作的命令
exists(key)：確認一個key是否存在
del(key)：刪除一個key
type(key)：返回值的類型
keys(pattern)：返回滿足給定pattern的所有key
randomkey：隨機返回key空間的一個key
rename(oldname, newname)：將key由oldname重命名為newname，若newname存在則刪除newname表示的key
dbsize：返回當前資料庫中key的數目
expire：設定一個key的活動時間（s）
ttl：獲得一個key的活動時間
select(index)：按索引查詢
move(key, dbindex)：將當前資料庫中的key轉移到有dbindex索引的資料庫
flushdb：刪除當前選擇資料庫中的所有key
flushall：刪除所有資料庫中的所有key2.對String操作的命令
set(key, value)：給資料庫中名稱為key的string賦予值value
get(key)：返回資料庫中名稱為key的string的value
getset(key, value)：給名稱為key的string賦予上一次的value
mget(key1, key2,?, key N)：返回庫中多個string（它們的名稱為key1，key2?）的value
setnx(key, value)：如果不存在名稱為key的string，則向庫中添加string，名稱為key，值為value
setex(key, time, value)：向庫中添加string（名稱為key，值為value）同時，設定過期時間time
mset(key1, value1, key2, value2,?key N, value N)：同時給多個string賦值，名稱為key i的string賦值value i
msetnx(key1, value1, key2, value2,?key N, value N)：如果所有名稱為key i的string都不存在，則向庫中添加string，名稱key i賦值為value i
incr(key)：名稱為key的string增1操作
incrby(key, integer)：名稱為key的string增加integer
decr(key)：名稱為key的string減1操作
decrby(key, integer)：名稱為key的string減少integer
append(key, value)：名稱為key的string的值附加value
substr(key, start, end)：返回名稱為key的string的value的子串3.對List操作的命令
rpush(key, value)：在名稱為key的list尾添加一個值為value的元素
lpush(key, value)：在名稱為key的list頭添加一個值為value的 元素
llen(key)：返回名稱為key的list的長度
lrange(key, start, end)：返回名稱為key的list中start至end之間的元素（下標從0開始，下同）
ltrim(key, start, end)：截取名稱為key的list，保留start至end之間的元素
lindex(key, index)：返回名稱為key的list中index位置的元素
lset(key, index, value)：給名稱為key的list中index位置的元素賦值為value
lrem(key, count, value)：刪除count個名稱為key的list中值為value的元素。count為0，刪除所有值為value的元素，count>0 從頭至尾刪除count個值為val

㈡ java基於cs結構的，含有客戶端，服務端的請假管理系統的源代碼

import redis.clients.jedis.Jedis;
//java代碼模擬處理redis分布式鎖代碼
public class redisTest {
private static long timeout = 1000;

㈢ 集群redis哨兵模式連接方式，解決database不生效問題（附源碼）

公司裡面項目基本都早敗謹使用哨兵模式
注意事項：

1 引入pom依賴

2 添加redis哨兵配置，database主動設置，才會生效

3 application.yml配置枯物

4 項目目錄

5 啟動測試連接

可以看到redis.clients.jedis.JedisSentinelPool : Created JedisSentinelPool to master at 10.10.195.249:6379已經啟動了

作為程序員第陸基 140 篇文章，每次寫一句歌詞記錄一下，看看人生有幾首歌的時間，wahahaha ...

㈣ 【Redis技術探索】「踩坑技術」一文教會你如何在支持Redis在低版本Jedis情況下兼容Redis的ACL機制

Redis的ACL功能提供了訪問控制的細粒度管理，允許對Redis伺服器的命令和數據進行精確的訪問控制，旨在保護Redis實例不受未經授權的訪問和濫用。通過ACL，用戶可以實現基於角色和許可權的訪問控制，確保只有經過授權的用戶才能執行特定命令或訪問特定數據。

針對低版本Jedis客戶端不支持Redis 6.0之後的ACL機制，本文提出了一種兼容解決方案。該方案通過改造項目代碼，實現對Redisson和Jedis代碼的優化調整，並加入對應配置以實現兼容ACL模式下的用戶名和密碼登錄。整個POC調研計劃預計耗時3-4天，包含對所有服務代碼的改造和自測。

在不修改現有框架版本的前提下，通過項目目錄與Jedis jar包內文件全限定名一致時的類載入優先性，覆蓋了Jedis源碼，實現對低版本Jedis源碼的改造。關鍵在於修改了BinaryClient類，針對低版本源碼中的auth指令，通過參數變更支持用戶名+密碼認證模式。

考慮到兼容性，代碼調整了指令修改和兼容單獨密碼的模式，確保了底層功能直接通過用戶名控制，簡化了開發過程，且對Spring框架和自定義框架透明化。通過靜態變數傳輸用戶名，簡化了配置過程，便於全局訪問。

實現Spring BeanPostProcessor介面的類方法，在RedisConfig類初始化前，將配置文件中的spring.redis.userName屬性值賦給靜態變數redisUserName，便於其他部分通過訪問RedisUserName.redisUserName獲取用戶名。代碼中部分如RedisUserName類載入和類名查找似乎存在冗餘，可能是遺留代碼或作者誤寫。

針對SAAS環境的用戶管理和Redis ACL用戶設計，增加了配置文件中的key或環境變數，修改對應的配置信息以設置Redis的ACL用戶和操作許可權。用戶密碼與整體操作許可權的設置成為關鍵步驟，確保了安全性和功能性。