开发者学堂课程【使用 Redis 消息队列完成秒杀过期订单处理 :SpringDataRedis 中测试消息通知】学习笔记,与课程紧密联系,让用户快速学习知识。
课程地址:https://developer.aliyun.com/learning/course/729/detail/13019
SpringDataRedis 中测试消息通知
内容介绍
一.创建测试类
二、进行测试
一、创建测试类
完成了 SpringDataRedis 中的消息监听的配置后,就可以将监听器运行,使其处于监听状态。
接着在 redis 客户端面前针对每一个主题发送一条消息来验证其效果。首先在test/java 下创建一个 RedisTest02 测试类
- RedisTest02 代码如下:
package cn.itcast.redis.test;
import org.springframework.context.ApplicationContext;0public class RedisTest02 {
public static void mallin(string[]args) {
//根据配置文件来加载驱动,表示在运行 main 方法时
ApplicationContext ac = new ClassPathxmlApplicationContext("applicationContext-redis.xml");
}
}
会找到 applicationContext-redis 配置文件,之后就会从上到下的依次执行,创建 redisTemplate,connecitonFactory 连接工厂,以及定义好的监听器,而当监听器定义好并真正执行之后就保持了程序会不断的监听redis 程序,以此达到执行 main 方法后控制台一直处于运行的状态。
Run as 执行会看见控制台一直处于运行状态,以此来监听<constructor-arg value=”ITCAST></constructor-arg>其中的 ITCAST 频道的消息。
二、进行测试
为验证监听是否成功。打开 redis 控制台,输入命令: publish ITCAST “VERY GOOD”,其中 ITCAST 为频道名称,””中为发布的内容,发送成功后。回到 elipse 的控制台,可以看到控制台显示:从 channel 为:ITCAST 获取了一条新的消息,消息内容为: VERY GOOD,说明监听成功。
到此已经成功配置了 spring data redis 服务器以及 spring data redis 中对消息的监听,之后的内容为结合 redis 上的自动发送失效 key 的通知以及监听程序,来完成失效优惠券的程序。