c# 使用线程对串口serialPort进行收发数据(四种)

本文主要介绍了c# 使用线程对串口serialPort进行收发数据,分享给大家,具体如下:

一共写了四种方法,窗体界面都是一样的:

方法一:

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;

namespace serialPort_0620
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
            //不进行跨线程安全检查
            System.Windows.Forms.Control.CheckForIllegalCrossThreadCalls = false;

        }

        private void Form1_Load(object sender, EventArgs e)
        {
            //检查是否含有串口
            string[] str = SerialPort.GetPortNames();
            for (int i = 0; i < str.Length; i++)
            {
                comboBox1.Items.Add(str[i]);
            }
            button2.Enabled = false;
            button3.Enabled = false;
            button4.Enabled = false;
            dataGridView1.Rows.Add(68);
            //标序号
            for (int i = 0; i < 69; i++)
            {
                dataGridView1.Rows[i].Cells[0].Value = i;
            }
        }
        /// <summary>
        /// 打开串口
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button1_Click(object sender, EventArgs e)
        {
            if (serialPort1.IsOpen)
            {
                MessageBox.Show("串口已打开");
            }
            else if (comboBox1.Text == "")
            {
                MessageBox.Show("请选择端口!");
            }
            else if (textBox1.Text == "")
            {
                MessageBox.Show("请输入波特率!");
            }

            else
            {
                serialPort1.PortName = comboBox1.Text;
                serialPort1.BaudRate = Convert.ToInt16(textBox1.Text);
                serialPort1.Open();
                button1.Enabled = false;
                button2.Enabled = true;
                button3.Enabled = true;
                button4.Enabled = true;
            }

        }

        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button3_Click(object sender, EventArgs e)
        {
            if (textBox1.Text == "")
            {
                MessageBox.Show("请输入要发送的数据");
            }
            else
            {
                serialPort1.WriteLine(textBox2.Text);
                string data = serialPort1.ReadLine();
                listBox1.Items.Add(data);
                int a = listBox1.Items.Count;
                listBox1.SelectedIndex = listBox1.Items.Count - 1;
            }
        }

        /// <summary>
        /// 接收数据
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button4_Click(object sender, EventArgs e)
        {

        }

        /// <summary>
        /// 关闭串口
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button2_Click(object sender, EventArgs e)
        {
            serialPort1.Close();
            button1.Enabled = true;
        }

        Thread thread;

        /// <summary>
        /// 开始
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button5_Click(object sender, EventArgs e)
        {
            if (false == serialPort1.IsOpen)
            {
                MessageBox.Show("端口未打开");
            }
            else
            {
                thread = new Thread(new ThreadStart(PrintEven));
                thread.Start();
            }
        }

        private void PrintEven()
        {
            while (true)
            {
                if (textBox2.Text == "")
                {
                    MessageBox.Show("请输入要发送的数据");
                }
                else
                {
                    if (serialPort1.IsOpen)
                    {
                        serialPort1.WriteLine(textBox2.Text);
                        string data = serialPort1.ReadLine();
                        listBox1.Items.Add(data);
                        listBox1.SelectedIndex = listBox1.Items.Count - 1;
                        for (int i = 0; i < 47; i++)
                        {
                            string[] result = data.Split(',');
                            dataGridView1.Rows[i].Cells[1].Value = result[i + 1];
                            dataGridView1.Rows[i].Cells[2].Value = Convert.ToDouble(result[i + 1]) * 5.0 / 1024.0;
                        }
                    }
                    Thread.Sleep(5000);
                }

            }
        }

        /// <summary>
        /// 结束
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button6_Click(object sender, EventArgs e)
        {
            thread.Abort();
        }
    }
}

//不进行跨线程安全检查

方法二:

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;

namespace serialPort_0620
{
    public partial class Form2 : Form
    {
        public Form2()
        {
            InitializeComponent();

        }

