[1078] 优化netty bytebuf释放
This commit is contained in:
@@ -83,7 +83,6 @@ public class Jt808Decoder extends ByteToMessageDecoder {
|
|||||||
}
|
}
|
||||||
|
|
||||||
Rs decode = handler.decode(buf, header, session, service);
|
Rs decode = handler.decode(buf, header, session, service);
|
||||||
buf.release();
|
|
||||||
ApplicationEvent applicationEvent = handler.getEvent();
|
ApplicationEvent applicationEvent = handler.getEvent();
|
||||||
if (applicationEvent != null) {
|
if (applicationEvent != null) {
|
||||||
applicationEventPublisher.publishEvent(applicationEvent);
|
applicationEventPublisher.publishEvent(applicationEvent);
|
||||||
|
|||||||
@@ -28,6 +28,7 @@ public abstract class Re {
|
|||||||
session.register(header.getPhoneNumber(), (int) header.getVersion(), header);
|
session.register(header.getPhoneNumber(), (int) header.getVersion(), header);
|
||||||
}
|
}
|
||||||
Rs rs = decode0(buf, header, session);
|
Rs rs = decode0(buf, header, session);
|
||||||
|
buf.release();
|
||||||
Rs rsHand = handler(header, session, service);
|
Rs rsHand = handler(header, session, service);
|
||||||
if (rs == null && rsHand != null) {
|
if (rs == null && rsHand != null) {
|
||||||
rs = rsHand;
|
rs = rsHand;
|
||||||
|
|||||||
Reference in New Issue
Block a user