在好例子网,分享、交流、成长!
您当前所在位置:首页C# 开发实例C#语言基础 → C# 串口监听例子源码(接收串口数据)

C# 串口监听例子源码(接收串口数据)

C#语言基础

下载此实例
  • 开发语言:C#
  • 实例大小:0.13M
  • 下载次数:101
  • 浏览次数:1841
  • 发布时间:2017-10-18
  • 实例类别:C#语言基础
  • 发 布 人:sarmyloveyour
  • 文件格式:.rar
  • 所需积分:2
 相关标签: 监听 串口

实例介绍

【实例简介】

【实例截图】

from clipboard

【核心代码】

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.IO.Ports;
using System.Threading;
using Microsoft.Win32;
using AxCommMonitor6x;

namespace 串口监听
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }


        public AxCommMonitor AxC1 = new AxCommMonitor6x.AxCommMonitor();
        long dwReadTotal = 0;
        long dwWriteTotal = 0;
        const int IRP_MJ_CREATE = 0x00;
        const int IRP_MJ_CLOSE = 0x02;
        const int IRP_MJ_READ = 0x03;
        const int IRP_MJ_WRITE = 0x04;
        const int IRP_MJ_DEVICE_CONTROL = 0x0E;
        const int IRP_MJ_CLEANUP = 0x12;
        const int IRP_MJ_MAXIMUM_FUNCTION = 0x1B;
        const int IRP_MJ_FLUSH_BUFFERS = 0x09;

        private void axCommMonitor1_OnAscii(object sender, AxCommMonitor6x.ICommMonitor6Events_OnAsciiEvent e)
        {
            //if (chk_R.Checked)
            //    return;

            switch (e.dwCtrlCode)
            {
                case IRP_MJ_CLOSE:
                    this.tbData.AppendText(string.Format("{0}: Close\r\n", e.sPortName));
                    break;
                case IRP_MJ_CREATE:
                    this.tbData.AppendText(string.Format("{0}: Open\r\n", e.sPortName));
                    break;
                case IRP_MJ_READ:
                    {
                        //dwReadTotal  = e.dwSize;
                        //this.redtData.SelectionColor = Color.Blue;
                        this.tbData.AppendText(string.Format("{0}, Read({1:D}): {2}\r\n", e.sPortName, e.dwSize, e.sData));
                        break;
                    }
                case IRP_MJ_WRITE:
                    {
                        //dwWriteTotal  = e.dwSize;
                        //this.redtData.SelectionColor = Color.Green;
                        this.tbData.AppendText(string.Format("{0}, Write({1:D}): {2}\r\n", e.sPortName, e.dwSize, e.sData));
                        break;
                    }
                default:
                    {
                        if (e.dwCtrlCode > 0x400)
                            tbData.AppendText(string.Format("{0}, CTLCode({1:D}): {2}\r\n", e.sPortName, e.dwCtrlCode, e.sData));
                        break;
                    }
            }

            if ((e.dwCtrlCode == IRP_MJ_READ) || (e.dwCtrlCode == IRP_MJ_WRITE))
            {
                tbData.Text = string.Format("Write:  {0:D}(Bytes), Read: {1:D}(Bytes)", dwWriteTotal, dwReadTotal);

            }

        }
        private void axCommMonitor1_OnMonitor(object sender, AxCommMonitor6x.ICommMonitor6Events_OnMonitorEvent e)
        {

            string ss = "";
            //if (!chk_R.Checked)
            //    return;

            if ((e.dwSize > 0) && ((e.dwCtrlCode == IRP_MJ_READ) || (e.dwCtrlCode == IRP_MJ_WRITE)))
            {
                byte[] numbers = (byte[])e.vtData;
                ss = Encoding.GetEncoding("GB2312").GetString(numbers);
            }



            switch (e.dwCtrlCode)
            {
                case IRP_MJ_CLOSE:
                    this.tbData.AppendText(string.Format("{0}: Close\r\n", e.sPortName));
                    break;
                case IRP_MJ_CREATE:
                    this.tbData.AppendText(string.Format("{0}: Open\r\n", e.sPortName));
                    break;
                case IRP_MJ_READ:
                    {
                        dwReadTotal  = e.dwSize;
                        //this.tbData.SelectionColor = Color.Blue;
                        this.tbData.AppendText(string.Format("{0}, Read({1:D}): {2}\r\n",
                             e.sPortName, e.dwSize, ss));
                        break;
                    }
                case IRP_MJ_WRITE:
                    {
                        dwWriteTotal  = e.dwSize;
                        //this.tbData.SelectionColor = Color.Green;
                        this.tbData.AppendText(string.Format("{0}, Write({1:D}): {2}\r\n",
                            e.sPortName, e.dwSize, ss));
                        break;
                    }
                default:
                    {
                        if (e.dwCtrlCode > 0x400)
                           tbData.AppendText(string.Format("{0}, CTLCode({1:D}): {2}\r\n",
                                e.sPortName, e.dwCtrlCode, ss));
                        break;
                    }
            }

            if ((e.dwCtrlCode == IRP_MJ_READ) || (e.dwCtrlCode == IRP_MJ_WRITE))
            {
                tbData.Text = string.Format("Write:  {0:D}(Bytes), Read: {1:D}(Bytes)",

                    dwWriteTotal, dwReadTotal);

            }


        }

        
        
        private SerialPort Sp = new SerialPort();
        public delegate void HandleInterfaceUpdataDelegate(string text); //委托,此为重点
        private HandleInterfaceUpdataDelegate interfaceUpdataHandle;
        private bool qiii = false;
        bool fActive = false;
        private void btENT_Click(object sender, EventArgs e)
        {
            //if ((cmID.Text.Trim() != "") && (cmRate.Text != ""))
            //{
            //    interfaceUpdataHandle = new HandleInterfaceUpdataDelegate(UpdateTextBox);//实例化委托对象
            //    Sp.PortName = cmID.Text.Trim();
            //    Sp.BaudRate = Convert.ToInt32(cmRate.Text.Trim());
            //    Sp.Parity = Parity.None;
            //    Sp.StopBits = StopBits.One;
            //    Sp.DataReceived  = new SerialDataReceivedEventHandler(Sp_DataReceived);
            //    Sp.ReceivedBytesThreshold = 1;
            //    try
            //    {
            //        Sp.Open();
            //        ATCommand3("AT CLIP=1\r", "OK");
            //        btPause.Enabled = true;
            //        btENT.Enabled = false;
            //    }
            //    catch
            //    {
            //        MessageBox.Show("端口"   cmID.Text.Trim()   "打开失败!");
            //    }
            //}
            //else
            //{
            //    MessageBox.Show("请输入正确的端口号和波特率!");
            //    cmID.Focus();
            //}
            if (!fActive)
                fActive = axCommMonitor1.StartMonitor(this.cmID.Text);
            else
            {
                axCommMonitor1.StopMonitor();
                fActive = false;
            }

            //if (fActive)
            //{
            //    btnOpen.Text = "Stop Monitor";
            //    btnOpen.ForeColor = Color.Blue;

            //}
            //else
            //{
            //    btnOpen.Text = "Start Monitor";
            //    btnOpen.ForeColor = Color.Black;
            //}
            //axCommMonitor1.StartMonitor(this.cmID.Text.Trim());

        }
        private void btPause_Click(object sender, EventArgs e)
        {

        }
        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            Sp.Close();
        }
        private void Form1_Load(object sender, EventArgs e)
        {
            GetComList();
            btPause.Enabled = false;
        }
        public void Sp_DataReceived(object sender, System.IO.Ports.SerialDataReceivedEventArgs e)
        {
            string strTemp = "";
            double iSecond = 0.5;
            DateTime dtOld = System.DateTime.Now;
            DateTime dtNow = System.DateTime.Now;
            TimeSpan dtInter;
            dtInter = dtNow - dtOld;
            int i = Sp.BytesToRead;
            if (i > 0)
            {
                try
                {
                    strTemp = Sp.ReadExisting();
                }
                catch
                { }
                if (strTemp.ToLower().IndexOf("\r") < 0)
                {
                    i = 0;
                }
                else
                {
                    this.Invoke(interfaceUpdataHandle, strTemp);
                }
            }
            while (dtInter.TotalSeconds < iSecond && i <= 0)
            {
                dtNow = System.DateTime.Now;
                dtInter = dtNow - dtOld;
                i = Sp.BytesToRead;
                if (i > 0)
                {
                    try
                    {
                        strTemp  = Sp.ReadExisting();
                    }
                    catch
                    { }
                    if (strTemp.ToLower().IndexOf("\r") < 0)
                    {
                        i = 0;
                    }
                    else
                    {
                        this.Invoke(interfaceUpdataHandle, strTemp);
                    }
                }
            }
            // do null
        }
        private void UpdateTextBox(string text)
        {
            tbData.Text = text;
        }
        /// <summary>
        /// 执行AT指令并返回 成功失败
        /// </summary>
        /// <param name="ATCmd">AT指令</param>
        /// <param name="StCmd">AT指令标准结束标识</param>
        /// <returns></returns>
        private void ATCommand3(string ATCmd, string StCmd)
        {
            string response = "";
            response = ATCommand(ATCmd, StCmd);
        }
        /// <summary>
        /// 执行AT指令并返回结果字符
        /// </summary>
        /// <param name="ATCmd">AT指令</param>
        /// <param name="StCmd">AT指令标准结束标识</param>
        /// <returns></returns>
        private string ATCommand(string ATCmd, string StCmd)
        {
            string response = "";
            int i;
            if (!ATCmd.EndsWith("\x01a"))
            {
                if (!(ATCmd.EndsWith("\r") || ATCmd.EndsWith("\r\n")))
                {
                    ATCmd = ATCmd   "\r";
                }
            }
            Sp.WriteLine(ATCmd);
            //第一次读响应数据
            if (Sp.BytesToRead > 0)
            {
                response = Sp.ReadExisting();
                //去除前端多可能多读取的字符
                if (response.IndexOf(ATCmd) > 0)
                {
                    response = response.Substring(response.IndexOf(ATCmd));
                }
                else
                {
                }
                if (response == "" || response.IndexOf(StCmd) < 0)
                {
                    if (response != "")
                    {
                        if (response.Trim() == "ERROR")
                        {
                            //throw vError = new UnknowException("Unknown exception in sending command:"   ATCmd);
                        }
                        if (response.IndexOf(" CMS ERROR") >= 0)
                        {
                            string[] cols = new string[100];
                            cols = response.Split(';');
                            if (cols.Length > 1)
                            {
                                string errorCode = cols[1];
                            }
                        }
                    }
                }
            }
            //读第一次没有读完的响应数据,直到读到特征数据或超时
            for (i = 0; i < 3; i  )
            {
                Thread.Sleep(1000);
                response = response   Sp.ReadExisting();
                if (response.IndexOf(StCmd) >= 0)
                {
                    break;
                }
            }
            return response;
        }
        /// <summary>
        /// 从注册表获取系统串口列表
        /// </summary>
        private void GetComList()
        {
            RegistryKey keyCom = Registry.LocalMachine.OpenSubKey("Hardware\\DeviceMap\\SerialComm");
            if (keyCom != null)
            {
                string[] sSubKeys = keyCom.GetValueNames();
                this.cmID.Items.Clear();
                foreach (string sName in sSubKeys)
                {
                    string sValue = (string)keyCom.GetValue(sName);
                    this.cmID.Items.Add(sValue);
                }
            }
        }
        private void cmID_DropDown(object sender, EventArgs e)
        {
            GetComList();
        }

        private void btPause_Click_1(object sender, EventArgs e)
        {
            Sp.Close();
            btENT.Enabled = true;
            btPause.Enabled = false;
        } 

    }
}

