無(wú)德之人常嫉他人之有德。——培根

(相關(guān)資料圖)

1.redis回調(diào)

1.概念

Redis是一種高性能的內(nèi)存數(shù)據(jù)存儲(chǔ)系統(tǒng)，它支持多種數(shù)據(jù)結(jié)構(gòu)和靈活的操作。除了提供常規(guī)的鍵值存儲(chǔ)功能外，Redis還支持訂閱/發(fā)布、事務(wù)、Lua腳本等高級(jí)功能，其中回調(diào)函數(shù)是Redis的一個(gè)重要特性之一。

回調(diào)函數(shù)是一種在特定事件發(fā)生時(shí)自動(dòng)執(zhí)行的函數(shù)。在Redis中，回調(diào)函數(shù)通常用于在特定事件發(fā)生時(shí)自動(dòng)執(zhí)行一些操作。這些事件包括：

通過(guò)使用回調(diào)函數(shù)，我們可以在這些事件發(fā)生時(shí)執(zhí)行一些自定義的邏輯，從而實(shí)現(xiàn)更加靈活和復(fù)雜的應(yīng)用程序。

2.腳本配置文件

在Redis中，回調(diào)函數(shù)通常是通過(guò)在配置文件中定義來(lái)注冊(cè)的。下面是一個(gè)示例配置文件，其中包含了一些回調(diào)函數(shù)的定義：

bashCopy code# Sample Redis configuration file?# Register a callback function to execute when a client connectsclient-connect-callback /path/to/client-connect-script.sh?# Register a callback function to execute when a client disconnectsclient-disconnect-callback /path/to/client-disconnect-script.sh?# Register a callback function to execute when a key expireskeyspace-event-notification expired /path/to/key-expire-script.sh?# Register a callback function to execute when a message is published to a channelnotify-keyspace-events KEA /path/to/pubsub-script.sh

在上面的示例中，我們注冊(cè)了四個(gè)回調(diào)函數(shù)。第一個(gè)回調(diào)函數(shù)在客戶端連接時(shí)執(zhí)行，第二個(gè)在客戶端斷開連接時(shí)執(zhí)行，第三個(gè)在鍵過(guò)期時(shí)執(zhí)行，第四個(gè)在消息發(fā)布時(shí)執(zhí)行。

要使用回調(diào)函數(shù)，我們需要編寫相應(yīng)的腳本。腳本可以是任何可執(zhí)行文件，如Bash腳本、Python腳本等等。下面是一個(gè)示例Bash腳本，用于在客戶端連接時(shí)打印一條消息：

bashCopy code#!/bin/bash?echo "A client has connected"

在上面的腳本中，我們使用了echo命令來(lái)輸出一條消息。當(dāng)客戶端連接時(shí)，Redis會(huì)自動(dòng)執(zhí)行這個(gè)腳本，并將消息輸出到控制臺(tái)。

3.概念總結(jié)

在編寫回調(diào)函數(shù)時(shí)，我們還需要考慮一些安全問(wèn)題。由于回調(diào)函數(shù)通常是在Redis進(jìn)程的上下文中執(zhí)行的，因此我們需要確保腳本不會(huì)執(zhí)行任何危險(xiǎn)操作，如刪除文件或執(zhí)行系統(tǒng)命令等等。為了確保安全性，我們可以使用一些技術(shù)，如沙盒化或限制腳本執(zhí)行權(quán)限等等。

總之，回調(diào)函數(shù)是Redis的一個(gè)非常有用的特性，它可以讓我們?cè)谔囟ㄊ录l(fā)生時(shí)自動(dòng)執(zhí)行一些操作，從而實(shí)現(xiàn)更加靈活和復(fù)雜的應(yīng)用程序。如果您正在使用Redis，并且想要了解更多關(guān)于回調(diào)函數(shù)的內(nèi)容，可以看Redis官方文檔。

2.場(chǎng)景需求

1.需求

例如：京東購(gòu)物車結(jié)算，在用戶進(jìn)行結(jié)算的時(shí)候，支付時(shí)間為30分鐘，用戶未在30分鐘之內(nèi)支付，則需要進(jìn)入待支付狀態(tài)。

3.實(shí)現(xiàn)方案

咱們可以采用redis ，key有效期回調(diào)事件實(shí)現(xiàn)，為每筆支付的訂單設(shè)置有限期為30分鐘，在當(dāng)前key失效的時(shí)候，redis進(jìn)行回調(diào)。

4.redis配置

首先找到redis.conf配置文件，如果你跟我一樣使用mac包管理工具brew安裝的。

找到homebrew.mxcl.redis.plist文件

打開之后就可以看到redis.conf的文件地址了。

打開配置文件之后找到notify-keyspace-events ""，然后設(shè)置成notify-keyspace-events "Ex"

notify-keyspace-events 的參數(shù)可以是以下字符的任意組合，它指定了服務(wù)器該發(fā)送哪些類型的通知：

5.代碼實(shí)現(xiàn)

首先發(fā)送一條普通消息，設(shè)置過(guò)期時(shí)間。

@ApiOperation(value = "測(cè)試redis回調(diào)")    @SaCheckLogin    @PostMapping("/test")    public ApiResponse testTask(){        redisUtil.set("FILE:userInfo","我是一條消息，來(lái)測(cè)試是否進(jìn)入回調(diào)",60);        return ApiResponse.ok();    }

添加RedisListenerConfig回調(diào)配置類

@Slf4j@Configurationpublic class RedisListenerConfig {?    @Bean    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {        RedisMessageListenerContainer container = new RedisMessageListenerContainer();        container.setConnectionFactory(connectionFactory);        return container;    }?    @Component    public static class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {        public RedisKeyExpirationListener(RedisMessageListenerContainer container) {            super(container);        }        @Override        public void onMessage(Message message, byte[] pattern) {            final String keyInfo = "FILE:userInfo";            String key = message.toString();            log.info("redis失效進(jìn)入回調(diào)函數(shù)攜帶key:{}", key);            if (key != null && key.startsWith(keyInfo)) {                log.info("需要特殊處理的key,進(jìn)行業(yè)務(wù)處理");            }        }    }}

6.測(cè)試結(jié)果

關(guān)鍵詞