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