Redis缓存集成2.4+
警告:此starter作废了,迁移到jeecg-boot-base-tools中
JeecgBoot 对redis进行了封装,提供数据存储,发布订阅,过期Key监听等功能,本文以jeecg-demo模块为例介绍如何集成redis,
[TOC]
集成方法
jeecg-demo模块pom中引入redis依赖
<!--redis缓存-->
<dependency>
<groupId>org.jeecgframework.boot</groupId>
<artifactId>jeecg-boot-starter-redis</artifactId>
</dependency>
发布订阅用法
方法说明
参数名 | 参数描述 | 参数类型 |
---|---|---|
handlerName | 消息监听beanName | String |
params | 参数 | Object |
//发布消息
void sendMessage(String handlerName, Map params)
简单3步完成消息的发送和接收
- 注入消息发送客户端
@Autowired
private JeecgRedisClient redisClient;
- 发送消息示例代码
BaseMap map = new BaseMap ();
map.put("orderId", "12345");
redisClient.sendMessage("demoHandler", map);
- 编写消息监听监听器 定义接收者实现JeecgRedisListerer 接口
/**
* 消息监听
*/
@Slf4j
@Component
public class DemoHandler implements JeecgRedisListerer {
@Override
public void onMessage(BaseMap message) {
String orderId=message.get("orderId").toString();
log.info("执行业务逻辑..............");
}
}