如何自定義redis工具jar包供其他SpringBoot項(xiàng)目直接使用

更新時(shí)間：2021年03月09日 15:28:31 作者：ID_云澤

這篇文章主要介紹了如何自定義redis工具jar包供其他SpringBoot項(xiàng)目直接使用,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

注：(最終redis數(shù)據(jù)庫(kù)連接信息由使用者項(xiàng)目模塊配置提供)

一、Redis常用存儲(chǔ)操作實(shí)現(xiàn)（redis-util模塊，該module最后會(huì)打包成jar供其他服務(wù)使用）

1.引用相關(guān)依賴(lài)

<!-- 如果有繼承父級(jí)spring-boot-starter-parent，可不用添加版本號(hào) -->
<!-- Redis緩存 [start] -->
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-redis</artifactId>
			<version>2.3.0.RELEASE</version>
		</dependency>
<!-- Redis緩存 [end] -->

2.配置reids連接信息

注：由于此時(shí)還處于redis-util工具包開(kāi)發(fā)階段，所以reids的配置文件還是由自己的模塊來(lái)提供，后期打包成jar時(shí)，會(huì)清除redis-util工具包里的redis連接信息，然后由需要使用redis-util工具的服務(wù)模塊提供reids的連接信息；
在reids-util的application.properties里配置redis數(shù)據(jù)庫(kù)連接信息

#Redis服務(wù)器地址
spring.redis.host=127.0.0.1
#Redis服務(wù)器連接端口
spring.redis.port=6379
#Redis數(shù)據(jù)庫(kù)索引（默認(rèn)為0）
spring.redis.database=0

3.自定義序列化類(lèi)，將存儲(chǔ)在Redis的對(duì)象序列化為json格式

import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import java.io.Serializable;
@Configuration
@EnableAutoConfiguration
public class RedisConfig {
  @Bean
  public RedisTemplate<String, Serializable> redisTemplate(LettuceConnectionFactory redisConnectionFactory){
    RedisTemplate<String, Serializable> template = new RedisTemplate();
    template.setKeySerializer(new StringRedisSerializer());
    template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
    template.setHashKeySerializer(new StringRedisSerializer());
    template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
    template.setConnectionFactory(redisConnectionFactory);
    return template;
  }
}

4.開(kāi)發(fā)相應(yīng)的redis常用方法

package com.gh.redis.util;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Repository;
import org.springframework.util.CollectionUtils;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;
import java.util.concurrent.TimeUnit;

@Repository
public class RedisUtil {

  @Autowired
  RedisTemplate<String, Serializable> redisTemplate;  // key-value是對(duì)象的

  public RedisUtil(){

  }

  /**
   * 判斷是否存在key
   * @param key 主鍵
   * @return true或false
   */
  public boolean hasKey(String key) {
    return Boolean.TRUE.equals(redisTemplate.hasKey(key));
  }

  /**
   * 新增、修改Redis鍵值
   * @param key 主鍵
   * @param value 值
   */
  public void insertOrUpdate(String key, Serializable value) {
    redisTemplate.opsForValue().set(key, value);
  }

  /**
   * 新增、修改Redis鍵值,并設(shè)置有效時(shí)間（秒）
   * @param key 主鍵
   * @param value 值
   * @param seconds 有效時(shí)間（秒）
   */
  public void insertOrUpdateBySeconds(String key, Serializable value, long seconds) {
    redisTemplate.opsForValue().set(key, value, seconds, TimeUnit.SECONDS);
  }

  /**
   * 新增、修改Redis鍵值,并設(shè)置有效時(shí)間（分）
   * @param key 主鍵
   * @param value 值
   * @param minutes 有效時(shí)間（分）
   */
  public void insertOrUpdateByMinutes(String key, Serializable value, long minutes) {
    redisTemplate.opsForValue().set(key, value, minutes, TimeUnit.MINUTES);
  }

