如何使用 redis 消息队列完成秒杀过期订单处理操作(二)

/**
 *  spring-data-redis-test\src\main\java\djh\it\listener\redismessagelistener.java
 *
 *  2024-7-24 创建消息的监听器 类 redismessagelistener.java
 *
 *  配置 redis 消息的监听器：获取 redis 中的消息并进行处理。
 */
package djh.it.listener;
import org.springframework.data.redis.connection.message;
import org.springframework.data.redis.connection.messagelistener;
public class redismessagelistener implements messagelistener {
    /**
     * onmessage : 处理消息。
     *      @param message ：完整的消息（频道的信息，以及消息的具体内容）
     *      @param bytes：获取的频道信息
     */
    @override
    public void onmessage( message message, byte[] bytes ) {
        system.out.println("从channel为：" + new string(message.getchannel())
            +"获取了一条新的消息，消息内容为：" + new string(message.getbody()));
    }
}

<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/xmlschema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:task="http://www.springframework.org/schema/task"
       xsi:schemalocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
            http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd
            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd ">
    <bean id="redistemplate" class="org.springframework.data.redis.core.redistemplate">
        <!-- 设置key序列化方式 -->
        <property name="keyserializer">
            <bean class="org.springframework.data.redis.serializer.stringredisserializer"></bean>
        </property>
        <!-- 设置value序列化方式 -->
        <property name="valueserializer">
            <bean class="org.springframework.data.redis.serializer.stringredisserializer"></bean>
        </property>
        <!-- 注入连接工厂 -->
        <property name="connectionfactory" ref="connectionfactory"></property>
    </bean>
    <!-- 创建connectionfactory交给spring容器管理 -->
    <bean id="connectionfactory" class="org.springframework.data.redis.connection.jedis.jedisconnectionfactory">
        <property name="hostname" value="127.0.0.1"></property>
        <property name="port" value="6379"></property>
        <property name="database" value="0"></property>
        <property name="poolconfig" ref="poolconfig"></property>
    </bean>
    <!-- 创建连接池的基本配置 -->
    <bean id="poolconfig" class="redis.clients.jedis.jedispoolconfig">
        <!-- 最大连接数 -->
        <property name="maxtotal" value="10"></property>
    </bean>
    <!-- 配置消息的监听器：
        1）监听器的适配器：（配置自定义的监听器）
        2）配置监听器容器：（对监听器进行统一管理）
    -->
    <!-- 配置处理消息的消息监听适配器 -->
    <bean class="org.springframework.data.redis.listener.adapter.messagelisteneradapter" id="messagelistener">
        <constructor-arg>
            <!-- 注入自定义的监听器 -->
            <bean class="djh.it.listener.redismessagelistener"></bean>
        </constructor-arg>
    </bean>
    <!-- 配置消息监听器容器 -->
    <bean class="org.springframework.data.redis.listener.redismessagelistenercontainer" id="rediscontainer">
        <!--
            由于需要和 redis 进行交互，注入连接工厂
            1）订阅的消息主题
            2）接收到消息之后处理的监听器
        -->
        <property name="connectionfactory" ref="connectionfactory"></property>
        <property name="messagelisteners">
            <map>
                <entry key-ref="messagelistener">
                    <!-- topic 的集合：订阅的主题
                        订阅了一个主题消息：主题的名称（dzs168)
                        接收到一条消息之后，交由自定义的消息监听器来进行处理
                     -->
                    <list>
                        <bean class="org.springframework.data.redis.listener.channeltopic">
                            <constructor-arg value="dzs168"></constructor-arg>
                        </bean>
                    </list>
                </entry>
            </map>
        </property>
    </bean>
</beans>

/**
 *  spring-data-redis-test\src\test\java\djh\it\redis\test\redistest02.java
 *
 *  2024-7-24 测试类 redistest02.java
 */
package djh.it.redis.test;
import org.springframework.context.applicationcontext;
import org.springframework.context.support.classpathxmlapplicationcontext;
public class redistest02 {
    public static void main( string[] args ) {
        applicationcontext ac = new classpathxmlapplicationcontext("applicationcontext-redis.xml");
    }
}

# 添加 
notify-keyspace-events ex 

# 创建数据库
create database `coupon` character set 'utf8' collate 'utf8_general_ci';
# 使用数据库
use coupon; 
# 创建数据表
drop table if exists `t_coupon`;
create table `t_coupon` (
  `id` bigint(20) not null auto_increment comment '主键',
  `name` varchar(60) default null comment '优惠券名称',
  `money` decimal(10,0) default null comment '金额',
  `coupon_desc` varchar(128) default null comment '优惠券说明',
  `create_time` datetime default null comment '获取时间',
  `expire_time` datetime default null comment '失效时间',
  `state` int(1) default null comment '状态，0-有效，1-已失效，2-已使用',
  primary key (`id`)
) engine=innodb auto_increment=4 default charset=utf8

