Java 中使用Redis 簡(jiǎn)單操作
簡(jiǎn)介
Redis 是完全開(kāi)源免費的,遵守BSD協(xié)議,是一個(gè)高性能的key-value數據庫。
Redis 與其他 key - value 緩存產(chǎn)品有以下三個(gè)特點(diǎn):
- Redis支持數據的持久化,可以將內存中的數據保存在磁盤(pán)中,重啟的時(shí)候可以再次加載進(jìn)行使用。
- Redis不僅僅支持簡(jiǎn)單的key-value類(lèi)型的數據,同時(shí)還提供list,set,zset,hash等數據結構的存儲。
- Redis支持數據的備份,即master-slave模式的數據備份。
創(chuàng )建項目
創(chuàng )建gradle項目。在 build.gradle
中添加:
compile group: 'redis.clients', name: 'jedis', version: '3.3.0'
testCompile group: 'junit', name: 'junit', version: '4.12'
創(chuàng )建Jedis連接池
package com.zeekling.redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* @author zeekling [lingzhaohui@zeekling.cn]
* @version 1.0
* @apiNote redis 連接池
* @since 2020-06-21
*/
public class RedisPool {
//Redis服務(wù)器IP
private static final String ADDR = "127.0.0.1";
//Redis的端口號
private static final Integer PORT = 6379;
//訪(fǎng)問(wèn)密碼
private static final String AUTH = null;
//可用連接實(shí)例的最大數目,默認為8;
//如果賦值為-1,則表示不限制,如果pool已經(jīng)分配了maxActive個(gè)jedis實(shí)例,則此時(shí)pool的狀態(tài)為exhausted(耗盡)
private static final Integer MAX_TOTAL = 1024;
//控制一個(gè)pool最多有多少個(gè)狀態(tài)為idle(空閑)的jedis實(shí)例,默認值是8
private static final Integer MAX_IDLE = 200;
//等待可用連接的最大時(shí)間,單位是毫秒,默認值為-1,表示永不超時(shí)。
//如果超過(guò)等待時(shí)間,則直接拋出JedisConnectionException
private static final Integer MAX_WAIT_MILLIS = 10000;
private static final Integer TIMEOUT = 10000;
//在borrow(用)一個(gè)jedis實(shí)例時(shí),是否提前進(jìn)行validate(驗證)操作;
//如果為true,則得到的jedis實(shí)例均是可用的
private static final Boolean TEST_ON_BORROW = true;
private static JedisPool jedisPool = null;
static {
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(MAX_TOTAL);
config.setMaxIdle(MAX_IDLE);
config.setMaxWaitMillis(MAX_WAIT_MILLIS);
config.setTestOnBorrow(TEST_ON_BORROW);
jedisPool = new JedisPool(config,ADDR,PORT,TIMEOUT,AUTH);
}
/**
* 獲取Jedis實(shí)例
* @return jedis實(shí)例
*/
public synchronized static Jedis getJedis(){
try {
if(jedisPool != null){
return jedisPool.getResource();
}else{
return null;
}
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
}
創(chuàng )建測試類(lèi)
package com.zeekling.redis;
import org.junit.Before;
import org.junit.Test;
import redis.clients.jedis.Jedis;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
/**
* @author zeekling [lingzhaohui@zeekling.cn]
* @version 1.0
* @apiNote
* @since 2020-06-22
*/
public class RedisPoolTest {
private Jedis jedis;
@Before
public void setJedis() {
jedis = RedisPool.getJedis();
if (jedis != null){
jedis.flushAll();
}
System.out.println("連接服務(wù)成功");
}
/**
* Redis操作字符串
*/
@Test
public void testString() {
System.out.println("--------------begin test string--------------------");
//添加數據
jedis.set("name", "zeekling"); //key為name放入value值為chx
System.out.println("拼接前:" + jedis.get("name"));//讀取key為name的值
//向key為name的值后面加上數據 ---拼接
jedis.append("name", " is my name;");
System.out.println("拼接后:" + jedis.get("name"));
//刪除某個(gè)鍵值對
jedis.del("name");
System.out.println("刪除后:" + jedis.get("name"));
//s設置多個(gè)鍵值對
jedis.mset("name", "zeekling", "age", "20", "email", "zeekling@zeekling.cn");
jedis.incr("age");//用于將鍵的整數值遞增1。如果鍵不存在,則在執行操作之前將其設置為0。 如果鍵包含錯誤類(lèi)型的值或包含無(wú)法表示為整數的字符串,則會(huì )返回錯誤。此操作限于64位有符號整數。
System.out.println(jedis.get("name") + " " + jedis.get("age") + " " + jedis.get("email"));
System.out.println("--------------end test string--------------------");
}
@Test
public void testMap() {
System.out.println("--------------begin test map--------------------");
//添加數據
Map<String, String> map = new HashMap<String, String>();
map.put("name", "zeekling");
map.put("age", "100");
map.put("email", "zeekling@zeekling.cn");
jedis.hset("user", map);
//取出user中的name,結果是一個(gè)泛型的List
//第一個(gè)參數是存入redis中map對象的key,后面跟的是放入map中的對象的key,后面的key是可變參數
List<String> list = jedis.hmget("user", "name", "age", "email");
System.out.println(list);
//刪除map中的某個(gè)鍵值
jedis.hdel("user", "age");
System.out.println("age:" + jedis.hmget("user", "age")); //因為刪除了,所以返回的是null
System.out.println("user的鍵中存放的值的個(gè)數:" + jedis.hlen("user")); //返回key為user的鍵中存放的值的個(gè)數2
System.out.println("是否存在key為user的記錄:" + jedis.exists("user"));//是否存在key為user的記錄 返回true
System.out.println("user對象中的所有key:" + jedis.hkeys("user"));//返回user對象中的所有key
System.out.println("user對象中的所有value:" + jedis.hvals("user"));//返回map對象中的所有value
//拿到key,再通過(guò)迭代器得到值
for (String key : jedis.hkeys("user")) {
System.out.println(key + ":" + jedis.hmget("user", key));
}
jedis.del("user");
System.out.println("刪除后是否存在key為user的記錄:" + jedis.exists("user"));//是否存在key為user的記錄
System.out.println("--------------end test map--------------------");
}
@Test
public void testList(){
System.out.println("--------------begin test list--------------------");
//移除javaFramwork所所有內容
jedis.del("javaFramwork");
//存放數據
jedis.lpush("javaFramework","spring");
jedis.lpush("javaFramework","springMVC");
jedis.lpush("javaFramework","mybatis");
//取出所有數據,jedis.lrange是按范圍取出
//第一個(gè)是key,第二個(gè)是起始位置,第三個(gè)是結束位置
System.out.println("長(cháng)度:"+jedis.llen("javaFramework"));
//jedis.llen獲取長(cháng)度,-1表示取得所有
System.out.println("javaFramework:"+jedis.lrange("javaFramework",0,-1));
jedis.del("javaFramework");
System.out.println("刪除后長(cháng)度:"+jedis.llen("javaFramework"));
System.out.println(jedis.lrange("javaFramework",0,-1));
System.out.println("--------------end test list--------------------");
}
@Test
public void testSet(){
System.out.println("--------------begin test set--------------------");
//添加
jedis.sadd("user","zeekling");
jedis.sadd("user","hu");
jedis.sadd("user","chen");
jedis.sadd("user","xiyu");
jedis.sadd("user","chx");
jedis.sadd("user","are");
//移除user集合中的元素are
jedis.srem("user","are");
System.out.println("user中的value:"+jedis.smembers("user"));//獲取所有加入user的value
System.out.println("chx是否是user中的元素:"+jedis.sismember("user","chx"));//判斷chx是否是user集合中的元素
System.out.println("集合中的一個(gè)隨機元素:"+jedis.srandmember("user"));//返回集合中的一個(gè)隨機元素
System.out.println("user中元素的個(gè)數:"+jedis.scard("user"));
System.out.println("--------------end test set--------------------");
}
/**
* 排序
*/
@Test
public void test(){
System.out.println("--------------begin test sort--------------------");
jedis.del("number");//先刪除數據,再進(jìn)行測試
jedis.rpush("number","4");//將一個(gè)或多個(gè)值插入到列表的尾部(最右邊)
jedis.rpush("number","5");
jedis.rpush("number","3");
jedis.lpush("number","9");//將一個(gè)或多個(gè)值插入到列表頭部
jedis.lpush("number","1");
jedis.lpush("number","2");
System.out.println(jedis.lrange("number",0,jedis.llen("number")));
System.out.println("排序:"+jedis.sort("number"));
System.out.println(jedis.lrange("number",0,-1));//不改變原來(lái)的排序
jedis.del("number");//測試完刪除數據
System.out.println("--------------end test sort--------------------");
}
}
備注
項目地址:redis學(xué)習

0 評論