。

这也是我们协议开发比较重要的一部分#xff0c;不过我们在此把它封装程一个单独的通讯库#xff0c;毕竟…继续接上篇

《半导体Gem/Secs基本协议库的开发3》本篇我们分享的比较简单windows系统下tcp和串口通讯。

这也是我们协议开发比较重要的一部分不过我们在此把它封装程一个单独的通讯库毕竟它的作用也只是收发消息而已。

so

easy~

no_debug_releasewin32:CONFIG(release,

$${PWD}/../../../deploy/lib/Release

$${PWD}/../../../deploy/lib/Debug

}OBJECTS_DIR

$${PWD}/../../../build/$${TARGET}/obj

MOC_DIR

$${PWD}/../../../build/$${TARGET}/mocSOURCES

\commucation.cpp

\tcpserverobject_win.cppHEADERS

\commucation.h

\tcpserverobject_win.h#BEFORE_LINK_CMD_LINE

echo

begin_to_compile_JC_Commucation!

#QMAKE_PRE_LINK

$$quote($$BEFORE_LINK_CMD_LINE)

#AFTER_LINK_CMD_LINE

../../../deploy/include/$$TARGET

#QMAKE_POST_LINK

$$quote($$AFTER_LINK_CMD_LINE)//

commucation.h

{TcpServer,TcpClient,SerialPort

}CommType;struct