        private void Form2_Load(object sender, EventArgs e)
        {
            string[] str = SerialPort.GetPortNames();
            for (int i = 0; i < str.Length; i++)
            {
                comboBox1.Items.Add(str[i]);
            }
            button2.Enabled = false;
            button3.Enabled = false;
            button4.Enabled = false;
            dataGridView1.Rows.Add(68);
            //标序号
            for (int i = 0; i < 69; i++)
            {
                dataGridView1.Rows[i].Cells[0].Value = i;
            }
        }
        /// <summary>
        /// 打开串口
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button1_Click(object sender, EventArgs e)
        {
            if (serialPort1.IsOpen)
            {
                MessageBox.Show("串口已打开");
            }
            else if (comboBox1.Text == "")
            {
                MessageBox.Show("请选择端口!");
            }
            else if (textBox1.Text == "")
            {
                MessageBox.Show("请输入波特率!");
            }

            else
            {
                serialPort1.PortName = comboBox1.Text;
                serialPort1.BaudRate = Convert.ToInt16(textBox1.Text);
                serialPort1.Open();
                button1.Enabled = false;
                button2.Enabled = true;
                button3.Enabled = true;
                button4.Enabled = true;
            }

        }

        private void button2_Click(object sender, EventArgs e)
        {
            serialPort1.Close();
            button1.Enabled = true;
        }

        private void button3_Click(object sender, EventArgs e)
        {
            if (textBox1.Text == "")
            {
                MessageBox.Show("请输入要发送的数据");
            }
            else
            {
                serialPort1.WriteLine(textBox2.Text);

            }
        }

        private void button4_Click(object sender, EventArgs e)
        {
            string data = serialPort1.ReadLine();
            listBox1.Items.Add(data);
            int a = listBox1.Items.Count;
            listBox1.SelectedIndex = listBox1.Items.Count - 1;
        }
        //创建线程
        Thread thread;

        //建立委托

        public delegate void SetTextHandler(string result);
        private void setItem(string result)
        {
            if (listBox1.InvokeRequired == true)
            {
                SetTextHandler setTextHandler = setItem;
                listBox1.Invoke(setTextHandler, new object[] { result });
            }
            else
            {

                listBox1.Items.Add(result);
                listBox1.SelectedIndex = listBox1.Items.Count - 1;
            }

        }

        private void button5_Click(object sender, EventArgs e)
        {
            if (false == serialPort1.IsOpen)
            {
                MessageBox.Show("端口未打开");
            }
            else
            {
                thread = new Thread(new ThreadStart(PrintEven));
                thread.Start();
            }
        }

       private void PrintEven()
        {
            while (true)
            {
                if (textBox2.Text == "")
                {
                    MessageBox.Show("请输入要发送的数据");
                }
                else
                {
                    if (serialPort1.IsOpen)
                    {
                        serialPort1.WriteLine(textBox2.Text);
                        string data = serialPort1.ReadLine();
                        setItem(data);
                        for (int i = 0; i < 47; i++)
                        {
                            string[] result = data.Split(',');
                             dataGridView1 .Rows[i].Cells[1].Value = result[i + 1];
                            dataGridView1.Rows[i].Cells[2].Value = Convert.ToDouble(result[i + 1]) * 5.0 / 1024.0;
                        }
                    }

                    Thread.Sleep(5000);
                }

            }
        }

        /// <summary>
        /// 结束
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button6_Click(object sender, EventArgs e)
        {
            thread.Abort();
        }
    }
}
// 建立委托 (参考网上  很规范的写法)

方法三:

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;

namespace serialPort_0620
{
    public partial class Form3 : Form
    {
        public Form3()
        {
            InitializeComponent();
        }

        private void Form3_Load(object sender, EventArgs e)
        {
            string[] str = SerialPort.GetPortNames();
            for (int i = 0; i < str.Length; i++)
            {
                comboBox1.Items.Add(str[i]);
            }
            button2.Enabled = false;
            button3.Enabled = false;
            button4.Enabled = false;
            dataGridView1.Rows.Add(68);
            //标序号
            for (int i = 0; i < 69; i++)
            {
                dataGridView1.Rows[i].Cells[0].Value = i;
            }
        }

        /// <summary>
        /// 打开串口
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button1_Click(object sender, EventArgs e)
        {
            if (serialPort1.IsOpen)
            {
                MessageBox.Show("串口已打开");
            }
            else if (comboBox1.Text == "")
            {
                MessageBox.Show("请选择端口!");
            }
            else if (textBox1.Text == "")
            {
                MessageBox.Show("请输入波特率!");
            }

            else
            {
                serialPort1.PortName = comboBox1.Text;
                serialPort1.BaudRate = Convert.ToInt16(textBox1.Text);
                serialPort1.Open();
                button1.Enabled = false;
                button2.Enabled = true;
                button3.Enabled = true;
                button4.Enabled = true;
            }

        }

