# redis 高级应用--使用 redis 消息队列完成秒杀过期订单处理（2）

redis 高级应用–使用 redis 消息队列完成秒杀过期订单处理（2）

一、springDataRedis 中定义消息的监听器

1、在 JAVA 程序中监听 redis 消息：配置监听 redis 的消息。

如果要在 java 代码中监听 redis 的主题消息，需要自定义处理消息的监听器类。

2、在工程 spring-data-redis-test （模块）中，创建消息的监听器类 RedisMessageListener.java

/**
 *  spring-data-redis-test\src\main\java\djh\it\listener\RedisMessageListener.java
 *
 *  2024-7-24 创建消息的监听器 类 RedisMessageListener.java
 *
 *  配置 redis 消息的监听器：获取 redis 中的消息并进行处理。
 */
package djh.it.listener;

import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;

public class RedisMessageListener implements MessageListener {
    /**
     * onMessage : 处理消息。
     *      @param message ：完整的消息（频道的信息，以及消息的具体内容）
     *      @param bytes：获取的频道信息
     */
    @Override
    public void onMessage( Message message, byte[] bytes ) {
        System.out.println("从channel为：" + new String(message.getChannel())
            +"获取了一条新的消息，消息内容为：" + new String(message.getBody()));
    }
}

二、springDataRedis 中配置消息的监听器

1、配置消息的监听器：

1）监听器的适配器：（配置自定义的监听器）
2）配置监听器容器：（对监听器进行统一管理）

2、在工程 spring-data-redis-test （模块）中，修改配置文件 applicationContext-redis.xml 添加消息监听。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:task="http://www.springframework.org/schema/task"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
            http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd
            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd ">

    <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
        <!-- 设置key序列化方式 -->
        <property name="keySerializer">
            <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"></bean>
        </property>
        <!-- 设置value序列化方式 -->
        <property name="valueSerializer">
            <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"></bean>
        </property>
        <!-- 注入连接工厂 -->
        <property name="connectionFactory" ref="connectionFactory"></property>
    </bean>

    <!-- 创建connectionFactory交给spring容器管理 -->
    <bean id="connectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
        <property name="hostName" value="127.0.0.1"></property>
        <property name="port" value="6379"></property>
        <property name="database" value="0"></property>
        <property name="poolConfig" ref="poolConfig"></property>
    </bean>

    <!-- 创建连接池的基本配置 -->
    <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <!-- 最大连接数 -->
        <property name="MaxTotal" value="10"></property>
    </bean>

    <!-- 配置消息的监听器：
        1）监听器的适配器：（配置自定义的监听器）
        2）配置监听器容器：（对监听器进行统一管理）
    -->

    <!-- 配置处理消息的消息监听适配器 -->
    <bean class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter" id="messageListener">
        <constructor-arg>
            <!-- 注入自定义的监听器 -->
            <bean class="djh.it.listener.RedisMessageListener"></bean>
        </constructor-arg>
    </bean>

    <!-- 配置消息监听器容器 -->
    <bean class="org.springframework.data.redis.listener.RedisMessageListenerContainer" id="redisContainer">
        <!--
            由于需要和 redis 进行交互，注入连接工厂
            1）订阅的消息主题
            2）接收到消息之后处理的监听器
        -->
        <property name="connectionFactory" ref="connectionFactory"></property>
        <property name="messageListeners">
            <map>
                <entry key-ref="messageListener">
                    <!-- topic 的集合：订阅的主题
                        订阅了一个主题消息：主题的名称（dzs168)
                        接收到一条消息之后，交由自定义的消息监听器来进行处理
                     -->
                    <list>
                        <bean class="org.springframework.data.redis.listener.ChannelTopic">
                            <constructor-arg value="dzs168"></constructor-arg>
                        </bean>
                    </list>
                </entry>
            </map>
        </property>

    </bean>

</beans>

三、springDataRedis 中测试消息通知

