2. 程式人生 > 其它 >JAVA中使用Jedis操作Redis

JAVA中使用Jedis操作Redis

阿新 • • 發佈：2022-04-29

redis安裝看這裡:https://my.oschina.net/u/2486137/blog/1541190

需要的jar:commons-pool2 ,redis.clients

①. 進入這裡檢視操作redis的客戶端語言及支援的操作方式: https://redis.io/clients

②.我選擇的是jedis ,這裡對jedis進行了一個小小的封裝,經過簡單的測試,挺好用的.

這裡儲存物件基本上都是以位元組陣列儲存的,所以寫了個序列化和反序列化的util

	/**
	 * 序列化
	 * @param t
	 * @return
	 * @throws Exception
	 */
	public static <T> byte[] serializable(T t) throws Exception {
		ByteArrayOutputStream bos = new ByteArrayOutputStream();
		ObjectOutputStream oos = new ObjectOutputStream(bos);
		oos.writeObject(t);
		byte[] b = bos.toByteArray();
		bos.close();
		oos.close();
		return b;
	}
	
	
	/**
	 * 反序列化
	 * @param b
	 * @return
	 * @throws Exception
	 */
	@SuppressWarnings("unchecked")
	public static <T> T unserializable(byte[] b) throws Exception {
		ByteArrayInputStream bis = new ByteArrayInputStream(b);
		ObjectInputStream ois = new ObjectInputStream(bis);
		T t = (T) ois.readObject();
		bis.close();
		ois.close();
		return t;
	}

③.連線池建立:

    private static final String CACHE_KEY = "cache-";
	private static Jedis jedis;
	private static JedisPool JEDIS_POOL = null;
	static {
		JedisPoolConfig config = new JedisPoolConfig();
		config.setMaxIdle(RedisConf.MAX_IDLE);
		config.setMaxTotal(RedisConf.MAX_TOTAL);
		config.setMaxWaitMillis(RedisConf.MAX_WAIT);
		config.setMinIdle(RedisConf.MIN_IDLE);
		JEDIS_POOL = new JedisPool(config, RedisConf.HOST, RedisConf.PORT, RedisConf.TIMEOUT,
		        RedisConf.AUTH);
		// 獲取jredis例項
		getJRedis();
	}

④.操作key-value鍵值對

public <K extends Serializable, V extends Serializable> void putMap(String key, Map<K, V> map)
	        throws Exception {
		if (StringUtils.isEmpty(key) || map.size() < 1) {
			return;
		}
		if (jedis == null) getJRedis();

		jedis.set((CACHE_KEY + key).getBytes(), SerializableUtil.serializable(map));
		// jedis.hmset(key.getBytes(), serializable(map));
	}

public <K extends Serializable, V extends Serializable> Map<K, V> getMap(String key)
	        throws Exception {
		if (StringUtils.isEmpty(key)) {
			throw new NullPointerException("key empty!");
		}
		if (jedis == null) getJRedis();

		if (!jedis.exists((CACHE_KEY + key).getBytes())) {
			return null;
		}
		return SerializableUtil.unserializable(jedis.get((CACHE_KEY + key).getBytes()));
	}
 
  Map map = new HashMap();
			map.put("age", 12);
			map.put("name", "tony");
			redis.put("map", map);
			System.out.println(redis.getMap("map"));

//測試結果:
{age=12, name=tony}

⑤.操作一個物件:

/**
	 * 新增一個物件
	 * 
	 * @param key
	 * @param t
	 * @throws Exception
	 */
	public <T extends Serializable> void putObject(String key, T t) throws Exception {
		if (StringUtils.isEmpty(key) || t == null) {
			return;
		}
		if (jedis == null) getJRedis();
		jedis.set((CACHE_KEY + key).getBytes(), SerializableUtil.serializable(t));
	}

	/**
	 * 獲取物件
	 * 
	 * @param key
	 * @return
	 * @throws Exception
	 */
	@Deprecated
	public <T extends Serializable> T getObject(String key) throws Exception {
		if (StringUtils.isEmpty(key)) {
			throw new NullPointerException("key empty!");
		}
		if (jedis == null) getJRedis();
		return SerializableUtil.unserializable(jedis.get((CACHE_KEY + key).getBytes()));

	}
 redis.putObject("person", new Person(1, "timor", 19L, "male", new Date()));
			 System.out.println(redis.getObject("person"));

//測試結果
Person [id=1, name=timor, age=19, gender=male, birthday=Thu Sep 21 16:00:50 CST 2017]

⑥.操作一個list

