Blog @ Blog

當(dāng)華美的葉片落盡，生命的脈絡(luò)才歷歷可見(jiàn)。－－聶魯達(dá)

導(dǎo)航

公告

留言簿(20)

隨筆分類(lèi)(156)

文章分類(lèi)(1)

隨筆檔案(198)

文章檔案(2)

相冊(cè)

Meet or get-together

閱讀排行榜

評(píng)論排行榜

常用鏈接

統(tǒng)計(jì)

隨筆 - 198
文章 - 2
評(píng)論 - 156
引用 - 0

積分與排名

積分 - 662706
排名 - 24

BBS

Sohu Club

Blog

Web

CSDN
VC KBase

簡(jiǎn)單封裝的串口通信類(lèi)

#include "stdafx.h"
#include "SerialPort.h"

#include "assert.h"

CSerialPort::CSerialPort()
{
    memset(&m_OverlappedRead, 0, sizeof(m_OverlappedRead));
    memset(&m_OverlappedWrite, 0, sizeof(m_OverlappedWrite));
    m_bOpened = false;
    m_ReadComThread = NULL;
    m_hIDCom = NULL;
    m_dwReadLen = 0;
}

CSerialPort::~CSerialPort()
{

}

BOOL CSerialPort::OpenPort(UINT nPort, UINT nBaud)
{
    ASSERT(nPort > 0 && nPort < 5);
    if(m_bOpened)
        return true;

    TCHAR szPort[15];
    TCHAR szComParams[50];
    DCB dcb;

    wsprintf(szPort, _T("COM%d"), nPort);
    m_hIDCom = ::CreateFile(szPort,
        GENERIC_READ | GENERIC_WRITE,
        0,
        NULL,
        OPEN_EXISTING,
        FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED,
        NULL);
    if(m_hIDCom == NULL)
        return false;

    memset(&m_OverlappedRead, 0, sizeof(OVERLAPPED));
    memset(&m_OverlappedWrite, 0, sizeof(OVERLAPPED));

    COMMTIMEOUTS CommTimeOuts;
    CommTimeOuts.ReadIntervalTimeout = 0xFFFFFFFF;
    CommTimeOuts.ReadTotalTimeoutConstant = 0;
    CommTimeOuts.ReadTotalTimeoutMultiplier = 0;
    CommTimeOuts.WriteTotalTimeoutMultiplier = 0;
    CommTimeOuts.WriteTotalTimeoutConstant = 5000;
    ::SetCommTimeouts(m_hIDCom, &CommTimeOuts);

    wsprintf(szComParams, _T("COM%d:%d,N,8,1"), nPort, nBaud);
    m_OverlappedRead.Offset = 0;
    m_OverlappedRead.OffsetHigh = 0;
    m_OverlappedRead.hEvent = ::CreateEvent(NULL, true, false, NULL);
    m_OverlappedWrite.Offset = 0;
    m_OverlappedWrite.OffsetHigh = 0;
    m_OverlappedWrite.hEvent = ::CreateEvent(NULL, true, false, NULL);

    dcb.DCBlength = sizeof(DCB);
    ::GetCommState(m_hIDCom, &dcb);
    dcb.BaudRate = nBaud;
    dcb.ByteSize = 8;
    dcb.Parity = 0;

    if(!SetCommState(m_hIDCom, &dcb) || !SetupComm(m_hIDCom, 4096, 4096) ||
        m_OverlappedRead.hEvent == NULL || m_OverlappedWrite.hEvent == NULL)
    {
        DWORD dwError = ::GetLastError();
        if(m_OverlappedRead.hEvent != NULL)
            ::CloseHandle(m_OverlappedRead.hEvent);
        if(m_OverlappedWrite.hEvent != NULL)
            ::CloseHandle(m_OverlappedWrite.hEvent);
        ::CloseHandle(m_hIDCom);
        return false;
    }
    ::SetCommMask(m_hIDCom, EV_RXCHAR);
    ::PurgeComm(m_hIDCom, PURGE_TXABORT | PURGE_RXABORT | PURGE_TXCLEAR | PURGE_RXCLEAR);
    ::EscapeCommFunction(m_hIDCom, SETDTR);

    m_bOpened =true;
    m_bExitThread =false;

    StartMonitoring();
    return m_bOpened;
}

