如何使用?redis?消息隊(duì)列完成秒殺過期訂單處理操作(二)

更新時(shí)間：2024年07月30日 11:01:14 作者：段子手-168

這篇文章主要介紹了如何使用?redis?消息隊(duì)列完成秒殺過期訂單處理操作,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧

1、打開 idea，創(chuàng)建 coupon-achieve 的 maven 工程。
2、在工程 coupon-achieve （模塊）中的 pom.xml 中導(dǎo)入依賴
3、在工程 coupon-achieve （模塊）中，創(chuàng)建實(shí)體類 Coupon.java
4、在工程 coupon-achieve （模塊）中，創(chuàng)建映射類 CouponMapper.java
5、在工程 coupon-achieve （模塊）中，創(chuàng)建工具類 CouponMapper.java
6、在工程 coupon-achieve （模塊）中，創(chuàng)建配置文件 CouponMapper.xml
7、在工程 coupon-achieve （模塊）中，創(chuàng)建 applicationContext.xml 配置文件。
8、在工程 coupon-achieve （模塊）中，創(chuàng)建 applicationContext-data-redis.xml 配置文件。
9、在工程 coupon-achieve （模塊）中，創(chuàng)建 jdbc.properties 配置文件。
10、在工程 coupon-achieve （模塊）中，創(chuàng)建 sqlMapConfig.xml 配置文件。
11、在工程 coupon-achieve （模塊）中，創(chuàng)建 log4j.properties 日志文件。
12、在工程 coupon-achieve （模塊）中，創(chuàng)建測(cè)試類 CouponTest.java
13、啟動(dòng) redis 服務(wù)端和客戶端，運(yùn)行測(cè)試類 CouponTest.java 進(jìn)行測(cè)試，如下圖，

六、失效問題處理：配置消息監(jiān)聽，借助 redis 的 key 失效通知設(shè)置優(yōu)惠券狀態(tài)

1、打開 idea，創(chuàng)建 coupon-expired 的 maven 工程。
2、在工程 coupon-expired （模塊）中的 pom.xml 中導(dǎo)入依賴
3、在工程 coupon-expired （模塊）中，創(chuàng)建監(jiān)聽器類 RedisMessageListener.java
4、在工程 coupon-expired （模塊）中，創(chuàng)建實(shí)體類 Coupon.java
5、在工程 coupon-expired （模塊）中，創(chuàng)建映射類 CouponMapper.java
6、在工程 coupon-expired （模塊）中，創(chuàng)建工具類 DataUtils.java
7、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 CouponMapper.xml 。
8、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 applicationContext.xml 。
9、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 applicationContext-data-redis.xml。
10、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 jdbc.properties。
11、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 sqlMapConfig.xml。
12、在工程 coupon-expired （模塊）中，創(chuàng)建日志文件 log4j.properties
13、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 CouponTest.java
14、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 RedisTest.java
15、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 RedisTest2.java
16、啟動(dòng) redis 服務(wù)端和客戶端，

七、總結(jié)

redis 高級(jí)應(yīng)用–使用 redis 消息隊(duì)列完成秒殺過期訂單處理

一、springDataRedis 中定義消息的監(jiān)聽器

1、在 JAVA 程序中監(jiān)聽 redis 消息：配置監(jiān)聽 redis 的消息。

如果要在 java 代碼中監(jiān)聽 redis 的主題消息，需要自定義處理消息的監(jiān)聽器類。

2、在工程 spring-data-redis-test （模塊）中，創(chuàng)建消息的監(jiān)聽器類 RedisMessageListener.java

/**
 *  spring-data-redis-test\src\main\java\djh\it\listener\RedisMessageListener.java
 *
 *  2024-7-24 創(chuàng)建消息的監(jiān)聽器 類 RedisMessageListener.java
 *
 *  配置 redis 消息的監(jiān)聽器：獲取 redis 中的消息并進(jìn)行處理。
 */
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 ：完整的消息（頻道的信息，以及消息的具體內(nèi)容）
     *      @param bytes：獲取的頻道信息
     */
    @Override
    public void onMessage( Message message, byte[] bytes ) {
        System.out.println("從channel為：" + new String(message.getChannel())
            +"獲取了一條新的消息，消息內(nèi)容為：" + new String(message.getBody()));
    }
}

二、springDataRedis 中配置消息的監(jiān)聽器

1、配置消息的監(jiān)聽器：

1）監(jiān)聽器的適配器：（配置自定義的監(jiān)聽器）
2）配置監(jiān)聽器容器：（對(duì)監(jiān)聽器進(jìn)行統(tǒng)一管理）

2、在工程 spring-data-redis-test （模塊）中，修改配置文件 applicationContext-redis.xml 添加消息監(jiān)聽。

<?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">
        <!-- 設(shè)置key序列化方式 -->
        <property name="keySerializer">
            <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"></bean>
        </property>
        <!-- 設(shè)置value序列化方式 -->
        <property name="valueSerializer">
            <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"></bean>
        </property>
        <!-- 注入連接工廠 -->
        <property name="connectionFactory" ref="connectionFactory"></property>
    </bean>
    <!-- 創(chuàng)建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>
    <!-- 創(chuàng)建連接池的基本配置 -->
    <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <!-- 最大連接數(shù) -->
        <property name="MaxTotal" value="10"></property>
    </bean>
    <!-- 配置消息的監(jiān)聽器：
        1）監(jiān)聽器的適配器：（配置自定義的監(jiān)聽器）
        2）配置監(jiān)聽器容器：（對(duì)監(jiān)聽器進(jìn)行統(tǒng)一管理）
    -->
    <!-- 配置處理消息的消息監(jiān)聽適配器 -->
    <bean class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter" id="messageListener">
        <constructor-arg>
            <!-- 注入自定義的監(jiān)聽器 -->
            <bean class="djh.it.listener.RedisMessageListener"></bean>
        </constructor-arg>
    </bean>
    <!-- 配置消息監(jiān)聽器容器 -->
    <bean class="org.springframework.data.redis.listener.RedisMessageListenerContainer" id="redisContainer">
        <!--
            由于需要和 redis 進(jìn)行交互，注入連接工廠
            1）訂閱的消息主題
            2）接收到消息之后處理的監(jiān)聽器
        -->
        <property name="connectionFactory" ref="connectionFactory"></property>
        <property name="messageListeners">
            <map>
                <entry key-ref="messageListener">
                    <!-- topic 的集合：訂閱的主題
                        訂閱了一個(gè)主題消息：主題的名稱（dzs168)
                        接收到一條消息之后，交由自定義的消息監(jiān)聽器來進(jìn)行處理
                     -->
                    <list>
                        <bean class="org.springframework.data.redis.listener.ChannelTopic">
                            <constructor-arg value="dzs168"></constructor-arg>
                        </bean>
                    </list>
                </entry>
            </map>
        </property>
    </bean>
</beans>

三、springDataRedis 中測(cè)試消息通知

1、在工程 spring-data-redis-test （模塊）中，創(chuàng)建測(cè)試類 RedisTest02.java

/**
 *  spring-data-redis-test\src\test\java\djh\it\redis\test\RedisTest02.java
 *
 *  2024-7-24 測(cè)試類 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、運(yùn)行測(cè)試類 RedisTest02.java 進(jìn)行消息監(jiān)聽，同時(shí)啟動(dòng)一客戶端，連接 redis 服務(wù)端，

進(jìn)行消息發(fā)送，觀察測(cè)試類控制臺(tái)輸出結(jié)果：

“ 從channel為：dzs168獲取了一條新的消息，消息內(nèi)容為：very good ”

3、測(cè)試消息說明

1）配置好消息監(jiān)聽，已經(jīng)訂閱的主題之后就可以啟動(dòng)程序進(jìn)行測(cè)試了。由于有監(jiān)聽程序在，只需要已 java 代碼的形式啟動(dòng)，創(chuàng)建 spring 容器（當(dāng) spring 容器加載之后，會(huì)創(chuàng)建監(jiān)聽器一直監(jiān)聽對(duì)應(yīng)的消息）。

2）當(dāng)程序啟動(dòng)之后，會(huì)一直保持運(yùn)行狀態(tài)。即訂閱了 dzs168 頻道的消息，這個(gè)時(shí)候通過 redis 的客戶端程序（redis-cli）發(fā)布一條消息。

3）publish topic名稱消息內(nèi)容：向指定頻道發(fā)送一條消息。

發(fā)送消息之后，我們?cè)趤砜?java 控制臺(tái)輸出驗(yàn)證是否獲取到了此消息。

4）至此已經(jīng)完成了在 java 代碼中獲取 redis 的消息通知。

四、失效問題處理：業(yè)務(wù)分析以及資料介紹

1、結(jié)合 redis 的 key 失效機(jī)制和消息完成過期優(yōu)惠券處理，解決過期優(yōu)惠券的問題：

1）在 redis 的內(nèi)部當(dāng)一個(gè) key 失效時(shí)，也會(huì)向固定的頻道中發(fā)送一條消息，只需要監(jiān)聽到此消息獲取數(shù)據(jù)庫(kù)中的 id，修改對(duì)應(yīng)的優(yōu)惠券狀態(tài)就可以了。

2）這也帶來了一些繁瑣的操作：用戶獲取到優(yōu)惠券之后需要將優(yōu)惠券存入 redis 服務(wù)器并設(shè)置超時(shí)時(shí)間。

3）由于要借助redis的key失效通知，有兩個(gè)注意事項(xiàng)各位需要注意：

事件通過 Redis 的訂閱與發(fā)布功能（pub/sub）來進(jìn)行分發(fā),故需要訂閱（__keyevent@0__:expired）頻道 0表示db0 根據(jù)自己的dbindex選擇合適的數(shù)字。
修改 redis.conf 文件

# 添加 
notify-keyspace-events Ex

2、模擬過期代金卷案例介紹：

1）使用 redis 的消息通知結(jié)合 springDataRedis 完成一個(gè)過期優(yōu)惠券的處理。

2）需要兩套程序，一個(gè)模擬用戶獲取優(yōu)惠券（coupon-achieve），一個(gè)模擬過期優(yōu)惠券的處理（coupon-expired ）。

3）第一套程序：coupon-achieve

用戶獲取優(yōu)惠券

手動(dòng)創(chuàng)建一個(gè)優(yōu)惠券保存到數(shù)據(jù)庫(kù)中。
同時(shí)保存到 redis 服務(wù)器中，同時(shí)設(shè)置失效時(shí)間。
由于 redis 中 key 的失效機(jī)制(只會(huì)發(fā)送key的失效消息)
key(coupon:優(yōu)惠券ID)-value(優(yōu)惠券ID)。

4）第二套程序：coupon-expired

過期優(yōu)惠券的處理

訂閱的主題: keyevent@0:expired配置消息監(jiān)聽器
獲取到失效消息(coupon:優(yōu)惠券id)，從失效消息中分離出優(yōu)惠券id

查詢數(shù)據(jù)庫(kù)，修改優(yōu)惠券狀態(tài)。

3、mysql 數(shù)據(jù)庫(kù)表創(chuàng)建。

# 創(chuàng)建數(shù)據(jù)庫(kù)
CREATE DATABASE `coupon` CHARACTER SET 'utf8' COLLATE 'utf8_general_ci';
# 使用數(shù)據(jù)庫(kù)
use coupon; 
# 創(chuàng)建數(shù)據(jù)表
DROP TABLE IF EXISTS `t_coupon`;
CREATE TABLE `t_coupon` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主鍵',
  `name` varchar(60) DEFAULT NULL COMMENT '優(yōu)惠券名稱',
  `money` decimal(10,0) DEFAULT NULL COMMENT '金額',
  `coupon_desc` varchar(128) DEFAULT NULL COMMENT '優(yōu)惠券說明',
  `create_time` datetime DEFAULT NULL COMMENT '獲取時(shí)間',
  `expire_time` datetime DEFAULT NULL COMMENT '失效時(shí)間',
  `state` int(1) DEFAULT NULL COMMENT '狀態(tài)，0-有效，1-已失效，2-已使用',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8

五、失效問題處理：模擬獲取優(yōu)惠券

1、在工程 spring-data-redis-test （模塊）中，創(chuàng)建測(cè)試類 RedisTest02.java

/**
 *  spring-data-redis-test\src\test\java\djh\it\redis\test\RedisTest02.java
 *
 *  2024-7-24 測(cè)試類 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、運(yùn)行測(cè)試類 RedisTest02.java 進(jìn)行消息監(jiān)聽，同時(shí)啟動(dòng)一客戶端，連接 redis 服務(wù)端，

進(jìn)行消息發(fā)送，觀察測(cè)試類控制臺(tái)輸出結(jié)果：

從channel為：dzs168獲取了一條新的消息，消息內(nèi)容為：very good

6-springDataRedis中測(cè)試消息通知.png

3、測(cè)試消息說明

3）publish topic名稱消息內(nèi)容：向指定頻道發(fā)送一條消息。

發(fā)送消息之后，我們?cè)趤砜?java 控制臺(tái)輸出驗(yàn)證是否獲取到了此消息。

4）至此已經(jīng)完成了在 java 代碼中獲取 redis 的消息通知。

12-失效問題處理：業(yè)務(wù)分析以及資料介紹

redis 高級(jí)應(yīng)用–使用 redis 消息隊(duì)列完成秒殺過期訂單處理（2）

四、失效問題處理：業(yè)務(wù)分析以及資料介紹

1、結(jié)合 redis 的 key 失效機(jī)制和消息完成過期優(yōu)惠券處理，解決過期優(yōu)惠券的問題：

2）這也帶來了一些繁瑣的操作：用戶獲取到優(yōu)惠券之后需要將優(yōu)惠券存入 redis 服務(wù)器并設(shè)置超時(shí)時(shí)間。

3）由于要借助redis的key失效通知，有兩個(gè)注意事項(xiàng)各位需要注意：

事件通過 Redis 的訂閱與發(fā)布功能（pub/sub）來進(jìn)行分發(fā),故需要訂閱（__keyevent@0__:expired）頻道 0表示db0 根據(jù)自己的dbindex選擇合適的數(shù)字。
修改 redis.conf 文件

# 添加 
notify-keyspace-events Ex

2、模擬過期代金卷案例介紹：

1）使用 redis 的消息通知結(jié)合 springDataRedis 完成一個(gè)過期優(yōu)惠券的處理。

2）需要兩套程序，一個(gè)模擬用戶獲取優(yōu)惠券，一個(gè)模擬過期優(yōu)惠券的處理。

3）第一套程序：coupon-achieve

用戶獲取優(yōu)惠券

手動(dòng)創(chuàng)建一個(gè)優(yōu)惠券保存到數(shù)據(jù)庫(kù)中。
同時(shí)保存到 redis 服務(wù)器中，同時(shí)設(shè)置失效時(shí)間。
由于 redis 中 key 的失效機(jī)制(只會(huì)發(fā)送key的失效消息)
key(coupon:優(yōu)惠券ID)-value(優(yōu)惠券ID)。

4）第二套程序：coupon-expired

過期優(yōu)惠券的處理

訂閱的主題: keyevent@0:expired配置消息監(jiān)聽器
獲取到失效消息(coupon:優(yōu)惠券id)，從失效消息中分離出優(yōu)惠券id

查詢數(shù)據(jù)庫(kù)，修改優(yōu)惠券狀態(tài)。

3、mysql 數(shù)據(jù)庫(kù)表創(chuàng)建。

# 創(chuàng)建數(shù)據(jù)庫(kù)
CREATE DATABASE `coupon` CHARACTER SET 'utf8' COLLATE 'utf8_general_ci';
# 使用數(shù)據(jù)庫(kù)
use coupon; 
# 創(chuàng)建數(shù)據(jù)表
DROP TABLE IF EXISTS `t_coupon`;
CREATE TABLE `t_coupon` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主鍵',
  `name` varchar(60) DEFAULT NULL COMMENT '優(yōu)惠券名稱',
  `money` decimal(10,0) DEFAULT NULL COMMENT '金額',
  `coupon_desc` varchar(128) DEFAULT NULL COMMENT '優(yōu)惠券說明',
  `create_time` datetime DEFAULT NULL COMMENT '獲取時(shí)間',
  `expire_time` datetime DEFAULT NULL COMMENT '失效時(shí)間',
  `state` int(1) DEFAULT NULL COMMENT '狀態(tài)，0-有效，1-已失效，2-已使用',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8

13-失效問題處理：模擬獲取優(yōu)惠券

redis 高級(jí)應(yīng)用–使用 redis 消息隊(duì)列完成秒殺過期訂單處理（2）

五、失效問題處理：模擬獲取優(yōu)惠券

1、打開 idea，創(chuàng)建 coupon-achieve 的 maven 工程。

--> idea --> File 
	--> New --> Project 
	--> Maven 
		Project SDK: ( 1.8(java version "1.8.0_131" ) 
	--> Next 
	--> Groupld : ( djh.it )
		Artifactld : ( coupon-achieve )
		Version : 1.0-SNAPSHOT
	--> Name: ( coupon-achieve )
		Location: ( ...\coupon-achieve\ )	
	--> Finish

2、在工程 coupon-achieve （模塊）中的 pom.xml 中導(dǎo)入依賴

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>cn.itcast</groupId>
	<artifactId>coupon-achieve</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>war</packaging>
	<properties>
		<spring.version>4.2.4.RELEASE</spring.version>
		<slf4j.version>1.6.6</slf4j.version>
		<log4j.version>1.2.12</log4j.version>
		<springdataredis.version>1.7.4.RELEASE</springdataredis.version>
<!--		<mysql.version>5.1.6</mysql.version>-->
		<mysql.version>8.0.23</mysql.version>
	</properties>
	<dependencies>
		<!-- spring data redis相關(guān)坐標(biāo) beg -->
		<dependency>
			<groupId>redis.clients</groupId>
			<artifactId>jedis</artifactId>
			<version>2.6.2</version>
		</dependency>
		<dependency>
			<groupId>org.apache.commons</groupId>
			<artifactId>commons-pool2</artifactId>
<!--			<version>2.2</version>-->
			<version>2.4.2</version>
		</dependency>
		<dependency>
			<groupId>org.springframework.data</groupId>
			<artifactId>spring-data-redis</artifactId>
			<version>${springdataredis.version}</version>
		</dependency>
		<!-- spring data redis相關(guān)坐標(biāo) end -->
		<!-- spring 相關(guān)坐標(biāo) beg -->
		<dependency>
			<groupId>org.aspectj</groupId>
			<artifactId>aspectjweaver</artifactId>
			<version>1.6.8</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-aop</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-orm</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-beans</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-core</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<!-- spring 相關(guān)坐標(biāo) end -->
		<!-- 日志相關(guān)坐標(biāo) beg -->
		<dependency>
			<groupId>log4j</groupId>
			<artifactId>log4j</artifactId>
			<version>${log4j.version}</version>
		</dependency>
		<dependency>
			<groupId>org.slf4j</groupId>
			<artifactId>slf4j-api</artifactId>
			<version>${slf4j.version}</version>
		</dependency>
		<dependency>
			<groupId>org.slf4j</groupId>
			<artifactId>slf4j-log4j12</artifactId>
			<version>${slf4j.version}</version>
		</dependency>
		<!-- 日志相關(guān)坐標(biāo) end -->
		<!-- 單元測(cè)試相關(guān)坐標(biāo) beg -->
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-test</artifactId>
			<version>4.2.4.RELEASE</version>
		</dependency>
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>4.10</version>
		</dependency>
		<!-- 單元測(cè)試相關(guān)坐標(biāo) end -->
		<!-- druid數(shù)據(jù)庫(kù)連接池 beg -->
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>druid</artifactId>
			<version>1.1.9</version>
		</dependency>
		<!-- druid數(shù)據(jù)庫(kù)連接池 end -->
		<!-- mysql驅(qū)動(dòng) beg -->
		<dependency>
			<groupId>mysql</groupId>
			<artifactId>mysql-connector-java</artifactId>
			<version>${mysql.version}</version>
		</dependency>
		<!-- mysql驅(qū)動(dòng) end -->
		<!-- mybatis核心包 -->
		<dependency>
			<groupId>org.mybatis</groupId>
			<artifactId>mybatis</artifactId>
			<version>3.4.5</version>
		</dependency>
		<!-- mybatis整合spring -->
		<dependency>
             <groupId>org.mybatis</groupId>
             <artifactId>mybatis-spring</artifactId>
             <version>1.3.1</version>
         </dependency>
	</dependencies>
	<build>
		<finalName>coupon-achieve</finalName>
		<pluginManagement>
			<plugins>
				<plugin>
					<groupId>org.apache.maven.plugins</groupId>
					<artifactId>maven-compiler-plugin</artifactId>
					<version>3.2</version>
					<configuration>
						<source>1.8</source>
						<target>1.8</target>
						<encoding>UTF-8</encoding>
						<showWarnings>true</showWarnings>
					</configuration>
				</plugin>
			</plugins>
		</pluginManagement>
	</build>
</project>

3、在工程 coupon-achieve （模塊）中，創(chuàng)建實(shí)體類 Coupon.java

/**
 *  redis-coupon\coupon-achieve2\src\main\java\cn\itcast\entity\Coupon.java
 *
 *  2024-7-24 創(chuàng)建實(shí)體類 Coupon.java
 */