/**
 *  spring-data-redis-test\src\test\java\djh\it\redis\test\redistest02.java
 *
 *  2024-7-24 测试类 redistest02.java
 */
package djh.it.redis.test;
import org.springframework.context.applicationcontext;
import org.springframework.context.support.classpathxmlapplicationcontext;
public class redistest02 {
    public static void main( string[] args ) {
        applicationcontext ac = new classpathxmlapplicationcontext("applicationcontext-redis.xml");
    }
}

# 添加 
notify-keyspace-events ex 

# 创建数据库
create database `coupon` character set 'utf8' collate 'utf8_general_ci';
# 使用数据库
use coupon; 
# 创建数据表
drop table if exists `t_coupon`;
create table `t_coupon` (
  `id` bigint(20) not null auto_increment comment '主键',
  `name` varchar(60) default null comment '优惠券名称',
  `money` decimal(10,0) default null comment '金额',
  `coupon_desc` varchar(128) default null comment '优惠券说明',
  `create_time` datetime default null comment '获取时间',
  `expire_time` datetime default null comment '失效时间',
  `state` int(1) default null comment '状态，0-有效，1-已失效，2-已使用',
  primary key (`id`)
) engine=innodb auto_increment=4 default charset=utf8

--> 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

<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相关坐标 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相关坐标 end -->
		<!-- spring 相关坐标 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 相关坐标 end -->
		<!-- 日志相关坐标 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>
		<!-- 日志相关坐标 end -->
		<!-- 单元测试相关坐标 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>
		<!-- 单元测试相关坐标 end -->
		<!-- druid数据库连接池 beg -->
		<dependency>
			<groupid>com.alibaba</groupid>
			<artifactid>druid</artifactid>
			<version>1.1.9</version>
		</dependency>
		<!-- druid数据库连接池 end -->
		<!-- mysql驱动 beg -->
		<dependency>
			<groupid>mysql</groupid>
			<artifactid>mysql-connector-java</artifactid>
			<version>${mysql.version}</version>
		</dependency>
		<!-- mysql驱动 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>

/**
 *  redis-coupon\coupon-achieve2\src\main\java\cn\itcast\entity\coupon.java
 *
 *  2024-7-24 创建实体类 coupon.java
 */
package cn.itcast.entity;
import java.math.bigdecimal;
import java.util.date;
/**
 * 优惠券实体类
 */
public class coupon {
	private long id;//主键id
	private string name;//优惠券名称
	private bigdecimal money;//优惠券金额
	private string coupondesc;//说明
	private date createtime;//获取时间
	private date expiretime;//失效时间
	private integer state;//状态 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 + "]";
	}
}

/**
 *  redis-coupon\coupon-achieve2\src\main\java\cn\itcast\mapper\couponmapper.java
 *
 *  2024-7-24 创建映射类 couponmapper.java
 */
package cn.itcast.mapper;
import cn.itcast.entity.coupon;
public interface couponmapper {
	//保存优惠券信息
	public void savecoupon(coupon coupon);
	//根据id更新优惠券信息
	public void updatecoupon(coupon coupon);
	//根据id查询优惠券信息
	public coupon selectcouponbyid(long id);
}

/**
 *  redis-coupon.coupon-achieve2.src.main.java.cn.itcast.utils.datautils.java
 *
 *  2024-7-24 创建工具类 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();
	}
}

<?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 -->

<?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.数据源,连接数据库 -->
	<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.工厂 生产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.扫描接口,接口代理开发 -->
	 <bean class="org.mybatis.spring.mapper.mapperscannerconfigurer">
	 	<property name="basepackage" value="cn.itcast.mapper"></property>
	 </bean>
	<!-- 4. 创建事物管理平台(对象) -->
	<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 -->

<?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 -->

# 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

<?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>

# 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

/**
 *  d:\java-test\idea2019\redis-coupon\coupon-achieve2\src\test\java\cn\itcast\coupon\test\coupontest.java
 *
 *  2024-7-24 创建测试类 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.创建一个优惠券
	 * 2.保存到数据库中
	 * 3.保存到redis服务器中，设置超时时间
	 */
	@test
	public void testgetcoupon() {
		date now = new date();
		int timeout = 1;// 优惠券的超时时间：1分钟
		//自定义一个优惠券
		coupon coupon = new coupon();
		coupon.setname("段子手168优惠券");
		coupon.setmoney(bigdecimal.one);//设置金额
		coupon.setcoupondesc("全品类优惠券50元");
		coupon.setcreatetime(now);
		coupon.setexpiretime(datautils.addtime(now, timeout));//设置优惠券的失效时间，一份后失效
		coupon.setstate(0);
		//将优惠券保存到数据库中
		couponmapper.savecoupon(coupon);
		//将优惠券设置到redis缓存中，并且设置超时件
		redistemplate.opsforvalue().set("coupon:"+coupon.getid(), coupon.getid()+"", timeout, timeunit.minutes);
	}
}

