zoukankan      html  css  js  c++  java
  • ModbusTCP可读取

    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.Net.Sockets;
    using System.Threading;
    using NModbus;
    using System.Net;
    
    namespace ModbusTcp
    {
        public partial class Form1 : Form
        {
    
            private static ModbusFactory modbusFactory;
            //private static IModbusMaster master=null;
            private static IModbusMaster master;
            //写线圈或写寄存器数组
            bool[] coilsBuffer;
            ushort[] registerBuffer;
            //参数(分别为站号,起始地址,长度)
            byte slaveAddress;
            ushort startAddress;
            ushort numberOfPoints;
            string functionCode;
            public Form1()
            {
                InitializeComponent();
    
            }
            /// <summary>
            /// 监听状态
            /// </summary>
           // private bool isConnected = false;
            private void Form1_Load(object sender, EventArgs e)
            {
                //IPAddress address = new IPAddress(new byte[]{127,0,0,1});
                //TcpClient client = new TcpClient(address.ToString(), 502);
                
                groupBox1.Enabled = false;
                groupBox2.Enabled = false;
            }
            private void comboBox1_SelectedIndexChanged(object sender, EventArgs e)
            {
                if (comboBox1.SelectedIndex >= 4)
                {
                    groupBox2.Enabled = true;
                    groupBox1.Enabled = false;
                }
                else
                {
                    groupBox1.Enabled = true;
                    groupBox2.Enabled = false;
                }
                comboBox1.Invoke(new Action(() => { functionCode = comboBox1.SelectedItem.ToString(); }));
            }
            /// <summary>
            /// 读/写
            /// </summary>
            /// <param name="sender"></param>
            /// <param name="e"></param>
            private void button1_Click(object sender, EventArgs e)
            {
                //初始化modbusmaster
                modbusFactory = new ModbusFactory();
                //在本地测试 所以使用回环地址,modbus协议规定端口号 502
                master = modbusFactory.CreateMaster(new TcpClient("127.0.0.1", 502));
                //设置读取超时时间
                master.Transport.ReadTimeout = 2000;
                master.Transport.Retries = 2000;
                comboBox1_SelectedIndexChanged(sender,e);
                ExecuteFunction();
            }
    
            private async void ExecuteFunction()
            {
                try
                {
                    //master = modbusFactory.CreateMaster(new TcpClient("127.0.0.1", 502));
                    if (functionCode != null)
                    {
                        switch (functionCode)
                        {
                            case "01 Read Coils"://读取单个线圈
                                SetReadParameters();
                                coilsBuffer = master.ReadCoils(slaveAddress, startAddress, numberOfPoints);
                                for (int i = 0; i < coilsBuffer.Length; i++)
                                {
                                    SetMsg(coilsBuffer[i] + "");
                                }
                                break;
                            case "02 Read DisCrete Inputs"://读取输入线圈/离散量线圈
                                SetReadParameters();
    
                                coilsBuffer = master.ReadInputs(slaveAddress, startAddress, numberOfPoints);
                                for (int i = 0; i < coilsBuffer.Length; i++)
                                {
                                    SetMsg(coilsBuffer[i] + "");
                                }
                                break;
                            case "03 Read Holding Registers"://读取保持寄存器
                                SetReadParameters();
                                registerBuffer = master.ReadHoldingRegisters(slaveAddress, startAddress, numberOfPoints);
                                for (int i = 0; i < registerBuffer.Length; i++)
                                {
                                    //SetMsg(registerBuffer[i]+"");
                                }
                               break;
                            case "04 Read Input Registers"://读取输入寄存器
                                SetReadParameters();
                                registerBuffer = master.ReadInputRegisters(slaveAddress, startAddress, numberOfPoints);
                                for (int i = 0; i < registerBuffer.Length; i++)
                                {
                                    SetMsg(registerBuffer[i] + "");
                                }
                                break;
                            case "05 Write Single Coil"://写单个线圈
                                SetWriteParametes();
                                await master.WriteSingleCoilAsync(slaveAddress, startAddress, coilsBuffer[0]);
                                break;
                            case "06 Write Single Registers"://写单个输入线圈/离散量线圈
                                SetWriteParametes();
                                await master.WriteSingleRegisterAsync(slaveAddress, startAddress, registerBuffer[0]);
                                break;
                            case "0F Write Multiple Coils"://写一组线圈
                                SetWriteParametes();
                                await master.WriteMultipleCoilsAsync(slaveAddress, startAddress, coilsBuffer);
                                break;
                            case "10 Write Multiple Registers"://写一组保持寄存器
                                SetWriteParametes();
                                await master.WriteMultipleRegistersAsync(slaveAddress, startAddress, registerBuffer);
                                break;
                            default:
                                break;
                        }
                    }
                    else {
                        MessageBox.Show("请选择功能码!");
                    }
                    master.Dispose();
                }
                catch (Exception ex)
                {
                     MessageBox.Show(ex.Message);
                }
            }
           
            /// <summary>
            /// 初始化读参数
            /// </summary>
            private void SetReadParameters()
            {
                if (txt_startAddr1.Text == "" || txt_slave1.Text == "" || txt_length.Text == "")
                {
                    MessageBox.Show("请填写读参数!");
                }
                else
                {
                    slaveAddress = byte.Parse(txt_slave1.Text);
                    startAddress = ushort.Parse(txt_startAddr1.Text);
                    numberOfPoints = ushort.Parse(txt_length.Text);
                }
            }
            /// <summary>
            /// 初始化写参数
            /// </summary>
            private void SetWriteParametes()
            {
                if (txt_slave2.Text == "" || txt_slave2.Text == "" || txt_data.Text == "")
                {
                    MessageBox.Show("请填写写参数!");
                }
                else
                {
                    slaveAddress = byte.Parse(txt_slave2.Text);
                    startAddress = ushort.Parse(txt_slave2.Text);
                    //判断是否写线圈
                    if (comboBox1.SelectedIndex == 4 || comboBox1.SelectedIndex == 6)
                    {
                        string[] strarr = txt_data.Text.Split(' ');
                        coilsBuffer = new bool[strarr.Length];
                        //转化为bool数组
                        for (int i = 0; i < strarr.Length; i++)
                        {
                            // strarr[i] == "0" ? coilsBuffer[i] = true : coilsBuffer[i] = false;
                            if (strarr[i] == "0")
                            {
                                coilsBuffer[i] = false;
                            }
                            else
                            {
                                coilsBuffer[i] = true;
                            }
                        }
                    }
                    else
                    {
                        //转化ushort数组
                        string[] strarr = txt_data.Text.Split(' ');
                        registerBuffer = new ushort[strarr.Length];
                        for (int i = 0; i < strarr.Length; i++)
                        {
                            registerBuffer[i] = ushort.Parse(strarr[i]);
                        }
                    }
                }
            }
            
            
            /// <summary>
            /// SetMessage
            /// </summary>
            /// <param name="msg"></param>
            public void SetMsg(string msg)
            {
                richTextBox1.Invoke(new Action(() => { richTextBox1.AppendText(msg + "
    "); }));
            }
            /// <summary>
            /// 清除文本
            /// </summary>
            /// <param name="sender"></param>
            /// <param name="e"></param>
           
    
            private void button2_Click_1(object sender, EventArgs e)
            {
                richTextBox1.Clear();
            }
        }
    }                    

    可以读取的ModbusTcp示例Demo

  • 相关阅读:
    linux下安装elasticsearch5.6.3
    linux下安装git
    环境安装备忘录 Zookeeper
    环境安装备忘录 JDK
    环境安装备忘录 Tomcat
    MySql 通过show status 优化数据库性能
    MySQL执行计划解读 转他人文章
    2015年12月21日 my.cnf 配置
    mysql 如何查看my.cnf的 位置
    mysql状态查看 QPS/TPS/缓存命中率查看
  • 原文地址:https://www.cnblogs.com/MuZiJin/p/11798043.html
Copyright © 2011-2022 走看看