C#和232串口通信方法(SerialPort控件)

1、本例程主要讲解使用C#，实现与232串口通信。达到采集串口数据，监控，可视化处理等。一概述 在Visual Studio 6.0中编写串口通讯程序，一般都使用MicrosoftCommunicationControl（简称MSComm）的通讯控件，只要通过对此控件的属性和事件进行相应编程操作，就可以轻松地实现串口通讯。但在Microsoft.Net技术广泛应用的今天，Visual Studio.Net没有将此控件加入控件库，所以人们采用了许多方法在Visual Studio.Net来编写串口通讯程序：第一种方法是通过采用Visual Studio 6.0中原来的MSComm控件这是最简单的，最

2、方便的方法，但需要注册；第二种方法是采用微软在.NET推出了一个串口控件，基于.NET的P/Invoke调用方法实现；第三种方法是自己用API写串口通信，虽然难度高，但可以方便实现自己想要的各种功能。现在微软推出了最新版本的Visual Studio 2005开发工具，可以不再采用第三方控件的方法来设计串口通讯程序。NET Framework 2.0 类库包含了SerialPort 类,方便地实现了所需要串口通讯的多种功能，为了使MSComm编程方法快速转换到以SerialPort类为核心的串口通讯的设计方法，本文着重讨论了Visual Studio 6.0的MSComm控件和SerialPo

3、rt 类设计方法的异同点。二SerialPort常用属性、方法和事件1命名空间System.IO.Ports命名空间包含了控制串口重要的SerialPort类，该类提供了同步 I/O 和事件驱动的 I/O、对管脚和中断状态的访问以及对串行驱动程序属性的访问，所以在程序代码起始位置需加入Using System.IO.Ports。2串口的通讯参数串口通讯最常用的参数就是通讯端口号及通讯格式(波特率、数据位、停止位和校验位)，在MSComm中相关的属性是CommPort和Settings。SerialPort类与MSComm有一些区别:a.通讯端口号PortName属性获取或设置通信端口，包括但不

4、限于所有可用的 COM 端口，请注意该属性返回类型为String，不是Mscomm.CommPort的short类型。通常情况下，PortName正常返回的值为COM1、COM2，SerialPort类最大支持的端口数突破了CommPort控件中CommPort属性不能超过16的限止，大大方便了用户串口设备的配置。b. 通讯格式SerialPort类对分别用BaudRate、Parity、DataBits、StopBits属性设置通讯格式中的波特率、数据位、停止位和校验位，其中Parity和StopBits分别是枚举类型Parity、StopBits，Parity类型中枚举了Odd(奇)、Ev

5、en(偶)、Mark、None、Space，Parity枚举了None、One、OnePointFive、Two。SerialPort类提供了七个重载的构造函数，既可以对已经实例化的SerialPort对象设置上述相关属性的值，也可以使用指定的端口名称、波特率和奇偶校验位数据位和停止位直接初始化 SerialPort 类的新实例。3串口的打开和关闭SerialPort类没有采用MSComm.PortOpen=True/False设置属性值打开关闭串口，相应的是调用类的Open()和Close()方法。4. 数据的发送和读取Serial类调用重载的Write和WriteLine方法发送数据，其中

6、WriteLine可发送字符串并在字符串末尾加入换行符，读取串口缓冲区的方法有许多，其中除了ReadExisting和ReadTo,其余的方法都是同步调用，线程被阻塞直到缓冲区有相应的数据或大于ReadTimeOut属性设定的时间值后，引发ReadExisting异常。5.DataReceived事件该事件类似于MSComm控件中的OnComm事件，DataReceived事件在接收到了ReceivedBytesThreshold设置的字符个数或接收到了文件结束字符并将其放入了输入缓冲区时被触发。其中ReceivedBytesThreshold相当于MSComm控件的Rthreshold属性，