  /**
   * 新增、修改Redis鍵值,并設(shè)置有效時(shí)間（小時(shí)）
   * @param key 主鍵
   * @param value 值
   * @param hours 有效時(shí)間（小時(shí)）
   */
  public void insertOrUpdateByHours(String key, Serializable value, long hours) {
    this.redisTemplate.opsForValue().set(key, value, hours, TimeUnit.HOURS);
  }

  /**
   * 新增、修改Redis鍵值,并設(shè)置有效時(shí)間（天）
   * @param key 主鍵
   * @param value 值
   * @param days 有效時(shí)間（天）
   */
  public void insertOrUpdateByDays(String key, Serializable value, long days) {
    this.redisTemplate.opsForValue().set(key, value, days, TimeUnit.DAYS);
  }

  /**
   * 通過(guò)主鍵獲取值
   * @param key 主鍵
   * @return
   */
  public Object get(String key) {
    return redisTemplate.opsForValue().get(key);
  }

  /**
   * 獲取redis的所有key里包含pattern字符的key集
   * @param pattern 模糊查詢(xún)字符
   * @return
   */
  public Set<String> getPattern(String pattern) {
    return redisTemplate.keys("*" + pattern + "*");
  }

  /**
   * 刪除指定redis緩存
   * @param key 主鍵
   * @return
   */
  public boolean remove(String key) {
    return Boolean.TRUE.equals(redisTemplate.delete(key));
  }

  /**
   * 刪除指定的多個(gè)緩存
   * @param keys 主鍵1，主鍵2，...
   * @return 刪除主鍵數(shù)
   */
  public int removes(String... keys){
    int count = 0;
    List<String> deleteFails = new ArrayList<>();

    for (String key : keys) {
      if (Boolean.TRUE.equals(redisTemplate.delete(key))) {
        ++count;
      } else {
        deleteFails.add(key);
      }
    }

    if (!CollectionUtils.isEmpty(deleteFails)) {
      System.err.println("======> Redis緩存刪除失敗的key：" + deleteFails.toString());
    }
    return count;
  }

  /**
   * 刪除所有的鍵值對(duì)數(shù)據(jù)
   * @return 清除鍵值對(duì)數(shù)據(jù)量
   */
  public int removeAll(){
    Set<String> keys = redisTemplate.keys("*");
    Long delete = 0L;

    if (keys != null) {
      delete = redisTemplate.delete(keys);
    }

    return delete != null ? delete.intValue() : 0;
  }

}

5.工具包開(kāi)發(fā)完成，測(cè)試一下

import com.gh.common.toolsclass.ResultData;
import com.gh.redis.util.RedisUtil;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.Set;

@SpringBootTest
class RedisApplicationTests {

  @Autowired
  private RedisUtil redisUtil;

  @Test
  void test1() {
    ResultData resultData = new ResultData();
    resultData.setCode(0);
    resultData.setMessage("redis測(cè)試");
    resultData.setData("666666");
    redisUtil.insertOrUpdate("demo", resultData);
    System.err.println(redisUtil.hasKey("demo"));
    Object demo = redisUtil.get("demo");
    ResultData bo = (ResultData) demo;
    System.err.println(bo.toString());
  }

  @Test
  void test2() {
    Set<String> list = redisUtil.getPattern("l");
    for (String s: list) {
      System.err.println(s);
    }
  }
}

其中ResultData是自定義的一個(gè)用于返回信息的對(duì)象，可用其他對(duì)象替代，但是該對(duì)象需要實(shí)現(xiàn)Serializable接口（ResultData implements Serializable）

運(yùn)行test1：

在這里插入圖片描述

運(yùn)行test2：

在這里插入圖片描述

其他方法自行測(cè)試，這里不一一展示；

6.清除redis數(shù)據(jù)庫(kù)連接信息