1、在工程 spring-data-redis-test （模块）中，创建测试类 RedisTest02.java

/**
 *  spring-data-redis-test\src\test\java\djh\it\redis\test\RedisTest02.java
 *
 *  2024-7-24 测试类 RedisTest02.java
 */
package djh.it.redis.test;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class RedisTest02 {
    public static void main( String[] args ) {
        ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext-redis.xml");
    }
}

2、运行测试类 RedisTest02.java 进行消息监听，同时启动一客户端，连接 redis 服务端，

进行消息发送，观察测试类控制台输出结果：

“ 从channel为：dzs168获取了一条新的消息，消息内容为：very good ”

6-springDataRedis中测试消息通知.png

3、测试消息说明

1）配置好消息监听，已经订阅的主题之后就可以启动程序进行测试了。由于有监听程序在，只需要已 java 代码的形式启动，创建 spring 容器（当 spring 容器加载之后，会创建监听器一直监听对应的消息）。

2）当程序启动之后，会一直保持运行状态。即订阅了 dzs168 频道的消息，这个时候通过 redis 的客户端程序（redis-cli）发布一条消息。

3）publish topic名称消息内容：向指定频道发送一条消息。

发送消息之后，我们在来看 java 控制台输出验证是否获取到了此消息。

4）至此已经完成了在 java 代码中获取 redis 的消息通知。

四、失效问题处理：业务分析以及资料介绍

1、结合 redis 的 key 失效机制和消息完成过期优惠券处理，解决过期优惠券的问题：

1）在 redis 的内部当一个 key 失效时，也会向固定的频道中发送一条消息，只需要监听到此消息获取数据库中的 id，修改对应的优惠券状态就可以了。

2）这也带来了一些繁琐的操作：用户获取到优惠券之后需要将优惠券存入 redis 服务器并设置超时时间。

3）由于要借助redis的key失效通知，有两个注意事项各位需要注意：

1. 事件通过 Redis 的订阅与发布功能（pub/sub）来进行分发,故需要订阅（__keyevent@0__:expired）频道 0表示db0 根据自己的dbindex选择合适的数字。
1. 修改 redis.conf 文件

# 添加 
notify-keyspace-events Ex

2、模拟过期代金卷案例介绍：

1）使用 redis 的消息通知结合 springDataRedis 完成一个过期优惠券的处理。

2）需要两套程序，一个模拟用户获取优惠券（coupon-achieve），一个模拟过期优惠券的处理（coupon-expired ）。

3）第一套程序：coupon-achieve

用户获取优惠券

手动创建一个优惠券保存到数据库中。
同时保存到 redis 服务器中，同时设置失效时间。
由于 redis 中 key 的失效机制(只会发送key的失效消息)
key(coupon:优惠券ID)-value(优惠券ID)。

4）第二套程序：coupon-expired

过期优惠券的处理

订阅的主题: keyevent@0:expired
配置消息监听器
获取到失效消息(coupon:优惠券id)，从失效消息中分离出优惠券id
查询数据库，修改优惠券状态。

3、mysql 数据库表创建。


# 创建数据库
CREATE DATABASE `coupon` CHARACTER SET 'utf8' COLLATE 'utf8_general_ci';
# 使用数据库
use coupon; 
# 创建数据表
DROP TABLE IF EXISTS `t_coupon`;
CREATE TABLE `t_coupon` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键',
  `name` varchar(60) DEFAULT NULL COMMENT '优惠券名称',
  `money` decimal(10,0) DEFAULT NULL COMMENT '金额',
  `coupon_desc` varchar(128) DEFAULT NULL COMMENT '优惠券说明',
  `create_time` datetime DEFAULT NULL COMMENT '获取时间',
  `expire_time` datetime DEFAULT NULL COMMENT '失效时间',
  `state` int(1) DEFAULT NULL COMMENT '状态，0-有效，1-已失效，2-已使用',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8

五、失效问题处理：模拟获取优惠券