7、该事件的用法与MsComm控件的OnComm事件在CommEvent为comEvSend和comEvEof时是一致的。 三SerialPort的使用对于熟悉MSComm控件的程序设计者，SerialPort类是相当容易上手的。在进行串口通讯时，一般的流程是设置通讯端口号及波特率、数据位、停止位和校验位，再打开端口连接，发送数据，接收数据，最后关闭端口连接这样几个步骤。数据接收的设计方法在这里比较重要，采用轮询的方法比较浪费时间，在Visual Basic中的延时方法中一般会调用API并用DOEvents方法来处理，但程序不易控制，建议采用DataReceived事件触发的方法，合理的设置Rec

8、eivedBytesThreshold的值，若接收的是定长的数据，则将ReceivedBytesThreshold设为接收数据的长度，若接收数据的结尾是固定的字符或字符串则可采用ReadTo的方法或在DataReceived事件中判断接收的字符是否满足条件。SerialPort类读取数据的许多方法是同步阻塞调用，尽量避免在主线程中调用，可以使用异步处理或线程间处理调用这些读取数据的方法。由于DataReceived事件在辅线程被引发，当收到完整的一条数据，返回主线程处理或在窗体上显示时，请注意跨线程的处理，C#可采用控件异步委托的方法Control.BeginInvoke及同步委托的方法Inv

9、oke。四结束语在.NET平台下熟练使用SerialPort 类，可以很好地开发出串口通讯类程序，对于过去使用MSComm控件设计了一些通讯程序，也可以将MSComm控件替换为SerialPort类，当然为了避免对以前的项目做大的改动，可以使用SerialPort类设计一些与MSComm控件具有相同接口的类，在今后工业控制中，SerialPort类将广泛地应用于串口通讯程序的设计中，发挥着与MSComm控件一样的作用。C# SerialPort运行方式 SerialPort中串口数据的读取与写入有较大的不同。由于串口不知道数据何时到达，因此有两种方法可以实现串口数据的读取。一、线程实时读串口；

10、二、事件触发方式实现。由于线程实时读串口的效率不是十分高效，因此比较好的方法是事件触发的方式。在SerialPort类中有DataReceived事件，当串口的读缓存有数据到达时则触发DataReceived事件，其中SerialPort.ReceivedBytesThreshold属性决定了当串口读缓存中数据多少个时才触发DataReceived事件，默认为1。另外，SerialPort.DataReceived事件运行比较特殊，其运行在辅线程，不能与主线程中的显示数据控件直接进行数据传输，必须用间接的方式实现。如下：SerialPortspSend;/spSend,spReceive用虚拟

11、串口连接，它们之间可以相互传输数据。spSend发送数据SerialPortspReceive;/spReceive接受数据TextBoxtxtSend;/发送区TextBoxtxtReceive;/接受区ButtonbtnSend;/数据发送按钮delegatevoidHandleInterfaceUpdateDelegate(stringtext);/委托，此为重点HandleInterfaceUpdateDelegateinterfaceUpdateHandle;publicvoidInitClient()/窗体控件已在初始化interfaceUpdateHandle=newHandle