BOOL CSerialPort::Close()
{
    if(!m_bOpened || m_hIDCom == NULL)
        return true;
    m_bExitThread = true;
    ::SetCommMask(m_hIDCom, 0);
    StopMonitoring();

    if(m_OverlappedRead.hEvent != NULL)
        ::CloseHandle(m_OverlappedRead.hEvent);

    if(m_OverlappedWrite.hEvent != NULL)
        ::CloseHandle(m_OverlappedWrite.hEvent);

    ::CloseHandle(m_hIDCom);

    m_bOpened = false;
    m_hIDCom = NULL;

    return true;
}

//向串口寫(xiě)數(shù)據(jù)
void CSerialPort::WriteToPort(BYTE *Byte, int Len)
{
    if(!m_bOpened || m_hIDCom == NULL)
        return;

    BOOL bWriteStat;
    DWORD dwBytesWritten;
    ClearReadBuf();
    bWriteStat = ::WriteFile(m_hIDCom, Byte, Len, &dwBytesWritten, &m_OverlappedWrite);

    if(!bWriteStat && (::GetLastError() == ERROR_IO_PENDING))
    {
        //WaitForSingleObject函數(shù)用來(lái)檢測(cè)hHandle事件的信號(hào)狀態(tài)，當(dāng)函數(shù)的執(zhí)行時(shí)間超過(guò)dwMilliseconds就
        //返回，但如果參數(shù)dwMilliseconds為INFINITE時(shí)函數(shù)將直到相應(yīng)時(shí)間事件變成有信號(hào)狀態(tài)才返回，
        //否則就一直等待下去，直到WaitForSingleObject有返回直才執(zhí)行后面的代碼。
        DWORD dw = ::WaitForSingleObject(m_OverlappedWrite.hEvent, INFINITE );
        if(dw == WAIT_TIMEOUT)
        {
            dwBytesWritten = 0;
            DCB dcb;
            ::GetCommState(m_hIDCom, &dcb);
            ::PurgeComm(m_hIDCom, PURGE_TXCLEAR);
            return;
        }
        else
        {
            ::GetOverlappedResult(m_hIDCom, &m_OverlappedWrite, &dwBytesWritten, false);//等待服務(wù)器完成IO操作
            m_OverlappedWrite.Offset += dwBytesWritten;
        }
    }
    return ;
}

//從串口讀取數(shù)據(jù)
int CSerialPort::ReadFromPort(BYTE *lpszBlock, int nRLen)
{
    if(!m_bOpened || m_hIDCom == NULL)
        return 0;

    BOOL bReadStat;
    DWORD dwBytesRead, dwErrorFlags;
    COMSTAT ComStat;
    ::ClearCommError(m_hIDCom, &dwErrorFlags, &ComStat);
    if(!ComStat.cbInQue)
        return 0;

    dwBytesRead = (DWORD) ComStat.cbInQue;
    if(nRLen < (int)dwBytesRead)
        dwBytesRead = (DWORD) nRLen;

    bReadStat = ::ReadFile(m_hIDCom, lpszBlock, dwBytesRead, &dwBytesRead, &m_OverlappedRead);
    if(!bReadStat)
    {
        if(::GetLastError() == ERROR_IO_PENDING)
        {
            ::WaitForSingleObject(m_OverlappedRead.hEvent, INFINITE);
            return (int)dwBytesRead;
        }
        return 0;
    }
    return (int)dwBytesRead;
}

