快捷導(dǎo)航

Redis Key過(guò)期監(jiān)聽(tīng)的配置詳解

更新時(shí)間：2024年06月11日 11:35:56 作者：hrui0706

這篇文章主要介紹了Redis Key過(guò)期監(jiān)聽(tīng)配置,默認(rèn)情況下在Windows系統(tǒng)中雙擊redis-server.exe用的是內(nèi)置的配置文件,文中通過(guò)代碼示例和圖文講解的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下

默認(rèn)情況下在Windows系統(tǒng)中雙擊redis-server.exe用的是內(nèi)置的配置文件

如果希望用這兩個(gè)配置文件

redis.windows.conf：這是用于在Windows上運(yùn)行Redis服務(wù)器的標(biāo)準(zhǔn)配置文件?？梢允褂眠@個(gè)文件通過(guò)命令行啟動(dòng)Redis服務(wù)器。
redis.windows-service.conf：這是專(zhuān)門(mén)為在Windows服務(wù)中運(yùn)行Redis設(shè)計(jì)的配置文件?？梢允褂眠@個(gè)文件將Redis作為Windows服務(wù)來(lái)運(yùn)行。

Window安裝Redis為服務(wù)并設(shè)置開(kāi)機(jī)自啟

在redis安裝目錄下管理員運(yùn)行cmd

redis-server --service-install redis.windows.conf --service-name redis

net start redis //開(kāi)機(jī)自啟

修改redis的配置文件

@Configuration
public class RedisConfig2 {
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
                                            MessageListenerAdapter listenerAdapter) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        // 訂閱鍵過(guò)期事件
        container.addMessageListener(listenerAdapter, new ChannelTopic("__keyevent@0__:expired"));
        return container;
    }
 
    @Bean
    MessageListenerAdapter listenerAdapter(RedisKeyExpiredListener listener) {
        return new MessageListenerAdapter(listener);
    }
}

@Component
public class RedisKeyExpiredListener implements MessageListener {
 
    @Autowired
    private ITReportTimesService tReportTimesService;
 
    @Override
    public void onMessage(Message message, byte[] pattern) {
        String expiredKey = message.toString();
        if (expiredKey.startsWith("sleep:decibels:")) {//只處理該key過(guò)期刪除時(shí)間
            Long userId = Long.valueOf(expiredKey.split(":")[2]);
            // 處理非正常關(guān)機(jī)導(dǎo)致的睡眠結(jié)束邏輯
            handleUnexpectedShutdown(userId);
        }
    }
 
    private void handleUnexpectedShutdown(Long userId) {
        // 處理睡眠監(jiān)測(cè)結(jié)束邏輯，例如記錄結(jié)束時(shí)間
        System.out.println("監(jiān)測(cè)到了@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@");
        //要處理的邏輯.......
    }
}

 @Autowired
    private RedisTemplate  redisTemplate;
 
    @GetMapping("/sleepTimes")//監(jiān)測(cè)時(shí)候每多少分鐘調(diào)用一次
    public AjaxResult sleepTimes(){
        LoginUser loginUser = getLoginUser();
        Long userId = loginUser.getUserId();
        // 往redis中記錄，延時(shí)30秒，通過(guò)Redis key過(guò)期監(jiān)聽(tīng)判斷用戶(hù)是否非正常關(guān)機(jī)
        String redisKey = "sleep:decibels:" + userId;
        //第一次會(huì)創(chuàng)建key和value  第二次調(diào)用會(huì)更新(覆蓋相同key)key和value
        redisTemplate.opsForValue().set(redisKey, "I am active", 60, TimeUnit.SECONDS);
        System.out.println("sleepTimes");
        return success();
    }

到此這篇關(guān)于Redis Key過(guò)期監(jiān)聽(tīng)的配置詳解的文章就介紹到這了,更多相關(guān)Redis Key過(guò)期監(jiān)聽(tīng)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: