springboot2.x整合redis的單機模式

maven依賴

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.6.RELEASE</version>
    <relativePath/> <!-- lookup parent from repository -->
  </parent>
  <groupId>com.ls</groupId>
  <artifactId>demo-redis</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <name>demo-redis</name>
  <description>Demo project for Spring Boot</description>

  <properties>
    <java.version>1.8</java.version>
    <jackson.version>2.9.8</jackson.version>
  </properties>

  <dependencies>
    <!--redis-->
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    <dependency>
      <groupId>org.apache.commons</groupId>
      <artifactId>commons-pool2</artifactId>
    </dependency>
    <dependency>
      <groupId>redis.clients</groupId>
      <artifactId>jedis</artifactId>
    </dependency>

    <!--jackson序列化-->
    <dependency>
      <groupId>com.fasterxml.jackson.core</groupId>
      <artifactId>jackson-core</artifactId>
      <version>${jackson.version}</version>
    </dependency>
    <dependency>
      <groupId>com.fasterxml.jackson.core</groupId>
      <artifactId>jackson-databind</artifactId>
      <version>${jackson.version}</version>
    </dependency>

    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>

  </dependencies>

  <build>
    <plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>

</project>


           

配置檔案:application.properties

#配置Redis
spring.redis.database=0
spring.redis.host=192.168.221.138
spring.redis.port=7000
#連接配接逾時時間（毫秒）
spring.redis.timeout=10000

           

RedisCacheConfig配置

包含釋出訂閱模式的配置

package com.ls.config;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.ls.constant.MessageConstant;
import com.ls.listen.MessageReceiverSupport;
import java.time.Duration;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.jedis.JedisClientConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

/**
 * Created by ls on 2021/6/26.
 *
 * @desc:
 */

@Configuration
public class RedisCacheConfig {
  @Value("${spring.redis.host}")
  private String host;
  @Value("${spring.redis.port}")
  private int port;

  @Value("${spring.redis.timeout}")
  private int timeout ;


  /** 配置JedisConnectionFactory*/
  @Bean
  public RedisConnectionFactory redisConnectionFactory(){
    RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration(host,port);
    JedisClientConfiguration.JedisClientConfigurationBuilder jedisClientConfiguration = JedisClientConfiguration.builder();
    jedisClientConfiguration.connectTimeout(Duration.ofMillis(timeout));//  connection timeout
    RedisConnectionFactory redisConnectionFactory = new JedisConnectionFactory(redisStandaloneConfiguration,
        jedisClientConfiguration.build());

    return redisConnectionFactory;
  }
  /** SpringBoot自定義配置RedisTemplate*/
  @Bean
  public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
    RedisTemplate<String, Object> template=new RedisTemplate<>();
    template.setConnectionFactory(redisConnectionFactory);
    // 使用Jackson2JsonRedisSerialize 替換預設序列化
    Jackson2JsonRedisSerializer jackson2JsonRedisSerializer=new Jackson2JsonRedisSerializer(Object.class);
    ObjectMapper mapper=new ObjectMapper();
    mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
    mapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
    jackson2JsonRedisSerializer.setObjectMapper(mapper);
    // 設定value的序列化規則和 key的序列化規則
    template.setValueSerializer(jackson2JsonRedisSerializer);
    template.setKeySerializer(new StringRedisSerializer());
    template.setHashKeySerializer(new StringRedisSerializer());
    template.afterPropertiesSet();
    return  template;
  }

  /**
   * Redis消息監聽器容器
   * 這個容器加載了RedisConnectionFactory和消息監聽器
   * 可以添加多個監聽不同話題的redis監聽器，隻需要把消息監聽器和相應的消息訂閱處理器綁定，該消息監聽器
   * 通過反射技術調用消息訂閱處理器的相關方法進行一些業務處理
   * @param redisConnectionFactory 連結工廠
   * @param adapter 擴充卡
   * @return redis消息監聽容器
   */
  @Bean
  public RedisMessageListenerContainer container(RedisConnectionFactory redisConnectionFactory,
      MessageListenerAdapter adapter) {
    RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    container.setConnectionFactory(redisConnectionFactory);
    //可以添加多個 messageListener
    container.addMessageListener(adapter, new PatternTopic(MessageConstant.AUDIT_LOG_CHANNEL));
    return container;
  }


  /**
   * 消息監聽器擴充卡，綁定消息處理器，利用反射技術調用消息處理器的業務方法
   * 将MessageReceiver注冊為一個消息監聽器，可以自定義消息接收的方法（handleMessage）
   * 如果不指定消息接收的方法，消息監聽器會預設的尋找MessageReceiver中的onMessage這個方法作為消息接收的方法
   * @param messageReceiver 消息接受
   * @return 擴充卡
   */
  @Bean
  public MessageListenerAdapter adapter(MessageReceiverSupport messageReceiver) {
    return new MessageListenerAdapter(messageReceiver, "onMessage");
  }



}