/**
	 * 新增一個List集合
	 * 
	 * @param key
	 * @param list
	 * @throws Exception
	 */
	@Deprecated
	public <S extends Serializable> void putList(String key, List<S> list) throws Exception {
		if (StringUtils.isEmpty(key) || list.size() < 1) {
			return;
		}
		if (jedis == null) getJRedis();
		jedis.set((CACHE_KEY + key).getBytes(), SerializableUtil.serializable(list));
	}
	@Deprecated
	public <S extends Serializable> List<S> getList(String key) throws Exception {
		if (StringUtils.isEmpty(key)) {
			throw new NullPointerException("key empty!");
		}
		if (jedis == null) getJRedis();
		return SerializableUtil.unserializable(jedis.get((CACHE_KEY + key).getBytes()));
	}
List<String> list = new ArrayList<String>();
			list.add("a");
			list.add("b");
			list.add("c");
			redis.putList("my-list", list);
			System.out.println(redis.getList("my-list"));

//測試結果
[a, b, c]

⑦.操作set: 

/**
	 * 新增一個Set集合
	 * 
	 * @param key
	 * @param set
	 * @throws Exception
	 */
	@Deprecated
	public <S extends Serializable> void putSet(String key, Set<S> set) throws Exception {
		if (StringUtils.isEmpty(key) || set.size() < 1) {
			return;
		}
		if (jedis == null) getJRedis();
		jedis.set((CACHE_KEY + key).getBytes(), SerializableUtil.serializable(set));
		// for (byte[] b : serializable(set)) {
		// jedis.sadd(key.getBytes(), b);
		// }

	}
	@Deprecated
	public <S extends Serializable> Set<S> getSet(String key) throws Exception {
		if (StringUtils.isEmpty(key)) {
			throw new NullPointerException("key empty!");
		}
		if (jedis == null) getJRedis();
		return SerializableUtil.unserializable(jedis.get((CACHE_KEY + key).getBytes()));
	}
RedisUtil redis = new RedisUtil();
			Set<String> set = new HashSet<String>();
			set.add("1");
			set.add("2");
			set.add("3");
			 redis.putSet("my-set", set);
			 System.out.println(redis.getSet("my-set"));

//測試結果
[3, 2, 1]

⑧. 上述寫的過於麻煩,這裡把上述全部廢棄不再使用,下面是完整的程式碼:

private static final String CACHE_KEY = "cache-";
	private static Jedis jedis;
	private static JedisPool JEDIS_POOL = null;
	static {
		JedisPoolConfig config = new JedisPoolConfig();
		config.setMaxIdle(RedisConf.MAX_IDLE);
		config.setMaxTotal(RedisConf.MAX_TOTAL);
		config.setMaxWaitMillis(RedisConf.MAX_WAIT);
		config.setMinIdle(RedisConf.MIN_IDLE);
		JEDIS_POOL = new JedisPool(config, RedisConf.HOST, RedisConf.PORT, RedisConf.TIMEOUT,
		        RedisConf.AUTH);
		// 獲取jredis例項
		getJRedis();
	}
	/**
	 * 根據key-獲取值
	 * @param key
	 * @return
	 * @throws Exception
	 */
	public <T extends Serializable> T get(String key) throws Exception {
		if (StringUtils.isEmpty(key)) return null;
		if (jedis == null) getJRedis();
		if (!jedis.exists((CACHE_KEY + key).getBytes())) return null;
		T t = SerializableUtil.unserializable(jedis.get((CACHE_KEY + key).getBytes()));
		return t;

	}

	/**
	 * 非持久化操作
	 * @param <T>
	 * 
	 * @param key
	 * @param t
	 * @param seconds 過期時間
	 * @throws Exception
	 */
	public <T> void put(String key, T t ,int seconds) throws Exception {
		if (StringUtils.isEmpty(key) || t == null || seconds < 1) {
			return;
		}
		if (jedis == null) getJRedis();
		jedis .setex((CACHE_KEY + key).getBytes(), seconds, SerializableUtil.serializable(t));
	}
	/**
	 * 持久化操作
	 * @param key
	 * @param t
	 * @throws Exception
	 */
	public <T> void put(String key, T t) throws Exception {
		if (StringUtils.isEmpty(key) || t == null) {
			return;
		}
		if (jedis == null) getJRedis();
		jedis.set((CACHE_KEY + key).getBytes(), SerializableUtil.serializable(t));
	}
	

	/**
	 * 刪除
	 * @param key
	 */
	public void remove(String key) {
		jedis.del(key.getBytes());
	}

	private synchronized static void getJRedis() {
		if (JEDIS_POOL == null) {
			return;
		}
		jedis = JEDIS_POOL.getResource();
	}
public interface RedisConf {
	String HOST = "redis";
	Integer PORT = 6379;
	String AUTH = "123";// 密碼 ,redis-conf檔案中的 requirepass屬性後的值即為密碼
	// 連線的最大數目，預設值為8；
	// 如果賦值為-1，則表示不限制；如果pool已經分配了maxActive個jedis例項，則此時pool的狀態為exhausted(耗盡)。
	Integer MAX_TOTAL = 100;
	// 等待可用連線的最大時間，單位毫秒，預設值為-1，表示永不超時。
	// 如果超過等待時間，則直接丟擲JedisConnectionException；
	Integer MAX_WAIT = -1;
	// 最大空閒的jedis例項個數，預設值也是8
	Integer MAX_IDLE = 30;
	// 最小連線數
	Integer MIN_IDLE = 50;
	// 連線超時時間
	Integer TIMEOUT = 5000;
}

轉載請註明出處謝謝!

相關推薦

JAVA中使用Jedis操作Redis

redis安裝看這裡:https://my.oschina.net/u/2486137/blog/1541190 需要的jar:commons-pool2 ,redis.clients

Spring中使用Jedis操作redis

13Spring中使用Jedis操作redis Redis是一款開源的記憶體KV儲存，相比較於membercached只有一種資料結構，redis支援多種資料結構。

Java使用Lettuce操作redis

maven包 # 包含了lettuce jar <dependency> <groupId>org.springframework.boot</groupId>

java中如何使用Redis

1.引入redis的jar包<!--配置2 使用 jedis 作客戶端驅動--> <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>

Java通過Jedis與Redis整合與事務控制 !

技術標籤：Redisredisjava Jedis 什麼是jedis? Redis官方網站上列一些Java的客戶端，有Jedis、Redisson、Jredis、JDBC-Redis、等其中官方推薦使用Jedis和Redisson。相當於Java操作Redis的中介軟體。在企業中用的

File類的特點?如何建立File類物件?Java中如何操作檔案內容,什麼是Io流Io流如何讀取和寫入檔案?位元組緩衝流使用原則?

　　　　　　　　　　　　　　　　　　　　　　　　　　重難點提示 　　　　　　　　　　　　　　　　　　　　　　　　　　學習目標

Java中原生操作JDBC連線及原理

技術標籤：javamysqljdkjavamysqljdbcsql 一、簡介 JDBC全稱又叫做Java DataBase Connectivity，也就是Java資料庫連線，說白了就是用Java語言來操作資料 庫，提供統一API訪問資料庫操作。

Jedis 操作redis簡易說明

參考地址:https://tech.antfin.com/docs/2/98726 1: maven引入jar <!-- Jedis --> <dependency>

11-Java中CAS操作

1. Java中CAS操作 在Java中使用鎖不好的地方就是當一個執行緒沒有獲取到鎖時會被阻塞掛起，這會導致執行緒上下文重新排程與開銷。Java提供了非阻塞的volatile關鍵字來解決共享變數的可見性問題。但是volatile只能

05 使用jedis操作redis資料庫

使用jedis操作redis資料庫 jedis Jedis是Redis官方推薦的Java連結工具 使用前先匯入，下面的測試建議也匯入測試的包

Jedis 操作Redis

 Jedis Jedis 是 Redis 的 Java 版本的客戶端實現。 maven座標： <dependency> <groupId>redis.clients</groupId>

Redis Java客戶端-通過原生jedis和SpringBoot操作Redis叢集

技術標籤：redis分散式系統Redis java客戶端 Redis java客戶端操作叢集 1. 使用Jedis java原生操作redis叢集

Redis基礎學習（六）：JAVA操作Redis之Jedis

技術標籤：# Redis Jedis 1、概述 Jedis是Redis官方推薦的Java連線開發工具。要在Java開發中使用好Redis中介軟體，必須對Jedis熟悉才能寫成漂亮的程式碼

Java操作Redis—Jedis

之所以使用Jedis，是因為它操作redis時使用的方法名與redis命令一致。 一、簡單使用

詳解java操作Redis資料庫的redis工具(RedisUtil,jedis工具JedisUtil,JedisPoolUtil)

該工具包含是封裝了jedis,包含redis.properties和jedisPool,序列化使用的是protostuff,map型別操作使用的是faston

Java操作Redis-Jedis

Jedis：Redis官方推薦的java連線開發工具，使用java操作Redis中介軟體，如果你要使用java操作Jedis，那麼一定要對Jedis十分的熟悉

Java中日期格式化YYYY-DD的操作bug

寫這篇博文是記錄下跨年的bug。去年隔壁組的小夥伴就是計算兩個日期之間間隔的天數，因為跨年的原因計算有誤。

Go語言中通過Lua指令碼操作Redis的方法

前言 為了在我的一個基本庫中降低與Redis的通訊成本，我將一系列操作封裝到LUA指令碼中，藉助Redis提供的EVAL命令來簡化操作。

Java中父類和子類之間的轉換操作示例

本文例項講述了Java中父類和子類之間的轉換操作。分享給大家供大家參考，具體如下：

java操作Redis快取設定過期時間的方法

關於Redis的概念和應用本文就不再詳解了，說一下怎麼在java應用中設定過期時間。