这篇文章主要介绍了redis怎样实现订单自动过期功能，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。

文章背景

我们的目的是在用户下单后，规定指定时间后自动将订单设置为“已过期”，不能再发起支付。

思路：

结合Redis的订阅、发布和键空间通知机制（Keyspace Notifications）进行实现。

配置redis.confg

notify-keyspace-events选项默认是不启用，改为notify-keyspace-events “Ex”。重启生效，索引位i的库，每当有过期的元素被删除时，向**keyspace@:expired**频道发送通知。
E表示键事件通知，所有通知以__keyevent@__:expired为前缀；
x表示过期事件，每当有过期被删除时发送。

与SpringBoot进行集成

1、注册JedisConnectionFactory

importorg.springframework.beans.factory.annotation.Value;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.data.redis.connection.RedisPassword;importorg.springframework.data.redis.connection.RedisStandaloneConfiguration;importorg.springframework.data.redis.connection.jedis.JedisConnectionFactory;importredis.clients.jedis.JedisPool;importredis.clients.jedis.JedisPoolConfig;@ConfigurationpublicclassRedisConfig{@Value("${redis.pool.maxTotal}")privateIntegermaxTotal;@Value("${redis.pool.minIdle}")privateIntegerminIdle;@Value("${redis.pool.maxIdle}")privateIntegermaxIdle;@Value("${redis.pool.maxWaitMillis}")privateIntegermaxWaitMillis;@Value("${redis.url}")privateStringredisUrl;@Value("${redis.port}")privateIntegerredisPort;@Value("${redis.timeout}")privateIntegerredisTimeout;@Value("${redis.password}")privateStringredisPassword;@Value("${redis.db.payment}")privateIntegerpaymentDataBase;privateJedisPoolConfigjedisPoolConfig(){JedisPoolConfigconfig=newJedisPoolConfig();config.setMaxTotal(maxTotal);config.setMinIdle(minIdle);config.setMaxIdle(maxIdle);config.setMaxWaitMillis(maxWaitMillis);returnconfig;}@BeanpublicJedisPooljedisPool(){JedisPoolConfigconfig=this.jedisPoolConfig();JedisPooljedisPool=newJedisPool(config,redisUrl,redisPort,redisTimeout,redisPassword);returnjedisPool;}@Bean(name="jedisConnectionFactory")publicJedisConnectionFactoryjedisConnectionFactory(){RedisStandaloneConfigurationredisStandaloneConfiguration=newRedisStandaloneConfiguration();redisStandaloneConfiguration.setDatabase(paymentDataBase);redisStandaloneConfiguration.setHostName(redisUrl);redisStandaloneConfiguration.setPassword(RedisPassword.of(redisPassword));redisStandaloneConfiguration.setPort(redisPort);returnnewJedisConnectionFactory(redisStandaloneConfiguration);}}

2、注册监听器

importorg.springframework.data.redis.connection.Message;importorg.springframework.data.redis.connection.MessageListener;importorg.springframework.stereotype.Service;importorg.springframework.transaction.annotation.Transactional;@Service(value="paymentListener")publicclassPaymentListenerimplementsMessageListener{@Override@TransactionalpublicvoidonMessage(Messagemessage,byte[]pattern){//过期事件处理流程}}

3、配置订阅对象

importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.beans.factory.annotation.Qualifier;importorg.springframework.beans.factory.annotation.Value;importorg.springframework.boot.autoconfigure.AutoConfigureAfter;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.data.redis.connection.jedis.JedisConnectionFactory;importorg.springframework.data.redis.listener.PatternTopic;importorg.springframework.data.redis.listener.RedisMessageListenerContainer;importorg.springframework.data.redis.listener.adapter.MessageListenerAdapter;@Configuration@AutoConfigureAfter(value=RedisConfig.class)publicclassPaymentListenerConfig{@Autowired@Qualifier(value="paymentListener")privatePaymentListenerpaymentListener;@Autowired@Qualifier(value="paymentListener")privateJedisConnectionFactoryconnectionFactory;@Value("${redis.db.payment}")privateIntegerpaymentDataBase;@BeanRedisMessageListenerContainerredisMessageListenerContainer(MessageListenerAdapterlistenerAdapter){RedisMessageListenerContainercontainer=newRedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);//监听paymentDataBase库的过期事件StringsubscribeChannel="__keyevent@"+paymentDataBase+"__:expired";container.addMessageListener(listenerAdapter,newPatternTopic(subscribeChannel));returncontainer;}@BeanMessageListenerAdapterlistenerAdapter(){returnnewMessageListenerAdapter(paymentListener);}}

paymentDataBase 库元素过期后就会跳入PaymentListener 的onMessage(Message message, byte[] pattern)方法。

感谢你能够认真阅读完这篇文章，希望小编分享的“redis怎样实现订单自动过期功能”这篇文章对大家有帮助，同时也希望大家多多支持亿速云，关注亿速云行业资讯频道，更多相关知识等着你来学习!