用VC实现多串口多线程工业控制

在中小型电站系统就地控制中，比如水电站中如果我们要进行各种设备控制的话，串口数量就可能比较多了，有的地方加上载波甚至可以达到10个以上，很多的解决方法是将某些功能设备并行接到一个串口上面尽量减少串口的数量，然后进行数据采集的时候采取环的方法进行。但是工业控制要求实时性比较高，比如报警和各种控制，如果不能在尽可能短的时间里面进行处理可能引发大的后果，我们觉得还是应该将各种不同设备接入不同的串口，比如水电站中间各个机组的PLC和机组的调速器通讯等就接入不同串口。如果某个相同设备数量很多，如温度装置，有的1个发电机组可能超过20个温度点，我们可以采用接入2个或者多个串口的方法处理。

　　为了使初学者能够更容易看懂串口通讯的处理过程，我采用援助非洲刚果（布）姆古古鲁水电站的温度表为实例进行程序的分析。在我们这个项目中有4台发电机组，每个机组温度表有20个点。由于这个与上位机通讯串口安排极多，我们只能将20个温度表并行接入串口进行通讯。在进行硬件通讯之前我们首先要看懂改硬件的通讯协议。

　　通讯协议就是上位机向改外围设备进行读取数据和进行某种功能控制时候的一系列指令和外围设备返回上位机的各数据位代表的意思。比如那个位是控制码，哪个位是数据，是什么数据等。

　　首先启动VC新建一个给予SDI的工程，然后加入SerialPort类。由于要进行多串口通讯，我们需要对SerialPort进行一些简单的修改，由于在与硬件通讯过程中一般通讯协议都采用BYTE类型数据传送，我们可以将该类中间的发送和接收数据类型修改成为BYTE类型。我修改了下面部分内容，详细改动请见附录提供的SERIALPORT类。

// // Write a string to the port // void CSerialPort::WriteToPort(BYTE bWriteBuffer[],int nWriteBufferSize) { 　assert(m_hComm != 0); 　int nSize = sizeof(bWriteBuffer)/sizeof(BYTE); 　m_nWriteBufferSize = nWriteBufferSize; 　for(int i = 0 ; i < nWriteBufferSize ; i ++) 　　m_bWriteBuffer[i] = bWriteBuffer[i]; 　　// set event for write 　　SetEvent(m_hWriteEvent); } ......

　　由于我们改串口接入了20台温度设备，在进行通讯的时候是通过发送某个地址的设备命令进行读取数据。我们首先对硬件设置相应的地址，这里我们设置0到19号地址。采集的时候采用循环的方式从0号地址向19号地址进行读取数据。当收到相应的数据包的时候我们进行相应的地址的数据解包处理。然后发送下一个地址的要数据命令。当地址为最后一台设备的时候我们将地址清0处理就可以了。但是如果我们这个20台设备中间某一个或者多个设备由于故障或者电源没开的话，上述通讯就会出现问题，我们发送没有运行的地址设备就会收不到相应的报文，我们就不会发送下一个地址的要数据命令，这是程序就会不走下去了。解决方法可以是我们从外部去判断是否对当前地址的发送要数据命令和收到数据命令是否超时。如果超时就进行跳过然后发送下一个地址要数据命令。当出现规定几个循环的时候进行该设备的采集参数清0等工作这个就可以随自己定义考虑了。具体实现如下：

　　定义SERIALPORT类对象，创建线程进行通讯。
　　

CSerialPort m_Ports; int nColtAddr,//这个用来存放当前采集设备地址。 nColts;//这个用来存放当前缓冲区收到的字节数目 HANDLE m_pThread;//外部控制线程 BYTE m_RecBuff[1000];//接收缓冲区 float fVal[20];//处理解包内容，这里可以根据实际情况进行定义。

　　启动串口监视线程和外部控制线程

nColtAddr = 0 ; nColts = 0; if(m_Ports.InitPort(this,1,4800,'N',8,1,EV_RXCHAR|EV_RXFLAG,1024)) { 　this->m_Ports.StartMonitoring();启动监视线程 　SetCommVal();发送第一台设备数据命令 }

　　下面是启动外部控制线程

unsigned int nDummy; m_pThread=(HANDLE) _beginthreadex(NULL,0,CommThread,this,CREATE_SUSPENDED,&nDummy);//开辟外部控制线程 ResumeThread(m_pThread); 运行线程

　　外部控制线程控制当前设备发送要数据命令和收到数据报文是否超时

UINT C××××View::CommThread(LPVOID pParam) { 　C××××View *pView = (C××××View *)pParam; 　while(1) 　{ 　　CTime cNowTime = CTime::GetCurrentTime(); 　　tNow = cNowTime.GetTime(); 　　struct _timeb timebuffer; 　　_ftime(&timebuffer); 　　int nNowMillSecond = timebuffer.millitm; 　　/// 　　tLast = cLastColtTime[0].GetTime(); 　　if((tNow - tLast)*1000 + (nNowMillSecond - nMillSecond[0]) > 800) 　　　　pView->SetCommVal();发送下一台设备要数据命令或者进行其他的相关处理 　　Sleep(100); 　} }

　　发送串口数据命令，这里要根据外部设备的制定的通讯协议来进行。这次温度表采用的是ASCII的形式通讯。

void C××××View::SetCommVal() { 　int HAddr,LAddr,m_Xnh; 　int nHAdd,nLAdd; 　nHAdd = ExchangeAscII((nColtAddr>>4)&0x0f); 　nLAdd = ExchangeAscII(nColtAddr&0x0f); 　m_Xnh = nHAdd^nLAdd^0x52^0x44; 　HAddr = ExchangeAscII((m_Xnh>>4)&0x0f); 　LAddr = ExchangeAscII(m_Xnh&0x0f); 　BYTE OutBuff[8] = {0x40,nHAdd,nLAdd,0x52,0x44,HAddr,LAddr,0x0d}; 　m_Ports.WriteToPort(OutBuff,8); 　cLastColtTime = CTime::GetCurrentTime(); 　nColtAddr++; 　if(nColtAddr > 19)//19 define max addr numbers 　nColtAddr = 0; }

　　ASCII码的一些简单变换，我们进行一下简单的封装，方便调用：

BYTE C××××View::ExchangeAscII(BYTE bInput) { 　BYTE bRef = 0; 　if(bInput > 9) 　　bRef = bInput+0x37; 　else 　　bRef = bInput+0x30; 　return bRef; } BYTE C××××View::ExchangeAscIItoNormal(BYTE bInput) { 　BYTE bRef = 0; 　if(bInput > 0x39) 　　bRef = bInput-0x37; 　else 　　bRef = bInput-0x30; 　return bRef; }