使用WindowsAPI和多线程进行串口通信[2]

// 数据接收

// 接收数据的任务由ReadFile函数完成。该函数从串口接收缓冲区中读取数据，

// 读取数据前，先用ClearCommError函数获得接收缓冲区中的字节数。接收

// 数据时，同步

// 和异步读取的差别同发送数据是一样的。

// lpInBuffer为接收数据的缓冲区指针，

// dwBytesToRead为准备读取的数据长度(即字节数)

DWORD CMyCom::ReadMyCom(LPVOID lpInBuffer, DWORD dwBytesToRead)

{

       BOOL bReadState;

       COMSTAT ComStat;        // 串行设备状态结构

       DWORD dwBytesRead, dwErrorFlags;

       if(!bOpen)return 0;             // 串口未打开

       // 用于读取串行设备的当前状态

       ClearCommError(hComDev, &dwErrorFlags, &ComStat);

       // 设定应该读取的数据长度

       dwBytesRead = min(dwBytesToRead, ComStat.cbInQue);

       // 读取数据

       if(dwBytesRead > 0)

bReadState = ReadFile(hComDev, lpInBuffer, dwBytesRead, &dwBytesRead, NULL);

       if(!bReadState)                   // 返回数据失败

              dwBytesToRead = 0;

       // 返回所读取的数据

       return dwBytesRead;

}

 

// 关闭串行设备

// 在整个应用程序结束或不再使用串行设备时，应将串行设备关闭，包括取消事

// 件监视，将设备打开标志bOpen置为FALSE以使事件监视线程结束，清除发送/接收缓冲

// 区和关闭设备句柄。

void CMyCom::CloseMyCom()

{

       bOpen = FALSE;

       // 取消事件监视，此时监视线程中的WaitCommEvent将返回

       SetCommMask(hComDev, 0);

       // 等待监视线程的结束

       WaitForSingleObject(hEvent, INFINITE);

       // 关闭事件句柄

       CloseHandle(hEvent);

       // 停止发送和接收数据，并清除发送和接收缓冲区

PurgeComm(hComDev, PURGE_TXABORT|PURGE_RXABORT|PURGE_TXCLEAR|

PURGE_RXCLEAR);

       // 关闭设备句柄

       CloseHandle(hComDev);

}

 

// 事件监视线程

// 事件监视线程对串口事件进行监视，当监视的事件发生时，监视线程即运行

UINT CommWatchProc(LPVOID pParam)

{

       //     pThread->m_bAutoDelete = TRUE;

       HWND hWnd = (HWND)pParam;

       char rbuf[1024];                 // 用于接受串口数据

       char wbuf[1];               // 用于返回数据

       CString strtemp;

       DWORD read;                                 // 保存串口缓冲区中的数据

 

       DWORD dwEventMask = 0;           // 发生的事件

      

       while(bOpen)              // 串口已被成功打开

       {

              WaitCommEvent(hComDev, &dwEventMask, NULL);

             if((dwEventMask & EV_RXCHAR) == EV_RXCHAR)

              {

                     // 接收到字符，在此加入语句进行处理

                     read = m_MyCom.ReadMyCom(rbuf);

                     if(read > 0)

                     {                  

                            for(int i=0; i<(int)read; i++)

                            {

                                   strtemp.Format("%c",rbuf[i]);

                                   recd += strtemp;

                            }

                                          m_MyCom.WriteMyCom(wbuf, DWORD(1));                   // 正确接收数据回写COM1端口数据1

                            }

              }

              if((dwEventMask & EV_ERR) == EV_ERR)

              {

                     MessageBox(NULL, _T("ComError"), _T("TRACE"), MB_OK);

              }

       }

      

       MessageBox(NULL, _T("ExitThread"), _T("TRACE"), MB_OK);

       SetEvent(hEvent);

 

       return 1;

}

 

CWinThread* pThread = AfxBeginThread(CommWatchProc, m_hWnd);

// 串口监视进程的建立

 

::TerminateThread(pThread, 0);         // 结束串口监视进程

delete pThread;                                       // 删除串口监视进程指针, 该语句可以省略

原文转自：http://www.ltesting.net