From d5449236ef0b3adafb3e4cc872f50479efa0ce7b Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期二, 11 三月 2025 16:10:29 +0800
Subject: [PATCH] 配置信息
---
src/main/java/com/zy/core/netty/handle/ProtocolDecoder.java | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/zy/core/netty/handle/ProtocolDecoder.java b/src/main/java/com/zy/core/netty/handle/ProtocolDecoder.java
index 7cb12d7..fc37c72 100644
--- a/src/main/java/com/zy/core/netty/handle/ProtocolDecoder.java
+++ b/src/main/java/com/zy/core/netty/handle/ProtocolDecoder.java
@@ -19,7 +19,7 @@
private final SnowflakeIdWorker snowflakeIdWorker;
- public ProtocolDecoder(SnowflakeIdWorker snowflakeIdWorker){
+ public ProtocolDecoder(SnowflakeIdWorker snowflakeIdWorker) {
this.snowflakeIdWorker = snowflakeIdWorker;
}
@@ -27,11 +27,11 @@
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> list) throws Exception {
int startMark = indexOfStartMark(in);
- if (startMark == -1){
+ if (startMark == -1) {
return;
}
// 鍘婚櫎鏃犵敤鍓嶇紑鎶ユ枃
- if (startMark != 0){
+ if (startMark != 0) {
in.readerIndex(startMark);
in.discardReadBytes();
}
@@ -46,7 +46,7 @@
list.add(analyzeProtocol(pac));
}
- public ChPackage analyzeProtocol(ChPackage pac){
+ public ChPackage analyzeProtocol(ChPackage pac) {
ByteBuf byteBuf = pac.getSourceBuff();
@@ -84,14 +84,14 @@
}
// 鑾峰彇鏍囪瘑浣嶄笅鏍�
- private int indexOfStartMark(ByteBuf inputBuffer){
+ private int indexOfStartMark(ByteBuf inputBuffer) {
int length = inputBuffer.writerIndex();
// 鎶ユ枃闀垮害鑷冲皯澶т簬2
if (length < 2) {
return -1;
}
int readerIndex = inputBuffer.readerIndex();
- for(int i = readerIndex; i < length - 1; i ++) {
+ for (int i = readerIndex; i < length - 1; i++) {
byte b1 = inputBuffer.getByte(i);
// "#" = b1
if (0x23 == b1) {
--
Gitblit v1.9.1