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

update netty优化业务线程池

Browse Source
This commit is contained in:
Lemon
2025-07-22 16:23:18 +08:00
parent 1edab2a4aa
commit dda3751cda
2 changed files with 23 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/EchoServerHandler.java
View File

@@ -27,5 +27,21 @@ public class EchoServerHandler extends ChannelInboundHandlerAdapter {
ctx.write(msg); ctx.write(msg);
//刷新缓存区 //刷新缓存区
ctx.flush(); ctx.flush();
// ByteBuf byteBuf = (ByteBuf) msg;
// ByteBuf byteBuf = Unpooled.copiedBuffer("680d01000004882300000001290100d510", StandardCharsets.UTF_8);
// // byteBuf.readBytes(bytes);
// YKCDataProtocol ykcDataProtocol = new YKCDataProtocol(new byte[]{});
//
// // 获取帧类型
// byte[] frameTypeBytes = ykcDataProtocol.getFrameType();
// String frameType = YKCUtils.frameType2Str(frameTypeBytes);
// // 获取序列号域
// int serialNumber = BytesUtil.bytesToIntLittle(ykcDataProtocol.getSerialNumber());
// if (!CollectionUtils.containsAny(NettyServerHandler.notPrintFrameTypeList, frameType)) {
// log.info("【>>>>>平台响应消息>>>>>】channel:{}, 响应帧类型:{}, 响应帧名称:{}, 序列号域:{}, response:{}",
// ctx.channel().id(), frameType, YKCFrameTypeCode.getFrameTypeStr(frameType), serialNumber,
// BytesUtil.binary(ykcDataProtocol.getBytes(), 16));
// }
} }
} }

11
jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java
View File

@@ -8,6 +8,7 @@ import com.jsowell.common.util.BytesUtil;
import com.jsowell.common.util.StringUtils; import com.jsowell.common.util.StringUtils;
import com.jsowell.common.util.YKCUtils; import com.jsowell.common.util.YKCUtils;
import com.jsowell.netty.service.yunkuaichong.YKCBusinessService; import com.jsowell.netty.service.yunkuaichong.YKCBusinessService;
import com.jsowell.netty.service.yunkuaichong.impl.YKCBusinessServiceImpl;
import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBuf;
import io.netty.channel.*; import io.netty.channel.*;
import io.netty.handler.timeout.IdleState; import io.netty.handler.timeout.IdleState;
@@ -19,6 +20,7 @@ import org.apache.commons.collections4.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import java.util.List; import java.util.List;
import java.util.Objects; import java.util.Objects;
@@ -32,15 +34,17 @@ import java.util.concurrent.ConcurrentHashMap;
@Component @Component
public class NettyServerHandler extends ChannelInboundHandlerAdapter { public class NettyServerHandler extends ChannelInboundHandlerAdapter {
@Autowired // @Resource
private YKCBusinessService ykcService; // private YKCBusinessService ykcService;
/** /**
* 管理一个全局map，保存连接进服务端的通道数量 * 管理一个全局map，保存连接进服务端的通道数量
*/ */
private static final ConcurrentHashMap<ChannelId, ChannelHandlerContext> CHANNEL_MAP = new ConcurrentHashMap<>(); private static final ConcurrentHashMap<ChannelId, ChannelHandlerContext> CHANNEL_MAP = new ConcurrentHashMap<>();
private final List<String> notPrintFrameTypeList = Lists.newArrayList("0x03"); // "0x03" protected static final List<String> notPrintFrameTypeList = Lists.newArrayList(); // "0x03"
private final YKCBusinessService ykcService = new YKCBusinessServiceImpl();
/** /**
* 有客户端连接服务器会触发此函数 * 有客户端连接服务器会触发此函数
@@ -150,7 +154,6 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
ByteBuf buffer = ctx.alloc().buffer().writeBytes(response); ByteBuf buffer = ctx.alloc().buffer().writeBytes(response);
// this.channelWrite(channel.id(), buffer); // this.channelWrite(channel.id(), buffer);
super.channelRead(ctx, buffer); super.channelRead(ctx, buffer);
if (!CollectionUtils.containsAny(notPrintFrameTypeList, frameType)) { if (!CollectionUtils.containsAny(notPrintFrameTypeList, frameType)) {
// 应答帧类型 // 应答帧类型
byte[] responseFrameTypeBytes = YKCFrameTypeCode.PlatformAnswersRelation.getResponseFrameTypeBytes(frameTypeBytes); byte[] responseFrameTypeBytes = YKCFrameTypeCode.PlatformAnswersRelation.getResponseFrameTypeBytes(frameTypeBytes);