当前位置导航:炫浪网>>网络学院>>编程开发>>Visual C#教程

浅谈C#异步数据接收串口操作类

  
  使用C#调用传统32位API实现串口操作,整个结构特别的简单。接收数据只需要定义数据接收事件即可。
  
  上传源代码我不会,需要源代码的请与我([email protected])联系。你也可以教我怎么上传源代码。
  
  using System;
  using System.Runtime.InteropServices;
  
  /// <summary>
  /// (C)2003-2005 C2217 Studio 保留所有权利
  ///
  /// 文件名称:   IbmsSerialPort.cs
  /// 文件ID:
  /// 文件说明:
  ///     封装动态链接库IbmsSerialPort.dll的功能,提供在.NET环境中
  ///     串口异步接收和发送数据的功能。
  ///
  /// 当前版本:  1.0
  ///
  /// 作者:  邓杨均
  /// 创建日期:  2005-2-2
  /// 最后修改日期: 2005-2-2
  ///
  /// 历史修改记录:
  ///
  /// </summary>
  
  namespace Ibms.Tool.IO
  {
  
  /// <summary>
  /// 当串口接收到数据时,会产生一个事件。
  /// SPRecvDataArgs就是该事件的参数,参数中的RecvData包含接收到的数据。
  /// 使用方法:
  /// </summary>
  public class SPRecvDataArgs:EventArgs
  {
  /// <summary>
  /// 接收到的数据组成的字节数组
  /// </summary>
  private byte[] recvData;
  
  /// <summary>
  /// 构造函数,需要一个包含数据的byte[]作为初始化参数来实例化 SPRecvDataArgs
  /// </summary>
  /// <param name="recvData">接收到的数据</param>
  public SPRecvDataArgs(byte[] recvData)
  {
  if( recvData == null)
  {
  throw(new ArgumentNullException());
  }
  
  this.recvData = recvData;
  }
  
  /// <summary>
  /// 返回接收到的数据内容
  /// </summary>
  public byte[] RecvData
  {
  get
  {
  return recvData;
  }
  }
  }
  
  /// <summary>
  /// 封装动态链接库IbmsSerialPort.dll的功能,提供在.NET环境中异步
  /// 串口接收和发送功能。特别实现的是异步通过信号自动接收数据的模式。
  /// </summary>
  public class IbmsSerialPort:IDisposable
  {
  
  #region 平台调用声明代码
  
  /// <summary>
  /// 声明IbmsSerialPort.dll的Ibms_OpenPort函数
  /// </summary>
  /// <param name="nPort">串口号</param>
  /// <param name="nRate">波特率</param>
  /// <returns></returns>
  [DllImport("IbmsSerialPort.dll")]
  public static extern IntPtr Ibms_OpenPort(int nPort, int nRate);
  
  /// <summary>
  /// 声明IbmsSerialPort.dll的Ibms_Close函数
  /// </summary>
  [DllImport("IbmsSerialPort.dll")]
  public static extern void Ibms_Close( IntPtr port);
  
  /// <summary>
  /// 声明IbmsSerialPort.dll的Ibms_SendData函数
  /// </summary>
  /// <param name="data"></param>
  /// <param name="nDataSize"></param>
  /// <returns></returns>
  [DllImport("IbmsSerialPort.dll")]
  public static extern bool Ibms_SendData( IntPtr port, byte[] data,int nDataSize);
  
  /// <summary>
  /// 声明IbmsSerialPort.dll的Ibms_SetFuncHandle函数
  /// </summary>
  /// <param name="handDataFunc"></param>
  [DllImport("IbmsSerialPort.dll")]
  public static extern void Ibms_SetFuncHandle( IntPtr port, HandleFunc handDataFunc);
  
  #endregion
  
  #region 定义字段
  
  /// <summary>
  /// 定义数据处理委托,作为API的函数指针传入动态链接库
  /// </summary>
  public delegate void HandleFunc(IntPtr pData, int nDataSize);
  
  /// <summary>
  /// 定义数据接收事件的原型
  /// </summary>
  public delegate void RecvData(object sender,SPRecvDataArgs e);
  
  /// <summary>
  /// 定义数据接收事件
  /// </summary>
  public event RecvData OnRecvData;
  
  /// <summary>
  /// 串口处理接收数据的委托
  /// </summary>
  private HandleFunc _handleDataFunc;
  
  /// <summary>
  /// 串口的编号,从1开始的整数,最大255
  /// </summary>
  private int port;
  
  /// <summary>
  /// 串口所支持的波特率,必须是标准波特率之一
  /// </summary>
  private StanderdRate rate;
  
  /// <summary>
  /// 串口当前的打开状态
  /// </summary>
  private bool openStatus=false;
  
  /// <summary>
  /// 串口句柄
  /// </summary>
  private IntPtr portHandle;
  
  #region 定义标准的串口波特率
  
  /// <summary>
  /// 标准的波特率
  /// </summary>
  public enum StanderdRate
  {
  R50=50,
  R75=75,
  R110=110,
  R150=150,
  R300=300,
  R600=600,
  R1200=1200,
  R2400=2400,
  R4800=4800,
  R9600=9600,
  R19200=19200,
  R38400=38400,
  R57600=57600,
  R76800=76800,
  R115200=115200
  };
  
  #endregion
  
  #endregion
  
  #region 定义方法
  
  /// <summary>
  /// 构造函数
  /// </summary>
  public IbmsSerialPort()
  {
  portHandle = (IntPtr)0;
  
  _handleDataFunc = new HandleFunc(OnDllRecvData);
  }
  
  /// <summary>
  /// 打开串口
  /// </summary>
  /// <param name="nPort">串口号</param>
  /// <param name="nRate">波特率</param>
  /// /// <exception cref="ApplicationException">抛出应用程序异常,包换错误描述</exception>
  public void Open(int nPort, StanderdRate nRate)
  {
  
  if(nPort > 255 || nPort < 0)
  {
  throw(new ArgumentOutOfRangeException());
  }
  
  port = nPort;
  rate = nRate;
  
  portHandle = Ibms_OpenPort( port, (int)rate );
  
  if( (IntPtr)0 == portHandle )
  {
  throw( new ApplicationException("打开串口失败"));
  }
  
  //注册函数指针
  Ibms_SetFuncHandle( portHandle, _handleDataFunc );
  
  openStatus = true;
  
  }
  
  /// <summary>
  /// 关闭串口
  /// </summary>
  public void Close()
  {
  if( openStatus )
  {
  Ibms_Close( portHandle);
  
  }
  
  openStatus = false;
  
  }
  
  /// <summary>
  /// 发送数据
  /// </summary>
  /// <param name="sendData">数据内容</param>
  /// <exception cref="ApplicationException">抛出应用程序异常,包换错误描述</exception>
  public void SendData( byte[] data )
  {
  if( !openStatus )
  {
  throw( new ApplicationException("串口没有打开,发送数据失败") );
  }
  
  if( !Ibms_SendData( portHandle, data, data.Length ) )
  {
  throw( new ApplicationException("串口发送数据失败") );
  }
  }
  
  /// <summary>
  /// 处理接收到的串口数据
  /// </summary>
  /// <param name="pData">串口数据接收缓冲区首地址</param>
  /// <param name="nDataSize">数据大小,一般数据大小不超过2K</param>
  unsafe protected void OnDllRecvData(IntPtr pUnhandleData, int nDataSize)
  {
  int dataSize= nDataSize ;
  
  byte * pData =(byte *) pUnhandleData;
  
  byte[] data = new byte[dataSize];
  
  //复制数据到byte数组
  for(int i=0; i<dataSize; i++)
  {
  data[i]= pData[i];
  }
  
  //激发事件
  OnRecvData( this, new SPRecvDataArgs(data) );
  
  }
  
  #endregion
  
  #region 定义属性
  
  /// <summary>
  /// 返回当前的串口号
  /// </summary>
  public int Port
  {
  get
  {
  return port;
  }
  }
  
  /// <summary>
  /// 返回当前串口的波特率
  /// </summary>
  public StanderdRate Rate
  {
  get
  {
  return
相关内容
赞助商链接