java 监听redis事件

第一步：利用RDM等redis连接工具查看相应事件，然后去网上搜索 一下，会有redis各种事件的说明，选择契合业务的事件；

 第二步：创建监听处理类；

package com.lechuang.auth.advice;

import com.lechuang.common.core.entity.LeChuangAuthUser;
import com.lechuang.common.core.entity.system.SystemUser;
import com.lechuang.common.core.utils.LeChuangUtil;
import com.lechuang.common.redis.service.RedisDBService;
import com.lechuang.common.redis.service.RedisService;
import lombok.RequiredArgsConstructor;
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.scheduling.annotation.Async;
import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
import org.springframework.security.core.userdetails.User;
import org.springframework.security.oauth2.common.DefaultOAuth2AccessToken;
import org.springframework.security.oauth2.provider.OAuth2Authentication;
import org.springframework.security.oauth2.provider.token.TokenStore;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

import javax.annotation.Resource;
import java.lang.reflect.Field;
import java.util.LinkedHashMap;

/**
 * 功能描述：Redis监听
 * 作者：唐泽齐
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class LiveRedisKeysExpireListener implements MessageListener {

    @Autowired
    private RedisDBService redisDBService;
    @Resource
    private TokenStore tokenStore;

    @Override
    public void onMessage(Message message, byte[] pattern) {
        Object o = redisDBService.getAndSet(9, "renewUser:" + message.toString(), null);
        if(!ObjectUtils.isEmpty(o)) {
            log.info("处理用户缓存信息更新："+message.toString());
            renewToken(o,message.toString());
        } else {
            redisDBService.del(9,"renewUser:" + message.toString());
        }
    }

    @Async
    void renewToken(Object o,String tokenKey) {
        try {
            SystemUser user = (SystemUser) o;
            OAuth2Authentication authentication = tokenStore.readAuthentication(tokenKey);
            UsernamePasswordAuthenticationToken token = (UsernamePasswordAuthenticationToken) authentication.getUserAuthentication();
            LinkedHashMap details = (LinkedHashMap) token.getDetails();
            LinkedHashMap principal = (LinkedHashMap) details.get("principal");

            LeChuangAuthUser authUser = (LeChuangAuthUser) token.getPrincipal();

            //更新username
            Field username = User.class.getDeclaredField("username");
            username.setAccessible(true);
            username.set(authUser,user.getUsername());
            //更新 avatar
            authUser.setAvatar(user.getAvatar());
            //将新凭证 写入 token
            DefaultOAuth2AccessToken oauthtoken = new DefaultOAuth2AccessToken(tokenKey);
            oauthtoken.setTokenType("Bearer");
            tokenStore.storeAccessToken(oauthtoken, authentication);
            redisDBService.del(9,"renewUser:"+tokenKey);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

第三步：将监听处理类加入项目环境配置中，伴随项目启动；

package com.lechuang.auth.advice;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;

import javax.annotation.Resource;

/**
 * 功能描述：Redis监听配置
 * 作者：唐泽齐
 */
@Configuration
public class RedisListenerConfig {

    @Resource
    private LiveRedisKeysExpireListener liveRedisKeysExpireListener;

    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(liveRedisKeysExpireListener, new PatternTopic("__keyevent@9__:expire"));
        return container;
    }

}