gitee/cim
1
0
Fork 0
mirror of https://gitee.com/farsunset/cim.git synced 2025-06-17 07:35:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

服务端sdk 优化日志打印，线程名加入UID信息

Browse Source
This commit is contained in:
远方 2022-04-16 12:07:03 +08:00
parent 0e8a6aba18
commit 4051660957
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
cim-boot-server/libs/cim-server-sdk-netty-4.2.0.jar
View File

Binary file not shown.

9
cim-server-sdk/src/main/java/com/farsunset/cim/coder/protobuf/WebMessageDecoder.java
View File

@ -23,6 +23,7 @@ package com.farsunset.cim.coder.protobuf;
import com.farsunset.cim.constant.CIMConstant;
import com.farsunset.cim.constant.ChannelAttr;
import com.farsunset.cim.exception.ReadInvalidTypeException;
import com.farsunset.cim.model.Pong;
import com.farsunset.cim.model.SentBody;
import com.farsunset.cim.model.proto.SentBodyProto;
@ -52,7 +53,13 @@ public class WebMessageDecoder extends MessageToMessageDecoder<BinaryWebSocketFr
return;
}
list.add(getBody(buffer));
if (CIMConstant.DATA_TYPE_SENT == type) {
list.add(getBody(buffer));
return;
}
throw new ReadInvalidTypeException(type);
}
protected SentBody getBody(ByteBuf buffer) throws IOException {