autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-06-13 03:39:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

阻止重复帧

Browse Source
This commit is contained in:
Guoqs
2024-10-28 14:45:15 +08:00
parent 6bb08fde40
commit 2eb4999038
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/AbstractYkcHandler.java
View File

@@ -22,6 +22,8 @@ public abstract class AbstractYkcHandler implements InitializingBean {
@Autowired @Autowired
private RedisCache redisCache; private RedisCache redisCache;
private static final String REQUEST_PREFIX = "Request_";
/** /**
* 执行逻辑 * 执行逻辑
* 有应答 * 有应答
@@ -96,7 +98,7 @@ public abstract class AbstractYkcHandler implements InitializingBean {
String frameTypeStr = YKCUtils.frameType2Str(ykcDataProtocol.getFrameType()); String frameTypeStr = YKCUtils.frameType2Str(ykcDataProtocol.getFrameType());
// 获取channelId // 获取channelId
String channelId = ctx.channel().id().asShortText(); String channelId = ctx.channel().id().asShortText();
String redisKey = "Request_" + channelId + "_" + frameTypeStr; String redisKey = REQUEST_PREFIX + channelId + "_" + frameTypeStr;
Boolean result = redisCache.setnx(redisKey, ykcDataProtocol.getHEXString(), 30); Boolean result = redisCache.setnx(redisKey, ykcDataProtocol.getHEXString(), 30);
// result返回false说明没有设置成功，就是说已经有相同请求了，所以返回true重复 // result返回false说明没有设置成功，就是说已经有相同请求了，所以返回true重复
return !result; return !result;