Java中如何操作Redis

這篇文章主要為大家展示了“Java中如何操作Redis”，內(nèi)容簡(jiǎn)而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“Java中如何操作Redis”這篇文章吧。

1.準(zhǔn)備操作

 1.1 新建工程

1.2 sca-jedis工程依賴

  <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工程依賴

 <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讀寫操作
        //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ì)思想，通過池減少對(duì)象的創(chuàng)建次數(shù)，實(shí)現(xiàn)對(duì)象的可重用性，所有池的設(shè)計(jì)都有這個(gè)設(shè)計(jì)模式的應(yīng)用
=例如整數(shù)池、字符串池、線程池、連接池

• AOP 代理模式

• Singleton 單例 HikariPool

• xxxAdapter 適配器模式

• Ribbon 策略

• RestTemplate 模板方法模式

• SL4J 門面

• 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ì)思想，通過池減少對(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();
        //通過redis連接獲取數(shù)據(jù)
        resource.set("class", "cgb2107");
        String aClass = resource.get("class");
        System.out.println(aClass);
        //釋放資源
        resource.close();//把連接還回去
        jedisPool.close();
    }
}

連接池配置也可以不寫，因?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ì)思想，通過池減少對(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 門面
* Interceptor 執(zhí)行鏈模式
* 工廠模式
* */
public class JedisPoolTests {
    @Test
    public void testJedisPool(){
        //單例模式創(chuàng)建連接池
        Jedis resource = JedisDataSource.getConnection2();
//        //定義連接池配置 可不寫，有默認(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();
//        通過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";//將來寫到配置中心
    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)鍵字

•  用來修飾屬性、保證緩存一致性，但是不安全

• 1.保證其線程可見性 一個(gè)線程改了值，其他線程立刻可見

• 2.不能保證其原子性 不保證線程安全 不保證原子性

• 3.禁止指令重排序（例如count++…）

• 加鎖synchronized可以保證原子性

• 在多線程的環(huán)境下會(huì)出現(xiàn)指令重排序的問題

6. 項(xiàng)目工程實(shí)踐

6.1 分布式id

在分布式系統(tǒng)中，數(shù)據(jù)量將越來越大時(shí)，就需要對(duì)數(shù)據(jù)進(jìn)行分表操作,但是,分表后，每個(gè)表中的數(shù)據(jù)都會(huì)按自己的節(jié)奏進(jìn)行自增，很有可能出現(xiàn)ID沖突。這時(shí)就需要一個(gè)單獨(dú)的機(jī)制來負(fù)責(zé)生成唯一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) {
        //構(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ù)器基于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ù)說明用戶登錄了
        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("你沒有權(quán)限訪問");
        }
        return permission;
    }

    //執(zhí)行登錄認(rèn)證、這樣的業(yè)務(wù)寫到認(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.用戶存在且密碼正確，將用戶信息寫入到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ù)器
        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ù)，檢查是否投票過，取消投票，獲取哪些人參與了投票）
* */
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){
            //投票過了再點(diǎn)就取消投票
            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);
    }
}

實(shí)現(xiàn)效果

7. StringRedisTemplate 應(yīng)用

 7.1 修改yml文件

7.2 創(chuàng)建啟動(dòng)類

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è)試字符串讀寫

@Test//測(cè)試字符串讀寫
    void testString01(){
        //獲取字符串對(duì)象
        ValueOperations<String, String> vo = redisTemplate.opsForValue();
        //2.讀寫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類型讀寫

@Test//測(cè)試字符串讀寫
    void testHash(){
        //獲取hash對(duì)象
        HashOperations<String, Object, Object> vo = redisTemplate.opsForHash();
        //2.讀寫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 的父類
默認(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.讀寫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());

以上是“Java中如何操作Redis”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道！