基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：78630559

本次赞助数额为： 5 元　

支付宝支付

微信支付

   源码介绍

---

因个人需求，需要测试串口数据，直接拿去应用就可以了，经历半个月的压力测试，都没问题， *组件功能：利用环形缓冲区的特点实现对接收到的数据环形缓冲进行缓冲，
 *进而减少应用程序对数据解析的压力，同时通过组件里面封装的读取缓冲
 *区的数据的函数，来读取缓冲区完整的一帧数据，从而减少或是避免数据
 *包的丢失的情况的发生，同时也减少了工程师重复编写数据解析方法的重，

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

namespace WindowsFormsApplication1
{
    public partial class Form1 : Form
    {
        #region 创建日志
        TornadoJournal.Journal ReceivedJournal = new TornadoJournal.Journal(System.Environment.CurrentDirectory   "\\"   "ReceivedJournal", "Journal"   DateTime.Now.ToString("yy-MM-dd-hh-mm-ss"));
        TornadoJournal.Journal SendJournal = new TornadoJournal.Journal(System.Environment.CurrentDirectory   "\\"   "SendJournal", "Journal"   DateTime.Now.ToString("yy-MM-dd-hh-mm-ss"));
        #endregion

        #region 构造函数
        public Form1()
        {
            InitializeComponent();
            tornadoSerialPort1_DealAnalyticaledDataDwangD = new tornadoSerialPort1_DealAnalyticaledDataDelegate(tornadoSerialPort1_DealAnalyticaledDataDwang);
            string[] str;
            if (tornadoSerialPort1.ScanSerialPort(out str))
            {
                comboBox1.Items.AddRange(str);
                comboBox1.SelectedIndex = comboBox1.Items.Count > 0 ? 0 : -1;//旋转第3个可用串口
            }
        }
        #endregion

        #region 打开、关闭串口
        private void button1_Click(object sender, EventArgs e)
        {
            if (button1.Text == "打开")
            {
                ReceivedJournal.CreateJournalFile();
                SendJournal.CreateJournalFile();
                button1.Text = "关闭";
                comboBox1.Enabled = false;
                tornadoSerialPort1.SetSerialPortParameter(9600, Parity.None, StopBits.One,8,1);
                tornadoSerialPort1.OpenSerialPort(comboBox1.Text);
            }
            else if (button1.Text == "关闭")
            {
                button1.Text = "打开";
                comboBox1.Enabled = true;
                tornadoSerialPort1.CloseSerialPort();
            }
        }
        #endregion

        #region 处理解析好的数据
        #region 创建更新textbox控件数据的委托
        public delegate void tornadoSerialPort1_DealAnalyticaledDataDelegate(byte[] data);
        tornadoSerialPort1_DealAnalyticaledDataDelegate tornadoSerialPort1_DealAnalyticaledDataDwangD;
        #endregion
        
        private void tornadoSerialPort1_DealAnalyticaledData(byte[] data)
        {
            BeginInvoke(tornadoSerialPort1_DealAnalyticaledDataDwangD, data);
        }

        Int64 count = 1;
        public void tornadoSerialPort1_DealAnalyticaledDataDwang(byte[] data)
        {
            textBox1.AppendText("\r\n");
            textBox1.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")   "\r\n");          
            textBox1.AppendText("接收成功次数："  count "\r\n");
            textBox1.AppendText("接收到的数据：");
            textBox1.AppendText(String.Join(",", data) );
            textBox1.AppendText("\r\n");
            textBox1.AppendText("原始数据：");
            foreach (byte b in data)
            {
                string hex16 =b.ToString("X2");//是否满足两位
                textBox1.AppendText(hex16   " ");
            }
            textBox1.AppendText("\r\n");
            int sum3 = data[0]   data[1]   data[2];
            int sum2 = (data[4] << 8) data[3];//待修改
            int temp = data[2] & 0x0F;
            textBox1.AppendText("帧起始符："   "\t"   Convert.ToString(data[0], 16)  "\r\n");
            textBox1.AppendText("卡片编号："   "\t"   Convert.ToString((((data[2] & 0x0F)<<8)  data[1]),10)   "\r\n");
            textBox1.AppendText("校验和  ："   "\t"   Convert.ToString(sum2, 16)   "\r\n");
            if((data[2]&0xc0)==0x00)
               textBox1.AppendText("电池状态：满电"   "\r\n");
            else if((data[2] & 0xc0) == 0x40)
               textBox1.AppendText("电池状态：半满"   "\r\n");
            else if ((data[2] & 0xc0) == 0x80)
               textBox1.AppendText("电池状态：电量低"   "\r\n");
            else if ((data[2] & 0xc0) == 0xC0)
               textBox1.AppendText("电池状态：欠压"   "\r\n");

            if ((data[2] & 0x30) == 0x00)
                textBox1.AppendText("卡片状态：正常"   "\r\n");  
            else
                textBox1.AppendText("卡片状态：异常"   "\r\n");
            if (sum3 == sum2)
            {
                textBox1.AppendText("校验成功"   "\r\n");
            }
            else
            {
                textBox1.AppendText("校验失败"   "\r\n");
            }
            ReceivedJournal.WriteStrMessageToJournalFile(textBox1.Text, Encoding.Default);
            count  ;
        }
        #endregion

        #region 自动发送数据
        private void button3_Click(object sender, EventArgs e)
        {
            try
            {
                if (SendDataThread != null) SendDataThread.Abort();
                SendDataThread = new Thread(new ThreadStart(SendDataT));
                SendDataThread.IsBackground = true;//设置为后台线程
                SendDataThread.Start();
                button3.Enabled = false;
            }
            catch { }
        }

        private Thread SendDataThread;
        private void SendDataT()
        {
            Int64 num = 0;
            Int64 count=1;
            byte[] bytedata = new byte[tornadoSerialPort1.FrameSize];
            bytedata[0] = 0xFF;
            bytedata[1] = 0x38;
            while (true)
            {
                try
                {
                    num  ;
                    if (num >= 380) num = 0;
                    bytedata[0] = 0xFF;
                    bytedata[1] = 0x38;
                    bytedata[2] = 0x78;
                    bytedata[3] = (byte)(0xFF & (num >> 8));
                    bytedata[4] = (byte)(0xFF & (num >> 0));
                    tornadoSerialPort1.SerialPortSendData(bytedata);
                    SendJournal.WriteStrMessageToJournalFile(string.Join(" ", bytedata)   "    "   count, Encoding.Default);
                    Thread.Sleep(1);
                    count  ;
                }
                catch { }
            }
        }
        #endregion

        #region 关闭自动发送线程
        private void buttonClear_Click(object sender, EventArgs e)
        {
            tornadoSerialPort1.SerialPortSendData(new byte[3]{1,2,3});
            //try
            //{
            //    if (SendDataThread != null) SendDataThread.Abort();
            //    button3.Enabled = true;
            //}
            //catch { };
        }
        #endregion

        private void textBox1_TextChanged(object sender, EventArgs e)
        {

        }

        private void comboBox1_SelectedIndexChanged(object sender, EventArgs e)
        {

        }

        private void btnClear_Click(object sender, EventArgs e)
        {
            textBox1.Clear();
        }

        private void Form1_Load(object sender, EventArgs e)
        {

        }

        private void groupBox1_Enter(object sender, EventArgs e)
        {

        }
    }
}