EthernetCommucationParam{__int32

nT3;

SerialCommucationParam{uint32_t

portNo

CommucationParam{EthernetCommucationParam

sParam;

setEventCallBack(OnMsgRecivedEvent

eProc3)

JC_CreatCommObject(CommucationType

parm);/***

JC_RunListenThread(ICommucation*

p);/***

JC_ReleaseCommObject(ICommucation*

p);/***

JC_SetEventCallBack(ICommucation*

pMsgRecivedProc,OnStateChangedEvent

pStateChangedProc,OnAsyncMsgTimeoutEvent

brief

JC_SendAsyncMessage(ICommucation*

pObject,

public:CommucationBase();virtual

bool

setEventCallBack(OnMsgRecivedEvent

eProc3);};#endif

commucationbase.hCommucationBase::CommucationBase()

{}CommucationBase::~CommucationBase()

{}bool

CommucationBase::CreateCommObject()

{return

CommucationBase::ReleaseCommObject()

{return;

CommucationBase::SendSyncMessage(std::string

strSendBuf,

{JC_UNUSED(strSendBuf);JC_UNUSED(needReply);JC_UNUSED(strRecvMsg);JC_UNUSED(iTimeOut);return

true;

CommucationBase::setEventCallBack(OnMsgRecivedEvent

eProc1,

{JC_UNUSED(eProc1);JC_UNUSED(eProc2);JC_UNUSED(eProc3);return;

}//

SERIALPORTCOMMUCATIONOBJECT_H#include

commucationbase.h

public:SerialportCommucationObject(CommucationParam

param);bool

setEventCallBack(OnMsgRecivedEvent

eProc3);

默认为EV_RXCHAR,即只要收发任意一个字符,则产生一个事件*

return:

/n本函数提供了一些常用的串口参数设置,若需要自行设置详细的DCB参数,可使用重载函数*

see:*/bool

本监听线程完成对串口数据的监听,并将接收到的数据打印到屏幕输出*

return:

pParam);private:CommucationParam

m_param;/**

msgRecivedEventProc;OnStateChangedEvent

stateChangedEventProc;OnAsyncMsgTimeoutEvent

serialportobject_win.cpp#include

#include

SerialportCommucationObject::s_bExit

false;/**

5;SerialportCommucationObject::SerialportCommucationObject(CommucationParam

param):

m_hListenThread(INVALID_HANDLE_VALUE)

}bool

SerialportCommucationObject::CreateCommObject()

{return

InitPort(m_param.sParam.portNo,m_param.sParam.baud,m_param.sParam.parity,m_param.sParam.databits,m_param.sParam.stopsbits);}void

SerialportCommucationObject::ReleaseCommObject()

{CloseListenTread();ClosePort();DeleteCriticalSection(m_csCommunicationSync);

}int

SerialportCommucationObject::SendData(SOCKET

fd,

char[len]{0};memcpy(umsg,msg,len);bool

WriteData(umsg,len)

SerialportCommucationObject::run()

{std::cout

std::endl;return;}else{std::cout

}void

SerialportCommucationObject::setEventCallBack(OnMsgRecivedEvent

eProc1,

SerialportCommucationObject::SendSyncMessage(std::string

strSendBuf,

{JC_UNUSED(strSendBuf);JC_UNUSED(iTimeOut);JC_UNUSED(needReply);JC_UNUSED(strRecvMsg);puts(SerialportCommucationObject::SendSyncMessage

not

SerialportCommucationObject::InitPort(UINT

portNo,

INVALID_HANDLE_VALUE;m_hListenThread

INVALID_HANDLE_VALUE;InitializeCriticalSection(m_csCommunicationSync);/**

*/char

szDCBparam[50];sprintf_s(szDCBparam,

baud%d

*/EnterCriticalSection(m_csCommunicationSync);/**

*/BOOL

在此可以设置输入输出的缓冲区大小,如果不设置,则系统会设置默认值.*

自己设置缓冲区大小时,要注意设置稍大一些,避免缓冲区溢出*//*if

(bIsSuccess

SetupComm(m_hComm,10,10);}*//**

*/COMMTIMEOUTS

CommTimeouts;CommTimeouts.ReadIntervalTimeout

0;CommTimeouts.ReadTotalTimeoutMultiplier

0;CommTimeouts.ReadTotalTimeoutConstant

0;CommTimeouts.WriteTotalTimeoutMultiplier

0;CommTimeouts.WriteTotalTimeoutConstant

0;if

*/LeaveCriticalSection(m_csCommunicationSync);return

bIsSuccess

SerialportCommucationObject::InitPort(UINT

portNo,

*/EnterCriticalSection(m_csCommunicationSync);/**

配置串口参数

*/LeaveCriticalSection(m_csCommunicationSync);return

true;

SerialportCommucationObject::OpenListenThread()

{/**

(!SetThreadPriority(m_hListenThread,

THREAD_PRIORITY_ABOVE_NORMAL)){return

false;}return

SerialportCommucationObject::CloseListenTread()

{if

*/CloseHandle(m_hListenThread);m_hListenThread

true;

SerialportCommucationObject::WriteData(unsigned

char

*/EnterCriticalSection(m_csCommunicationSync);/**

*/bResult

PURGE_RXABORT);LeaveCriticalSection(m_csCommunicationSync);return

false;}/**

*/LeaveCriticalSection(m_csCommunicationSync);return

true;

SerialportCommucationObject::GetBytesInCOM()

{DWORD

在调用ReadFile和WriteFile之前,通过本函数清除以前遗留的错误标志

*/if

SerialportCommucationObject::ReadChar(char

cRecved)

*/EnterCriticalSection(m_csCommunicationSync);/**

*/bResult

PURGE_RXABORT);LeaveCriticalSection(m_csCommunicationSync);return

false;}/**

*/LeaveCriticalSection(m_csCommunicationSync);return

(BytesRead

SerialportCommucationObject::openPort(UINT

portNo)

*/EnterCriticalSection(m_csCommunicationSync);/**

*/char

INVALID_HANDLE_VALUE){LeaveCriticalSection(m_csCommunicationSync);return

false;}/**

*/LeaveCriticalSection(m_csCommunicationSync);return

true;

SerialportCommucationObject::ClosePort()

{/**

INVALID_HANDLE_VALUE){CloseHandle(m_hComm);m_hComm

}UINT

SerialportCommucationObject::ListenThread(void

*pParam)

reinterpret_castSerialportCommucationObject*(pParam);//

线程循环,轮询方式读取串口数据while

pSerialPort-GetBytesInCOM();/**

*/if

0){Sleep(SLEEP_TIME_INTERVAL);continue;}/**

*/char

public:JcTcpClientObject(CommucationParam

param);bool

setEventCallBack(OnMsgRecivedEvent

eProc3);int

initialization();private:CommucationParam

m_param;int

tcpclientobject_win.cpp#include

#include

1024*10JcTcpClientObject::JcTcpClientObject(CommucationParam

param):

JcTcpClientObject::CreateCommObject()

{if(

INVALID_SOCKET){WSACleanup();return

false;}struct

htons(m_param.eParam.nPort);addr.sin_addr.S_un.S_addr

inet_addr(m_param.eParam.pIP);if

(connect(c_client,

INVALID_SOCKET){WSACleanup();return

false;}return

JcTcpClientObject::ReleaseCommObject()

false;}closesocket(c_client);WSACleanup();

}int

JcTcpClientObject::SendData(SOCKET

fd,const

JcTcpClientObject::initialization()

{WORD

CreateCommObject();if(!m_connected_status)

return

{if(m_asyncFlag){memset(recvBuf,0,BUFSIZE);int

iRecvsize

QByteArray(recvBuf,iRecvsize);do{if(m_buffer.size()

Message

static_castuint8_t(m_buffer.at(0));m_messageLength

(m_messageLength

static_castuint8_t(m_buffer.at(1));m_messageLength

(m_messageLength

static_castuint8_t(m_buffer.at(2));m_messageLength

(m_messageLength

static_castuint8_t(m_buffer.at(3));}if(m_buffer.size()

m_messageLength

{msgRecivedEventProc(this,recvBuf,iRecvsize,(void*)c_client);m_buffer.clear();m_messageLength

0);}::Sleep(10);}closesocket(c_client);WSACleanup();});thrd.detach();

}void

JcTcpClientObject::setEventCallBack(OnMsgRecivedEvent

eProc1,

JcTcpClientObject::SendSyncMessage(std::string

strSendBuf,

sizeof(timeOut));setsockopt(c_client,

SOL_SOCKET,

sizeof(timeOut));printf(开始发送消息\n);int

iRet

strSendBuf.c_str());if(needReply){iRet

recv(c_client,

public:JcTcpServerObject(CommucationParam

param);virtual

setEventCallBack(OnMsgRecivedEvent

eProc3);int

msgRecivedEventProc;OnStateChangedEvent

stateChangedEventProc;OnAsyncMsgTimeoutEvent

tcpserverobject_win.cpp#include

#include

std;JcTcpServerObject::JcTcpServerObject(CommucationParam

param):

}JcTcpServerObject::~JcTcpServerObject()

}bool

JcTcpServerObject::CreateCommObject()

return

true;setsockopt(s_server,SOL_SOCKET,SO_REUSEADDR,(const

char*)bReuseaddr,sizeof(bool));///

设置超时//

setsockopt(s_server,SOL_SOCKET,SO_SNDTIMEO,(char

setsockopt(s_server,SOL_SOCKET,SO_RCVTIMEO,(char

*)nNetTimeout,sizeof(int));struct

sockaddr_in

server_addr;server_addr.sin_family

htons(m_param.eParam.nPort);server_addr.sin_addr.S_un.S_addr

inet_addr(m_param.eParam.pIP);if

(bind(s_server,

JcTcpServerObject::ReleaseCommObject()

false;}closesocket(s_server);WSACleanup();

}int

JcTcpServerObject::SendData(SOCKET

fd,

JcTcpServerObject::initialization()

{WORD

初始化启动套接字if(!CreateCommObject()){return;}std::cout

等待Host连接到设备

iTempLen;FD_ZERO(fd);FD_SET(s_server,fd);//

timeval

select(0,fdOld,NULL,NULL,/*tm*/NULL);if

iResult){for(UINT

(FD_ISSET(fd.fd_array[i],fdOld)){///

(fd.fd_array[i]

s_server){memset(addrAccept,0,sizeof(addrTemp));s_accept

INVALID_SOCKET

客户端连接if(stateChangedEventProc){stateChangedEventProc(this,0,(void*)fd.fd_array[i]);}FD_SET(s_accept,fd);printf(%s:%d

has

server!\n,inet_ntoa(addrAccept.sin_addr),ntohs(addrAccept.sin_port));}}else

///

非服务器,接收数据(因为fd是读数据集)memset(szDataBuff,0,BUFSIZE);iRecvSize

recv(fd.fd_array[i],szDataBuff,BUFSIZE,0);memset(addrTemp,0,sizeof(addrTemp));iTempLen

sizeof(addrTemp);getpeername(fd.fd_array[i],(sockaddr

(SOCKET_ERROR

表示正常连接1表示断开连接if(stateChangedEventProc){stateChangedEventProc(this,1,(void*)fd.fd_array[i]);}closesocket(fd.fd_array[i]);FD_CLR(fd.fd_array[i],fd);i--;printf(Failed

recv

errorcode:%d.\n,inet_ntoa(addrTemp.sin_addr),ntohs(addrTemp.sin_port),WSAGetLastError());continue;}if

iRecvSize){///

closed!\n,inet_ntoa(addrTemp.sin_addr),ntohs(addrTemp.sin_port));///

param2:

表示正常连接1表示断开连接if(stateChangedEventProc){stateChangedEventProc(this,1,(void*)fd.fd_array[i]);}closesocket(fd.fd_array[i]);FD_CLR(fd.fd_array[i],fd);i--;}if

iRecvSize){///

\n,iRecvSize,inet_ntoa(addrTemp.sin_addr),ntohs(addrTemp.sin_port));///

QByteArray(szDataBuff,iRecvSize);do{if(m_buffer.size()

Message

static_castuint8_t(m_buffer.at(0));m_messageLength

(m_messageLength

static_castuint8_t(m_buffer.at(1));m_messageLength

(m_messageLength

static_castuint8_t(m_buffer.at(2));m_messageLength

(m_messageLength

static_castuint8_t(m_buffer.at(3));}if(m_buffer.size()

m_messageLength

{msgRecivedEventProc(this,szDataBuff,iRecvSize,(void*)fd.fd_array[i]);m_buffer.clear();m_messageLength

0);}}}///

JcTcpServerObject::setEventCallBack(OnMsgRecivedEvent

eProc1,

JcTcpServerObject::SendSyncMessage(std::string

strSendBuf,

{JC_UNUSED(strSendBuf);JC_UNUSED(needReply);JC_UNUSED(strRecvMsg);JC_UNUSED(iTimeOut);return

true;