溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要為大家展示了“Java中如何操作Redis”，內容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領大家一起研究并學習一下“Java中如何操作Redis”這篇文章吧。
<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>
<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>
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中設置了密碼
String ping = jedis.ping();
System.out.println(ping);
}
}測試結果
注意保持一致：
/usr/local/docker/redis01/conf/目錄下
修改配置文件之后需要重啟，然后再測試連接 拓展:設定編譯版本
@Test
public void testString01(){
//1.創建連接對象
Jedis jedis=new Jedis(ip,port);
//2.執行redis讀寫操作
//2.1想redis中存儲字符串數據
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對象轉換為json字符串
jedis.set("lession",jsonStr);
//2.2刪除數據
jedis.del("id");
//2.3獲取數據
String id=jedis.get("id");
jsonStr=jedis.get("lession");
System.out.println(id);
System.out.println(jsonStr);
//3.釋放資源
jedis.close();
}
==享元模式：==設計思想，通過池減少對象的創建次數，實現對象的可重用性，所有池的設計都有這個設計模式的應用
=例如整數池、字符串池、線程池、連接池
AOP 代理模式
Singleton 單例 HikariPool
xxxAdapter 適配器模式
Ribbon 策略
RestTemplate 模板方法模式
SL4J 門面
Interceptor 執行鏈模式
工廠模式
package com.jt;
import org.junit. Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/*享元模式：設計思想，通過池減少對象的創建次數，實現對象的可重用性，所有池的設計都有這個設計模式的應用
* 例如整數池、字符串池、線程池、連接池
* Jedis連接池（與redis數據庫的連接）
* */
public class JedisPoolTests {
@Test
public void testJedisPool(){
//定義連接池配置
JedisPoolConfig config=new JedisPoolConfig();
//最大連接數
config.setMaxTotal(1000);
//最大空閑時間
config.setMaxIdle(60);
//創建連接池
JedisPool jedisPool=new JedisPool(config,"192.168.126.129",6379);
//從池中獲取一個連接
Jedis resource = jedisPool.getResource();
//通過redis連接獲取數據
resource.set("class", "cgb2107");
String aClass = resource.get("class");
System.out.println(aClass);
//釋放資源
resource.close();//把連接還回去
jedisPool.close();
}
}連接池配置也可以不寫，因為有默認的
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;
/*享元模式：設計思想，通過池減少對象的創建次數，實現對象的可重用性，所有池的設計都有這個設計模式的應用
* 例如整數池、字符串池、線程池、連接池
* Jedis連接池（與redis數據庫的連接）
* AOP 代理模式
* Singleton 單例 HikariPool
* xxxAdapter 適配器模式
* Ribbon 策略
* RestTemplate 模板方法模式
* SL4J 門面
* Interceptor 執行鏈模式
* 工廠模式
* */
public class JedisPoolTests {
@Test
public void testJedisPool(){
//單例模式創建連接池
Jedis resource = JedisDataSource.getConnection2();
// //定義連接池配置 可不寫，有默認的
// JedisPoolConfig config=new JedisPoolConfig();
// //最大連接數
// config.setMaxTotal(1000);
// //最大空閑時間
// config.setMaxIdle(60);
// //創建連接池
// JedisPool jedisPool=new JedisPool(config,"192.168.126.129",6379);
// //從池中獲取一個連接
// Jedis resource = jedisPool.getResource();
// 通過redis連接獲取數據
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;
/*單例模式創建連接池*/
public class JedisDataSource {
private static volatile JedisPool jedisPool;
private static final String HOST="192.168.126.129";//將來寫到配置中心
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();
}
}用來修飾屬性、保證緩存一致性，但是不安全
1.保證其線程可見性 一個線程改了值，其他線程立刻可見
2.不能保證其原子性 不保證線程安全 不保證原子性
3.禁止指令重排序（例如count++…）
加鎖synchronized可以保證原子性
在多線程的環境下會出現指令重排序的問題
在分布式系統中，數據量將越來越大時，就需要對數據進行分表操作,但是,分表后，每個表中的數據都會按自己的節奏進行自增，很有可能出現ID沖突。這時就需要一個單獨的機制來負責生成唯一ID，生成出來的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) {
//構建最多只有3個線程的線程池
ExecutorService es= Executors.newFixedThreadPool(3);
for(int i=1;i<=10;i++){
//從池中取線程執行任務
es.execute(new Runnable() {//這個任務會存儲到阻塞式任務隊列中 阻塞隊列.
@Override
public void run() {
System.out.println(getId());
}
});
}
}
}package com.jt.redis; /*基于reids的單點登錄設計和實現 * 1.用戶登陸成功后將登錄信息存儲到redis * 2.用戶攜帶token訪問資源，資源服務器基于token從reidis查詢用戶信息 * */ import redis.clients.jedis.Jedis; import java.util.UUID; public class SSODemo01 { static String token; static Object doResource(String token){ //校驗token是否為空 if(token==null){ throw new RuntimeException("請先登錄"); } //基于token查詢redis數據,假如有對應數據說明用戶登錄了 Jedis jedis=JedisDataSource.getConnection(); String username = jedis.hget(token,"username"); if(username==null){ throw new RuntimeException("登錄超時，請重新登錄"); } String permission = jedis.hget(token,"permission"); jedis.close(); if(!"sys-jedis-create".equals(permission)){ throw new RuntimeException("你沒有權限訪問"); } return permission; } //執行登錄認證、這樣的業務寫到認證服務器 static String doLoginin(String username,String password){ //1.校驗數據的合法性（判定用戶名、密碼是否為空、密碼長度...） if(username==null||"".equals(username)) { throw new RuntimeException("請輸入用戶名"); } if(password==null||"".equals(password)) { throw new RuntimeException("請輸入密碼"); } //2.基于用戶名查詢用戶信息，并判定密碼是否正確 if(!"jack".equals(username)){ throw new RuntimeException("用戶不存在"); } if(!"123456".equals(password)){ throw new RuntimeException("密碼不正確"); } //3.用戶存在且密碼正確，將用戶信息寫入到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.登陸操作（用戶身份認證） token = SSODemo01.doLoginin("jack", "123456"); System.out.println(token); //2.攜帶token訪問資源服務器 Object o = doResource(token); System.out.println(o); } }
package com.jt.redis;
import redis.clients.jedis.Jedis;
import javax.swing.text.html.HTMLEditorKit;
import java.util.Set;
/*基于某個活動的簡易投票系統設計
* 1.投票數據存儲到redis（key為活動id，多個用戶id的集合）
* 2.一個用戶不能執行多次投票
* 3.具體業務操作（投票，獲取總票數，檢查是否投票過，取消投票，獲取哪些人參與了投票）
* */
public class VoteDemo01 {
//指定活動投票總數
static Long getCount(String activiryId ){
//1.建立連接
Jedis jedis=new Jedis("192.168.126.129",6379);
Long scard = jedis.scard(activiryId);
return scard;
}
//獲取哪些人參與活動投票
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.執行投票
Boolean flag = jedis.sismember(activiryId, userId);
if(flag){
//投票過了再點就取消投票
jedis.srem(activiryId,userId);
System.out.println("取消投票");
}else {
//沒投過票
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);
}
}實現效果
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/*此對象可以實現與redis數據庫的交互，存取數據的特點
會以字符串序列化的方式存儲key/value
序列化/反序列化
狹義：序列化：1.將對象轉化為字節 ；反序列化：將字節轉化為對象
廣義：序列化：對象→json式字符串或字節 反序列化：將字符串/字節→對象
*/
private StringRedisTemplate redisTemplate;
@Test
void testGetConnection(){
RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
String ping = connection.ping();
System.out.println(ping);
}
}==StringRedisTemplate==
此對象可以實現與redis數據庫的交互，存取數據的特點
會以字符串序列化的方式存儲key/value
序列化/反序列化
狹義：序列化：1.將對象轉化為字節 ；反序列化：將字節轉化為對象
廣義：序列化：對象→json式字符串或字節 反序列化：將字符串/字節→對象
實現效果
@Test//測試字符串讀寫
void testString01(){
//獲取字符串對象
ValueOperations<String, String> vo = redisTemplate.opsForValue();
//2.讀寫rerdis數據
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);
}@Test//測試字符串讀寫
void testHash(){
//獲取hash對象
HashOperations<String, Object, Object> vo = redisTemplate.opsForHash();
//2.讀寫rerdis數據
vo.put("blog", "id", "100");
vo.put("blog", "time", new Date().toString());
Object o = vo.get("blog", "id");
System.out.println(o);
}
RedisTemplate是StringRedisTemplate 的父類
默認采用JDK的序列化、反序列化方式存取數據
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.獲取字符串對象
ValueOperations<String, String> vo = redisTemplate.opsForValue();
//2.讀寫rerdis數據
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());
以上是“Java中如何操作Redis”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