标签: 监听 串口

实例下载地址

C# 串口监听例子源码(接收串口数据)

不能下载?内容有错? 点击这里报错 + 投诉 + 提问

好例子网口号:伸出你的我的手 — 分享

网友评论

第 1 楼 Steven Kwok 发表于: 2018-06-28 13:53 00
老师好,请问一下这个demo在64位机上是不是不能运行?

支持(0) 盖楼(回复)

第 2 楼 wanglong126 发表于: 2021-11-05 14:01 02
点击监听程序报错 System.Windows.Forms.AxHost.InvalidActiveXStateException:“Exception_WasThrown”

支持(0) 盖楼(回复)

发表评论

(您的评论需要经过审核才能显示)

查看所有2条评论>>

小贴士

感谢您为本站写下的评论,您的评论对其它用户来说具有重要的参考价值,所以请认真填写。

  • 类似“顶”、“沙发”之类没有营养的文字,对勤劳贡献的楼主来说是令人沮丧的反馈信息。
  • 相信您也不想看到一排文字/表情墙,所以请不要反馈意义不大的重复字符,也请尽量不要纯表情的回复。
  • 提问之前请再仔细看一遍楼主的说明,或许是您遗漏了。
  • 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦,又没人会搭理,于人于己都无利。

关于好例子网

本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享,对搜索内容的合法性不具有预见性、识别性、控制性,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论平台是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定,若资源存在侵权或相关问题请联系本站客服人员,点此联系我们。关于更多版权及免责申明参见 版权及免责申明

;
报警