• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            山寨:不是最好的,是最適合我們的!歡迎體驗山寨 中文版MSDN

            Blog @ Blog

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

            常用鏈接

            統(tǒng)計

            積分與排名

            BBS

            Blog

            Web

            最新評論

            簡單封裝的串口通信類

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

            #include 
            "assert.h"

            CSerialPort::CSerialPort()
            {
                memset(
            &m_OverlappedRead, 0sizeof(m_OverlappedRead));
                memset(
            &m_OverlappedWrite, 0sizeof(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, 0sizeof(OVERLAPPED));
                memset(
            &m_OverlappedWrite, 0sizeof(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, truefalse, NULL);
                m_OverlappedWrite.Offset 
            = 0;
                m_OverlappedWrite.OffsetHigh 
            = 0;
                m_OverlappedWrite.hEvent 
            = ::CreateEvent(NULL, truefalse, 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, 40964096||
                    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;
            }


            //向串口寫數(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ù)用來檢測hHandle事件的信號狀態(tài),當(dāng)函數(shù)的執(zhí)行時間超過dwMilliseconds就
                    
            //返回,但如果參數(shù)dwMilliseconds為INFINITE時函數(shù)將直到相應(yīng)時間事件變成有信號狀態(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é)線程
                    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 閱讀(2782) 評論(3)  編輯 收藏 引用 所屬分類: 分享代碼

            評論

            # re: 簡單封裝的串口通信類 2008-01-07 21:11 isabc

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

            比如我們想通過MessageBox來輸出一個整形變量的值,可以用以下代碼實現(xiàn):

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

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

            # re: 簡單封裝的串口通信類 2008-01-08 10:09 isabc

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


              回復(fù)  更多評論   

            # re: 簡單封裝的串口通信類 2008-01-08 16:58 isabc

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

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

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

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

            廣告信息(免費廣告聯(lián)系)

            中文版MSDN:
            歡迎體驗

            久久久久久久久久久精品尤物| 四虎国产永久免费久久| 97久久综合精品久久久综合| 亚洲国产香蕉人人爽成AV片久久| 色综合久久综合网观看| 77777亚洲午夜久久多喷| 久久亚洲私人国产精品| 人妻少妇久久中文字幕| 久久精品国产亚洲av水果派| 久久久精品人妻一区二区三区蜜桃| 精产国品久久一二三产区区别 | 久久这里有精品视频| 久久久无码精品亚洲日韩软件| 久久国产视屏| 久久人人爽人人爽人人片AV麻烦| 99精品久久久久久久婷婷| 久久久久久久精品妇女99| 久久精品国产第一区二区三区| 国内精品久久久久久久97牛牛| 精品999久久久久久中文字幕| 久久精品9988| 日本高清无卡码一区二区久久| 久久亚洲日韩看片无码| 久久亚洲私人国产精品vA| 国产99久久九九精品无码| 伊人色综合久久天天网| 国产美女久久久| 久久精品?ⅴ无码中文字幕| 91麻豆国产精品91久久久| 国产精品女同久久久久电影院| 国产L精品国产亚洲区久久| 一本久久综合亚洲鲁鲁五月天亚洲欧美一区二区| 色综合合久久天天给综看| 久久99热只有频精品8| 久久久久久国产精品免费免费| 99久久无色码中文字幕人妻| 久久免费视频网站| 精品久久久无码21p发布| 久久久艹| 久久精品国产精品亚洲精品| 久久精品人人做人人爽电影|