如何使用?redis?消息隊(duì)列完成秒殺過(guò)期訂單處理操作(二)
更新時(shí)間：2024年07月30日 11:01:14 作者：段子手-168
這篇文章主要介紹了如何使用?redis?消息隊(duì)列完成秒殺過(guò)期訂單處理操作,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧
redis 高級(jí)應(yīng)用–使用 redis 消息隊(duì)列完成秒殺過(guò)期訂單處理
一、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)聽器來(lái)進(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è)試消息說(shuō)明
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í)候通過(guò) redis 的客戶端程序（redis-cli）發(fā)布一條消息。
3）publish topic名稱 消息內(nèi)容 ： 向指定頻道發(fā)送一條消息。
發(fā)送消息之后，我們?cè)趤?lái)看 java 控制臺(tái)輸出驗(yàn)證是否獲取到了此消息。
4）至此已經(jīng)完成了在 java 代碼中獲取 redis 的消息通知。
四、失效問(wèn)題處理：業(yè)務(wù)分析以及資料介紹
1、結(jié)合 redis 的 key 失效機(jī)制和消息完成過(guò)期優(yōu)惠券處理，解決過(guò)期優(yōu)惠券的問(wèn)題：
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）這也帶來(lái)了一些繁瑣的操作：用戶獲取到優(yōu)惠券之后需要將優(yōu)惠券存入 redis 服務(wù)器并設(shè)置超時(shí)時(shí)間。
3）由于要借助redis的key失效通知，有兩個(gè)注意事項(xiàng)各位需要注意：
事件通過(guò) Redis 的訂閱與發(fā)布功能（pub/sub）來(lái)進(jìn)行分發(fā),故需要訂閱（__keyevent@0__:expired）頻道 0表示db0 根據(jù)自己的dbindex選擇合適的數(shù)字。
修改 redis.conf 文件
# 添加 notify-keyspace-events Ex
2、模擬過(guò)期代金卷案例介紹：
1）使用 redis 的消息通知結(jié)合 springDataRedis 完成一個(gè)過(guò)期優(yōu)惠券的處理。
2）需要兩套程序，一個(gè)模擬 用戶獲取優(yōu)惠券（coupon-achieve），一個(gè)模擬 過(guò)期優(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
過(guò)期優(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)惠券說(shuō)明', `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
五、失效問(wèn)題處理：模擬獲取優(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è)試消息說(shuō)明
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í)候通過(guò) redis 的客戶端程序（redis-cli）發(fā)布一條消息。
3）publish topic名稱 消息內(nèi)容 ： 向指定頻道發(fā)送一條消息。
發(fā)送消息之后，我們?cè)趤?lái)看 java 控制臺(tái)輸出驗(yàn)證是否獲取到了此消息。
4）至此已經(jīng)完成了在 java 代碼中獲取 redis 的消息通知。
12-失效問(wèn)題處理：業(yè)務(wù)分析以及資料介紹
redis 高級(jí)應(yīng)用–使用 redis 消息隊(duì)列完成秒殺過(guò)期訂單處理（2）
四、失效問(wèn)題處理：業(yè)務(wù)分析以及資料介紹
1、結(jié)合 redis 的 key 失效機(jī)制和消息完成過(guò)期優(yōu)惠券處理，解決過(guò)期優(yōu)惠券的問(wèn)題：
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）這也帶來(lái)了一些繁瑣的操作：用戶獲取到優(yōu)惠券之后需要將優(yōu)惠券存入 redis 服務(wù)器并設(shè)置超時(shí)時(shí)間。
3）由于要借助redis的key失效通知，有兩個(gè)注意事項(xiàng)各位需要注意：
事件通過(guò) Redis 的訂閱與發(fā)布功能（pub/sub）來(lái)進(jìn)行分發(fā),故需要訂閱（__keyevent@0__:expired）頻道 0表示db0 根據(jù)自己的dbindex選擇合適的數(shù)字。
修改 redis.conf 文件
# 添加 notify-keyspace-events Ex
2、模擬過(guò)期代金卷案例介紹：
1）使用 redis 的消息通知結(jié)合 springDataRedis 完成一個(gè)過(guò)期優(yōu)惠券的處理。
2）需要兩套程序，一個(gè)模擬 用戶獲取優(yōu)惠券，一個(gè)模擬 過(guò)期優(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
過(guò)期優(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)惠券說(shuō)明', `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-失效問(wèn)題處理：模擬獲取優(yōu)惠券
redis 高級(jí)應(yīng)用–使用 redis 消息隊(duì)列完成秒殺過(guò)期訂單處理（2）
五、失效問(wèn)題處理：模擬獲取優(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;//說(shuō)明
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, stdout12、在工程 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 分鐘后失效。
六、失效問(wèn)題處理：配置消息監(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;//說(shuō)明
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í)過(guò)期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, stdout13、在工程 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ì)于過(guò)期代金卷，紅包，訂單解決方案的分析
2、- redis消息隊(duì)列的介紹及入門
3、- redis整合SpringData redis開發(fā)
4、- 在Java程序中監(jiān)聽redis消息通知
5、- 結(jié)合redis的key失效機(jī)制和消息通知完成過(guò)期訂單處理
上一節(jié)關(guān)聯(lián)鏈接請(qǐng)點(diǎn)擊
# redis 高級(jí)應(yīng)用–使用 redis 消息隊(duì)列完成秒殺過(guò)期訂單處理（1）
到此這篇關(guān)于如何使用 redis 消息隊(duì)列完成秒殺過(guò)期訂單處理操作的文章就介紹到這了,更多相關(guān)redis 秒殺過(guò)期訂單處理內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:
- Springboot3+Redis實(shí)現(xiàn)消息隊(duì)列的多種方法小結(jié)
- 一文詳解消息隊(duì)列中為什么不用redis作為隊(duì)列
- SpringBoot集成Redisson實(shí)現(xiàn)消息隊(duì)列的示例代碼
- redis?消息隊(duì)列完成秒殺過(guò)期訂單處理方法(一)
- Redis高階使用消息隊(duì)列分布式鎖排行榜等(高階用法)
- Redis消息隊(duì)列的三種實(shí)現(xiàn)方式
- Redis使用ZSET實(shí)現(xiàn)消息隊(duì)列的項(xiàng)目實(shí)踐
- Redis使用ZSET實(shí)現(xiàn)消息隊(duì)列使用小結(jié)
- python使用redis實(shí)現(xiàn)消息隊(duì)列(異步)的實(shí)現(xiàn)完整例程
- 詳解Redis Stream做消息隊(duì)列
- 基于Redis實(shí)現(xiàn)消息隊(duì)列的示例代碼
相關(guān)文章
Redis優(yōu)化token校驗(yàn)主動(dòng)失效的實(shí)現(xiàn)方案
在普通的token頒發(fā)和校驗(yàn)中 當(dāng)用戶發(fā)現(xiàn)自己賬號(hào)和密碼被暴露了時(shí)修改了登錄密碼后舊的token仍然可以通過(guò)系統(tǒng)校驗(yàn)直至token到達(dá)失效時(shí)間,所以系統(tǒng)需要token主動(dòng)失效的一種能力,所以本文給大家介紹了Redis優(yōu)化token校驗(yàn)主動(dòng)失效的實(shí)現(xiàn)方案,需要的朋友可以參考下2024-03-03
解析高可用Redis服務(wù)架構(gòu)分析與搭建方案
我們按照由簡(jiǎn)至繁的步驟，搭建一個(gè)最小型的高可用的Redis服務(wù)。 本文通過(guò)四種方案給大家介紹包含每種方案的優(yōu)缺點(diǎn)及詳細(xì)解說(shuō)，具體內(nèi)容詳情跟隨小編一起看看吧2021-06-06
ziplist 是一個(gè)經(jīng)過(guò)特殊編碼的雙向鏈表，旨在提高內(nèi)存效率，它存儲(chǔ)字符串和整數(shù)值，其中整數(shù)被編碼為實(shí)際整數(shù)而不是一系列字符，這篇文章主要介紹了Redis?ziplist?壓縮列表的源碼解析,需要的朋友可以參考下2022-06-06
Redis連接命令主要是用于客戶端與服務(wù)器建立連接的,Redis是一種流行的內(nèi)存數(shù)據(jù)庫(kù),支持多種數(shù)據(jù)結(jié)構(gòu),其中鍵命令是核心操作之一,在Redis中,鍵（Key）是用來(lái)存儲(chǔ)數(shù)據(jù)的主要元素,每個(gè)鍵都有一個(gè)唯一的名稱,本文給大家介紹了Redis中的連接命令與鍵命令操作2024-09-09
詳解redis腳本命令執(zhí)行問(wèn)題(redis.call)
這篇文章主要介紹了redis腳本命令執(zhí)行問(wèn)題(redis.call),分別介紹了redis-cli命令行中執(zhí)行及l(fā)inux命令行中執(zhí)行問(wèn)題，本文給大家介紹的非常詳細(xì)，需要的朋友參考下吧2022-03-03
Redis壓縮列表的設(shè)計(jì)與實(shí)現(xiàn)
壓縮列表（Ziplist）是 Redis 為了節(jié)省內(nèi)存而設(shè)計(jì)的一種緊湊型數(shù)據(jù)結(jié)構(gòu),主要用于存儲(chǔ)長(zhǎng)度較短且數(shù)量較少的元素集合,本文給大家介紹了Redis壓縮列表的設(shè)計(jì)與實(shí)現(xiàn),文中通過(guò)代碼示例講解的非常詳細(xì),需要的朋友可以參考下2024-08-08
下面小編就為大家?guī)?lái)一篇Redis Sentinel服務(wù)配置流程(詳解)。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-03-03
Redis設(shè)置鍵的生存時(shí)間或過(guò)期時(shí)間的方法詳解
這篇文章主要介紹了Redis如何設(shè)置鍵的生存時(shí)間或過(guò)期時(shí)間,通過(guò)EXPIRE命令或者PEXIPIRE命令,客戶端可以以秒或者毫秒精度為數(shù)據(jù)庫(kù)中的某個(gè)鍵設(shè)置生存時(shí)間,文中有詳細(xì)的代碼供供大家參考,需要的朋友可以參考下2024-03-03
Redis中的跳表是一種高效的多層鏈表結(jié)構(gòu),通過(guò)隨機(jī)概率算法決定節(jié)點(diǎn)的層數(shù),從而實(shí)現(xiàn)快速的插入、刪除和查詢操作,跳表的平均時(shí)間復(fù)雜度為O(logn),最差情況為O(n),每個(gè)節(jié)點(diǎn)包含值和指向更高層節(jié)點(diǎn)的指針,以及回退指針以提高操作效率2025-02-02
Redis實(shí)現(xiàn)訂單自動(dòng)過(guò)期功能的示例代碼
這篇文章主要介紹了Redis實(shí)現(xiàn)訂單自動(dòng)過(guò)期功能的示例代碼，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-05-05