| | |
| | | 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.AESUtils;
|
| | | import com.hdl.sdk.connect.utils.AesUtil;
|
| | | import com.hdl.sdk.connect.utils.ProtocolParse;
|
| | | import com.hdl.sdk.socket.codec.ByteToMessageDecoder;
|
| | |
| | | if(AuthenticateConfig.getInstance().ifNeedEncrypt(response.getTopic())){
|
| | | //需要解密
|
| | | byte[] bodyBytes = AesUtil.aesDecrypt(body,AuthenticateConfig.getInstance().getLocalSecret());
|
| | | // byte[] bodyBytes = AESUtils.decryptAES(body,AuthenticateConfig.getInstance().getLocalSecret());
|
| | | response.setData(new String(bodyBytes, "utf-8"));
|
| | | Log.i("TAG", "decoder: ");
|
| | | // Log.i("TAG", "解密 主题:"+response.getTopic()+ " body: "+response.getData());
|
| | | }else{
|
| | | response.setData(new String(body, "utf-8"));
|
| | | }
|
| | |
|
| | |
|
| | |
|
| | | if (byteArray.length >= bodyLength + bodyStartIndex) {
|
| | | //保存余留
|