package cn.itcast.entity;
import java.math.BigDecimal;
import java.util.Date;
/**
 * 優(yōu)惠券實(shí)體類
 */
public class Coupon {
	private Long id;//主鍵id
	private String name;//優(yōu)惠券名稱
	private BigDecimal money;//優(yōu)惠券金額
	private String couponDesc;//說明
	private Date createTime;//獲取時(shí)間
	private Date expireTime;//失效時(shí)間
	private Integer state;//狀態(tài) 0：可用 1：已失效 2：已使用
	public Coupon() {}
	public Coupon(String name, BigDecimal money, String couponDesc, Date createTime, Date expireTime,Integer state) {
		this.name = name;
		this.money = money;
		this.couponDesc = couponDesc;
		this.createTime = createTime;
		this.expireTime = expireTime;
		this.state = state;
	}
	public Long getId() {
		return id;
	}
	public void setId(Long id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public BigDecimal getMoney() {
		return money;
	}
	public void setMoney(BigDecimal money) {
		this.money = money;
	}
	public String getCouponDesc() {
		return couponDesc;
	}
	public void setCouponDesc(String couponDesc) {
		this.couponDesc = couponDesc;
	}
	public Date getCreateTime() {
		return createTime;
	}
	public void setCreateTime(Date createTime) {
		this.createTime = createTime;
	}
	public Date getExpireTime() {
		return expireTime;
	}
	public void setExpireTime(Date expireTime) {
		this.expireTime = expireTime;
	}
	public Integer getState() {
		return state;
	}
	public void setState(Integer state) {
		this.state = state;
	}
	@Override
	public String toString() {
		return "Coupon [id=" + id + ", name=" + name + ", money=" + money + ", couponDesc=" + couponDesc
				+ ", createTime=" + createTime + ", expireTime=" + expireTime + ", state=" + state + "]";
	}
}

4、在工程 coupon-achieve （模塊）中，創(chuàng)建映射類 CouponMapper.java

/**
 *  redis-coupon\coupon-achieve2\src\main\java\cn\itcast\mapper\CouponMapper.java
 *
 *  2024-7-24 創(chuàng)建映射類 CouponMapper.java
 */
package cn.itcast.mapper;
import cn.itcast.entity.Coupon;
public interface CouponMapper {
	//保存優(yōu)惠券信息
	public void saveCoupon(Coupon coupon);
	//根據(jù)id更新優(yōu)惠券信息
	public void updateCoupon(Coupon coupon);
	//根據(jù)id查詢優(yōu)惠券信息
	public Coupon selectCouponById(long id);
}

5、在工程 coupon-achieve （模塊）中，創(chuàng)建工具類 CouponMapper.java

/**
 *  redis-coupon.coupon-achieve2.src.main.java.cn.itcast.utils.DataUtils.java
 *
 *  2024-7-24 創(chuàng)建工具類 CouponMapper.java
 */
package cn.itcast.utils;
import java.util.Calendar;
import java.util.Date;
public class DataUtils {
	public static Date addTime(Date date,int minute) {
		Calendar calendar = Calendar.getInstance();
		calendar.setTime(date);
		calendar.add(Calendar.MINUTE, minute);
		return calendar.getTime();
	}
}

6、在工程 coupon-achieve （模塊）中，創(chuàng)建配置文件 CouponMapper.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="cn.itcast.mapper.CouponMapper">
	<resultMap id="BaseResultMap" type="cn.itcast.entity.Coupon">
		<id column="id" property="id" jdbcType="BIGINT" />
		<result column="name" property="name" jdbcType="VARCHAR" />
		<result column="money" property="money" jdbcType="DECIMAL" />
		<result column="coupon_desc" property="couponDesc" jdbcType="VARCHAR" />
		<result column="create_time" property="createTime" jdbcType="TIMESTAMP" />
		<result column="expire_time" property="expireTime" jdbcType="TIMESTAMP" />
		<result column="state" property="state" jdbcType="INTEGER" />
	</resultMap>
	<sql id="Base_Column_List">
		id,name,money,coupon_desc,create_time,expire_time,state
	</sql>
	<sql id="table">
		t_coupon
	</sql>
	<select id="selectCouponById" resultMap="BaseResultMap" parameterType="long">
		select <include refid="Base_Column_List" /> from <include refid="table" /> where id =#{id,jdbcType=BIGINT}
	</select>
	<insert id="saveCoupon" parameterType="cn.itcast.entity.Coupon" useGeneratedKeys="true" keyProperty="id">
		insert into <include refid="table" /> (name,money,coupon_desc,create_time,expire_time,state)
		values (#{name}, #{money},#{couponDesc},#{createTime}, #{expireTime}, #{state})
	</insert>
	<update id="updateCoupon" parameterType="cn.itcast.entity.Coupon">
		update <include refid="table" />
		set name = #{name},
		money = #{money},
		coupon_desc = #{couponDesc},
		create_time = #{createTime},
		expire_time = #{expireTime},
		state = #{state,jdbcType=INTEGER}
		where  id = #{id,jdbcType=BIGINT}
	</update>
</mapper>
<!-- redis-coupon\coupon-achieve2\src\main\resources\cn\itcast\mapper\CouponMapper.xml -->

7、在工程 coupon-achieve （模塊）中，創(chuàng)建 applicationContext.xml 配置文件。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:context="http://www.springframework.org/schema/context" 
	xmlns:mvc="http://www.springframework.org/schema/mvc"
	xmlns:aop="http://www.springframework.org/schema/aop" 
	xmlns:tx="http://www.springframework.org/schema/tx"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
	http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
	http://www.springframework.org/schema/context 
	http://www.springframework.org/schema/context/spring-context-4.0.xsd
	http://www.springframework.org/schema/mvc 
	http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd
	http://www.springframework.org/schema/aop 
	http://www.springframework.org/schema/aop/spring-aop-4.0.xsd 
	http://www.springframework.org/schema/tx 
	http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
	http://www.springframework.org/schema/util 
	http://www.springframework.org/schema/util/spring-util-4.0.xsd">
	<context:component-scan base-package="cn.itcast"></context:component-scan>
	<!-- 1.數(shù)據(jù)源,連接數(shù)據(jù)庫(kù) -->
	<context:property-placeholder location="classpath:jdbc.properties"/>
	<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
		<property name="driverClassName" value="${jdbc.driver}"></property>
		<property name="url" value="${jdbc.url}"></property>
		<property name="username" value="${jdbc.username}"></property>
		<property name="password" value="${jdbc.password}"></property>
	</bean>
	<!-- 2.工廠 生產(chǎn)sqlSession -->
	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
		<property name="dataSource" ref="dataSource"></property>
		<property name="typeAliasesPackage" value="cn.itcast.entity"></property>
		<property name="configLocation" value="classpath:sqlMapConfig.xml"></property>
	</bean>
	<!-- 3.掃描接口,接口代理開發(fā) -->
	 <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
	 	<property name="basePackage" value="cn.itcast.mapper"></property>
	 </bean>
	<!-- 4. 創(chuàng)建事物管理平臺(tái)(對(duì)象) -->
	<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource"></property>
	</bean>
	<!-- 5.事物管理策略 -->
	<tx:advice id="txAdvice" transaction-manager="transactionManager">
		<tx:attributes>
			<tx:method name="save*" propagation="REQUIRED"/>
			<tx:method name="update*" propagation="REQUIRED"/>
			<tx:method name="delete*" propagation="REQUIRED"/>
			<tx:method name="*" propagation="REQUIRED"/>
		</tx:attributes>
	</tx:advice>
	<!-- 6.事物切面 -->
	<aop:config>
		<aop:advisor advice-ref="txAdvice" pointcut="execution(* cn.itcast.service.*.*(..))"/>
	</aop:config>
	<import resource="classpath:applicationContext-data-redis.xml"/>
</beans>
<!-- redis-coupon\coupon-achieve2\src\main\resources\applicationContext.xml -->

8、在工程 coupon-achieve （模塊）中，創(chuàng)建 applicationContext-data-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
		">
	<description>spring-data整合jedis</description>
	<!-- springData Redis 核心api-->
	<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
		<property name="connectionFactory" ref="connectionFactory"></property>
		<property name="keySerializer">
			<bean class="org.springframework.data.redis.serializer.StringRedisSerializer"></bean>	
		</property>
		<property name="valueSerializer">
			<bean class="org.springframework.data.redis.serializer.StringRedisSerializer"></bean>
		</property>
	</bean>
	<!-- jedis連接工廠 -->
	<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>
	<!-- jedis連接池的配置信息 -->
	<bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
		<property name="maxIdle" value="5"></property>
		<property name="maxTotal" value="10"></property>
		<property name="testOnBorrow" value="true"></property>
	</bean>
</beans>
<!-- redis-coupon\coupon-achieve2\src\main\resources\applicationContext-data-redis.xml -->

9、在工程 coupon-achieve （模塊）中，創(chuàng)建 jdbc.properties 配置文件。

# redis-coupon\coupon-achieve2\src\main\resources\jdbc.properties
jdbc.url=jdbc:mysql://localhost:3306/coupon
jdbc.driver=com.mysql.jdbc.Driver
jdbc.username=root
jdbc.password=12311

10、在工程 coupon-achieve （模塊）中，創(chuàng)建 sqlMapConfig.xml 配置文件。

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>	
</configuration>

11、在工程 coupon-achieve （模塊）中，創(chuàng)建 log4j.properties 日志文件。

# redis-coupon\coupon-achieve2\src\main\resources\log4j.properties
### direct log messages to stdout ###
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target=System.out
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n
### direct messages to file mylog.log ###
log4j.appender.file=org.apache.log4j.FileAppender
log4j.appender.file.File=c:/mylog.log
log4j.appender.file.layout=org.apache.log4j.PatternLayout
log4j.appender.file.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n
### set log levels - for more verbose logging change 'info' to 'debug' ###
log4j.rootLogger=debug, stdout

12、在工程 coupon-achieve （模塊）中，創(chuàng)建測(cè)試類 CouponTest.java

/**
 *  D:\java-test\idea2019\redis-coupon\coupon-achieve2\src\test\java\cn\itcast\coupon\test\CouponTest.java
 *
 *  2024-7-24 創(chuàng)建測(cè)試類 CouponTest.java
 */
package cn.itcast.coupon.test;
import java.math.BigDecimal;
import java.util.Date;
import java.util.concurrent.TimeUnit;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import cn.itcast.entity.Coupon;
import cn.itcast.mapper.CouponMapper;
import cn.itcast.utils.DataUtils;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext.xml")
public class CouponTest {
	@Autowired
	private CouponMapper couponMapper;
	@Autowired
	private RedisTemplate<String,String> redisTemplate;
	/**
	 * 1.創(chuàng)建一個(gè)優(yōu)惠券
	 * 2.保存到數(shù)據(jù)庫(kù)中
	 * 3.保存到redis服務(wù)器中，設(shè)置超時(shí)時(shí)間
	 */
	@Test
	public void testGetCoupon() {
		Date now = new Date();
		int timeOut = 1;// 優(yōu)惠券的超時(shí)時(shí)間：1分鐘
		//自定義一個(gè)優(yōu)惠券
		Coupon coupon = new Coupon();
		coupon.setName("段子手168優(yōu)惠券");
		coupon.setMoney(BigDecimal.ONE);//設(shè)置金額
		coupon.setCouponDesc("全品類優(yōu)惠券50元");
		coupon.setCreateTime(now);
		coupon.setExpireTime(DataUtils.addTime(now, timeOut));//設(shè)置優(yōu)惠券的失效時(shí)間，一份后失效
		coupon.setState(0);
		//將優(yōu)惠券保存到數(shù)據(jù)庫(kù)中
		couponMapper.saveCoupon(coupon);
		//將優(yōu)惠券設(shè)置到redis緩存中，并且設(shè)置超時(shí)件
		redisTemplate.opsForValue().set("coupon:"+coupon.getId(), coupon.getId()+"", timeOut, TimeUnit.MINUTES);
	}
}

13、啟動(dòng) redis 服務(wù)端和客戶端，運(yùn)行測(cè)試類 CouponTest.java 進(jìn)行測(cè)試，如下圖，

在數(shù)據(jù)庫(kù)中查詢到插入的記錄，redis 客戶端也查詢到數(shù)據(jù)，但 1 分鐘后失效。

六、失效問題處理：配置消息監(jiān)聽，借助 redis 的 key 失效通知設(shè)置優(yōu)惠券狀態(tài)

1、打開 idea，創(chuàng)建 coupon-expired 的 maven 工程。

--> idea --> File 
	--> New --> Project 
	--> Maven 
		Project SDK: ( 1.8(java version "1.8.0_131" ) 
	--> Next 
	--> Groupld : ( djh.it )
		Artifactld : ( coupon-expired )
		Version : 1.0-SNAPSHOT
	--> Name: ( coupon-expired )
		Location: ( ...\coupon-expired\ )	
	--> Finish

2、在工程 coupon-expired （模塊）中的 pom.xml 中導(dǎo)入依賴

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>cn.itcast</groupId>
	<artifactId>coupon-expired</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>war</packaging>
	<properties>
		<spring.version>4.2.4.RELEASE</spring.version>
		<slf4j.version>1.6.6</slf4j.version>
		<log4j.version>1.2.12</log4j.version>
		<springdataredis.version>1.7.4.RELEASE</springdataredis.version>
		<!--		<mysql.version>5.1.6</mysql.version>-->
		<mysql.version>8.0.23</mysql.version>
	</properties>
	<dependencies>
		<!-- spring data redis相關(guān)坐標(biāo) beg -->
		<dependency>
			<groupId>redis.clients</groupId>
			<artifactId>jedis</artifactId>
			<version>2.6.2</version>
		</dependency>
		<dependency>
			<groupId>org.apache.commons</groupId>
			<artifactId>commons-pool2</artifactId>
<!--			<version>2.2</version>-->
			<version>2.4.2</version>
		</dependency>
		<dependency>
			<groupId>org.springframework.data</groupId>
			<artifactId>spring-data-redis</artifactId>
			<version>${springdataredis.version}</version>
		</dependency>
		<!-- spring data redis相關(guān)坐標(biāo) end -->
		<!-- spring 相關(guān)坐標(biāo) beg -->
		<dependency>
			<groupId>org.aspectj</groupId>
			<artifactId>aspectjweaver</artifactId>
			<version>1.6.8</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-aop</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-orm</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-beans</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-core</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<!-- spring 相關(guān)坐標(biāo) end -->
		<!-- 日志相關(guān)坐標(biāo) beg -->
		<dependency>
			<groupId>log4j</groupId>
			<artifactId>log4j</artifactId>
			<version>${log4j.version}</version>
		</dependency>
		<dependency>
			<groupId>org.slf4j</groupId>
			<artifactId>slf4j-api</artifactId>
			<version>${slf4j.version}</version>
		</dependency>
		<dependency>
			<groupId>org.slf4j</groupId>
			<artifactId>slf4j-log4j12</artifactId>
			<version>${slf4j.version}</version>
		</dependency>
		<!-- 日志相關(guān)坐標(biāo) end -->
		<!-- 單元測(cè)試相關(guān)坐標(biāo) beg -->
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-test</artifactId>
			<version>4.2.4.RELEASE</version>
		</dependency>
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>4.10</version>
		</dependency>
		<!-- 單元測(cè)試相關(guān)坐標(biāo) end -->
		<!-- druid數(shù)據(jù)庫(kù)連接池 beg -->
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>druid</artifactId>
			<version>1.1.9</version>
		</dependency>
		<!-- druid數(shù)據(jù)庫(kù)連接池 end -->
		<!-- mysql驅(qū)動(dòng) beg -->
		<dependency>
			<groupId>mysql</groupId>
			<artifactId>mysql-connector-java</artifactId>
			<version>${mysql.version}</version>
		</dependency>
		<!-- mysql驅(qū)動(dòng) end -->
		<!-- mybatis核心包 -->
		<dependency>
			<groupId>org.mybatis</groupId>
			<artifactId>mybatis</artifactId>
			<version>3.4.5</version>
		</dependency>
		<!-- mybatis整合spring -->
		<dependency>
             <groupId>org.mybatis</groupId>
             <artifactId>mybatis-spring</artifactId>
             <version>1.3.1</version>
         </dependency>
	</dependencies>
	<build>
		<finalName>coupon-expired</finalName>
		<pluginManagement>
			<plugins>
				<plugin>
					<groupId>org.apache.maven.plugins</groupId>
					<artifactId>maven-compiler-plugin</artifactId>
					<version>3.2</version>
					<configuration>
						<source>1.8</source>
						<target>1.8</target>
						<encoding>UTF-8</encoding>
						<showWarnings>true</showWarnings>
					</configuration>
				</plugin>
			</plugins>
		</pluginManagement>
	</build>
</project>
<!-- redis-coupon\coupon-expired2\pom.xml -->

3、在工程 coupon-expired （模塊）中，創(chuàng)建監(jiān)聽器類 RedisMessageListener.java

/**
 *  redis-coupon\coupon-expired2\src\main\java\cn\itcast\redis\listener\RedisMessageListener.java
 *
 *  2024-7-24 創(chuàng)建監(jiān)聽器類 RedisMessageListener.java
 */
package cn.itcast.redis.listener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import cn.itcast.entity.Coupon;
import cn.itcast.mapper.CouponMapper;
public class RedisMessageListener implements MessageListener {
	@Autowired
	private CouponMapper couponMapper;
	//處理消息
	/**
	 * 獲取的時(shí)失效key通知：
	 * 		發(fā)送的消息：key（coupon:優(yōu)惠券id）
	 * 
	 *  1.接收到消息獲取消息（驗(yàn)證是否時(shí)優(yōu)惠券失效的key）
	 *  2.從消息中分離出優(yōu)惠券id
	 *  3.查詢數(shù)據(jù)庫(kù)獲取優(yōu)惠券對(duì)象
	 *  4.設(shè)置失效狀態(tài)，更新數(shù)據(jù)庫(kù)
	 * 
	 */
	public void onMessage(Message message, byte[] pattern) {
		String key = new String (message.getBody());
		if(key.startsWith("coupon")) {
			String id = key.split(":")[1];
			Coupon coupon = couponMapper.selectCouponById(Long.parseLong(id));
			coupon.setState(1);
			couponMapper.updateCoupon(coupon);
		}
	}
}

4、在工程 coupon-expired （模塊）中，創(chuàng)建實(shí)體類 Coupon.java

/**
 *  redis-coupon\coupon-expired2\src\main\java\cn\itcast\entity\Coupon.java
 *
 *  2024-7-24 創(chuàng)建實(shí)體類 Coupon.java
 */
package cn.itcast.entity;
import java.math.BigDecimal;
import java.util.Date;
/**
 * 優(yōu)惠券實(shí)體類
 */
public class Coupon {
	private Long id;//主鍵id
	private String name;//優(yōu)惠券名稱
	private BigDecimal money;//優(yōu)惠券金額
	private String couponDesc;//說明
	private Date createTime;//獲取時(shí)間
	private Date expireTime;//失效時(shí)間
	private Integer state;//狀態(tài) 0：可用 1：已失效 2：已使用
	public Coupon() {}
	public Coupon(String name, BigDecimal money, String couponDesc, Date createTime, Date expireTime,Integer state) {
		this.name = name;
		this.money = money;
		this.couponDesc = couponDesc;
		this.createTime = createTime;
		this.expireTime = expireTime;
		this.state = state;
	}
	public Long getId() {
		return id;
	}
	public void setId(Long id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public BigDecimal getMoney() {
		return money;
	}
	public void setMoney(BigDecimal money) {
		this.money = money;
	}
	public String getCouponDesc() {
		return couponDesc;
	}
	public void setCouponDesc(String couponDesc) {
		this.couponDesc = couponDesc;
	}
	public Date getCreateTime() {
		return createTime;
	}
	public void setCreateTime(Date createTime) {
		this.createTime = createTime;
	}
	public Date getExpireTime() {
		return expireTime;
	}
	public void setExpireTime(Date expireTime) {
		this.expireTime = expireTime;
	}
	public Integer getState() {
		return state;
	}
	public void setState(Integer state) {
		this.state = state;
	}
	@Override
	public String toString() {
		return "Coupon [id=" + id + ", name=" + name + ", money=" + money + ", couponDesc=" + couponDesc
				+ ", createTime=" + createTime + ", expireTime=" + expireTime + ", state=" + state + "]";
	}
}

5、在工程 coupon-expired （模塊）中，創(chuàng)建映射類 CouponMapper.java

/**
 *  redis-coupon\coupon-expired2\src\main\java\cn\itcast\mapper\CouponMapper.java
 *
 *  2024-7-24 創(chuàng)建映射類 CouponMapper.java
 */
package cn.itcast.mapper;
import cn.itcast.entity.Coupon;
public interface CouponMapper {
	//保存優(yōu)惠券信息
	public void saveCoupon(Coupon coupon);
	//根據(jù)id更新優(yōu)惠券信息
	public void updateCoupon(Coupon coupon);
	//根據(jù)id查詢優(yōu)惠券信息
	public Coupon selectCouponById(long id);
}

6、在工程 coupon-expired （模塊）中，創(chuàng)建工具類 DataUtils.java

/**
 *  redis-coupon.coupon-expired2.src.main.java.cn.itcast.utils.DataUtils.java
 *
 *  2024-7-24 創(chuàng)建工具類 DataUtils.java
 */
package cn.itcast.utils;
import java.util.Calendar;
import java.util.Date;
public class DataUtils {
	public static Date addTime(Date date,int minute) {
		Calendar calendar = Calendar.getInstance();
		calendar.setTime(date);
		calendar.add(Calendar.MINUTE, 10);
		return calendar.getTime();
	}
}

7、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 CouponMapper.xml 。

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="cn.itcast.mapper.CouponMapper">
	<resultMap id="BaseResultMap" type="cn.itcast.entity.Coupon">
		<id column="id" property="id" jdbcType="BIGINT" />
		<result column="name" property="name" jdbcType="VARCHAR" />
		<result column="money" property="money" jdbcType="DECIMAL" />
		<result column="coupon_desc" property="couponDesc" jdbcType="VARCHAR" />
		<result column="create_time" property="createTime" jdbcType="TIMESTAMP" />
		<result column="expire_time" property="expireTime" jdbcType="TIMESTAMP" />
		<result column="state" property="state" jdbcType="INTEGER" />
	</resultMap>
	<sql id="Base_Column_List">
		id,name,money,coupon_desc,create_time,expire_time,state
	</sql>
	<sql id="table">
		t_coupon
	</sql>
	<select id="selectCouponById" resultMap="BaseResultMap" parameterType="long">
		select <include refid="Base_Column_List" /> from <include refid="table" /> where id =#{id,jdbcType=BIGINT}
	</select>
	<insert id="saveCoupon" parameterType="cn.itcast.entity.Coupon" useGeneratedKeys="true" keyColumn="id" keyProperty="id">
		insert into <include refid="table" /> (name,money,coupon_desc,create_time,expire_time,state)
		values (#{name}, #{money},#{couponDesc},#{createTime}, #{expireTime}, #{state})
	</insert>
	<update id="updateCoupon" parameterType="cn.itcast.entity.Coupon">
		update <include refid="table" />
		set name = #{name},
		money = #{money},
		coupon_desc = #{couponDesc},
		create_time = #{createTime},
		expire_time = #{expireTime},
		state = #{state,jdbcType=INTEGER}
		where  id = #{id,jdbcType=BIGINT}
	</update>
</mapper>
<!-- redis-coupon\coupon-expired2\src\main\resources\cn\itcast\mapper\CouponMapper.xml -->

8、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 applicationContext.xml 。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:context="http://www.springframework.org/schema/context" 
	xmlns:mvc="http://www.springframework.org/schema/mvc"
	xmlns:aop="http://www.springframework.org/schema/aop" 
	xmlns:tx="http://www.springframework.org/schema/tx"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
	http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
	http://www.springframework.org/schema/context 
	http://www.springframework.org/schema/context/spring-context-4.0.xsd
	http://www.springframework.org/schema/mvc 
	http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd
	http://www.springframework.org/schema/aop 
	http://www.springframework.org/schema/aop/spring-aop-4.0.xsd 
	http://www.springframework.org/schema/tx 
	http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
	http://www.springframework.org/schema/util 
	http://www.springframework.org/schema/util/spring-util-4.0.xsd">
	<context:component-scan base-package="cn.itcast"></context:component-scan>
	<!-- 1.數(shù)據(jù)源,連接數(shù)據(jù)庫(kù) -->
	<context:property-placeholder location="classpath:jdbc.properties"/>
	<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
		<property name="driverClassName" value="${jdbc.driver}"></property>
		<property name="url" value="${jdbc.url}"></property>
		<property name="username" value="${jdbc.username}"></property>
		<property name="password" value="${jdbc.password}"></property>
	</bean>
	<!-- 2.工廠 生產(chǎn)sqlSession -->
	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
		<property name="dataSource" ref="dataSource"></property>
		<property name="typeAliasesPackage" value="cn.itcast.entity"></property>
		<property name="configLocation" value="classpath:sqlMapConfig.xml"></property>
	</bean>
	<!-- 3.掃描接口,接口代理開發(fā) -->
	 <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
	 	<property name="basePackage" value="cn.itcast.mapper"></property>
	 </bean>
	<!-- 4. 創(chuàng)建事物管理平臺(tái)(對(duì)象) -->
	<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource"></property>
	</bean>
	<!-- 5.事物管理策略 -->
	<tx:advice id="txAdvice" transaction-manager="transactionManager">
		<tx:attributes>
			<tx:method name="save*" propagation="REQUIRED"/>
			<tx:method name="update*" propagation="REQUIRED"/>
			<tx:method name="delete*" propagation="REQUIRED"/>
			<tx:method name="*" propagation="REQUIRED"/>
		</tx:attributes>
	</tx:advice>
	<!-- 6.事物切面 -->
	<aop:config>
		<aop:advisor advice-ref="txAdvice" pointcut="execution(* cn.itcast.service.*.*(..))"/>
	</aop:config>
	<import resource="classpath:applicationContext-data-redis.xml"/>
</beans>
<!-- redis-coupon\coupon-expired2\src\main\resources\applicationContext.xml -->

9、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 applicationContext-data-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
		">
	<description>spring-data整合jedis</description>
	<!-- springData Redis的核心API -->
	<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
		<property name="connectionFactory" ref="connectionFactory"></property>
		<property name="keySerializer">
			<bean class="org.springframework.data.redis.serializer.StringRedisSerializer"></bean>	
		</property>
		<property name="valueSerializer">
			<bean class="org.springframework.data.redis.serializer.StringRedisSerializer"></bean>
		</property>
	</bean>
	<!-- 連接工廠 -->
	<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="maxIdle" value="5"></property>
		<property name="maxTotal" value="10"></property>
		<property name="testOnBorrow" value="true"></property>
	</bean>
	<!-- 配置監(jiān)聽 -->
	<bean class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter" id="messageListener">
	    <constructor-arg>
	        <bean class="cn.itcast.redis.listener.RedisMessageListener"/>
	    </constructor-arg>
	</bean>
	<!-- 監(jiān)聽容器 -->
	<bean class="org.springframework.data.redis.listener.RedisMessageListenerContainer" id="redisContainer">
	    <property name="connectionFactory" ref="connectionFactory"/>
	    <property name="messageListeners">
	    	<map>
	            <entry key-ref="messageListener">
	                <list>
	                	<!-- __keyevent@0__:expired  配置訂閱的主題名稱
	                	此名稱時(shí)redis提供的名稱，標(biāo)識(shí)過期key消息通知
	                			0表示db0 根據(jù)自己的dbindex選擇合適的數(shù)字
	                	 -->
	                    <bean class="org.springframework.data.redis.listener.ChannelTopic">
	                        <constructor-arg value="__keyevent@0__:expired"></constructor-arg>
	                    </bean>
	                </list>
	            </entry>
		    </map>
		 </property>
	</bean>
</beans>
<!-- redis-coupon\coupon-expired2\src\main\resources\applicationContext-data-redis.xml -->

10、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 jdbc.properties。

# redis-coupon\coupon-expired2\src\main\resources\jdbc.properties
jdbc.url=jdbc:mysql://localhost:3306/coupon
jdbc.driver=com.mysql.jdbc.Driver
jdbc.username=root
jdbc.password=12311

11、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 sqlMapConfig.xml。

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>	
</configuration>

12、在工程 coupon-expired （模塊）中，創(chuàng)建日志文件 log4j.properties

# redis-coupon\coupon-expired2\src\main\resources\log4j.properties
### direct log messages to stdout ###
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target=System.out
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n
### direct messages to file mylog.log ###
log4j.appender.file=org.apache.log4j.FileAppender
log4j.appender.file.File=c:/mylog.log
log4j.appender.file.layout=org.apache.log4j.PatternLayout
log4j.appender.file.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n
### set log levels - for more verbose logging change 'info' to 'debug' ###
log4j.rootLogger=debug, stdout

13、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 CouponTest.java

/**
 *  redis-coupon\coupon-expired2\src\test\java\cn\itcast\coupon\test\CouponTest.java
 *
 *  2024-7-24 創(chuàng)建測(cè)試類 CouponTest.java
 */
package cn.itcast.coupon.test;
import java.math.BigDecimal;
import java.util.Date;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import cn.itcast.entity.Coupon;
import cn.itcast.mapper.CouponMapper;
import cn.itcast.utils.DataUtils;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext.xml")
public class CouponTest {
	@Autowired
	private CouponMapper couponMapper;
	@Test
	public void testSaveCoupon() {
		Date now = new Date();
		Coupon coupon = new Coupon("測(cè)試優(yōu)惠券", BigDecimal.ONE, 
				"全品類優(yōu)惠10元", now, DataUtils.addTime(now, 1),0);
		couponMapper.saveCoupon(coupon );
	}
	@Test
	public void testUpdateCoupon() {
		Coupon coupon = couponMapper.selectCouponById(1l);
		coupon.setState(1);
		couponMapper.updateCoupon(coupon);
	}
	@Test
	public void selectCouponById() {
		Coupon coupon = couponMapper.selectCouponById(1l);
		System.out.println(coupon);
	}
}

14、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 RedisTest.java

/**
 *  redis-coupon\coupon-expired2\src\test\java\cn\itcast\redis\RedisTest.java
 *
 *  2024-7-24 創(chuàng)建測(cè)試類 RedisTest.java
 */
package cn.itcast.redis;
import java.util.concurrent.TimeUnit;
import org.apache.log4j.Logger;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext-data-redis.xml")
public class RedisTest {
	private static Logger log = Logger.getLogger(RedisTest.class);
	@Autowired
	private RedisTemplate<String, String> redisTemplate;
	@Test
	public void testSend() {
		redisTemplate.opsForValue().set("itcast","very good！");
		String value = redisTemplate.opsForValue().get("itcast");
		log.info("從redis中獲取的數(shù)據(jù)："+value);
	}
}

15、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 RedisTest2.java

/**
 *  redis-coupon\coupon-expired2\src\test\java\cn\itcast\redis\RedisTest2.java
 *
 *  2024-7-24 創(chuàng)建測(cè)試類 RedisTest2.java
 */
package cn.itcast.redis;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class RedisTest2 {
	public static void main(String[] args) {
		ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml");
	}
}

16、啟動(dòng) redis 服務(wù)端和客戶端，

1）在工程 coupon-expired （模塊）中，運(yùn)行測(cè)試類 RedisTest2.java 進(jìn)行監(jiān)聽。

2）在工程 coupon-achieve （模塊）中，運(yùn)行測(cè)試類 CouponTest.java 進(jìn)行測(cè)試，
在數(shù)據(jù)庫(kù)中查詢到插入的記錄，redis 客戶端也查詢到數(shù)據(jù)，但 1 分鐘后失效。
同時(shí)，mysql 數(shù)據(jù)庫(kù)中的狀態(tài)，由 “0” 變?yōu)?“1”。

七、總結(jié)

1、- 對(duì)于過期代金卷，紅包，訂單解決方案的分析

2、- redis消息隊(duì)列的介紹及入門

3、- redis整合SpringData redis開發(fā)

4、- 在Java程序中監(jiān)聽redis消息通知

5、- 結(jié)合redis的key失效機(jī)制和消息通知完成過期訂單處理

上一節(jié)關(guān)聯(lián)鏈接請(qǐng)點(diǎn)擊
# redis 高級(jí)應(yīng)用–使用 redis 消息隊(duì)列完成秒殺過期訂單處理（1）

到此這篇關(guān)于如何使用 redis 消息隊(duì)列完成秒殺過期訂單處理操作的文章就介紹到這了,更多相關(guān)redis 秒殺過期訂單處理內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线 免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

如何使用?redis?消息隊(duì)列完成秒殺過期訂單處理操作(二)

目錄

redis 高級(jí)應(yīng)用–使用 redis 消息隊(duì)列完成秒殺過期訂單處理

一、springDataRedis 中定義消息的監(jiān)聽器

1、在 JAVA 程序中監(jiān)聽 redis 消息：配置監(jiān)聽 redis 的消息。

2、在工程 spring-data-redis-test （模塊）中，創(chuàng)建消息的監(jiān)聽器 類 RedisMessageListener.java

二、springDataRedis 中配置消息的監(jiān)聽器

1、配置消息的監(jiān)聽器：

2、在工程 spring-data-redis-test （模塊）中，修改 配置文件 applicationContext-redis.xml 添加消息監(jiān)聽。

三、springDataRedis 中測(cè)試消息通知

1、在工程 spring-data-redis-test （模塊）中，創(chuàng)建 測(cè)試類 RedisTest02.java

2、運(yùn)行測(cè)試類 RedisTest02.java 進(jìn)行消息監(jiān)聽，同時(shí)啟動(dòng)一客戶端，連接 redis 服務(wù)端，

3、測(cè)試消息說明

四、失效問題處理：業(yè)務(wù)分析以及資料介紹

1、結(jié)合 redis 的 key 失效機(jī)制和消息完成過期優(yōu)惠券處理，解決過期優(yōu)惠券的問題：

2、模擬過期代金卷案例介紹：

3、mysql 數(shù)據(jù)庫(kù)表創(chuàng)建。

五、失效問題處理：模擬獲取優(yōu)惠券

1、在工程 spring-data-redis-test （模塊）中，創(chuàng)建 測(cè)試類 RedisTest02.java

2、運(yùn)行測(cè)試類 RedisTest02.java 進(jìn)行消息監(jiān)聽，同時(shí)啟動(dòng)一客戶端，連接 redis 服務(wù)端，

3、測(cè)試消息說明

redis 高級(jí)應(yīng)用–使用 redis 消息隊(duì)列完成秒殺過期訂單處理（2）

四、失效問題處理：業(yè)務(wù)分析以及資料介紹

1、結(jié)合 redis 的 key 失效機(jī)制和消息完成過期優(yōu)惠券處理，解決過期優(yōu)惠券的問題：

2、模擬過期代金卷案例介紹：

3、mysql 數(shù)據(jù)庫(kù)表創(chuàng)建。

redis 高級(jí)應(yīng)用–使用 redis 消息隊(duì)列完成秒殺過期訂單處理（2）

五、失效問題處理：模擬獲取優(yōu)惠券

1、打開 idea，創(chuàng)建 coupon-achieve 的 maven 工程。

2、在工程 coupon-achieve （模塊）中的 pom.xml 中導(dǎo)入依賴

3、在工程 coupon-achieve （模塊）中，創(chuàng)建實(shí)體類 Coupon.java

4、在工程 coupon-achieve （模塊）中，創(chuàng)建映射類 CouponMapper.java

5、在工程 coupon-achieve （模塊）中，創(chuàng)建工具類 CouponMapper.java

6、在工程 coupon-achieve （模塊）中，創(chuàng)建 配置文件 CouponMapper.xml

7、在工程 coupon-achieve （模塊）中，創(chuàng)建 applicationContext.xml 配置文件。

8、在工程 coupon-achieve （模塊）中，創(chuàng)建 applicationContext-data-redis.xml 配置文件。

9、在工程 coupon-achieve （模塊）中，創(chuàng)建 jdbc.properties 配置文件。

10、在工程 coupon-achieve （模塊）中，創(chuàng)建 sqlMapConfig.xml 配置文件。

11、在工程 coupon-achieve （模塊）中，創(chuàng)建 log4j.properties 日志文件。

12、在工程 coupon-achieve （模塊）中，創(chuàng)建測(cè)試類 CouponTest.java

13、啟動(dòng) redis 服務(wù)端和客戶端，運(yùn)行測(cè)試類 CouponTest.java 進(jìn)行測(cè)試，如下圖，

六、失效問題處理：配置消息監(jiān)聽，借助 redis 的 key 失效通知設(shè)置優(yōu)惠券狀態(tài)

1、打開 idea，創(chuàng)建 coupon-expired 的 maven 工程。

2、 在工程 coupon-expired （模塊）中的 pom.xml 中導(dǎo)入依賴

3、在工程 coupon-expired （模塊）中，創(chuàng)建監(jiān)聽器類 RedisMessageListener.java

4、在工程 coupon-expired （模塊）中，創(chuàng)建實(shí)體類 Coupon.java

5、在工程 coupon-expired （模塊）中，創(chuàng)建映射類 CouponMapper.java

6、在工程 coupon-expired （模塊）中，創(chuàng)建工具類 DataUtils.java

7、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 CouponMapper.xml 。

8、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 applicationContext.xml 。

9、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 applicationContext-data-redis.xml。

10、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 jdbc.properties。

11、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 sqlMapConfig.xml。

12、在工程 coupon-expired （模塊）中，創(chuàng)建日志文件 log4j.properties

13、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 CouponTest.java

14、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 RedisTest.java

15、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 RedisTest2.java

16、啟動(dòng) redis 服務(wù)端和客戶端，

七、總結(jié)

相關(guān)文章

最新評(píng)論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

一、springDataRedis 中定義消息的監(jiān)聽器

1、在 JAVA 程序中監(jiān)聽 redis 消息：配置監(jiān)聽 redis 的消息。

2、在工程 spring-data-redis-test （模塊）中，創(chuàng)建消息的監(jiān)聽器類 RedisMessageListener.java

二、springDataRedis 中配置消息的監(jiān)聽器

2、在工程 spring-data-redis-test （模塊）中，修改配置文件 applicationContext-redis.xml 添加消息監(jiān)聽。

三、springDataRedis 中測(cè)試消息通知

1、在工程 spring-data-redis-test （模塊）中，創(chuàng)建測(cè)試類 RedisTest02.java

2、運(yùn)行測(cè)試類 RedisTest02.java 進(jìn)行消息監(jiān)聽，同時(shí)啟動(dòng)一客戶端，連接 redis 服務(wù)端，

四、失效問題處理：業(yè)務(wù)分析以及資料介紹

1、結(jié)合 redis 的 key 失效機(jī)制和消息完成過期優(yōu)惠券處理，解決過期優(yōu)惠券的問題：

3、mysql 數(shù)據(jù)庫(kù)表創(chuàng)建。

五、失效問題處理：模擬獲取優(yōu)惠券

1、在工程 spring-data-redis-test （模塊）中，創(chuàng)建測(cè)試類 RedisTest02.java

2、運(yùn)行測(cè)試類 RedisTest02.java 進(jìn)行消息監(jiān)聽，同時(shí)啟動(dòng)一客戶端，連接 redis 服務(wù)端，

1、結(jié)合 redis 的 key 失效機(jī)制和消息完成過期優(yōu)惠券處理，解決過期優(yōu)惠券的問題：

2、模擬過期代金卷案例介紹：

3、mysql 數(shù)據(jù)庫(kù)表創(chuàng)建。

1、打開 idea，創(chuàng)建 coupon-achieve 的 maven 工程。

3、在工程 coupon-achieve （模塊）中，創(chuàng)建實(shí)體類 Coupon.java

4、在工程 coupon-achieve （模塊）中，創(chuàng)建映射類 CouponMapper.java

5、在工程 coupon-achieve （模塊）中，創(chuàng)建工具類 CouponMapper.java

6、在工程 coupon-achieve （模塊）中，創(chuàng)建配置文件 CouponMapper.xml

7、在工程 coupon-achieve （模塊）中，創(chuàng)建 applicationContext.xml 配置文件。

8、在工程 coupon-achieve （模塊）中，創(chuàng)建 applicationContext-data-redis.xml 配置文件。

9、在工程 coupon-achieve （模塊）中，創(chuàng)建 jdbc.properties 配置文件。

10、在工程 coupon-achieve （模塊）中，創(chuàng)建 sqlMapConfig.xml 配置文件。

11、在工程 coupon-achieve （模塊）中，創(chuàng)建 log4j.properties 日志文件。

12、在工程 coupon-achieve （模塊）中，創(chuàng)建測(cè)試類 CouponTest.java

13、啟動(dòng) redis 服務(wù)端和客戶端，運(yùn)行測(cè)試類 CouponTest.java 進(jìn)行測(cè)試，如下圖，

六、失效問題處理：配置消息監(jiān)聽，借助 redis 的 key 失效通知設(shè)置優(yōu)惠券狀態(tài)

1、打開 idea，創(chuàng)建 coupon-expired 的 maven 工程。

2、在工程 coupon-expired （模塊）中的 pom.xml 中導(dǎo)入依賴

3、在工程 coupon-expired （模塊）中，創(chuàng)建監(jiān)聽器類 RedisMessageListener.java

4、在工程 coupon-expired （模塊）中，創(chuàng)建實(shí)體類 Coupon.java

5、在工程 coupon-expired （模塊）中，創(chuàng)建映射類 CouponMapper.java

6、在工程 coupon-expired （模塊）中，創(chuàng)建工具類 DataUtils.java

7、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 CouponMapper.xml 。

8、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 applicationContext.xml 。

9、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 applicationContext-data-redis.xml。

10、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 jdbc.properties。

11、在工程 coupon-expired （模塊）中，創(chuàng)建配置文件 sqlMapConfig.xml。

12、在工程 coupon-expired （模塊）中，創(chuàng)建日志文件 log4j.properties

13、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 CouponTest.java

14、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 RedisTest.java

15、在工程 coupon-expired （模塊）中，創(chuàng)建測(cè)試類 RedisTest2.java

16、啟動(dòng) redis 服務(wù)端和客戶端，

七、總結(jié)