最近在使用HP-SOCKET做一个嵌入式程序,主要是上位机与下位机设备之间的网络交互。初次交互时,下位机需要保存上位机的IP地址,端口号等,方便进行后续的通信。
在这其中,使用了一个队列的机制。即每次上位机问询,进行一个队列的存储,主要存储了上位机IP、端口、功能码、数据。然后下位机应答时,从队列中取数据,并发给相应的IP和端口。
这时候就出现了问题,从队列中取出的IP地址始终是乱码的,因此应答总是不成功。
具体代码如下:
struct recv_type
{
int len = 0;//长度
char rec_data[BUF_SIZE] ={0};//接收缓存
LPCTSTR lpszRemoteAddress;//上位机IP
USHORT usRemotePort;//上位机端口
};
//定义了一个队列
std::queue<recv_type> m_recv_queue;
//监听函数
EnHandleResult m_UdpNodeListener::OnReceive(IUdpNode* pSender, LPCTSTR lpszRemoteAddress, USHORT usRemotePort, const BYTE* pData, int iLength)
{
recv_type recv_info;
if(iLength<BUF_SIZE)
{
recv_info.lpszRemoteAddress = lpszRemoteAddress;
recv_info.usRemotePort = usRemotePort;
recv_info.len = iLength;
memcpy(recv_info.rec_data,pData,recv_info.len);
this->SetRecvBuf(recv_info);
}
return HR_IGNORE;
}
//进队列
bool m_UdpNodeListener::SetRecvBuf(recv_type& recv_info)
{
if(this->m_recv_queue.size() >= 1000) {
return false;
}
this->m_recv_queue.push(recv_info);
return true;
}```
//出队列
bool m_UdpNodeListener::GetRecvBuf(recv_type& recv_info)
{
if(this->m_recv_queue.size() <= 0) {
return false;
}
recv_info = this->m_recv_queue.front();
this->m_recv_queue.pop();
return true;
}
//队列大小
int m_UdpNodeListener::GetRecvBufSize()
{
return this->m_recv_queue.size();
}
//run
bool Communication::Run()
{
if((*this->m_UdpNode)->Start(nullptr,5566,EnCastMode::CM_BROADCAST,"255.255.255.255"))
while(1)
{
std::string cmd_data;
std::string sendData;
int num = this->m_udplistener->GetRecvBufSize();
for(int i = 0 ; i< num; i++)
{
recv_type recv_info;
if(this->m_udplistener->GetRecvBuf(recv_info))
{
neb::CJsonObject recJson;
int msgid = 0;
if(!recJson.Parse((const char*)recv_info.rec_data))
{
break;
}
recJson.Get("cmd",cmd_data);
if(cmd_data == "aaa")
{
sendData = “aaaaaaa”;
(*this->m_UdpNode)->Send(recv_info.lpszRemoteAddress,recv_info.usRemotePort,(BYTE*)sendData.c_str(),sendData.size());
}
else if(cmd_data == "bbb")
{
sendData = “bbbbbbb”;
(*this->m_UdpNode)->Send(recv_info.lpszRemoteAddress,recv_info.usRemotePort,(BYTE*)sendData.c_str(),sendData.size());
}
}
}
}
}
return true;
}
打印了IP地址,发现入队列的IP是正常的,出队列的IP地址确成了乱码。后面反复调试,终于发现了问题。
原来HP-SOCKET的“LPCTSTR”类型最后是没有“\0”的,因此出队列时,该数据就成了乱码。
问题找到了,修改就好说了,只需在IP地址后面加上“\0”即可。
修改后的代码如下:
EnHandleResult m_UdpNodeListener::OnReceive(IUdpNode* pSender, LPCTSTR lpszRemoteAddress, USHORT usRemotePort, const BYTE* pData, int iLength)
{
recv_type recv_info;
if(iLength<BUF_SIZE)
{
//增加“\0”,否则取出来乱码
std::string addr = lpszRemoteAddress;
addr += "\0";
recv_info.lpszRemoteAddress = addr.data();
recv_info.usRemotePort = usRemotePort;
recv_info.len = iLength;
memcpy(recv_info.rec_data,pData,recv_info.len);
this->SetRecvBuf(recv_info);
}
return HR_IGNORE;
}
以上就是问题解决的整个过程,我想其他人可能也遇到过队列的相似问题,特写出来供大家参考,欢迎交流讨论。
如果觉得这篇文章对您有帮助,欢迎点赞、评论、转发、收藏!您的支持是我创作的最大动力!