C#串口通信—傳輸文件測試 - s0611163－IT工程師數位筆記本

文章出處

說明：該程序可能不具備實用性，僅測試用。

一、使用虛擬串口工具VSPD虛擬兩個串口COM1和COM2

二、約定

占一個字節，代碼如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace COMClient
{
    /// <summary>
    /// 約定
    /// </summary>
    public enum Protocol
    {
        Client端發送文件名 = 0,
        Client端發送數據塊 = 1,
        Client端發送最后一個數據塊 = 2,

        Server端本次接收完畢 = 3,
        Server端結束 = 4
    }
}

View Code

三、功能說明：

COMClient程序監聽COM1串口，COMServer程序監聽COM2串口。COMClient先擇文件，發送，COMServer接收文件。數據分多次發送，每次發送的數據，通過第一個字節判斷發送的這段數據是干啥的，后面的字節是數據本身。

四、COMClient端發送文件

代碼：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.IO.Ports;
using System.IO;
using System.Threading;

namespace COMClient
{
    public partial class Form1 : Form
    {
        #region 變量
        /// <summary>
        /// 串口資源
        /// </summary>
        private static SerialPort serialPort = null;
        /// <summary>
        /// 文件
        /// </summary>
        private static FileStream fs = null;
        private static long index = 0;
        private static long blockCount;
        private static int size = 4095;
        private static DateTime dt;
        #endregion

        #region Form1
        public Form1()
        {
            InitializeComponent();
        }
        #endregion

        #region Form1_Load
        private void Form1_Load(object sender, EventArgs e)
        {
            serialPort = new SerialPort("COM1");
            serialPort.DataReceived += new SerialDataReceivedEventHandler(serialPort_DataReceived);
            serialPort.Open();
        }
        #endregion

        #region btnConn_Click
        private void btnConn_Click(object sender, EventArgs e)
        {
            if (openFileDialog1.ShowDialog() == DialogResult.OK)
            {
                dt = DateTime.Now;
                fs = new FileStream(openFileDialog1.FileName, FileMode.Open, FileAccess.Read);
                blockCount = (fs.Length - 1) / size + 1;

                List<byte> bList = new List<byte>();
                bList.Add((int)Protocol.Client端發送文件名);
                bList.AddRange(ASCIIEncoding.UTF8.GetBytes(openFileDialog1.FileName));
                byte[] bArr = bList.ToArray();
                serialPort.Write(bArr, 0, bArr.Length);
            }
        }
        #endregion

        /// <summary>
        /// 接收串口數據事件
        /// </summary>
        public void serialPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            if (serialPort.BytesToRead == 0) return;

            int bt = serialPort.ReadByte();

            switch (bt)
            {
                case (int)Protocol.Server端本次接收完畢:
                    if (index != blockCount - 1)
                    {
                        byte[] bArr = new byte[size + 1];
                        bArr[0] = (int)Protocol.Client端發送數據塊;
                        fs.Read(bArr, 1, size);
                        index++;
                        Thread.Sleep(1);
                        serialPort.Write(bArr, 0, bArr.Length);
                    }
                    else
                    {
                        byte[] bArr = new byte[fs.Length - (size * index) + 1];
                        bArr[0] = (int)Protocol.Client端發送最后一個數據塊;
                        fs.Read(bArr, 1, bArr.Length - 1);
                        index++;
                        serialPort.Write(bArr, 0, bArr.Length);
                    }
                    break;
                case (int)Protocol.Server端結束:
                    index = 0;
                    double totalSeconds = DateTime.Now.Subtract(dt).TotalSeconds;
                    MessageBox.Show("完成，耗時" + totalSeconds + "秒，速度" + (fs.Length / 1024.0 / totalSeconds).ToString("#.0") + "KB/S");
                    fs.Close();
                    fs.Dispose();
                    break;
            }
        }

    }
}

View Code

五、COMServer端接收文件

代碼：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.IO.Ports;
using System.IO;

namespace COMServer
{
    public partial class Form1 : Form
    {
        #region 變量
        /// <summary>
        /// 串口資源
        /// </summary>
        private static SerialPort serialPort = null;
        /// <summary>
        /// 文件
        /// </summary>
        private static FileStream fs = null;
        #endregion

        #region Form1
        public Form1()
        {
            InitializeComponent();
        }
        #endregion

        #region Form1_Load
        private void Form1_Load(object sender, EventArgs e)
        {
            serialPort = new SerialPort("COM2");
            serialPort.DataReceived += new SerialDataReceivedEventHandler(serialPort_DataReceived);
            serialPort.Open();
        }
        #endregion

        /// <summary>
        /// 接收串口數據事件
        /// </summary>
        public void serialPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            if (serialPort.BytesToRead == 0) return;

            #region 接收數據
            int bt = serialPort.ReadByte();
            List<byte> bList = new List<byte>();
            while (serialPort.BytesToRead > 0)
            {
                byte[] bArr = new byte[serialPort.BytesToRead];
                serialPort.Read(bArr, 0, bArr.Length);
                bList.AddRange(bArr);
            }
            byte[] receiveData = bList.ToArray();
            #endregion

            switch (bt)
            {
                case (int)Protocol.Client端發送文件名:
                    string path = ASCIIEncoding.UTF8.GetString(receiveData);
                    string fileName = Path.GetFileName(path);
                    fs = new FileStream(@"d:\_臨時文件\COM測試" + fileName, FileMode.Create, FileAccess.Write);
                    byte[] bArr = new byte[1];
                    bArr[0] = (int)Protocol.Server端本次接收完畢;
                    serialPort.Write(bArr, 0, bArr.Length);
                    break;
                case (int)Protocol.Client端發送數據塊:
                    fs.Write(receiveData, 0, receiveData.Length);
                    fs.Flush();
                    bArr = new byte[1];
                    bArr[0] = (int)Protocol.Server端本次接收完畢;
                    serialPort.Write(bArr, 0, bArr.Length);
                    break;
                case (int)Protocol.Client端發送最后一個數據塊:
                    fs.Write(receiveData, 0, receiveData.Length);
                    fs.Flush();
                    bArr = new byte[1];
                    bArr[0] = (int)Protocol.Server端結束;
                    serialPort.Write(bArr, 0, bArr.Length);
                    fs.Close();
                    fs.Dispose();
                    break;
            }
        }

    }
}