自此redis-util工具包開(kāi)發(fā)完成，可供其他服務(wù)使用，最后清除redis-util模塊application.properties里的redis數(shù)據(jù)庫(kù)連接信息。之后的連接信息由使用者模塊提供，這樣才符合redis-util作為一個(gè)純工具包的定義。

二、創(chuàng)建一個(gè)consumer項(xiàng)目來(lái)引用redis-util工具包

1.在consumer項(xiàng)目的pom.xml中添加reids-utils的依賴(lài)

<!-- redis工具包 [start] -->
<dependency>
      <groupId>com.gh</groupId>
      <artifactId>redis-util</artifactId>
      <version>0.0.1-SNAPSHOT</version>
    </dependency>
<!-- redis工具包 [end] -->

pom如何引用自定義jar包依賴(lài)自行百度，如果在同一父工程模塊下，可直接這么引用。不在同一父工程，需要先將jar包放到maven倉(cāng)庫(kù)。

2.在consumer的application.properties配置文件里添加redis數(shù)據(jù)的連接信息

#Redis服務(wù)器地址
spring.redis.host=127.0.0.1
#Redis服務(wù)器連接端口
spring.redis.port=6379
#Redis數(shù)據(jù)庫(kù)索引（默認(rèn)為0）
spring.redis.database=0

3.測(cè)試在cunsumer里是否可以使用redis-util工具包的方法

package com.gh.consumer;

import com.gh.common.toolsclass.ResultData;
import com.gh.redis.util.RedisUtil;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
class ConsumerApplicationTests {

// 這里使用該構(gòu)造器注入的方式，因?yàn)槭褂米兞孔⑷?
  final RedisUtil redisUtil;

  @Autowired
  public ConsumerApplicationTests(RedisUtil redisUtil){
    this.redisUtil = redisUtil;
  }

  @Test
  void test1() {
    // 如果存在demo緩存，就刪除
    if (redisUtil.hasKey("demo")) {
      System.err.println(redisUtil.remove("demo"));
    }
    // 插入新的demo緩存
    ResultData resultData = new ResultData();
    resultData.setCode(0);
    resultData.setMessage("redis測(cè)試-2");
    resultData.setData("888888");
    redisUtil.insertOrUpdate("demo", resultData);
    Object demo = redisUtil.get("demo");
    ResultData bo = (ResultData) demo;
    System.err.println(bo.toString());
  }

  @Test
  void test2() {
    redisUtil.insertOrUpdate("test", "redis工具測(cè)試");
    System.err.println(redisUtil.get("test"));
  }

}

運(yùn)行test1，此時(shí)會(huì)發(fā)現(xiàn)控制臺(tái)提示找不到RedisUtil的bean

在這里插入圖片描述

4.在啟動(dòng)類(lèi)添加掃描

其他注解不用管，解決redis-util工具包bean掃描不到的問(wèn)題，只需要添加注解@ComponentScan(value = “com.gh.redis.*”)就好

package com.gh.consumer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
//import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.ComponentScans;
import org.springframework.scheduling.annotation.EnableScheduling;


//@EnableDiscoveryClient eureka開(kāi)啟發(fā)現(xiàn)服務(wù)功能
@EnableFeignClients(basePackages = "com.gh.consumer.feign")
//@ComponentScan(basePackages = "com.gh.consumer.*")
@ComponentScans(value = {
		@ComponentScan(value = "com.gh.consumer.*")
		,@ComponentScan(value = "com.gh.redis.*")
})
@EnableScheduling	// 開(kāi)啟定時(shí)任務(wù)功能
@SpringBootApplication
public class ConsumerApplication {

	public static void main(String[] args) {
		SpringApplication.run(ConsumerApplication.class, args);
	}
}

5.再次測(cè)試

在這里插入圖片描述

成功調(diào)用redis-utils工具包方法！

到此這篇關(guān)于如何自定義redis工具jar包供其他SpringBoot項(xiàng)目直接使用的文章就介紹到這了,更多相關(guān)redis工具jar包springboot使用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: