devbox
小小林熬夜学编程
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

C# 联合KepServer对PLC进行数据读写_c# kepserver

作者：小小林熬夜学编程 | 2024-05-29 10:21:44

赞

踩

c# kepserver

KepServer可以将任何工业设备的通信协议转换为opc协议，然后用OPCAutomation进行上位机数据读写。

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using OPCAutomation;

namespace KepTest1
{
    public partial class FrmMain : Form
    {
        public FrmMain()
        {
            InitializeComponent();
            this.Load += FrmMain_Load;
        }

        private void FrmMain_Load(object sender, EventArgs e)
        {
            this.btnRefresh_Click(btnRefresh, null);
            this.dataGridViewValue.AutoGenerateColumns = false;
        }

        OPCServer opcServer;
        OPCGroups opcGroups;
        OPCGroup opcGroup;

        OPCItems opcItems;
        OPCItem opcItem; //项
        Dictionary<string, OPCItem> dicOpcItem = new Dictionary<string, OPCItem>();
        List<OPCItem> opcItemList = new List<OPCItem>(); //项的集合

        OPCBrowser opcBrowser;
        string strHostName = null;
        object opcServerList;

        List<OpcValue> opcValueList = new List<OpcValue>();

        int clientHandle; //change句柄

        int count;

        //异步写入相关
        Array writeErrors;
        int cancelId;

        private void btnConn_Click(object sender, EventArgs e)
        {
            //连接服务器
            if (opcServer != null)
            {
                opcServer = new OPCServer();
            }
            try
            {
                opcServer.Connect(this.cmb_ServerName.Text, this.cmb_ServerNode.Text);
            }
            catch (Exception ex)
            {
                MessageBox.Show("连接失败：" + ex.Message);
                return;
            }

            opcBrowser = this.opcServer.CreateBrowser(); //由OPC 节点创建浏览器
            opcBrowser.ShowBranches();//展示浏览器属性
            opcBrowser.ShowLeafs(true); //叶节点展示

            //绑定 其实是浏览器browers
            this.listBoxServer.Items.Clear();

            foreach (var item in opcBrowser)
            {
                if (!this.listBoxServer.Items.Contains(item))
                {
                    this.listBoxServer.Items.Add(item.ToString());
                }
            }

            //通信组集合
            opcGroups = this.opcServer.OPCGroups;
            opcGroups.DefaultGroupDeadband = 0; //只要有变化，就显示出来
            opcGroups.DefaultGroupIsActive = true;
            //opcGroups.DefaultGroupUpdateRate = 200; //200毫秒刷新一次

            //通信组实例化
            opcGroup = opcGroups.Add("S71500Test");
            opcGroup.IsActive = true;
            opcGroup.IsSubscribed = true; //是否开启异步回调
            opcGroup.UpdateRate = 200;

            opcItems = opcGroup.OPCItems;
            opcGroup.DataChange += OpcGroup_DataChange;

        }

        //订阅模式
        private void OpcGroup_DataChange(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps)
        {
            for (int i = 0; i < NumItems; i++)
            {
                //clientHandle = Convert.ToInt32(ClientHandles.GetValue(i + 1));
                //opcValueList[clientHandle - 1].Value = ItemValues.GetValue(i + 1).ToString();
                //opcValueList[clientHandle - 1].InsertTime = Convert.ToDateTime(TimeStamps.GetValue(i + 1));

                //this.dataGridViewValue.DataSource = null;
                //this.dataGridViewValue.DataSource = opcValueList;

                clientHandle = Convert.ToInt32(ClientHandles.GetValue(i + 1));
                opcValueList[clientHandle - 1].Value = ItemValues.GetValue(i + 1).ToString();
                opcValueList[clientHandle - 1].InsertTime = Convert.ToDateTime(TimeStamps.GetValue(i + 1));
                opcValueList[clientHandle - 1].OPCDataType = ItemValues.GetValue(i + 1).GetType().ToString();
                opcValueList[clientHandle - 1].OPCQuality = Qualities.GetValue(i + 1).ToString();
            }
            xktTextShowBasic1.VarValue = opcValueList[0].Value;
        }

        private void btnRefresh_Click(object sender, EventArgs e)
        {
            //清空
            this.cmb_ServerNode.Items.Clear();
            this.cmb_ServerName.Items.Clear();
            Task.Run(async () =>
            {
                IPHostEntry IPhost = Dns.GetHostEntry(Environment.MachineName);
                if (IPhost.AddressList.Length > 0)
                {
                    
                    for (int i = 0; i < IPhost.AddressList.Length; i++)
                    {
                        await Task.Delay(500);
                        string host = Dns.GetHostEntry(IPhost.AddressList[i]).HostName;//计算机名称

                        if (!this.cmb_ServerNode.Items.Contains(host))
                        {
                            this.cmb_ServerNode.Invoke(new Action(() =>
                            {
                                this.cmb_ServerNode.Items.Add(host);
                            }));
                        }
                    }
                }
            });

        }

        //如果改变
        private void cmb_ServerNode_SelectedIndexChanged(object sender, EventArgs e)
        {
            if (opcServer == null)
            {
                opcServer = new OPCServer();
            }

            this.cmb_ServerName.Items.Clear();

            strHostName = this.cmb_ServerNode.Text.Trim(); //获取主机名

            try
            {
                opcServerList = opcServer.GetOPCServers(strHostName);

                //object serviceList = KepServer.GetOPCServers(this.cmb_ServerNode.Text);

                Task.Run(async () => 
                {
                    foreach (var item in (Array)opcServerList)
                    {
                        await Task.Delay(500);
                        if (!this.cmb_ServerName.Items.Contains(item))
                        {
                            this.cmb_ServerName.Invoke(new Action(() =>
                            {
                                this.cmb_ServerName.Items.Add(item);
                            }));
                            
                        }
                    }
                });

            }
            catch (Exception)
            {

            }


        }


        private void listBoxServer_MouseDoubleClick(object sender, MouseEventArgs e)
        {
            opcValueList.Add(new OpcValue());
            opcValueList[count].Name = this.listBoxServer.Text.Trim();
            opcItem = opcItems.AddItem(this.listBoxServer.Text.Trim(), count + 1);
            opcItemList.Add(opcItem);
            count += 1;
        }

        //读取
        private void button1_Click(object sender, EventArgs e)
        {
            opcValueList.Add(new OpcValue() { Name = "MD200",ItemId = "Siemens1500.siemens1513.MD200" });
            opcValueList.Add(new OpcValue() { Name = "DB24DBW8", ItemId = "Siemens1500.siemens1513.DB24DBW8" });
            opcValueList.Add(new OpcValue() { Name = "DB24DBD34",ItemId = "Siemens1500.siemens1513.DB24DBD34" });


                //opcServer通过Ip 端口号得到： opcServer.Connect(this.cmb_ServerName.Text, this.cmb_ServerNode.Text);
                //opcGroups 由Opc服务器得到：opcGroups = this.opcServer.OPCGroups;
                //opcGroup 由 opcGroups 实例化得到：opcGroup = opcGroups.Add("S71500Test");
                //opcItems由opcGroup中得到： opcItems = opcGroup.OPCItems; 而来 实例化opcItems 得到 opcItem
                //做集合opcItem 方便取出opcItem，方便写变量
            
            for (int i = 0; i < opcValueList.Count; i++)
            {
                opcItem = opcItems.AddItem(opcValueList[i].ItemId, i + 1);
                opcItemList.Add(opcItem);
                dicOpcItem.Add(opcValueList[i].Name, opcItem);
            }
        }

        private void btnWrite_Click(object sender, EventArgs e)
        {
            string value = txtWrite.Text.Trim();

            //同步写入
            //dicOpcItem["MD200"].Write(value);

            //异步写入
            int[] reServerHandle = new int[2] { 0, dicOpcItem["MD200"].ServerHandle };
            Array arrayReServerHandle = reServerHandle.ToArray();
            object[] reValue = new object[2] { "", value};

            Array values = reValue.ToArray();
            opcGroup.AsyncWrite(1, ref arrayReServerHandle, ref values, out writeErrors, 2022, out cancelId);
        }

        private void btnDisc_Click(object sender, EventArgs e)
        {
            opcServer.Disconnect();
            Environment.Exit(0);
        }
    }
}


  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
  • 105
  • 106
  • 107
  • 108
  • 109
  • 110
  • 111
  • 112
  • 113
  • 114
  • 115
  • 116
  • 117
  • 118
  • 119
  • 120
  • 121
  • 122
  • 123
  • 124
  • 125
  • 126
  • 127
  • 128
  • 129
  • 130
  • 131
  • 132
  • 133
  • 134
  • 135
  • 136
  • 137
  • 138
  • 139
  • 140
  • 141
  • 142
  • 143
  • 144
  • 145
  • 146
  • 147
  • 148
  • 149
  • 150
  • 151
  • 152
  • 153
  • 154
  • 155
  • 156
  • 157
  • 158
  • 159
  • 160
  • 161
  • 162
  • 163
  • 164
  • 165
  • 166
  • 167
  • 168
  • 169
  • 170
  • 171
  • 172
  • 173
  • 174
  • 175
  • 176
  • 177
  • 178
  • 179
  • 180
  • 181
  • 182
  • 183
  • 184
  • 185
  • 186
  • 187
  • 188
  • 189
  • 190
  • 191
  • 192
  • 193
  • 194
  • 195
  • 196
  • 197
  • 198
  • 199
  • 200
  • 201
  • 202
  • 203
  • 204
  • 205
  • 206
  • 207
  • 208
  • 209
  • 210
  • 211
  • 212
  • 213
  • 214
  • 215
  • 216
  • 217
  • 218
  • 219
  • 220
  • 221
  • 222
  • 223
  • 224
  • 225
  • 226
  • 227
  • 228
  • 229
  • 230
  • 231
  • 232
  • 233
  • 234
  • 235
  • 236
  • 237
  • 238
  • 239
  • 240
  • 241
  • 242
  • 243
  • 244
  • 245
  • 246
  • 247
  • 248
  • 249
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace KepTest1
{
    public class OpcValue
    {
        public int Id { get; set; }
        public string ItemId { get; set; }
        public string Name { get; set; }
        public string Value { get; set; }
        //通信质量
        public string OPCQuality { get; set; }
        //ClientHandle
        public int ClientHandle { get; set; }
        public string OPCDataType { get; set; }
        public DateTime InsertTime { get; set; }
    }
}


  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23

在这里插入图片描述
在这里插入图片描述

KepServer配置：
在这里插入图片描述
西门子PLC配置：

#T1(IN := #start,
    PT := t#1S);
#C1(CU := #T1.Q,
    R := #reset,
    PV := 30000);

IF #T1.Q THEN
    RESET_TIMER(#T1);
    
    ;
END_IF;

IF #start THEN
    "OpcDb".ushort[1] := #C1.CV;
    "OpcDb".ushort[2] := "OpcDb".ushort[1] + 1;
    "OpcDb".ushort[3] := "OpcDb".ushort[2] + 1;
    "OpcDb".ushort[4] := "OpcDb".ushort[3] + 1;
    "OpcDb".ushort[5] := "OpcDb".ushort[4] + 1;
    "OpcDb".ushort[6] := "OpcDb".ushort[5] + 1;
    
    "MD204" := "OpcDb".ushort[6] + 1.1;
    "MD208" := "OpcDb".ushort[6] + 1.2;
    "MD200" := "OpcDb".ushort[6] + 5.5;
    "OpcDb".float[0] := "OpcDb".ushort[6] + 6.6;
    "OpcDb".float[1] := "OpcDb".ushort[6] + 7.1;
    "OpcDb".float[2] := "OpcDb".ushort[6] + 8.1;
    "OpcDb".float[3] := "OpcDb".ushort[6] + 9.9;

END_IF;



  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31

在这里插入图片描述

            //opcServer通过Ip 端口号得到： opcServer.Connect(this.cmb_ServerName.Text, this.cmb_ServerNode.Text);
            //opcGroups 由Opc服务器得到：opcGroups = this.opcServer.OPCGroups;
            //opcGroup 由 opcGroups 实例化得到：opcGroup = opcGroups.Add("S71500Test");
            //opcItems由opcGroup中得到： opcItems = opcGroup.OPCItems; 而来 实例化opcItems 得到 opcItem
            //做集合opcItem 方便取出opcItem，方便写变量

  • 1
  • 2
  • 3
  • 4
  • 5

需要先注册OPCDA，在System32 和syswow64中有OPCDAAuto.dll。注册后就可以引入dll了，引入之后就有了using OPCAutomation

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小小林熬夜学编程/article/detail/641708
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号