C#基于事件驱动的多串口多线程串口通讯软件架构设计

最近写一个串口通讯程序，客户对界面，容量要求都比较高。要求支持多串口同时工作。于是自己提炼了一个架构，用于抛砖引玉。 本来想用VC，基于成本考虑，决定采用.Net，而且C#的事件比VC的消息容易控制些，只是跨线程触发的时候稍微注意下。

先上个图

上图是整个通讯控制架构，根据配置文件加载实例，每个串口打开一个线程用以处理命令队列。命令加以优先级来区分轻重缓急。

   //向队列追加命令
public void CmdQueeAppend(CommPak oPak)
{
lock( _LstCommPaks )
{
_LstCommPaks.Add( oPak );
}
}

public class CommPakCollection : System.Collections.CollectionBase
{
public Type ItemType
{
get { return typeof(CommPak); }
}

   public CommPak Add(CommPak oCln)
{
//根据优先级进行排序
int iPos = List.Count;
for (int i = List.Count - 1; i > 0; i--)
{
if (oCln.Priorty > this[i].Priorty)
iPos = i;
}

    List.Insert(iPos, oCln);
return oCln;
}

.....

}

线程体：

   public void ThreadMain( )
{
Status = CommPortStatus.Started;

    while ( Status == CommPortStatus.Started)
{
CommPak oPak = CmdQueePop();
if (oPak != null)
{
//发送这个包
oPak.Send( m_SerialPort );
//休息一段时间，防止多串口时占用太多CPU
}
Thread.Sleep(5);
}
}

下图是命令的基类， 各命令根据具体情况从此类派生，来处理各自的输入输出。

public static class CommPakPriortys
{
public const int Lowest = -2;
public const int Low = -1;
public const int Normal = 0;
public const int High = 1;
public const int Immdiatly = 2;
}

接收到数据或者异常时触发事件

   protected void ReportError(DeviceReturnEventArgs oArg)
{
if (onCommAnswered != null)
onCommAnswered(this, oArg);
}

public class DeviceReturnEventArgs : EventArgs
{

   public DeviceReturnEventArgs():base()
{
}

   //错误消息
public string Message = string.Empty;
//错误代码
public CommErrorTypes Error = CommErrorTypes.NoError;
//正确执行后，返回的数据包
public CommRecvPak RevcPak;
}