UINT CSerialPort::CommThread(LPVOID pParam)
{
    CSerialPort* pSerialPort = (CSerialPort*)pParam;
    BYTE Buffer[4096];
    DWORD dwEvent, dwError;
    COMSTAT ComStat;
    int ReadLen = 0;
    memset(pSerialPort->m_ReadBuf, '\0', sizeof(pSerialPort->m_ReadBuf));
    ::SetCommMask(pSerialPort->m_hIDCom, EV_RXCHAR);
    while(!pSerialPort->m_bExitThread)
    {
        memset(Buffer, '\0', 4096);
        ::WaitCommEvent(pSerialPort->m_hIDCom, &dwEvent, NULL);
        ::ClearCommError(pSerialPort->m_hIDCom, &dwError, &ComStat);
        if((dwEvent & EV_RXCHAR) && ComStat.cbInQue)
        {
            pSerialPort->m_dwReadLen = pSerialPort->ReadFromPort(Buffer,4096);
            pSerialPort->m_dwReadLen = ReadLen >4096 ? 4096 : ReadLen;
            if(pSerialPort->m_dwReadLen > 0)
            {
                memcpy(pSerialPort->m_ReadBuf, Buffer,pSerialPort->m_dwReadLen);
            }
        }
        ::PurgeComm(pSerialPort->m_hIDCom, PURGE_RXCLEAR);
    }
    return 0;
}

BOOL CSerialPort::StartMonitoring()
{
    if(m_ReadComThread == NULL)
    {
        if(!(m_ReadComThread = ::AfxBeginThread(CommThread, this)))
            return false;
    }
    return true;
}

BOOL CSerialPort::StopMonitoring()
{
    if(m_ReadComThread != NULL)
    {
        ::TerminateThread(m_ReadComThread->m_hThread, 0); //終結(jié)線(xiàn)程
        m_ReadComThread = NULL;
    }
    return true;
}

void CSerialPort::ClearReadBuf()
{
    memset(m_ReadBuf, '\0', sizeof(m_ReadBuf));
    m_dwReadLen = 0;
}

posted on 2008-01-07 21:11 isabc 閱讀(2820) 評(píng)論(3) 編輯收藏引用所屬分類(lèi): 分享代碼

評(píng)論

# re: 簡(jiǎn)單封裝的串口通信類(lèi) 2008-01-07 21:11 isabc

在C語(yǔ)言中格式化字符串可以使用printf
但是在WINDOWS編程設(shè)計(jì)中卻行不通了，但是卻有變通的方法
那就是用 wsprintf這個(gè)函數(shù) 它的格式如下：
wsprintf(緩沖區(qū),格式，要格式化的值)；
第一個(gè)參數(shù)是字符緩沖區(qū)，后面是格式字符串，wsprintf不是將格式化結(jié)果寫(xiě)到標(biāo)準(zhǔn)輸出，而是將其寫(xiě)入緩沖區(qū)中，該函數(shù)返回該字符串的長(zhǎng)度。

比如我們想通過(guò)MessageBox來(lái)輸出一個(gè)整形變量的值，可以用以下代碼實(shí)現(xiàn)：

char szBuffer[100];
ing number=100;
wsprintf(szBuffer, “%d”,number);
MessgaeBox(NULL,szBrffer,TEXT(“格式化字符串”),0);

這個(gè)函數(shù)除了將內(nèi)容格式化輸出到第一個(gè)參數(shù)所提供的字符串緩沖區(qū)以外，其它功能與printf函數(shù)相同。
回復(fù) 更多評(píng)論

# re: 簡(jiǎn)單封裝的串口通信類(lèi) 2008-01-08 10:09 isabc

HANDLE CreateEvent(
LPSECURITY_ATTRIBUTES lpEventAttributes,
// 指定對(duì)象的安全描述符，一般設(shè)為NULL （安全屬性結(jié)構(gòu)如下）
BOOL bManualReset, // 指定是否人工重置
BOOL bInitialState, // 返回的句柄是否可繼承
LPCTSTR lpName // 對(duì)象的名字，用于多進(jìn)程間共享對(duì)象
);
返回的為event對(duì)象的句柄
安全屬性結(jié)構(gòu)
typedef struct _SECURITY_ATTRIBUTES {
DWORD nLength;
LPVOID lpSecurityDescriptor;
BOOL bInheritHandle;
} SECURITY_ATTRIBUTES, *PSECURITY_ATTRIBUTES;

回復(fù) 更多評(píng)論

# re: 簡(jiǎn)單封裝的串口通信類(lèi) 2008-01-08 16:58 isabc