12、InterfaceUpdateDelegate(UpdateTextBox);/实例化委托对象spSend.Open();/SerialPort对象在程序结束前必须关闭，在此说明spReceive.DataReceived+=Ports.SerialDataReceivedEventHandler(spReceive_DataReceived);spReceive.ReceivedBytesThreshold=1;spReceive.Open();publicvoidbtnSend_Click(objectsender,EventArgse)spSend.WriteLine(txtSend.T

13、ext);publicvoidspReceive_DataReceived(objectsender,Ports.SerialDataReceivedEventArgse)bytereadBuffer=newbytespReceive.ReadBufferSize;spReceive.Read(readBuffer,0,readBuffer.Length);this.Invoke(interfaceUpdateHandle,newstringEncoding.Unicode.GetString(readBuffer);privatevoidUpdateTextBox(stringtext)tx

14、tReceive.Text=text;点评:这个例子包括了这个控件几乎所有的操作,非常有参考价值.serialPort是在.net framework2.0中才有的东西,感觉这个东西和MSCOMM很相似.这里给出的例子是基于和CSHAPE的,相应的可以在Cshape和c+中使用,基本上都是一样的.Imports System Imports System.IO.Ports Imports System.Threading Public Class PortChat Shared _continue As BooleanShared _serialPort As SerialPort

15、 Public Shared Sub Main() Dim name As StringDim message As StringDim sComparer As StringComparer = StringComparer.OrdinalIgnoreCase Dim readThread As Thread = New Thread(AddressOf Read) Create a new SerialPort object with default settings._serialPort = New SerialPort() Allow the user to set the appr

16、opriate properties._serialPort.PortName = SetPortName(_serialPort.PortName) _serialPort.BaudRate = SetPortBaudRate(_serialPort.BaudRate) _serialPort.Parity = SetPortParity(_serialPort.Parity) _serialPort.DataBits = SetPortDataBits(_serialPort.DataBits) _serialPort.StopBits = SetPortStopBits(_serialP

17、ort.StopBits) _serialPort.Handshake = SetPortHandshake(_serialPort.Handshake) Set the read/write timeouts_serialPort.ReadTimeout = 500 _serialPort.WriteTimeout = 500 _serialPort.Open() _continue = TruereadThread.Start() Console.Write(Name: ) name = Console.ReadLine() Console.WriteLine(Type QUIT to e

18、xit) While (_continue) message = Console.ReadLine() If sComparer.Equals(quit, message) Then_continue = FalseElse_serialPort.WriteLine( _ String.Format(: 1, name, message) End Ifend whilereadThread.Join() _serialPort.Close() End SubPublic Shared Sub Read() While (_continue) TryDim message As String =

19、 _serialPort.ReadLine() Console.WriteLine(message) Catch ex As TimeoutException Do nothingEnd TryEnd WhileEnd SubPublic Shared Function SetPortName(ByVal defaultPortName As String) As StringDim newPortName As StringConsole.WriteLine(Available Ports:) Dim s As StringFor Each s In SerialPort.GetPortNa

20、mes() Console.WriteLine( 0, s) Next s Console.Write(COM port(0): , defaultPortName) newPortName = Console.ReadLine() If newPortName = ThennewPortName = defaultPortName End IfReturn newPortName End FunctionPublic Shared Function SetPortBaudRate(ByVal defaultPortBaudRate As Integer) As IntegerDim newB

21、audRate As StringConsole.Write(Baud Rate(0): , defaultPortBaudRate) newBaudRate = Console.ReadLine() If newBaudRate = ThennewBaudRate = defaultPortBaudRate.ToString() End IfReturn Integer.Parse(newBaudRate) End FunctionPublic Shared Function SetPortParity(ByVal defaultPortParity As Parity) As Parity

22、 Dim newParity As StringConsole.WriteLine(Available Parity options:) Dim s As StringFor Each s In Enum.GetNames(GetType(Parity) Console.WriteLine( 0, s) Next s Console.Write(Parity(0):, defaultPortParity.ToString() newparity = Console.ReadLine() If newparity = Thennewparity = defaultPortParity.ToStr

23、ing() End IfReturn CType(Enum.Parse(GetType(Parity), newParity), Parity) End FunctionPublic Shared Function SetPortDataBits(ByVal defaultPortDataBits As Integer) As IntegerDim newDataBits As StringConsole.Write(Data Bits(0): , defaultPortDataBits) newDataBits = Console.ReadLine() If newDataBits = Th

24、ennewDataBits = defaultPortDataBits.ToString() End IfReturn Integer.Parse(newDataBits) End FunctionPublic Shared Function SetPortStopBits(ByVal defaultPortStopBits As StopBits) As StopBits Dim newStopBits As StringConsole.WriteLine(Available Stop Bits options:) Dim s As StringFor Each s In Enum.GetN

25、ames(GetType(StopBits) Console.WriteLine( 0, s) Next s Console.Write(Stop Bits(0):, defaultPortStopBits.ToString() newStopBits = Console.ReadLine() If newStopBits = ThennewStopBits = defaultPortStopBits.ToString() End IfReturn CType(Enum.Parse(GetType(StopBits), newStopBits), StopBits) End FunctionP

26、ublic Shared Function SetPortHandshake(ByVal defaultPortHandshake As Handshake) As Handshake Dim newHandshake As StringConsole.WriteLine(Available Handshake options:) Dim s As StringFor Each s In Enum.GetNames(GetType(Handshake) Console.WriteLine( 0, s) Next s Console.Write(Stop Bits(0):, defaultPor

27、tHandshake.ToString() newHandshake = Console.ReadLine() If newHandshake = ThennewHandshake = defaultPortHandshake.ToString() End IfReturn CType(Enum.Parse(GetType(Handshake), newHandshake), Handshake) End Function End Classusing System; using System.IO.Ports; using System.Threading; public class Por

28、tChat static bool _continue; static SerialPort _serialPort; public static void Main() string name; string message; StringComparer stringComparer = StringComparer.OrdinalIgnoreCase; Thread readThread = new Thread(Read); / Create a new SerialPort object with default settings._serialPort = new SerialPo

29、rt(); / Allow the user to set the appropriate properties._serialPort.PortName = SetPortName(_serialPort.PortName); _serialPort.BaudRate = SetPortBaudRate(_serialPort.BaudRate); _serialPort.Parity = SetPortParity(_serialPort.Parity); _serialPort.DataBits = SetPortDataBits(_serialPort.DataBits); _seri

30、alPort.StopBits = SetPortStopBits(_serialPort.StopBits); _serialPort.Handshake = SetPortHandshake(_serialPort.Handshake); / Set the read/write timeouts_serialPort.ReadTimeout = 500; _serialPort.WriteTimeout = 500; _serialPort.Open(); _continue = true; readThread.Start(); Console.Write(Name: ); name

31、= Console.ReadLine(); Console.WriteLine(Type QUIT to exit); while (_continue) message = Console.ReadLine(); if (stringComparer.Equals(quit, message) _continue = false; else _serialPort.WriteLine( String.Format(: 1, name, message) ); readThread.Join(); _serialPort.Close(); public static void Read() w

32、hile (_continue) try string message = _serialPort.ReadLine(); Console.WriteLine(message); catch (TimeoutException) public static string SetPortName(string defaultPortName) string portName; Console.WriteLine(Available Ports:); foreach (string s in SerialPort.GetPortNames() Console.WriteLine( 0, s); C

33、onsole.Write(COM port(0): , defaultPortName); portName = Console.ReadLine(); if (portName = ) portName = defaultPortName; return portName; public static int SetPortBaudRate(int defaultPortBaudRate) string baudRate; Console.Write(Baud Rate(0): , defaultPortBaudRate); baudRate = Console.ReadLine(); if

34、 (baudRate = ) baudRate = defaultPortBaudRate.ToString(); return int.Parse(baudRate); public static Parity SetPortParity(Parity defaultPortParity) string parity; Console.WriteLine(Available Parity options:); foreach (string s in Enum.GetNames(typeof(Parity) Console.WriteLine( 0, s); Console.Write(Pa

35、rity(0):, defaultPortParity.ToString(); parity = Console.ReadLine(); if (parity = ) parity = defaultPortParity.ToString(); return (Parity)Enum.Parse(typeof(Parity), parity); public static int SetPortDataBits(int defaultPortDataBits) string dataBits; Console.Write(Data Bits(0): , defaultPortDataBits)

36、; dataBits = Console.ReadLine(); if (dataBits = ) dataBits = defaultPortDataBits.ToString(); return int.Parse(dataBits); public static StopBits SetPortStopBits(StopBits defaultPortStopBits) string stopBits; Console.WriteLine(Available Stop Bits options:); foreach (string s in Enum.GetNames(typeof(St

37、opBits) Console.WriteLine( 0, s); Console.Write(Stop Bits(0):, defaultPortStopBits.ToString(); stopBits = Console.ReadLine(); if (stopBits = ) stopBits = defaultPortStopBits.ToString(); return (StopBits)Enum.Parse(typeof(StopBits), stopBits); public static Handshake SetPortHandshake(Handshake defaul

38、tPortHandshake) string handshake; Console.WriteLine(Available Handshake options:); foreach (string s in Enum.GetNames(typeof(Handshake) Console.WriteLine( 0, s); Console.Write(Stop Bits(0):, defaultPortHandshake.ToString(); handshake = Console.ReadLine(); if (handshake = ) handshake = defaultPortHan

39、dshake.ToString(); return (Handshake)Enum.Parse(typeof(Handshake), handshake); SerialPort类的源代码已经放在下面，SerialPort类是由Remon Spekreijse提供的免费串口类。CSerialPort支持线连接的串口编程，而且是基于多线程的，工作流程：1.设置串口参数。函数原型：BOOL CSerialPort:InitPort(CWnd* pPortOwner, / the owner (CWnd) of the port (receives message) UINT portnr, / p

40、ortnumber (1.4) UINT baud, / baudrate char parity, / parity UINT databits, / databits UINT stopbits, / stopbits DWORD dwCommEvents, / EV_RXCHAR, EV_CTS etc UINT writebuffersize) / size to the writebuffer2.串口监测线程。BOOL CSerialPort:StartMonitoring() BOOL CSerialPort:RestartMonitoring()BOOL CSerialPort:

41、StopMonitoring()void CSerialPort:WriteChar(CSerialPort* port)void CSerialPort:ReceiveChar(CSerialPort* port, COMSTAT comstat)void CSerialPort:WriteToPort(char* string)3.监测线程接收事件信息，再进行消息处理即可。SerialPort类的应用基于对话框的串口程序开发：1.将SerialPort类添加进工程；2.进行消息的映射；（注意：在SerialPort类的头文件中的：#define WM_COMM_RXCHAR WM_USER

42、+7需要手动进行映射）在工程的主对话框头文件中，格式如下：afx_msg LONG OnComm(WPARAM ch,LPARAM port);在工程的主对话框的CPP文件中，格式如下：BEGIN_MESSAGE_MAP(CMySerialPortTestDlg, CDialog)/AFX_MSG_MAP(CMySerialPortTestDlg)ON_MESSAGE(WM_COMM_RXCHAR,OnComm)./AFX_MSG_MAPEND_MESSAGE_MAP()然后在CPP中添加消息处理函数，本例中为OnComm。例如：LONG CTestDlg:OnComm(WPARAM ch,

43、LPARAM port)m_strEditReceiveMsg += ch;UpdateData(FALSE);return 0;/m_strEditReceiveMsg 为EDIT控件（接收框）的变量。/下面的m_strEditSendMsg同样处理。3.实现串口的初始化，打开/关闭串口按钮的响应函数，最后是发送信息按钮的函数实现。void CTestDlg:OnButtonOpen()int nPort=m_ctrlComboComPort.GetCurSel()+1;if(m_SerialPort.InitPort(this, nPort, 9600,N,8,1,EV_RXFLAG |

44、EV_RXCHAR,512)m_SerialPort.StartMonitoring();m_bSerialPortOpened=TRUE;elseAfxMessageBox(没有发现此串口或被占用);m_bSerialPortOpened=FALSE;GetDlgItem(IDC_BUTTON_OPEN)-EnableWindow(!m_bSerialPortOpened);GetDlgItem(IDC_BUTTON_CLOSE)-EnableWindow(m_bSerialPortOpened);void CTestDlg:OnButtonClose()m_SerialPort.ClosePort();m_bSerialPortOpened=FALSE;GetDlgItem(IDC_BUTTON_OPEN)-EnableWindow(!m_bSerialPortOpened);GetDlgItem(IDC_BUTTON_CLOSE)-EnableWindow(m_bSerialPortOpened);void CTestDlg:OnButtonSend()i