1.問題描述
在wkt模擬器上, 通過以下代碼可以正確的讀出數據:
conn = (SocketConnection) Connector.open(url, Connector.READ_WRITE, true);
is = conn.openDataInputStream();
os = conn.openDataOutputStream();
// 創建登陸報文
loginPacketBytes = generateLoginPacket();
// 發送登陸報文
// System.out.println("****發送登陸報文****");
os.write(loginPacketBytes, 0, loginPacketBytes.length);
os.flush();
// 先讀取ConstantValue.HEADER_LENGTH個字節,循環遍歷尋找正確的魔數
recByteNum = is.read(recBytes, 0, ConstantValue.READ_LENGTH);
若從服務器真是返回的字節數是100個字節, 而ConstantValue.READ_LENGTH定義的長度大于100.
那么在模擬器上沒有問題, 能夠讀到100個字節.
但是到了真機上面測試, 若定義的要讀取的字節數大于實際傳送的字節數, 那就會出現異常情況.
導致根本就讀不到數據.
2.解決方法
先讀取一小部分數據, 得到報文頭(一般都有報文頭, 報文頭中都有整個報文的總長度)
解析報文頭, 這里需要注意的是可能收到的第一個數據并不就是報文的有效數據, 報文的有效數據可能并不在數據緩沖區的首位置, 所以需要正確找到報文頭, 方法各不相同, 有的是使用魔數這種方式, 有個就靠判斷某個值是否等于報文的總長度. 總之記住有效報文的開始位置, 這里記著index,
然后創建一個字節緩沖區, 剛好來接受剩余的數據
byte addBytes[] = new byte[recHeader.getBufferSize() + index - (recByteNum - ConstantValue.HEADER_LENGTH)];
is.readFully(addBytes);這樣一般就可以正確的讀出有效數據了.
3.最新方法 int loop = 0;
int hasReadLen = 0;
// 讀取報文頭
while (true)
{
loop++;
if (loop >= m_oNET_DVR.m_iTimeOutVal / NET_DVR_PARAM.LOOP_INTERVAL)
{
SDK.SetLastError(NET_DVR_Dec.NET_DVR_NETWORK_RECV_TIMEOUT);
return NET_DVR_Dec.RET_FAIL;
}
if (m_oCfgIs.available() >= NET_DVR_PARAM.REC_PACKET_HEADER_LENGTH)
{
// 讀取報文頭
recByteNum = m_oCfgIs.read(m_byCfgRecBuf, 0, NET_DVR_PARAM.REC_PACKET_HEADER_LENGTH);
hasReadLen += recByteNum;
if (recByteNum == NET_DVR_PARAM.REC_PACKET_HEADER_LENGTH)
{
// 解析報文總長度
pakcetTotalLen = NetHelper.convertNetBytesToInt(m_byCfgRecBuf, 0);
break;
}
else
{
SDK.SetLastError(NET_DVR_Dec.NET_DVR_NETWORK_RECV_ERROR);
return NET_DVR_Dec.RET_FAIL;
}
}
Thread.sleep(NET_DVR_PARAM.LOOP_INTERVAL);
}
// 讀取報文體
while (true)
{
loop++;
if (loop >= m_oNET_DVR.m_iTimeOutVal / NET_DVR_PARAM.LOOP_INTERVAL)
{
SDK.SetLastError(NET_DVR_Dec.NET_DVR_NETWORK_RECV_TIMEOUT);
return NET_DVR_Dec.RET_FAIL;
}
// 讀取剩余數據
recByteNum = m_oCfgIs.read(m_byCfgRecBuf, hasReadLen, pakcetTotalLen - hasReadLen);
hasReadLen += recByteNum;
// 讀取完畢
if (hasReadLen >= pakcetTotalLen)
{
break;
}
else
{
Thread.sleep(100);
continue;
}
}