csy-new
/
qa-cmt-sync-new
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改redis存储时间

main
zhaoyu 2025-04-17 14:18:00 +08:00
parent 08f8248087
commit 9e2462fb7e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
review_repo/src/main/java/com/zcloud/Kafka/KafkaMessageListener.java
View File

@ -64,11 +64,11 @@ public class KafkaMessageListener {
Long b = Long.parseLong(str3); Long b = Long.parseLong(str3);
if(a<b){ if(a<b){
redisTemplate.opsForValue().set("Kafka@"+terminalNo, jsonObject.toJSONString()); redisTemplate.opsForValue().set("Kafka@"+terminalNo, jsonObject.toJSONString());
redisTemplate.expire("Kafka@"+terminalNo, 30, TimeUnit.MINUTES); redisTemplate.expire("Kafka@"+terminalNo, 5, TimeUnit.MINUTES);
} }
}else { }else {
redisTemplate.opsForValue().set("Kafka@"+terminalNo, jsonObject.toJSONString()); redisTemplate.opsForValue().set("Kafka@"+terminalNo, jsonObject.toJSONString());
redisTemplate.expire("Kafka@"+terminalNo, 30, TimeUnit.MINUTES); redisTemplate.expire("Kafka@"+terminalNo, 5, TimeUnit.MINUTES);
} }
} }
} }