Java中操作Redis的詳細(xì)方法
更新時(shí)間：2021年11月11日 09:35:38 作者：利威爾兵短
基于Jedis實(shí)現(xiàn)對(duì)redis中字符串的操作，文中通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，包括連接池JedisPool應(yīng)用的實(shí)例代碼，對(duì)Java操作Redis的相關(guān)知識(shí)感興趣的朋友一起看看吧
1.準(zhǔn)備操作
1.1 新建工程
1.2 sca-jedis工程依賴(lài)
<dependencies>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.5.2</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.8.6</version>
</dependency>
</dependencies>
1.3 sca-tempalte工程依賴(lài)
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>2.3.2.RELEASE</version>
<scope>import</scope>
<type>pom</type>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
1.4 測(cè)試是否可以連接Redis
package com.jt;
import org.junit.Test;
import redis.clients.jedis.Jedis;
public class JedisTests {
@Test
public void testGetConnection(){
//假如不能連通,要注釋掉redis.conf中 bind 127.0.0.1,
//并將protected-mode的值修改為no,然后重啟redis再試
Jedis jedis=new Jedis("192.168.126.129",6379);
//jedis.auth("123456");//假如在redis.conf中設(shè)置了密碼
String ping = jedis.ping();
System.out.println(ping);
}
}
測(cè)試結(jié)果
注意保持一致：
1.5 修改redis.conf文件
/usr/local/docker/redis01/conf/目錄下
修改配置文件之后需要重啟，然后再測(cè)試連接 拓展:設(shè)定編譯版本
2. 基于Jedis實(shí)現(xiàn)對(duì)redis中字符串的操作
@Test
public void testString01(){
//1.創(chuàng)建連接對(duì)象
Jedis jedis=new Jedis(ip,port);
//2.執(zhí)行redis讀寫(xiě)操作
//2.1想redis中存儲(chǔ)字符串?dāng)?shù)據(jù)
jedis.set("id", "100");
jedis.expire("id", 2);
jedis.set("token", UUID.randomUUID().toString());
jedis.incr("id");
Map<String,Object> map=new HashMap<>();
map.put("code", "201");
map.put("name", "redis");
Gson gson=new Gson();
String jsonStr = gson.toJson(map);//將map對(duì)象轉(zhuǎn)換為json字符串
jedis.set("lession",jsonStr);
//2.2刪除數(shù)據(jù)
jedis.del("id");
//2.3獲取數(shù)據(jù)
String id=jedis.get("id");
jsonStr=jedis.get("lession");
System.out.println(id);
System.out.println(jsonStr);
//3.釋放資源
jedis.close();
}
3. 模式總結(jié)
==享元模式：==設(shè)計(jì)思想，通過(guò)池減少對(duì)象的創(chuàng)建次數(shù)，實(shí)現(xiàn)對(duì)象的可重用性，所有池的設(shè)計(jì)都有這個(gè)設(shè)計(jì)模式的應(yīng)用
=例如整數(shù)池、字符串池、線程池、連接池
- AOP 代理模式
- Singleton 單例 HikariPool
- xxxAdapter 適配器模式
- Ribbon 策略
- RestTemplate 模板方法模式
- SL4J 門(mén)面
- Interceptor 執(zhí)行鏈模式
- 工廠模式
4. 連接池JedisPool應(yīng)用
package com.jt;
import org.junit. Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/*享元模式：設(shè)計(jì)思想，通過(guò)池減少對(duì)象的創(chuàng)建次數(shù)，實(shí)現(xiàn)對(duì)象的可重用性，所有池的設(shè)計(jì)都有這個(gè)設(shè)計(jì)模式的應(yīng)用
* 例如整數(shù)池、字符串池、線程池、連接池
* Jedis連接池（與redis數(shù)據(jù)庫(kù)的連接）
* */
public class JedisPoolTests {
@Test
public void testJedisPool(){
//定義連接池配置
JedisPoolConfig config=new JedisPoolConfig();
//最大連接數(shù)
config.setMaxTotal(1000);
//最大空閑時(shí)間
config.setMaxIdle(60);
//創(chuàng)建連接池
JedisPool jedisPool=new JedisPool(config,"192.168.126.129",6379);
//從池中獲取一個(gè)連接
Jedis resource = jedisPool.getResource();
//通過(guò)redis連接獲取數(shù)據(jù)
resource.set("class", "cgb2107");
String aClass = resource.get("class");
System.out.println(aClass);
//釋放資源
resource.close();//把連接還回去
jedisPool.close();
}
}
連接池配置也可以不寫(xiě)，因?yàn)橛心J(rèn)的
5. 單例模式創(chuàng)建連接池
package com.jt;
import com.jt.redis.JedisDataSource;
import org.junit.Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/*享元模式：設(shè)計(jì)思想，通過(guò)池減少對(duì)象的創(chuàng)建次數(shù)，實(shí)現(xiàn)對(duì)象的可重用性，所有池的設(shè)計(jì)都有這個(gè)設(shè)計(jì)模式的應(yīng)用
* 例如整數(shù)池、字符串池、線程池、連接池
* Jedis連接池（與redis數(shù)據(jù)庫(kù)的連接）
* AOP 代理模式
* Singleton 單例 HikariPool
* xxxAdapter 適配器模式
* Ribbon 策略
* RestTemplate 模板方法模式
* SL4J 門(mén)面
* Interceptor 執(zhí)行鏈模式
* 工廠模式
* */
public class JedisPoolTests {
@Test
public void testJedisPool(){
//單例模式創(chuàng)建連接池
Jedis resource = JedisDataSource.getConnection2();
// //定義連接池配置 可不寫(xiě)，有默認(rèn)的
// JedisPoolConfig config=new JedisPoolConfig();
// //最大連接數(shù)
// config.setMaxTotal(1000);
// //最大空閑時(shí)間
// config.setMaxIdle(60);
// //創(chuàng)建連接池
// JedisPool jedisPool=new JedisPool(config,"192.168.126.129",6379);
// //從池中獲取一個(gè)連接
// Jedis resource = jedisPool.getResource();
// 通過(guò)redis連接獲取數(shù)據(jù)
resource.set("class", "cgb2107");
String aClass = resource.get("class");
System.out.println(aClass);
//釋放資源
resource.close();//把連接還回去
JedisDataSource.getJedisPool().close();
}
}
package com.jt.redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/*單例模式創(chuàng)建連接池*/
public class JedisDataSource {
private static volatile JedisPool jedisPool;
private static final String HOST="192.168.126.129";//將來(lái)寫(xiě)到配置中心
private static final Integer PORT=6379;
//餓漢式
static {
JedisPoolConfig jedisPoolConfig=new JedisPoolConfig();
jedisPoolConfig.setMaxTotal(16);
jedisPoolConfig.setMaxIdle(60);
jedisPool=new JedisPool(jedisPoolConfig,HOST,PORT);
}
public static Jedis getConnection(){
return jedisPool.getResource();
}
public static JedisPool getJedisPool(){
return jedisPool;
}
//懶漢式
public static Jedis getConnection2(){
if(jedisPool==null){
synchronized (JedisDataSource.class){
if(jedisPool==null){
JedisPoolConfig jedisPoolConfig=new JedisPoolConfig();
jedisPoolConfig.setMaxTotal(16);
jedisPoolConfig.setMaxIdle(60);
jedisPool=new JedisPool(jedisPoolConfig,HOST,PORT);
// return jedisPool.getResource();
}
}
}
return jedisPool.getResource();
}
}
拓展：volatile關(guān)鍵字
- 用來(lái)修飾屬性、保證緩存一致性，但是不安全
- 1.保證其線程可見(jiàn)性 一個(gè)線程改了值，其他線程立刻可見(jiàn)
- 2.不能保證其原子性 不保證線程安全 不保證原子性
- 3.禁止指令重排序（例如count++…）
- 加鎖synchronized可以保證原子性
- 在多線程的環(huán)境下會(huì)出現(xiàn)指令重排序的問(wèn)題
6. 項(xiàng)目工程實(shí)踐
6.1 分布式id
在分布式系統(tǒng)中，數(shù)據(jù)量將越來(lái)越大時(shí)，就需要對(duì)數(shù)據(jù)進(jìn)行分表操作,但是,分表后，每個(gè)表中的數(shù)據(jù)都會(huì)按自己的節(jié)奏進(jìn)行自增，很有可能出現(xiàn)ID沖突。這時(shí)就需要一個(gè)單獨(dú)的機(jī)制來(lái)負(fù)責(zé)生成唯一ID，生成出來(lái)的ID也可以叫做 分布式ID
package com.jt.redis;
import redis.clients.jedis.Jedis;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class IdGeneratorDemo1 {
public static Long getId(){
// Jedis jedis=new Jedis("192.168.126.129",6379);
Jedis jedis=JedisDataSource.getConnection();
Long id = jedis.incr("id");
jedis.close();
return id;
}
public static void main(String[] args) {
//構(gòu)建最多只有3個(gè)線程的線程池
ExecutorService es= Executors.newFixedThreadPool(3);
for(int i=1;i<=10;i++){
//從池中取線程執(zhí)行任務(wù)
es.execute(new Runnable() {//這個(gè)任務(wù)會(huì)存儲(chǔ)到阻塞式任務(wù)隊(duì)列中 阻塞隊(duì)列.
@Override
public void run() {
System.out.println(getId());
}
});
}
}
}
6.2 單點(diǎn)登陸
package com.jt.redis;
/*基于reids的單點(diǎn)登錄設(shè)計(jì)和實(shí)現(xiàn)
* 1.用戶登陸成功后將登錄信息存儲(chǔ)到redis
* 2.用戶攜帶token訪問(wèn)資源，資源服務(wù)器基于token從reidis查詢用戶信息
* */
import redis.clients.jedis.Jedis;
import java.util.UUID;
public class SSODemo01 {
static String token;
static Object doResource(String token){
//校驗(yàn)token是否為空
if(token==null){
throw new RuntimeException("請(qǐng)先登錄");
}
//基于token查詢r(jià)edis數(shù)據(jù),假如有對(duì)應(yīng)數(shù)據(jù)說(shuō)明用戶登錄了
Jedis jedis=JedisDataSource.getConnection();
String username = jedis.hget(token,"username");
if(username==null){
throw new RuntimeException("登錄超時(shí)，請(qǐng)重新登錄");
}
String permission = jedis.hget(token,"permission");
jedis.close();
if(!"sys-jedis-create".equals(permission)){
throw new RuntimeException("你沒(méi)有權(quán)限訪問(wèn)");
}
return permission;
}
//執(zhí)行登錄認(rèn)證、這樣的業(yè)務(wù)寫(xiě)到認(rèn)證服務(wù)器
static String doLoginin(String username,String password){
//1.校驗(yàn)數(shù)據(jù)的合法性（判定用戶名、密碼是否為空、密碼長(zhǎng)度...）
if(username==null||"".equals(username)) {
throw new RuntimeException("請(qǐng)輸入用戶名");
}
if(password==null||"".equals(password)) {
throw new RuntimeException("請(qǐng)輸入密碼");
}
//2.基于用戶名查詢用戶信息，并判定密碼是否正確
if(!"jack".equals(username)){
throw new RuntimeException("用戶不存在");
}
if(!"123456".equals(password)){
throw new RuntimeException("密碼不正確");
}
//3.用戶存在且密碼正確，將用戶信息寫(xiě)入到redis
Jedis jedis=JedisDataSource.getConnection();
String token= UUID.randomUUID().toString();
jedis.hset(token,"username",username);
jedis.hset(token,"permission","sys-jedis-create");
jedis.close();
//4.將token信息返回給客戶端
return token;
}
public static void main(String[] args) {
//1.登陸操作（用戶身份認(rèn)證）
token = SSODemo01.doLoginin("jack", "123456");
System.out.println(token);
//2.攜帶token訪問(wèn)資源服務(wù)器
Object o = doResource(token);
System.out.println(o);
}
}
6.3 投票系統(tǒng)
package com.jt.redis;
import redis.clients.jedis.Jedis;
import javax.swing.text.html.HTMLEditorKit;
import java.util.Set;
/*基于某個(gè)活動(dòng)的簡(jiǎn)易投票系統(tǒng)設(shè)計(jì)
* 1.投票數(shù)據(jù)存儲(chǔ)到redis（key為活動(dòng)id，多個(gè)用戶id的集合）
* 2.一個(gè)用戶不能執(zhí)行多次投票
* 3.具體業(yè)務(wù)操作（投票，獲取總票數(shù)，檢查是否投票過(guò)，取消投票，獲取哪些人參與了投票）
* */
public class VoteDemo01 {
//指定活動(dòng)投票總數(shù)
static Long getCount(String activiryId ){
//1.建立連接
Jedis jedis=new Jedis("192.168.126.129",6379);
Long scard = jedis.scard(activiryId);
return scard;
}
//獲取哪些人參與活動(dòng)投票
static Object doGetMembers(String activiryId){
//1.建立連接
Jedis jedis=new Jedis("192.168.126.129",6379);
Set<String> smembers = jedis.smembers(activiryId);
return smembers;
}
//投票操作
static void doVote(String activiryId,String userId){
//1.建立連接
Jedis jedis=new Jedis("192.168.126.129",6379);
//2.執(zhí)行投票
Boolean flag = jedis.sismember(activiryId, userId);
if(flag){
//投票過(guò)了再點(diǎn)就取消投票
jedis.srem(activiryId,userId);
System.out.println("取消投票");
}else {
//沒(méi)投過(guò)票
jedis.sadd(activiryId,userId);
System.out.println("投票成功");
}
//3.釋放資源
jedis.close();
}
public static void main(String[] args) {
String activiryId="101";
String userId="1";
String userId1="2";
String userId2="3";
doVote(activiryId,userId);
doVote(activiryId,userId1);
doVote(activiryId,userId2);
Long count = getCount(activiryId);
System.out.println(count);
Object o = doGetMembers(activiryId);
System.out.println(o);
}
}
實(shí)現(xiàn)效果
7. StringRedisTemplate 應(yīng)用
7.1 修改yml文件
7.2 創(chuàng)建啟動(dòng)類(lèi)
package com.jt;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.core.StringRedisTemplate;
@SpringBootTest
public class StringRedisTemplateTests {
@Autowired/*此對(duì)象可以實(shí)現(xiàn)與redis數(shù)據(jù)庫(kù)的交互，存取數(shù)據(jù)的特點(diǎn)
會(huì)以字符串序列化的方式存儲(chǔ)key/value
序列化/反序列化
狹義：序列化：1.將對(duì)象轉(zhuǎn)化為字節(jié) ；反序列化：將字節(jié)轉(zhuǎn)化為對(duì)象
廣義：序列化：對(duì)象→json式字符串或字節(jié) 反序列化：將字符串/字節(jié)→對(duì)象
*/
private StringRedisTemplate redisTemplate;
@Test
void testGetConnection(){
RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
String ping = connection.ping();
System.out.println(ping);
}
}
==StringRedisTemplate==
此對(duì)象可以實(shí)現(xiàn)與redis數(shù)據(jù)庫(kù)的交互，存取數(shù)據(jù)的特點(diǎn)
會(huì)以字符串序列化的方式存儲(chǔ)key/value
序列化/反序列化
狹義：序列化：1.將對(duì)象轉(zhuǎn)化為字節(jié) ；反序列化：將字節(jié)轉(zhuǎn)化為對(duì)象
廣義：序列化：對(duì)象→json式字符串或字節(jié) 反序列化：將字符串/字節(jié)→對(duì)象
實(shí)現(xiàn)效果
7.3 測(cè)試字符串讀寫(xiě)
@Test//測(cè)試字符串讀寫(xiě)
void testString01(){
//獲取字符串對(duì)象
ValueOperations<String, String> vo = redisTemplate.opsForValue();
//2.讀寫(xiě)rerdis數(shù)據(jù)
vo.set("name", "redis");
vo.set("author", "tony", Duration.ofSeconds(10));
String name = vo.get("name");
System.out.println(name);
String author = vo.get("author");
System.out.println(author);
}
拓展：lettuce
7.4 Hash類(lèi)型讀寫(xiě)
@Test//測(cè)試字符串讀寫(xiě)
void testHash(){
//獲取hash對(duì)象
HashOperations<String, Object, Object> vo = redisTemplate.opsForHash();
//2.讀寫(xiě)rerdis數(shù)據(jù)
vo.put("blog", "id", "100");
vo.put("blog", "time", new Date().toString());
Object o = vo.get("blog", "id");
System.out.println(o);
}
8. RedisTemplate 應(yīng)用
RedisTemplate是StringRedisTemplate 的父類(lèi)
默認(rèn)采用JDK的序列化、反序列化方式存取數(shù)據(jù)
package com.jt;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import java.time.Duration;
@SpringBootTest
public class RedisTemplateTests {
@Autowired
private RedisTemplate redisTemplate;
@Test
void testString01(){
//1.獲取字符串對(duì)象
ValueOperations<String, String> vo = redisTemplate.opsForValue();
//2.讀寫(xiě)rerdis數(shù)據(jù)
vo.set("name", "redis");
vo.set("author", "tony", Duration.ofSeconds(10));
String name = vo.get("name");
System.out.println(name);
String author = vo.get("author");
System.out.println(author);
}
}
修改序列化方式
redisTemplate.setKeySerializer(RedisSerializer.string());
總結(jié)
- 為什么使用redis連接池？每次創(chuàng)建連接比較耗時(shí)，最好創(chuàng)建后能重復(fù)使用
- 連接池設(shè)計(jì)使用享元模式
- volatile 單線程沒(méi)必要
到此這篇關(guān)于Java中如何操作Redis的文章就介紹到這了,更多相關(guān)Java操作Redis內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Java 保留字列表 (依字母排序 共14組) : Java保留字是指現(xiàn)有Java版本尚未使用 但以后版本可能會(huì)作為關(guān)鍵字使用2012-10-10
Spring Security使用單點(diǎn)登錄的權(quán)限功能
本文主要介紹了Spring Security使用單點(diǎn)登錄的權(quán)限功能，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-04-04
Springboot+Shiro記錄用戶登錄信息并獲取當(dāng)前登錄用戶信息的實(shí)現(xiàn)代碼
這篇文章主要介紹了Springboot+Shiro記錄用戶登錄信息，并獲取當(dāng)前登錄用戶信息,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-05-05
解決SpringBoot整合ElasticSearch遇到的連接問(wèn)題
這篇文章主要介紹了解決SpringBoot整合ElasticSearch遇到的連接問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-08-08
java 非對(duì)稱(chēng)加密算法DH實(shí)現(xiàn)詳解
這篇文章主要介紹了java 非對(duì)稱(chēng)加密算法DH實(shí)現(xiàn)詳解 ,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-07-07
MyBatis-Plus動(dòng)態(tài)表名的使用
本文主要介紹了MyBatis-Plus動(dòng)態(tài)表名的使用，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04
Java基于Runtime調(diào)用外部程序出現(xiàn)阻塞的解決方法
這篇文章主要介紹了Java基于Runtime調(diào)用外部程序出現(xiàn)阻塞的解決方法,是一個(gè)非常實(shí)用的技巧,需要的朋友可以參考下2014-09-09
這篇文章主要介紹了MapStruct解了對(duì)象映射的毒，對(duì)MapStruct感興趣的同學(xué)，可以參考下2021-04-04
windows 32位eclipse遠(yuǎn)程hadoop開(kāi)發(fā)環(huán)境搭建
這篇文章主要介紹了windows 32位eclipse遠(yuǎn)程hadoop開(kāi)發(fā)環(huán)境搭建的相關(guān)資料,需要的朋友可以參考下2016-07-07
一文教你利用Stream?API批量Mock數(shù)據(jù)的方法
在日常開(kāi)發(fā)的過(guò)程中我們經(jīng)常會(huì)遇到需要mock一些數(shù)據(jù)的場(chǎng)景，比如說(shuō)?mock?一些接口的返回或者說(shuō)?mock?一些測(cè)試消息用于隊(duì)列生產(chǎn)者發(fā)送消息。本文將教你如何通過(guò)?Stream?API?批量?Mock?數(shù)據(jù)，需要的可以參考一下2022-09-09