程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> .NET網頁編程 >> .NET實例教程 >> C#異步數據接收串口操作類

C#異步數據接收串口操作類

編輯:.NET實例教程

使用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 rate;
}
}

/// <summary>
/// 返回當前串口的狀態
/// </summary>
public bool OpenStatus
{
get
{
return openStatus;
}
}


#endregion


#region 非托管資源的及時釋放

/// <summary>
/// 因為包含了非托管的資源(占用系統串口),必須實現IDisposable接口
/// 在使用完該類的時候,必須記得調用Dispose(),回收系統資源
/// <example>
///
/// 方法1
/// {
/// SerialPort port =new SerialPort();
/// ...
/// //在try-catch-finaly的finaly中釋放資源
///
/// port.Dispose();
/// }
///
/// 方法2
/// using( SerialPort port = new SerialPort())
/// {
/// ...
/// }
/// 變量超出作用域時會自動調用其Dispose()方法
///
/// </example>
/// </summary>

~IbmsSerialPort()
{
Dispose( false );
}

protected virtual void Dispose( bool disposing )
{
if( disposing )
{
//清理托管的對象
}

//清理非托管的資源
Close();
}


#region IDisposable 成員

public void Dispose()
{
// TODO: 添加 SerialPort.Dispose 實現
Dispose( true );

GC.SuppressFinalize(this);
}

#endregion
#endregion

}

}
 

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved