做过串口通讯的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等，希望能与大家一块共享。