一：需要監聽過期的redis keys

     在redis.conf 裡新增 notify-keyspace-events "Ex" ，放到配置引數的最後。

二：不需要賬號密碼訪問

     改變redis.conf 裡的protected-mode 的屬性值為 no

三：去掉繫結的地址

    在redis.conf 裡登出掉 bind 127.0.0.1

./redis-service ../redis.conf &

pubsub配置：

@Configuration
@Import( value = ServiceApplication.class )
public class PubsubConfiguration  {

/*    @Autowired
    private RedisClient redisClient;*/

    @Bean
    MessageListenerAdapter messageListener() {
        return new MessageListenerAdapter( new RedisMessageListener() );
    }


    @Autowired
    @Bean
    public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory ) {

        final RedisMessageListenerContainer container =
                new RedisMessageListenerContainer();
        container.setConnectionFactory( connectionFactory );
        container.addMessageListener( messageListener(), new ChannelTopic( "
 
[email protected]__:expired" ) );

        return container;
    }

/*    @Bean
    public MessageListener listener() {
        return new RedisMessageListener();
    }*/
}

 springboot 啟動類

@SpringBootApplication
@ComponentScan
public class ServiceApplication implements CommandLineRunner {

    private static Logger logger = LoggerFactory.getLogger(ServiceApplication.class);

    @Override
    public void run(String... strings) throws Exception {

    }

    public static void main(String[] args) throws Exception {
        ApplicationContext ctx = SpringApplication.run(ServiceApplication.class, args);
        SpringContextUtil.setApplicationContext(ctx);
        logger.info("service start success .....");
    }

}
 

監聽類實現：

public class RedisMessageListener implements MessageListener {

    protected Logger logger = LoggerFactory.getLogger(RedisMessageListener.class);

    @Autowired
    private BookTableBo bookTableBo;
    @Autowired
    private CalledRecordBo calledRecordBo;

    @Autowired
    private MqService mqService;

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String key = message.toString();
        try {
            System.out.println( "Message received: " + message.toString() );
            logger.info( "Message received: " + message.toString() );
            if(StringUtils.isNotBlank(key) && key.startsWith(RedisUtils.TABLE_PREFIX)){
                String[] tKey = key.split("_");
                if(tKey.length==7){
                    String traceID = UUID.randomUUID().toString();
                    Integer groupID = Integer.parseInt(tKey[2]);
                    Integer shopID = Integer.parseInt(tKey[3]);
                    long mealDate = Long.parseLong(tKey[4]);
                    Integer mealTimeTypeID = Integer.parseInt(tKey[5]);
                    Integer tableID = Integer.parseInt(tKey[6]);
                    String redisKey = new StringBuilder()
                            .append(groupID)
                            .append("_")
                            .append(shopID)
                            .append("_")
                            .append(mealDate)
                            .append("_")
                            .append(mealTimeTypeID)
                            .toString();
                    if(null == bookTableBo){
                        bookTableBo =(BookTableBo)  SpringContextUtil.getBean("bookTableBo");
                    }
                    if(null == mqService){
                        mqService =(MqService)  SpringContextUtil.getBean("mqService");
                    }
                    DataSourceContextHolder.setDataSourceType(Constants.DB_ROUTEKEY_PREFIX_READ + groupID);
                    List<Integer> userableUnLockTables = bookTableBo.userableUnLockTable(groupID,
                            shopID,
                            tableID,
                            traceID,
                            redisKey,
                            mealDate,
                            mealTimeTypeID);

                    List<MealTimeTableStatusMqVO> mealTimeTableStatusMqBeans = new ArrayList<>();
                    for (Integer one:userableUnLockTables){
                        mealTimeTableStatusMqBeans.add(MqUtils.buildMealTimeTableStatusMqBean(one, OrderStatusEnum.FREE.getStatus(),0L,0L,0,"",0,"",0));
                    }
                    mqService.sendMessToShop(shopID, MqUtils.buildUnTakeUpTableMq(traceID,mealDate,mealTimeTypeID,mealTimeTableStatusMqBeans));
                    mqService.sendTableStatusChangeMq(groupID,shopID,mealDate,mealTimeTypeID,userableUnLockTables,null);
                }
            }
        }catch (Exception e){
            logger.error("handler expire key error"+key,e);
        }
    }
	}