做过串口通讯的VCer肯定都熟悉MsComm控件和CodeProject上的CSerial。也许更多的程序员更愿意使用不需要控件的CSerial。但是不幸的是，CSerial类仅仅完成对底层串口通讯的封装，有时候并不如MsComm控件好用。
CSerialPort为bluejoe在CSerial基础上开发的类，支持开启事件监视线程。CTaskedPort为CSerialPort的派生类，它支持基于任务的事件处理。
用户发送一条命令（如：AT），可能就需要等待串口的回应（如：OK）才决定做下一步，这个AT命令其实就是一项任务（CPortTask），任务的结束一般需要用户指定关键词（如：OK或者ERROR）。CTaskedPort自动将命令和关键词列表封装成一个任务。
本包主要包括以下几个类：
CSerialPort：类似于CSerial的类，类声明如下：
class CSerialPort
{
public:
void AssertConnected();
CWinThread * GetListener();
CString ReadAll();
CWinThread * EnableListener(BOOL bEnable = TRUE);
BOOL SetDCB(DCB * pDCB, int nHandshaking);
enum
{
comNone,
comXOnXOff,
comRTS,
comRTSXOnXOff
};
BOOL IsConnected();
BOOL GetOverlappedResult(OVERLAPPED * pol, DWORD * pLength, BOOL bWait);
BOOL GetTimeouts(COMMTIMEOUTS * cto);
BOOL SetTimeouts(COMMTIMEOUTS * cto);
BOOL Purge(DWORD nFlags);
BOOL GetComStat(COMSTAT * pcs);
UINT CommThread();
BOOL ClearOutputBuffer();
BOOL ClearInputBuffer();
BOOL FlushOutputBuffer();
BOOL SetDCB(DCB * pDCB);
HANDLE GetHandle();
BOOL Open(int nPort);
BOOL GetDCB(DCB * pDCB);
BOOL SetDCB(UINT nBaudRate, BYTE cParity = NOPARITY, BYTE nByteSize = 8, BYTE nStopBits = ONESTOPBIT);
BOOL Open(CString sPort);
void Close();
CString Read(BOOL bWait = FALSE);
DWORD Read(char *pBuffer, DWORD nLength, BOOL bWait = FALSE);
DWORD Write(char *pBuffer, DWORD nLength, DWORD nWaitLimit = INFINITE);
DWORD Write(CString sBuffer, DWORD nWaitLimit = INFINITE);
static UINT CommThread(LPVOID pParam);
//开启监视线程，以事件方式通知
CWinThread * StartListener(DWORD nEventMask = EV_BREAK | EV_ERR | EV_RXCHAR);
//开启监视线程，以消息方式通知
CWinThread * StartListener(CWnd * pOwner, UINT nNotifyMessageID = IDU_COMM_EVENT, DWORD nEventMask = EV_BREAK | EV_ERR | EV_RXCHAR);
CSerialPort();
virtual ~CSerialPort();
private:
CWnd * m_pOwner;
CWinThread * m_pThread;
UINT m_nNotifyMessageID;
OVERLAPPED m_osRead; // 用于重叠读
OVERLAPPED m_osWrite; // 用于重叠写
BOOL m_bConnected;
volatile HANDLE m_hHandle;
volatile HANDLE m_hShutDownEvent;
protected:
virtual void OnDisconnect();
virtual void OnEvent(DWORD nEvent);
virtual void OnEvRLSD();
virtual void OnEvErr();
virtual void OnEvDSR();
virtual void OnEvBreak();
virtual void OnEvTxEmpty();
virtual void OnEvRXFlag();
virtual void OnEvRxChar();
virtual void OnEvRing();
virtual void OnEvCTS();
};
CPortTask：完成对串口任务的封装，类声明如下：
class CPortTask
{
protected:
CStringArray m_sMatches;
CByteArray m_nMatchCodes;
int m_nLimit;
HANDLE m_hCompleteEvent;
BOOL m_bCompleted;
CWnd * m_pOwner;
UINT m_nNotifyMessageID;
CMutex m_Mutex;
int m_nMatchIndex;
int m_nDirty; //数据脏计数，每次接收到数据，该计数自动加1
CTaskedPort * m_pOwnerPort;
CString m_sFullInput; //该任务消化的字符
void EndTask(); //结束当前任务
void CompleteTask(); //完成当前任务
public:
CStringArray * GetMatches();
CString m_sTaskName;
CString GetInputBuffer();
int GetDirty();
void SetBufferSize(int nLimit); //设置缓冲区长度
void AbortTask(); //取消当前任务
void ResetTask(); //重置当前任务
void SetOwner(CTaskedPort * pOwnerPort); //设置隶属CTaskedPort
int GetMatchCode(); //获取匹配码
CPortTask(CString sTaskName);
~CPortTask();
void AttachEvent(CWnd * pOwner, UINT nMessageID = IDU_TASK_COMPLETE); //设置消息通知方式
void AttachEvent(HANDLE hEvent); //设置事件通知方式
int Catch(CString sInput); //消化字符串
BOOL IsCompleted(); //指定该任务是否已完成
virtual void OnTaskCompleted();
int AddMatches(CString sMatches); //添加多个匹配项，匹配项之间以|分隔
int AddMatch(CString sMatch); //添加匹配项
int AddMatch(CString sMatch, int nValue); //添加匹配项，并指定匹配码
};
CTaskedPort：支持任务的串口操作类，类声明如下：
class CTaskedPort : public CSerialPort
{
private:
CPortTask * m_pBGTask; //后台任务
CPortTask * m_pFGTask; //前台任务
public:
void WaitForTask(CPortTask *pTask, int nEndCondition, CWaiting * pWaiting, DWORD nIdleTimeLimit);
void Close();
//等待时间
enum
{
tmShort = 20,
tmNormal = 1000,
tmInitialize = 3000,
tmLong = 6000,
tmLonger = 20000,
};
//指定GetInput函数的行为
enum
{
//指定GetInput调用的终止条件
//0-3: 匹配条件
ecDirty = 0x0001, //有值即返回
ecWaiting = 0x0002, //不等待
ecOkOrError = 0x0004, //有OK或者ERROR即返回
ecCrlf = 0x0008, //有回车即返回
//4-7: 指定发生等待超时时GetInput的动作选项
ecRetryAlways = 0x0100, //一直等待
ecRetryPrompt = 0x0200, //提示用户是否继续
};
CMutex m_Mutex;
BOOL Open(CString sPort);
int Request(CString sRequest, CString & sResponse, int nEndCondition, CWaiting * pWaiting, char * sFind = NULL, CString sTaskName = "", DWORD nIdleTimeLimit = tmNormal);
DWORD SendCommand(CString sCommand, DWORD nIdleTimeLimit = tmNormal);
CString Request(CString sRequest, int nEndCondition, CWaiting * pWaiting, char * sFind = NULL, CString sTaskName = "", DWORD nIdleTimeLimit = tmNormal);
void UnloadTask(CPortTask * pTask);
void LoadFGTask(CPortTask * pTask);
void LoadBGTask(CPortTask * pTask);
CString m_sInputBuffer;
void OnEvRxChar();
CTaskedPort();
virtual ~CTaskedPort();
};
CTaskedPort支持的任务包括后台任务和前台任务，它同时只允许一个任务被激活：如果存在前台任务，后台任务自动隐藏；新前台任务的载入，会自动覆盖旧的任务。
后台任务一直存在，用以监视用户指定的串口事件，并构造字符缓冲区。当用户调用Request函数时，CTaskedPort自动创建一个前台任务，并disable后台监视任务。前台任务一直等待，直到关键字的出现（或者超时）。这个等待过程表现出来的是一个同步接口，用户只需要等待Request函数结束即可。至于用户可能需要在等待过程中做一些其它的操作，如：显示进度条，这就需要用到CWaiting类。
CWaiting：CWaiting类用以指定等待过程中的动作，系统中已提供了3种CWaiting类：CDumbWaiting（啥都不干）、CProgressWaiting（显示进度条）和CNewProgressWaiting（创建一个新的进度窗口并显示进度）。CNewProgressWaiting继承于CProgressWaiting，它们之间的区别在于CProgressWaiting可以依附于任何一个窗口（如：当前的主窗口），而CNewProgressWaiting创建一个新的窗口。
创建一个CWaiting对象，将它作为参数，传入Request函数，就这么简单，你的程序就完成了同步等待和异步显示。
此外，Request允许用户指定等待时限。在等待超时时，是否直接结束等待，还是继续重试，还是弹出提示框询问用户，这些动作都可以通过Request的参数指定。
CTaskedPort还提供了丰富的接口，用户可以通过继承，来实现更多的功能。
本包已经成功应用到bluejoe的手机串口通讯软件，目前还没有发现什么问题。希望各位使用探讨，并希望各位提出修改意见。
所附源码还包括其它的工具类，包括CUtil、CRichException、CWin32Exception等，希望能与大家一块共享。
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent