同步机制
2021-09-23 10:28:13 3 举报
登录查看完整内容
Redis数据同步机制
作者其他创作
大纲/内容
多实体类
成功
返回方法返回对象
@ConditionalOnProperty(\"HK\")
返回void
@CachePut @CacheEvict@CacheEvictVo
@CacheableVo(key = “枚举常量\
Piple管道批量请求
RedisDAspect按照xx.class切面
Redis是否存在数据
HZQueueConfiguration
根据key走service逻辑
Redis存储的数据结构是JSON
目的：空填充内部走@Cacheable原注解逻辑
@Cacheable
获取#变量值
LINK:QUOTA:USER:85915745
redis.set
mq队列
可能存在值，可能不存在值
否（插入Redis）
point.proceed();// 执行原service逻辑;直接走缓存，因为此时已经保证了每个数据都是有缓存的
声明exchange、queue、binding
只负责发
@缓存注解
QueueConfiguration
非本地
85915745
读
@CacheableVo
当前env为杭州，则推送mq HK队列信息
@After 切面
@CacheEvict
1.当前env Redis缓存更新
同步更新（接受数据）
@CacheEvictVo
listenerContainer queue hk
env判断
直接利用原缓存
IQueueHZMessageService
所有Vo Redis 按照拼接规则拼接
信息发送
走本地和非本地逻辑
更新
IQueueMessageService
redis.del
env hz，则ack mq HK mq
IQueueHKMessageService
2.非当前env Redis缓存更新
map数组空value设置为null
解析注解变量生成Redis Key
HKQueueConfiguration
解析key为USER对应的value数组
listenerContainer queue hz
DB填充
@ConditionalOnProperty(\"HZ\")
主动更新(推数据)
单个实体类
只负责收
rediskeyuser.register.hz.queueuser.register.topic.hz.exchange
rediskeyuser.register.hk.queueregister.topic.hk.exchange
删除
根据配置走config
是（读Redis）
根据onMessage的opt
封装MqSend.java
失败
属性包含opt、redisKey、data
font color=\"#9c27b0\
返回队列rabbitBack
Redis Key解析
本地
0 条评论
回复 删除
下一页
