异步串口通信 VC++
//MyComm.h 多机控制 异步串口通信
class CMyComm
{
public:
CMyComm();
virtual ~CMyComm();
void PreOpenSetupQueue(DWord dwInQueue, DWORD dwOutQueue);
// size of input buffer, size of output buffer
BOOL Open(int nPort, int nBaud);
//默认无校验，每个字节发送11个bit，异步方式。
//若设置校验后，校验错则字节被替换为0x7E
BOOL SetupQueue(DWORD dwInQueue, DWORD dwOutQueue);
// size of input buffer, size of output buffer
BOOL ResetParity(char Parity);//parity = 'N', 'O', 'E', 'M', 'S' 不区分大小写
//分别表示 no, odd, even, mark, space
// 在Open()前设置无效。
BOOL SendData(LPCVOID lpBuf, DWORD dwToWrite);
DWORD ReadData(LPVOID lpBuf, DWORD dwToRead);
void Close();
protected:
HANDLE m_hCom;
BOOL m_bOpened;
OVERLAPPED m_osReader;
OVERLAPPED m_osWriter;
DWORD m_dwInBuf;
DWORD m_dwOutBuf;
};
//////////////////////////////////////////////////////////
//MyComm.cpp
#include "stdafx.h"
#include "MyComm.h"
///////////////////////////////////////////
CMyComm::CMyComm()
{
m_bOpened = FALSE;
m_dwInBuf = 512;
m_dwOutBuf = 512;
m_hCom = NULL;
}
void CMyComm::PreOpenSetupQueue(DWORD dwInQueue, DWORD dwOutQueue)
{
m_dwInBuf = dwInQueue;
m_dwOutBuf = dwOutQueue;
}
BOOL CMyComm::Open(int nPort, int nBaud)
{
ASSERT(nPort > 0 nPort < 5 nBaud >= 110 nBaud <= 128000);
if( m_bOpened ) return TRUE;
char szPort[15];
char lpDef[15];
DCB dcb = {0};
dcb.DCBlength = sizeof(dcb);
wsprintf(szPort, "COM%d", nPort);
wsprintf(lpDef, "%d,n,8,1", nBaud);
m_hCom = CreateFile(szPort, GENERIC_READ GENERIC_WRITE,
0, NULL, OPEN_EXISTING, FILE_FLAG_OVERLAPPED, NULL);
if( m_hCom == INVALID_HANDLE_VALUE ) return FALSE;
FillMemory(&m_osReader, sizeof(OVERLAPPED), 0);
FillMemory(&m_osWriter, sizeof(OVERLAPPED), 0);
m_osReader.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
m_osWriter.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
int byteUsedTime = 14400 / nBaud +1;
COMMTIMEOUTS timeouts = {20 + byteUsedTime, byteUsedTime, 1000, byteUsedTime , 20};
dcb.fParity = TRUE;
dcb.fErrorChar = TRUE;
dcb.ErrorChar = '~';
if( m_osReader.hEvent == NULL m_osWriter.hEvent == NULL
!SetCommTimeouts(m_hCom, &timeouts)
!BuildCommDCB(lpDef, &dcb) !SetupComm(m_hCom, m_dwInBuf, m_dwOutBuf)) {
if( m_osReader.hEvent != NULL )
CloseHandle( m_osReader.hEvent );
if( m_osWriter.hEvent != NULL )
CloseHandle( m_osWriter.hEvent );
CloseHandle( m_hCom );
return FALSE;
}
m_bOpened = TRUE;
return m_bOpened;
}
BOOL CMyComm::SetupQueue(DWORD dwInQueue, DWORD dwOutQueue)
{
if (m_hCom == NULL) return FALSE;
m_dwInBuf = dwInQueue;
m_dwOutBuf = dwOutQueue;
return SetupComm(m_hCom, m_dwInBuf, m_dwOutBuf);
}
BOOL CMyComm::ResetParity(char Parity)
{
if (m_hCom == NULL) return FALSE;
DCB dcb;
dcb.DCBlength = sizeof( DCB );
if (!GetCommState(m_hCom, &dcb)) return FALSE;
BYTE cParity;
Parity = tolower(Parity);
switch (Parity) {
case 'o':
cParity = 1;
break;
case 'e':
cParity = 2;
break;
case 'm':
cParity = 3;
break;
case 's':
cParity = 4;
break;
default:
cParity = 0;
break;
}
dcb.Parity = cParity;
return SetCommState(m_hCom, &dcb);
}
BOOL CMyComm::SendData(LPCVOID lpBuf, DWORD dwToWrite)
{
TRACE("SSSSSSSSSSSSS 00\n");
if( !m_bOpened m_hCom == NULL ) return FALSE;
DWORD dwWritten;
if (WriteFile(m_hCom, lpBuf, dwToWrite, &dwWritten, &m_osWriter)) return TRUE;
if (GetLastError() != ERROR_IO_PENDING) return FALSE;
GetOverlappedResult(m_hCom, &m_osWriter, &dwWritten, TRUE);
TRACE("SSSSSSSSSSSSS 11\n");
return (dwToWrite == dwWritten);
}
DWORD CMyComm::ReadData(LPVOID lpBuf, DWORD dwToRead)
{
TRACE("RRRRRRRRRRRR 00\n");
if( !m_bOpened m_hCom == NULL ) return 0;
DWORD dwRead;
if (ReadFile(m_hCom, lpBuf, dwToRead, &dwRead, &m_osReader) ) return dwRead;
if (GetLastError() != ERROR_IO_PENDING) return 0;
if (WaitForSingleObject(m_osReader.hEvent, INFINITE) != WAIT_OBJECT_0 )
return 0;
if (!GetOverlappedResult(m_hCom, &m_osReader, &dwRead, FALSE) )
return 0;
TRACE("RRRRRRRRRRRR 11\n");
return dwRead;
}
void CMyComm::Close()
{
if (m_osReader.hEvent != NULL) CloseHandle( m_osReader.hEvent );
if (m_osWriter.hEvent != NULL) CloseHandle( m_osWriter.hEvent );
if (m_hCom != NULL) CloseHandle( m_hCom );
m_bOpened = FALSE;
}
CMyComm::~CMyComm()
{
Close();
}
// main.cpp
char Buf[40];
int nArray[3];
CMyComn myCom;
UINT SendDataProc(LPVOID pParam);
void OnCommSendReceive()
{
myCom.PreOpenSetupQueue(12, 12);
if (!myCom.Open(2, 4800)) return;
//假如想改变校验位，在此位置，如：myCom.ResetParity('m');
FillMemory(Buf, 40, 0);
nArray[0] = 0;
nArray[1] = 17;
nArray[2] = 88888;
AfxBeginThread(SendDataProc, (LPVOID)(12));
TRACE("EEEEEEEE\n");
int nRead = myCom.ReadData(Buf, 12);
int* nA = (int*) Buf;
TRACE("AAAAAAAAAAAAAA %d, %d %d %d\n",nRead, nA[0], nA[1], nA[1]);
}
UINT SendDataProc(LPVOID pParam)
{
return myCom.SendData((LPVOID)nArray, (DWORD) pParam);
}
