使用redission客户端操作redis
 

maven依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><version>2.2.8.RELEASE</version>
</dependency>
<dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.9.0</version><optional>true</optional>
</dependency>
<dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>3.9.0</version>
</dependency>

redis配置文件

#Redisson配置
singleServerConfig:address: "redis://127.0.0.1:6379"password: 123456clientName: nulldatabase: 0 #选择使用哪个数据库0~15idleConnectionTimeout: 10000pingTimeout: 30000connectTimeout: 10000timeout: 30000retryAttempts: 30retryInterval: 1500reconnectionTimeout: 3000failedAttempts: 30subscriptionsPerConnection: 5subscriptionConnectionMinimumIdleSize: 1subscriptionConnectionPoolSize: 50connectionMinimumIdleSize: 200connectionPoolSize: 2000dnsMonitoringInterval: 5000#dnsMonitoring: falsethreads: 2
nettyThreads: 2
codec:class: "org.redisson.client.codec.StringCodec"
transportMode: "NIO"

配置类文件主要有三个
 

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;import java.io.IOException;@Configuration
public class RedissonConfig {@Bean@Primarypublic RedissonClient redisson() throws IOException {// 本例子使用的是yaml格式的配置文件，读取使用Config.fromYAML，如果是Json文件，则使用Config.fromJSONConfig config = Config.fromYAML(RedissonConfig.class.getClassLoader().getResource("redisson-config.yml"));return Redisson.create(config);}
}

import org.redisson.api.RedissonClient;
import org.redisson.spring.data.connection.RedissonConnectionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;@Configuration
public class RedisListenerConfig {@Autowiredprivate RedissonClient redisson;@Beanpublic RedisMessageListenerContainer redisMessageListenerContainer(MessageListener listener) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(new RedissonConnectionFactory(redisson));// 添加 KeyExpirationListener 到监听器容器container.addMessageListener(listener, new PatternTopic("__keyevent@*:expired"));return container;}
}

import cn.hutool.core.collection.CollectionUtil;
import com.hs.customer.constant.RedisCacheKey;
import com.hs.customer.dao.TUserDAO;
import com.hs.customer.enums.RoleCodeType;
import com.hs.customer.pojo.dto.UserAllDTO;
import com.hs.customer.service.impl.RedisService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.stereotype.Component;import java.util.Arrays;
import java.util.List;@Component
@Slf4j
public class KeyExpirationListener implements MessageListener {@Overridepublic void onMessage(Message message, byte[] bytes) {String expiredKey = new String(message.getBody());log.info("onMessage --> redis 过期的key是：{}", expiredKey);try {} catch (Exception e) {e.printStackTrace();}}
}

*****需要修改redis的配置文件 notify-keyspace-events "Ex"