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

使用ChannelHandlerContext

Browse Source
This commit is contained in:
Guoqs
2024-08-01 11:35:31 +08:00
parent 1099874666
commit 1cec3f64c5
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -97,11 +97,11 @@ public abstract class AbstractHandler implements InitializingBean {
* 阻止重复帧 * 阻止重复帧
* @return true 重复 * @return true 重复
*/ */
protected boolean verifyTheDuplicateRequest(YKCDataProtocol ykcDataProtocol, Channel channel) { protected boolean verifyTheDuplicateRequest(YKCDataProtocol ykcDataProtocol, ChannelHandlerContext ctx) {
// 获取序列号域 // 获取序列号域
int serialNumber = BytesUtil.bytesToIntLittle(ykcDataProtocol.getSerialNumber()); int serialNumber = BytesUtil.bytesToIntLittle(ykcDataProtocol.getSerialNumber());
// 获取channelId // 获取channelId
String channelId = channel.id().asShortText(); String channelId = ctx.channel().id().asShortText();
String redisKey = "Request_" + channelId + "_" + serialNumber; String redisKey = "Request_" + channelId + "_" + serialNumber;
Boolean result = redisCache.setnx(redisKey, ykcDataProtocol.getHEXString(), 30); Boolean result = redisCache.setnx(redisKey, ykcDataProtocol.getHEXString(), 30);
// result返回false说明没有设置成功，就是说已经有相同请求了，所以返回true重复 // result返回false说明没有设置成功，就是说已经有相同请求了，所以返回true重复

6
jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/LoginRequestHandler.java
View File

@@ -106,7 +106,7 @@ public class LoginRequestHandler extends AbstractHandler {
} }
@Override @Override
public byte[] supplyProcess(YKCDataProtocol ykcDataProtocol, ChannelHandlerContext channel) { public byte[] supplyProcess(YKCDataProtocol ykcDataProtocol, ChannelHandlerContext ctx) {
// 获取消息体 // 获取消息体
byte[] msgBody = ykcDataProtocol.getMsgBody(); byte[] msgBody = ykcDataProtocol.getMsgBody();
@@ -118,7 +118,7 @@ public class LoginRequestHandler extends AbstractHandler {
String pileSn = BytesUtil.binary(pileSnByte, 16); String pileSn = BytesUtil.binary(pileSnByte, 16);
// 保存时间 // 保存时间
saveLastTimeAndCheckChannel(pileSn, channel); saveLastTimeAndCheckChannel(pileSn, ctx);
// 桩类型 0 表示直流桩， 1 表示交流桩 // 桩类型 0 表示直流桩， 1 表示交流桩
startIndex += length; startIndex += length;
@@ -164,7 +164,7 @@ public class LoginRequestHandler extends AbstractHandler {
String business = BytesUtil.bcd2Str(businessTypeByteArr); String business = BytesUtil.bcd2Str(businessTypeByteArr);
// *********************** 字段解析完成，下面进行逻辑处理 *********************** // // *********************** 字段解析完成，下面进行逻辑处理 *********************** //
if (verifyTheDuplicateRequest(ykcDataProtocol, channel)) { if (verifyTheDuplicateRequest(ykcDataProtocol, ctx)) {
return null; return null;
} }