        /// <summary>
        /// 关闭串口
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button2_Click(object sender, EventArgs e)
        {

            serialPort1.Close();
            button1.Enabled = true;
        }
        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button3_Click(object sender, EventArgs e)
        {
            if (textBox1.Text == "")
            {
                MessageBox.Show("请输入要发送的数据");
            }
            else
            {
                serialPort1.WriteLine(textBox2.Text);

            }
        }
        /// <summary>
        /// 接收数据
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button4_Click(object sender, EventArgs e)
        {

            string data = serialPort1.ReadLine();
            listBox1.Items.Add(data);
            int a = listBox1.Items.Count;
            listBox1.SelectedIndex = listBox1.Items.Count - 1;
        }
        //创建线程
        Thread thread;
        /// <summary>
        /// 开始
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button5_Click(object sender, EventArgs e)
        {
            if (false == serialPort1.IsOpen)
            {
                MessageBox.Show("端口未打开");
            }
            else
            {
                thread = new Thread(new ThreadStart(PrintEven));
                thread.Start();
            }
        }

        private void PrintEven()
        {
            while (true)
            {
                if (textBox2.Text == "")
                {
                    MessageBox.Show("请输入要发送的数据");
                }
                else
                {
                    if (serialPort1.IsOpen)
                    {
                        serialPort1.WriteLine(textBox2.Text);
                        string data = serialPort1.ReadLine();
                        //setItem(data);

                        listBox1.Invoke(new Action(()=> {
                            listBox1.Items.Add(data);
                            listBox1.SelectedIndex = listBox1.Items.Count - 1;
                            for (int i = 0; i < 47; i++)
                            {
                                string[] result = data.Split(',');
                                dataGridView1.Rows[i].Cells[1].Value = result[i + 1];
                                dataGridView1.Rows[i].Cells[2].Value = Convert.ToDouble(result[i + 1]) * 5.0 / 1024.0;
                            }

                        }));

                    }

                    Thread.Sleep(5000);
                }

            }
        }

        private void button6_Click(object sender, EventArgs e)
        {

        }
    }
}
//第二种委托 更常用

方法四:

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

namespace serialPort_0620
{
    public partial class Form4 : Form
    {
        public Form4()
        {
            InitializeComponent();
        }

        private void Form4_Load(object sender, EventArgs e)
        {
            string[] str = SerialPort.GetPortNames();
            for (int i = 0; i < str.Length; i++)
            {
                comboBox1.Items.Add(str[i]);
            }
            button2.Enabled = false;
            button3.Enabled = false;
            button4.Enabled = false;
            dataGridView1.Rows.Add(68);
            //标序号
            for (int i = 0; i < 69; i++)
            {
                dataGridView1.Rows[i].Cells[0].Value = i;
            }
        }

        /// <summary>
        /// 打开串口
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button1_Click(object sender, EventArgs e)
        {
            if (serialPort1.IsOpen)
            {
                MessageBox.Show("串口已打开");
            }
            else if (comboBox1.Text == "")
            {
                MessageBox.Show("请选择端口!");
            }
            else if (textBox1.Text == "")
            {
                MessageBox.Show("请输入波特率!");
            }

            else
            {
                serialPort1.PortName = comboBox1.Text;
                serialPort1.BaudRate = Convert.ToInt16(textBox1.Text);
                serialPort1.Open();
                button1.Enabled = false;
                button2.Enabled = true;
                button3.Enabled = true;
                button4.Enabled = true;
            }
        }

        /// <summary>
        /// 关闭串口
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button2_Click(object sender, EventArgs e)
        {
            serialPort1.Close();
            button1.Enabled = true;
        }

        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button3_Click(object sender, EventArgs e)
        {
            if (textBox1.Text == "")
            {
                MessageBox.Show("请输入要发送的数据");
            }
            else
            {
                serialPort1.WriteLine(textBox2.Text);

            }
        }

        /// <summary>
        /// 接收数据
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button4_Click(object sender, EventArgs e)
        {
            string data = serialPort1.ReadLine();
            listBox1.Items.Add(data);
            int a = listBox1.Items.Count;
            listBox1.SelectedIndex = listBox1.Items.Count - 1;
        }

