autumn/JChargePointProtocol
1
0
Fork 0
mirror of https://gitee.com/san-bing/JChargePointProtocol synced 2026-05-06 19:09:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

连接创建后不发报文，ctx可能为空

Browse Source
This commit is contained in:
三丙
2025-09-13 17:03:59 +08:00
parent 7c6a1df15e
commit b660fd94c2
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/listener/tcp/TcpSession.java
View File

@@ -85,9 +85,11 @@ public class TcpSession extends ProtocolSession {
public void close(SessionCloseReason reason) { public void close(SessionCloseReason reason) {
super.close(reason); super.close(reason);
if (ctx != null) {
ctx.flush(); ctx.flush();
ctx.close(); ctx.close();
} }
}
public void writeAndFlush(ByteBuf byteBuf) { public void writeAndFlush(ByteBuf byteBuf) {
writeAndFlushConsumer.accept(byteBuf); writeAndFlushConsumer.accept(byteBuf);