| | |
|---|
| | | package com.hdl.sdk.connect.protocol;
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | import android.util.Log;
|
|---|
| | |
|
|---|
| | | import com.hdl.sdk.common.config.AuthenticateConfig;
|
|---|
| | | import com.hdl.sdk.common.event.EventDispatcher;
|
|---|
| | | import com.hdl.sdk.common.utils.ByteUtils;
|
|---|
| | | import com.hdl.sdk.connect.bean.LinkResponse;
|
|---|
| | | import com.hdl.sdk.connect.utils.AesUtil;
|
|---|
| | | import com.hdl.sdk.connect.utils.ProtocolParse;
|
|---|
| | | import com.hdl.sdk.socket.codec.ByteToMessageDecoder;
|
|---|
| | |
|
|---|
| | |
|---|
| | | if (bodyLength > 0) {
|
|---|
| | | if (byteArray.length >= bodyLength + bodyStartIndex) {
|
|---|
| | | byte[] body = ByteUtils.getRangeBytes(bytes, bodyStartIndex, bodyStartIndex + bodyLength);
|
|---|
| | | response.setData(new String(body, "utf-8"));
|
|---|
| | |
|
|---|
| | | if(AuthenticateConfig.getInstance().ifNeedEncrypt(response.getTopic())){
|
|---|
| | | //需要解密
|
|---|
| | | byte[] bodyBytes = AesUtil.aesDecrypt(body,AuthenticateConfig.getInstance().getLocalSecret());
|
|---|
| | | response.setData(new String(bodyBytes, "utf-8"));
|
|---|
| | | Log.i("TAG", "decoder: ");
|
|---|
| | | }else{
|
|---|
| | | response.setData(new String(body, "utf-8"));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | if (byteArray.length >= bodyLength + bodyStartIndex) {
|
|---|
| | | //保存余留
|
|---|