        //创建线程
        Thread thread;
        /// <summary>
        /// 开始
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button5_Click(object sender, EventArgs e)
        {
            if (false == serialPort1.IsOpen)
            {
                MessageBox.Show("端口未打开");
            }
            else
            {
                thread = new Thread(new ThreadStart(PrintEven));
                thread.Start();
            }

        }

        private void PrintEven()
        {
            while (true)
            {
                if (textBox2.Text == "")
                {
                    MessageBox.Show("请输入要发送的数据");
                }
                else
                {
                    if (serialPort1.IsOpen)
                    {

                        listBox1.Invoke(new Action(set));

                    }

                    Thread.Sleep(5000);
                }

            }
        }
        void set()
        {
            serialPort1.WriteLine(textBox2.Text);
            string data = serialPort1.ReadLine();
            listBox1.Items.Add(data);
            listBox1.SelectedIndex = listBox1.Items.Count - 1;
            for (int i = 0; i < 47; i++)
            {
                string[] result = data.Split(',');
                dataGridView1.Rows[i].Cells[1].Value = result[i + 1];
                dataGridView1.Rows[i].Cells[2].Value = Convert.ToDouble(result[i + 1]) * 5.0 / 1024.0;
            }

        }

        /// <summary>
        /// 结束
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button6_Click(object sender, EventArgs e)
        {
            thread.Abort();
        }
    }
}
//建立委托,invoke的第二种写法

到此这篇关于c# 使用线程对串口serialPort进行收发数据(四种)的文章就介绍到这了,更多相关c# 串口serialPort收发数据内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • C# 串口接收数据中serialPort.close()死锁的实例

    最近在做一个有关高铁模拟仓显示系统的客户端程序,在这个程序中要运用串口serialPort传输数据,因为每次接收数据结束后要更新UI界面,所以就用到了的Invoke,将更新UI的程序代码封装到一个方法中,然后通过Incoke调用,程序跑起来没有任何问题,但是当你执行serialPort.close()是程序就会发生死锁,整个程序卡在那里动都动不了. 上网查了很多资料,有各种这样的说法,有的说定义一个接收数据的标志,如果在执行关闭程序是进行判断,如果数据接收完了就关闭串口,没有的话继续执行,但是经

  • c# 模拟串口通信 SerialPort的实现示例

    目录 一.前导知识 实现串口通信的必要设置 二.实验 绘制窗口 测试 三.总结 四.附件完整代码 一.前导知识 串行口是计算机的标准接口,现在的PC机(个人电脑)一般至少有两个串行口COM1和COM2.串行口应用广泛,在数据通信.计算机网络以及分布式工业控制系统中,经常采用串行通信来交换数据和信息 电气标准及协议来分包括RS-232-C.RS-422.RS485.USB(Universal Serial Bus)等 实现串口通信的必要设置 串口通信最重要的参数是波特率.数据位.停止位和奇偶校验.

  • C#中的串口通信SerialPort详解

    今天这篇文章带大家学习下C#中的串口通讯.在日常的开发工作中,如果工作内容是CS方向的同学应该很容易接触到串口通讯方面的业务需求.那么也就很容易想到C#中SerialPort类,它就是专门来处理串口通讯相关的. 了解什么是串口通讯 串口通讯是指外设和计算机间通过数据信号线,地线,控制线等,按位进行传输数据的一种通讯方式. 这种通讯方式使用的数据线少,在远距离通信中可以节约成本,但其传输速度比并行通讯慢. 串口是计算机上一种非常通用的设备通讯协议.大多数计算机包含两个基于RS-232的串口. 串口

  • C#基于SerialPort类实现串口通讯详解

    本文实例为大家分享了C#基于SerialPort类实现串口通讯的具体代码,供大家参考,具体内容如下 最终效果 窗体设置: using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Threading.Tasks; usi

  • C#串口编程System.IO.Ports.SerialPort类

    从Microsoft .Net 2.0版本以后,就默认提供了System.IO.Ports.SerialPort类,用户可以非常简单地编写少量代码就完成串口的信息收发程序. 1. 串口硬件信号定义 DB9 Connector 信号定义.串口测试将2.3针脚短接即可. 2.串口端口号搜索 string[] portList = System.IO.Ports.SerialPort.GetPortNames(); for (int i = 0; i < portList.Length; i++) {

  • c# 使用线程对串口serialPort进行收发数据(四种)

    本文主要介绍了c# 使用线程对串口serialPort进行收发数据,分享给大家,具体如下: 一共写了四种方法,窗体界面都是一样的: 方法一: 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;

  • Python Serial串口基本操作(收发数据)

    1.需要模块以及测试工具 模块名:pyserial 使用命令下载:python -m pip install pyserial 串口调试工具:sscom5.13.1.exe 2.导入模块 import serial 3.打开串口 直接通过new一个Serial()的实例即可打开 返回实例 # encoding=utf-8 import serial if __name__ == '__main__': com = serial.Serial('COM3', 115200) print com 运

  • java自带的四种线程池实例详解

    目录 java预定义的哪四种线程池? 四种线程池有什么区别? 线程池有哪几个重要参数? 如何自定义线程池 总结 java预定义的哪四种线程池? newSingleThreadExexcutor:单线程数的线程池(核心线程数=最大线程数=1) newFixedThreadPool:固定线程数的线程池(核心线程数=最大线程数=自定义) newCacheThreadPool:可缓存的线程池(核心线程数=0,最大线程数=Integer.MAX_VALUE) newScheduledThreadPool:

  • Java实现TCP/IP协议的收发数据(服务端)代码实例

    这篇文章主要介绍了Java实现TCP/IP协议的收发数据(服务端)代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 功能如下: 注: 只有服务端,没有客户端,测试时采用第三方软件作为客户端的. 收发数据目前能正常收发数据,只是中文的会变成乱码显示. 采用Thread类实现一个收发数据的线程. 服务端代码: import java.io.IOException; import java.io.InputStream; import java

  • Android自带的四种线程池使用总结

    在Android开发中,如果我们要执行某个耗时任务,一般都会考虑开启一个线程去处理. 因为我们都知道一个线程run方法执行完毕后,才算真正结束,但是,这只是结束,并没有被回收,会一直闲置在那里,等待GC去回收,所以如果每执行一个任务,我们都new一个线程,那么在某些极端的场景下,是比较消耗内存的. 之前的内存优化的文章中,我讲过关于android中的池的概念,也就是复用的机制,那么对于线程也有个线程池. 这篇文章先简单介绍下Android中自带的四种线程池: 1 .newCachedThread

  • Java四种线程池的使用详解

    Java通过Executors提供四种线程池,分别为: newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程. newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待. newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行. newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,

  • PHP向socket服务器收发数据的方法

    本文实例讲述了PHP向socket服务器收发数据的方法.分享给大家供大家参考.具体如下: 在PHP要向其它程序发送数据,则需要使用到php的socket功能来实例了,下面我们简单看一个实例,代码如下: 复制代码 代码如下: /*socket收发数据     @host(string) socket服务器IP     @post(int) 端口     @str(string) 要发送的数据     @back 1|0 socket端是否有数据返回     返回true|false|服务端数据 *

  • Java中四种线程池的使用示例详解

    在什么情况下使用线程池? 1.单个任务处理的时间比较短 2.将需处理的任务的数量大 使用线程池的好处: 1.减少在创建和销毁线程上所花的时间以及系统资源的开销 2.如不使用线程池,有可能造成系统创建大量线程而导致消耗完系统内存以及"过度切换". 本文详细的给大家介绍了关于Java中四种线程池的使用,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍: FixedThreadPool 由Executors的newFixedThreadPool方法创建.它是一种线程数量固定的线程

  • 四种Java线程池用法解析

    本文为大家分析四种Java线程池用法,供大家参考,具体内容如下 1.new Thread的弊端 执行一个异步任务你还只是如下new Thread吗? new Thread(new Runnable() { @Override public void run() { // TODO Auto-generated method stub } } ).start(); 那你就out太多了,new Thread的弊端如下: a. 每次new Thread新建对象性能差. b. 线程缺乏统一管理,可能无限

  • C/C++中退出线程的四种解决方法

    退出线程可以有四种方法: 1.线程函数的return返回(最好这样):其中用线程函数的return返回, 而终止线程是最安全的, 在线程函数return返回后, 会清理函数内申请的类对象, 即调用这些对象的析构函数. 然后会自动调用 _endthreadex()函数来清理 _beginthreadex(...)函数申请的资源(主要是创建的tiddata对象). 2.调用 _endthreadex()函数 或 ExitThread()函数(最好不要):如果使用这两种方法退出线程, 则不会执行线程函

随机推荐