--> 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

<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相关坐标 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相关坐标 end -->
		<!-- spring 相关坐标 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 相关坐标 end -->
		<!-- 日志相关坐标 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>
		<!-- 日志相关坐标 end -->
		<!-- 单元测试相关坐标 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>
		<!-- 单元测试相关坐标 end -->
		<!-- druid数据库连接池 beg -->
		<dependency>
			<groupid>com.alibaba</groupid>
			<artifactid>druid</artifactid>
			<version>1.1.9</version>
		</dependency>
		<!-- druid数据库连接池 end -->
		<!-- mysql驱动 beg -->
		<dependency>
			<groupid>mysql</groupid>
			<artifactid>mysql-connector-java</artifactid>
			<version>${mysql.version}</version>
		</dependency>
		<!-- mysql驱动 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 -->

/**
 *  redis-coupon\coupon-expired2\src\main\java\cn\itcast\redis\listener\redismessagelistener.java
 *
 *  2024-7-24 创建监听器类 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;
	//处理消息
	/**
	 * 获取的时失效key通知：
	 * 		发送的消息：key（coupon:优惠券id）
	 * 
	 *  1.接收到消息获取消息（验证是否时优惠券失效的key）
	 *  2.从消息中分离出优惠券id
	 *  3.查询数据库获取优惠券对象
	 *  4.设置失效状态，更新数据库
	 * 
	 */
	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);
		}
	}
}

/**
 *  redis-coupon\coupon-expired2\src\main\java\cn\itcast\entity\coupon.java
 *
 *  2024-7-24 创建实体类 coupon.java
 */
package cn.itcast.entity;
import java.math.bigdecimal;
import java.util.date;
/**
 * 优惠券实体类
 */
public class coupon {
	private long id;//主键id
	private string name;//优惠券名称
	private bigdecimal money;//优惠券金额
	private string coupondesc;//说明
	private date createtime;//获取时间
	private date expiretime;//失效时间
	private integer state;//状态 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 + "]";
	}
}

/**
 *  redis-coupon\coupon-expired2\src\main\java\cn\itcast\mapper\couponmapper.java
 *
 *  2024-7-24 创建映射类 couponmapper.java
 */
package cn.itcast.mapper;
import cn.itcast.entity.coupon;
public interface couponmapper {
	//保存优惠券信息
	public void savecoupon(coupon coupon);
	//根据id更新优惠券信息
	public void updatecoupon(coupon coupon);
	//根据id查询优惠券信息
	public coupon selectcouponbyid(long id);
}

/**
 *  redis-coupon.coupon-expired2.src.main.java.cn.itcast.utils.datautils.java
 *
 *  2024-7-24 创建工具类 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();
	}
}

<?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 -->

<?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.数据源,连接数据库 -->
	<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.工厂 生产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.扫描接口,接口代理开发 -->
	 <bean class="org.mybatis.spring.mapper.mapperscannerconfigurer">
	 	<property name="basepackage" value="cn.itcast.mapper"></property>
	 </bean>
	<!-- 4. 创建事物管理平台(对象) -->
	<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 -->

<?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>
	<!-- 配置监听 -->
	<bean class="org.springframework.data.redis.listener.adapter.messagelisteneradapter" id="messagelistener">
	    <constructor-arg>
	        <bean class="cn.itcast.redis.listener.redismessagelistener"/>
	    </constructor-arg>
	</bean>
	<!-- 监听容器 -->
	<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  配置订阅的主题名称
	                	此名称时redis提供的名称，标识过期key消息通知
	                			0表示db0 根据自己的dbindex选择合适的数字
	                	 -->
	                    <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 -->

# 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

<?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>

# 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

/**
 *  redis-coupon\coupon-expired2\src\test\java\cn\itcast\coupon\test\coupontest.java
 *
 *  2024-7-24 创建测试类 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("测试优惠券", bigdecimal.one, 
				"全品类优惠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);
	}
}

/**
 *  redis-coupon\coupon-expired2\src\test\java\cn\itcast\redis\redistest.java
 *
 *  2024-7-24 创建测试类 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中获取的数据："+value);
	}
}

/**
 *  redis-coupon\coupon-expired2\src\test\java\cn\itcast\redis\redistest2.java
 *
 *  2024-7-24 创建测试类 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");
	}
}