查詢(xún)當(dāng)前的超時(shí)設(shè)置應(yīng)調(diào)用GetCommTimeouts函數(shù)，該函數(shù)會(huì)填充一個(gè)COMMTIMEOUTS結(jié)構(gòu)。調(diào)用SetCommTimeouts可以用某一個(gè)COMMTIMEOUTS結(jié)構(gòu)的內(nèi)容來(lái)設(shè)置超時(shí)。
　　讀寫(xiě)串口的超時(shí)有兩種：間隔超時(shí)和總超時(shí)。間隔超時(shí)是指在接收時(shí)兩個(gè)字符之間的最大時(shí)延。總超時(shí)是指讀寫(xiě)操作總共花費(fèi)的最大時(shí)間。寫(xiě)操作只支持總超時(shí)，而讀操作兩種超時(shí)均支持。用COMMTIMEOUTS結(jié)構(gòu)可以規(guī)定讀寫(xiě)操作的超時(shí)。
COMMTIMEOUTS結(jié)構(gòu)的定義為： typedef struct _COMMTIMEOUTS {
DWORD ReadIntervalTimeout; //讀間隔超時(shí)
DWORD ReadTotalTimeoutMultiplier; //讀時(shí)間系數(shù)
DWORD ReadTotalTimeoutConstant; //讀時(shí)間常量
DWORD WriteTotalTimeoutMultiplier; // 寫(xiě)時(shí)間系數(shù)
DWORD WriteTotalTimeoutConstant; //寫(xiě)時(shí)間常量
} COMMTIMEOUTS,*LPCOMMTIMEOUTS;

COMMTIMEOUTS結(jié)構(gòu)的成員都以毫秒為單位。總超時(shí)的計(jì)算公式是：
總超時(shí)＝時(shí)間系數(shù)×要求讀/寫(xiě)的字符數(shù)＋時(shí)間常量
例如，要讀入10個(gè)字符，那么讀操作的總超時(shí)的計(jì)算公式為：
讀總超時(shí)＝ReadTotalTimeoutMultiplier×10＋ReadTotalTimeoutConstant
可以看出：間隔超時(shí)和總超時(shí)的設(shè)置是不相關(guān)的，這可以方便通信程序靈活地設(shè)置各種超時(shí)。

如果所有寫(xiě)超時(shí)參數(shù)均為0，那么就不使用寫(xiě)超時(shí)。如果ReadIntervalTimeout為0，那么就不使用讀間隔超時(shí)。如果ReadTotalTimeoutMultiplier 和 ReadTotalTimeoutConstant 都為0，則不使用讀總超時(shí)。如果讀間隔超時(shí)被設(shè)置成MAXDWORD并且讀時(shí)間系數(shù)和讀時(shí)間常量都為0，那么在讀一次輸入緩沖區(qū)的內(nèi)容后讀操作就立即返回，而不管是否讀入了要求的字符。
　　在用重疊方式讀寫(xiě)串口時(shí)，雖然ReadFile和WriteFile在完成操作以前就可能返回，但超時(shí)仍然是起作用的。在這種情況下，超時(shí)規(guī)定的是操作的完成時(shí)間，而不是ReadFile和WriteFile的返回時(shí)間。
配置串口的示例代碼： SetupComm(hCom,1024,1024); //輸入緩沖區(qū)和輸出緩沖區(qū)的大小都是1024

COMMTIMEOUTS TimeOuts;
//設(shè)定讀超時(shí)
TimeOuts.ReadIntervalTimeout=1000;
TimeOuts.ReadTotalTimeoutMultiplier=500;
TimeOuts.ReadTotalTimeoutConstant=5000;
//設(shè)定寫(xiě)超時(shí)
TimeOuts.WriteTotalTimeoutMultiplier=500;
TimeOuts.WriteTotalTimeoutConstant=2000;
SetCommTimeouts(hCom,&TimeOuts); //設(shè)置超時(shí)
回復(fù) 更多評(píng)論

刷新評(píng)論列表

只有注冊(cè)用戶(hù)登錄后才能發(fā)表評(píng)論。


相關(guān)文章: 存儲(chǔ)過(guò)程示例 SQL創(chuàng)建數(shù)據(jù)庫(kù)示例代碼封裝ADO編程Connection對(duì)象的類(lèi) 連接服務(wù)流程代碼 GSM短信息部分代碼！簡(jiǎn)單封裝的串口通信類(lèi)

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問(wèn) Chat2DB 管理