基于OPC和TCP/IP的数据采集处理学习

1.OPC相关资源和学习资料

• OPC软件

KEPServerEX v6安装包百度网盘链接提取码：tb27 

KEPServerEX v6安装教程

• OPC相关教程

KEPServer EX6的配置

C#编写OPC客户端读取OPC服务器的数据（最高效简洁版）

KepServer 6.5模拟

C# 读写opc ua服务器，浏览所有节点，读写节点，读历史数据，调用方法，订阅，批量订阅操作

Java OPC client开发踩坑记

• OPC学习

OPC客户端访问OPC服务器的3步：明确连接哪个OPC服务器，添加需要访问的数据标签，设定处理数据变化的函数。

DLL针对这3个步骤，提供了3个函数：Connect，AddTag和SetDataChangeEvent。

如何使用DLL：

1、在工程的解决方案中“引用”，“浏览”，找到DLL，再引用它。

2、通过DLL提供的类，实例化一个管理器。

3、按照OPC客户端的工作步骤，通过调用这个类提供的对应函数进行OPC操作。

using OPCAutomation;
using System;
using System.Collections.Generic;
using System.Net;


namespace ConsoleApp1
{
    class Program
    {
        static void Main(string[] args)
        {
            OPCServer server = new OPCServer();

            //此处127.0.0.1字符串，为本地IP地址，也可别的电脑IP或者电脑名称；此处测试，就以本地IP测试；
            IPHostEntry host = Dns.GetHostEntry("127.0.0.1");

            //获取此电脑上的所有OPC服务器的ProgId，有了它，才能连接到OPC服务器。注意此处为一组OPC服务器集合，

            //而非单个，具体数量根据实际情况而定，当然，也可以是一个，我只是想说它是一个服务器的集合。
            object progIds = server.GetOPCServers(host.HostName);
            foreach (string progId in (Array)progIds)
            {

                //此处是获得单个progId，方便后面连接。
                server.Connect(progId);
            }

            //此处为常规设置，group中还有许多参数没有设置，我都采取了它的默认值，我没有特殊要求，所以不用改。
            OPCGroups groups = server.OPCGroups;
            OPCGroup group = groups.Add("myGroup");
            //此处必须修改，因为默认订阅功能为false；当然你也可以根据别的方式获取数据。

            group.IsSubscribed = true;
            group.DataChange += Group_DataChange;

            //此处为设定需要的ItemIds，就是你需要订阅的哪些数据。

            List<string> ItemIds = new List<string>(){
                "simulator.Test.k0",
                "simulator.Test.k0",
                
            };
            for (int i = 0; i < ItemIds.Count; i++)
            {
                OPCItem myItem = group.OPCItems.AddItem(ItemIds[i], i);

            }

            Console.ReadKey();
        }

        private static void Group_DataChange(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps)
        {

            //此处注意i是从1开始，因为getvalue没有0.下面输出分别为数据的ClientHandles(就是上文AddItem方法的第二个参数。)，Itemvalue就是值，Qualities为质量，timestamps为时间。
            for (int i = 1; i < NumItems + 1; i++)
            {
                Console.WriteLine(ClientHandles.GetValue(i).ToString() + "--" + ItemValues.GetValue(i).ToString() + "--" + Qualities.GetValue(i).ToString() + "--" + TimeStamps.GetValue(i).ToString());
            }
        }
    }
}
           

2.TCP相关

• TCP相关教程

C#网络编程

C#编程 socket编程之tcp服务器端和客户端

• TCP学习

服务器端

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            //1.创建socket
            //使用指定的寻址地址族、套接字类型和协议初始化Socket类的新实例，实现套接字接口
            Socket tcpServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            //2.绑定ip跟端口号
            //用指定为byte数组的地址初始化IPAddress的新实例，提供ip地址
            IPAddress ipaddress = new IPAddress(new byte[] { 127, 0, 0, 1 });
            //用指定的地址和端口号初始化EndPoint的新实例，对ip+端口做了一层封装构成标识网络地址
            EndPoint point = new IPEndPoint(ipaddress, 6666);
            //使Socket与本地一个网络地址相连，用来做通信
            tcpServer.Bind(point);
            //3.利用Listen()方法开始监听（等待客户端连接）
            //将socket置于监听状态，挂起连接队列的最大长度是100
            tcpServer.Listen(100);
            //将指定字符串写入标准输入流
            Console.WriteLine("开始监听");
            //4.利用Accept()方法尝试与客户端建立一个连接
            //如果新的连接建立，Accept()返回，创建新的Socket
            Socket clienSocket = tcpServer.Accept();
            Console.WriteLine("一个客户端连接过来了");
            string msg = "Connected";
            //将指定字符串中的字符编码为一个字节序列
            byte[] data = Encoding.UTF8.GetBytes(msg);
            //5.使用Send()在套接字上写数据
            //将数据发送到连接的Socket
            clienSocket.Send(data);
            Console.WriteLine("向客户端发送了一条数据");
            //创建一个字节数组用来当作容器，存储客户端发送过来的数据
            byte[] data2 = new byte[1024];
            //6.使用Receive()在套接字上读数据
            //从绑定的套接字接收数据，存入数据缓冲区
            int length = clienSocket.Receive(data2);
            //将指定字节数组的一个字节序列解码为一个字符串
            string msg2 = Encoding.UTF8.GetString(data2,0,length);
            Console.WriteLine("接收到了一个客户端发送过来的消息：" + msg2);
            //获取用户按下的下一个字符或功能键
            Console.ReadKey();
        }
    }
}
           

客户端

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;

namespace ConsoleApplication2
{
    class Program
    {
        static void Main(string[] args)
        {
            //1.创建Socket tcpClient
            Socket tcpClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            //2.通过ip和端口号定位一个要连接的服务器端
            IPAddress ipaddress = new IPAddress(new byte[] { 127, 0, 0, 1 });
            EndPoint point = new IPEndPoint(ipaddress, 6666);
            //3.建立与远程主机的联系
            tcpClient.Connect(point);
            byte[] data = new byte[1024];
            int length = tcpClient.Receive(data);
            string msg = Encoding.UTF8.GetString(data, 0, length);
            Console.WriteLine(msg);
            string msg2 = Console.ReadLine();
            tcpClient.Send(Encoding.UTF8.GetBytes(msg2));
            Console.ReadKey();

        }
    }
}