您的位置：首頁 >觀察 > 正文

環球報道:手把手帶你了解redis回調機制及代碼實現

來源：騰訊云時間：2023-03-10 22:14:54

無德之人常嫉他人之有德。——培根

(相關資料圖)

1.redis回調

1.概念

Redis是一種高性能的內存數據存儲系統，它支持多種數據結構和靈活的操作。除了提供常規的鍵值存儲功能外，Redis還支持訂閱/發布、事務、Lua腳本等高級功能，其中回調函數是Redis的一個重要特性之一。

回調函數是一種在特定事件發生時自動執行的函數。在Redis中，回調函數通常用于在特定事件發生時自動執行一些操作。這些事件包括：

客戶端連接/斷開連接數據庫鍵過期發布/訂閱消息

通過使用回調函數，我們可以在這些事件發生時執行一些自定義的邏輯，從而實現更加靈活和復雜的應用程序。

2.腳本配置文件

在Redis中，回調函數通常是通過在配置文件中定義來注冊的。下面是一個示例配置文件，其中包含了一些回調函數的定義：

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

在上面的示例中，我們注冊了四個回調函數。第一個回調函數在客戶端連接時執行，第二個在客戶端斷開連接時執行，第三個在鍵過期時執行，第四個在消息發布時執行。

要使用回調函數，我們需要編寫相應的腳本。腳本可以是任何可執行文件，如Bash腳本、Python腳本等等。下面是一個示例Bash腳本，用于在客戶端連接時打印一條消息：

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

在上面的腳本中，我們使用了echo命令來輸出一條消息。當客戶端連接時，Redis會自動執行這個腳本，并將消息輸出到控制臺。

3.概念總結

在編寫回調函數時，我們還需要考慮一些安全問題。由于回調函數通常是在Redis進程的上下文中執行的，因此我們需要確保腳本不會執行任何危險操作，如刪除文件或執行系統命令等等。為了確保安全性，我們可以使用一些技術，如沙盒化或限制腳本執行權限等等。

總之，回調函數是Redis的一個非常有用的特性，它可以讓我們在特定事件發生時自動執行一些操作，從而實現更加靈活和復雜的應用程序。如果您正在使用Redis，并且想要了解更多關于回調函數的內容，可以看Redis官方文檔。

2.場景需求

1.需求

例如：京東購物車結算，在用戶進行結算的時候，支付時間為30分鐘，用戶未在30分鐘之內支付，則需要進入待支付狀態。

3.實現方案

咱們可以采用redis ，key有效期回調事件實現，為每筆支付的訂單設置有限期為30分鐘，在當前key失效的時候，redis進行回調。

4.redis配置

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

找到homebrew.mxcl.redis.plist文件

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

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

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

字符	發送的通知
K	鍵空間通知，所有通知以__keyspace@__ 為前綴
E	鍵事件通知，所有通知以 __keyevent@__ 為前綴
g	DEL 、 EXPIRE 、 RENAME 等類型無關的通用命令的通知
$	字符串命令的通知
l	列表命令的通知
s	集合命令的通知
h	哈希命令的通知
z	有序集合命令的通知
x	過期事件，每當有過期鍵被刪除時發送
e	驅逐事件，每當有鍵因為maxmemory政策而被刪除時發送
A	參數 g$lshzxe 的別名

5.代碼實現

首先發送一條普通消息，設置過期時間。

@ApiOperation(value = "測試redis回調")    @SaCheckLogin    @PostMapping("/test")    public ApiResponse testTask(){        redisUtil.set("FILE:userInfo","我是一條消息，來測試是否進入回調",60);        return ApiResponse.ok();    }

添加RedisListenerConfig回調配置類

@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失效進入回調函數攜帶key:{}", key);            if (key != null && key.startsWith(keyInfo)) {                log.info("需要特殊處理的key,進行業務處理");            }        }    }}