mirror of
https://gitee.com/farsunset/cim.git
synced 2025-07-24 08:41:46 +08:00
更新 ClientMessageDecoder.java
This commit is contained in:
远方夕阳
parent
c0bddbb848
commit
98b9c3c33b
@ -1,138 +1,136 @@
|
||||
/**
|
||||
* Copyright 2013-2023 Xia Jun(3979434@qq.com).
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*
|
||||
***************************************************************************************
|
||||
* *
|
||||
* Website : http://www.farsunset.com *
|
||||
* *
|
||||
***************************************************************************************
|
||||
*/
|
||||
package com.farsunset.cim.sdk.android.filter;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import com.farsunset.cim.sdk.android.constant.CIMConstant;
|
||||
import com.farsunset.cim.sdk.android.model.HeartbeatRequest;
|
||||
import com.farsunset.cim.sdk.android.model.Message;
|
||||
import com.farsunset.cim.sdk.android.model.ReplyBody;
|
||||
import com.farsunset.cim.sdk.android.model.proto.MessageProto;
|
||||
import com.farsunset.cim.sdk.android.model.proto.ReplyBodyProto;
|
||||
import com.google.protobuf.InvalidProtocolBufferException;
|
||||
|
||||
import android.util.Log;
|
||||
import io.netty.buffer.ByteBuf;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.handler.codec.ByteToMessageDecoder;
|
||||
|
||||
/**
|
||||
* 客户端消息解码
|
||||
*/
|
||||
public class ClientMessageDecoder extends ByteToMessageDecoder {
|
||||
final static String TAG = ClientMessageDecoder.class.getSimpleName();
|
||||
@Override
|
||||
protected void decode(ChannelHandlerContext arg0, ByteBuf buffer, List<Object> queue) throws Exception {
|
||||
|
||||
/**
|
||||
* 消息头3位
|
||||
*/
|
||||
if (buffer.readableBytes() < CIMConstant.DATA_HEADER_LENGTH) {
|
||||
return;
|
||||
}
|
||||
|
||||
buffer.markReaderIndex();
|
||||
|
||||
buffer.markReaderIndex();
|
||||
|
||||
byte conetnType = buffer.readByte();
|
||||
|
||||
byte lv = buffer.readByte();// int 低位
|
||||
byte hv = buffer.readByte();// int 高位
|
||||
|
||||
int conetnLength = getContentLength(lv, hv);
|
||||
|
||||
// 如果消息体没有接收完整，则重置读取，等待下一次重新读取
|
||||
if (conetnLength > buffer.readableBytes()) {
|
||||
buffer.resetReaderIndex();
|
||||
return;
|
||||
}
|
||||
|
||||
byte[] dataBytes = new byte[conetnLength];
|
||||
buffer.readBytes(dataBytes);
|
||||
|
||||
Object message = mappingMessageObject(dataBytes, conetnType);
|
||||
|
||||
if(message!=null){
|
||||
queue.add(message);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
private Object mappingMessageObject(byte[] bytes, byte type) throws InvalidProtocolBufferException {
|
||||
|
||||
if (CIMConstant.ProtobufType.S_H_RQ == type) {
|
||||
HeartbeatRequest request = HeartbeatRequest.getInstance();
|
||||
Log.i(TAG, request.toString());
|
||||
return request;
|
||||
}
|
||||
|
||||
if (CIMConstant.ProtobufType.REPLYBODY == type) {
|
||||
ReplyBodyProto.Model bodyProto = ReplyBodyProto.Model.parseFrom(bytes);
|
||||
ReplyBody body = new ReplyBody();
|
||||
body.setKey(bodyProto.getKey());
|
||||
body.setTimestamp(bodyProto.getTimestamp());
|
||||
body.putAll(bodyProto.getDataMap());
|
||||
body.setCode(bodyProto.getCode());
|
||||
body.setMessage(bodyProto.getMessage());
|
||||
|
||||
Log.i(TAG, body.toString());
|
||||
|
||||
return body;
|
||||
}
|
||||
|
||||
if (CIMConstant.ProtobufType.MESSAGE == type) {
|
||||
MessageProto.Model bodyProto = MessageProto.Model.parseFrom(bytes);
|
||||
Message message = new Message();
|
||||
message.setMid(bodyProto.getMid());
|
||||
message.setAction(bodyProto.getAction());
|
||||
message.setContent(bodyProto.getContent());
|
||||
message.setSender(bodyProto.getSender());
|
||||
message.setReceiver(bodyProto.getReceiver());
|
||||
message.setTitle(bodyProto.getTitle());
|
||||
message.setExtra(bodyProto.getExtra());
|
||||
message.setTimestamp(bodyProto.getTimestamp());
|
||||
message.setFormat(bodyProto.getFormat());
|
||||
|
||||
Log.i(TAG, message.toString());
|
||||
return message;
|
||||
}
|
||||
|
||||
return null;
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 解析消息体长度
|
||||
*
|
||||
* @param type
|
||||
* @param length
|
||||
* @return
|
||||
*/
|
||||
private int getContentLength(byte lv, byte hv) {
|
||||
int l = (lv & 0xff);
|
||||
int h = (hv & 0xff);
|
||||
return (l | (h <<= 8));
|
||||
}
|
||||
|
||||
}
|
||||
/**
|
||||
* Copyright 2013-2023 Xia Jun(3979434@qq.com).
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*
|
||||
***************************************************************************************
|
||||
* *
|
||||
* Website : http://www.farsunset.com *
|
||||
* *
|
||||
***************************************************************************************
|
||||
*/
|
||||
package com.farsunset.cim.sdk.android.filter;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import com.farsunset.cim.sdk.android.constant.CIMConstant;
|
||||
import com.farsunset.cim.sdk.android.model.HeartbeatRequest;
|
||||
import com.farsunset.cim.sdk.android.model.Message;
|
||||
import com.farsunset.cim.sdk.android.model.ReplyBody;
|
||||
import com.farsunset.cim.sdk.android.model.proto.MessageProto;
|
||||
import com.farsunset.cim.sdk.android.model.proto.ReplyBodyProto;
|
||||
import com.google.protobuf.InvalidProtocolBufferException;
|
||||
|
||||
import android.util.Log;
|
||||
import io.netty.buffer.ByteBuf;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.handler.codec.ByteToMessageDecoder;
|
||||
|
||||
/**
|
||||
* 客户端消息解码
|
||||
*/
|
||||
public class ClientMessageDecoder extends ByteToMessageDecoder {
|
||||
final static String TAG = ClientMessageDecoder.class.getSimpleName();
|
||||
@Override
|
||||
protected void decode(ChannelHandlerContext arg0, ByteBuf buffer, List<Object> queue) throws Exception {
|
||||
|
||||
/**
|
||||
* 消息头3位
|
||||
*/
|
||||
if (buffer.readableBytes() < CIMConstant.DATA_HEADER_LENGTH) {
|
||||
return;
|
||||
}
|
||||
|
||||
buffer.markReaderIndex();
|
||||
|
||||
byte conetnType = buffer.readByte();
|
||||
|
||||
byte lv = buffer.readByte();// int 低位
|
||||
byte hv = buffer.readByte();// int 高位
|
||||
|
||||
int conetnLength = getContentLength(lv, hv);
|
||||
|
||||
// 如果消息体没有接收完整，则重置读取，等待下一次重新读取
|
||||
if (conetnLength > buffer.readableBytes()) {
|
||||
buffer.resetReaderIndex();
|
||||
return;
|
||||
}
|
||||
|
||||
byte[] dataBytes = new byte[conetnLength];
|
||||
buffer.readBytes(dataBytes);
|
||||
|
||||
Object message = mappingMessageObject(dataBytes, conetnType);
|
||||
|
||||
if(message!=null){
|
||||
queue.add(message);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
private Object mappingMessageObject(byte[] bytes, byte type) throws InvalidProtocolBufferException {
|
||||
|
||||
if (CIMConstant.ProtobufType.S_H_RQ == type) {
|
||||
HeartbeatRequest request = HeartbeatRequest.getInstance();
|
||||
Log.i(TAG, request.toString());
|
||||
return request;
|
||||
}
|
||||
|
||||
if (CIMConstant.ProtobufType.REPLYBODY == type) {
|
||||
ReplyBodyProto.Model bodyProto = ReplyBodyProto.Model.parseFrom(bytes);
|
||||
ReplyBody body = new ReplyBody();
|
||||
body.setKey(bodyProto.getKey());
|
||||
body.setTimestamp(bodyProto.getTimestamp());
|
||||
body.putAll(bodyProto.getDataMap());
|
||||
body.setCode(bodyProto.getCode());
|
||||
body.setMessage(bodyProto.getMessage());
|
||||
|
||||
Log.i(TAG, body.toString());
|
||||
|
||||
return body;
|
||||
}
|
||||
|
||||
if (CIMConstant.ProtobufType.MESSAGE == type) {
|
||||
MessageProto.Model bodyProto = MessageProto.Model.parseFrom(bytes);
|
||||
Message message = new Message();
|
||||
message.setMid(bodyProto.getMid());
|
||||
message.setAction(bodyProto.getAction());
|
||||
message.setContent(bodyProto.getContent());
|
||||
message.setSender(bodyProto.getSender());
|
||||
message.setReceiver(bodyProto.getReceiver());
|
||||
message.setTitle(bodyProto.getTitle());
|
||||
message.setExtra(bodyProto.getExtra());
|
||||
message.setTimestamp(bodyProto.getTimestamp());
|
||||
message.setFormat(bodyProto.getFormat());
|
||||
|
||||
Log.i(TAG, message.toString());
|
||||
return message;
|
||||
}
|
||||
|
||||
return null;
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 解析消息体长度
|
||||
*
|
||||
* @param type
|
||||
* @param length
|
||||
* @return
|
||||
*/
|
||||
private int getContentLength(byte lv, byte hv) {
|
||||
int l = (lv & 0xff);
|
||||
int h = (hv & 0xff);
|
||||
return (l | (h <<= 8));
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user