202107021

xiaoyong931011

2021-07-21 f79dd632f83167b3cd5ad01e2f7c494b92c834d3

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
package com.xzx.gc.listener; 
 
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.data.redis.core.RedisTemplate; 
import org.springframework.stereotype.Component; 
  
@Component 
@Slf4j 
public class RedisMessageListener implements MessageListener { 
  
  
    @Autowired 
    private RedisTemplate<String, String> redisTemplate; 
  
    @Override 
    public void onMessage(Message message, byte[] pattern) { 
        String str = (String) redisTemplate.getValueSerializer().deserialize(message.getBody()); 
        if(!str.startsWith("xzx:user:signNonce")) { 
            log.trace("REDIS键：{} 已过期", str); 
        } 
 
 
        // redisUtil.setex(Constants.REDIS_USER_KEY+"token:"+userInfoVo.getUserId(),token,TokenUtil.TIME); 
 
//        String key= Constants.REDIS_USER_KEY+"token:"; 
//        if(str.startsWith(key)){ 
//            String userId= StrUtil.subAfter(str,key,true); 
// 
//        } 
    } 
  
  
}