热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

C#WPF上位机实现和下位机TCP通讯的方法

C#WPF上位机实现和下位机TCP通讯的方法-下位机使用北京大华程控电源DH1766-1,上位机使用WPF。实现了电压电流实时采集,曲线显示。上午在公司调试成功,手头没有程控电源,

下位机使用北京大华程控电源DH1766-1,上位机使用WPF。实现了电压电流实时采集,曲线显示。上午在公司调试成功,手头没有程控电源,使用TCP服务端模拟。昨天写的TCP服务端正好排上用场。

界面如下:

服务端

服务端实在上篇基础上实现的。需要做如下更改:

while (true)
             {
               try
               {
                 byte[] bufferDate = new byte[1024];
                 int realLen = pSocket.Receive(bufferDate);
                 if (realLen <= 0)
                 {
                   this.Invoke(addTextDelegate, pSocket.RemoteEndPoint.ToString() + "退出\r\n");
                   socketList.Remove(pSocket);
                   //客户端退出的时候会发送一个空字节
                   pSocket.Shutdown(SocketShutdown.Both);
                   pSocket.Close();
                   return;
                 }
                 string receiveStr = Encoding.Default.GetString(bufferDate, 0, realLen);
                 switch (receiveStr)
                 {
                   case "MEAS:VOLTage:ALL?\n":
                     proxSocket.Send(Encoding.Default.GetBytes(r.Next(16,25).ToString()+ ","+r.Next(16, 25).ToString()+","+ r.Next(16, 25).ToString()));
                     break;
                   case "MEAS:CURR:ALL?\n":
                     proxSocket.Send(Encoding.Default.GetBytes(r.Next(2, 5).ToString() + "," + r.Next(2, 5).ToString() + "," + r.Next(2, 5).ToString()));
                     break;
                   default:
                     break;
                 }
                 this.Invoke(addTextDelegate, receiveStr + "from" + pSocket.RemoteEndPoint.ToString() + "\r\n");
               }
               catch (Exception ex)
               {
                 this.Invoke(addTextDelegate, pSocket.RemoteEndPoint.ToString() + "异常退出\r\n");
                 socketList.Remove(pSocket);
                 pSocket.Shutdown(SocketShutdown.Both);
                 pSocket.Close();
                 return;
               }
             }

在While循环中加入:

switch (receiveStr)
{
  case "MEAS:VOLTage:ALL?\n":
  proxSocket.Send(Encoding.Default.GetBytes(r.Next(16,25).ToString()+ ","+r.Next(16, 25).ToString()+","+ r.Next(16, 25).ToString()));
  break;
  case "MEAS:CURR:ALL?\n":
  proxSocket.Send(Encoding.Default.GetBytes(r.Next(2, 5).ToString() + "," + r.Next(2, 5).ToString() + "," + r.Next(2, 5).ToString()));
  break;
  default:
  break;
}

模拟电源,当收到电压查询时,发送16~25中随机数,由于电源是三个通道的,因此发送三个随机数,用逗号隔开。同样收到电流查询,发送2~5之间的随机数。

完整的客户端源码:

public partial class Form1 : Form
  {
    public Form1()
    {
      InitializeComponent();
      addTextDelegate = new AddTextDelegate(AddText);
    }
    private AddTextDelegate addTextDelegate;
    private List socketList = new List();

    public delegate void AddTextDelegate(string text);
    private void AddText(string text)
    {
      txtLog.Text += text;
    }

    Random r = new Random();

    private void btnStart_Click(object sender, EventArgs e)
    {
      //参数:寻址方式  传输数据方式 通信协议
      Socket socket = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);

      IPAddress iPAddress = IPAddress.Parse(txtIP.Text);

      //创建EndPoint
      IPEndPoint iPEndPoint = new IPEndPoint(iPAddress, int.Parse(txtPort.Text));

      //绑定端口
      socket.Bind(iPEndPoint);

      //开启侦听
      socket.Listen(10);

      txtLog.Text += "服务启动开启侦听……\r\n";

      Thread thread = new Thread((s) =>
       {
         Socket serSocket = (Socket)s;
         while (true)//不断接收客户端连接
         {
           this.Invoke(addTextDelegate, "服务正在等待客户端连接……\r\n");

           //开始接收客户端的连接
           //阻塞当前线程,等待客户端连接
           //客户端连接上之后,服务端自动生成一个socket和连接的客端通信
           Socket proxSocket = serSocket.Accept();

           this.Invoke(addTextDelegate, "客户端连接成功!\r\n" + proxSocket.RemoteEndPoint.ToString());

           //proxSocket.Send(Encoding.Default.GetBytes("连接成功!"));

           socketList.Add(proxSocket);//当前通信的socket放到集合中

           new Thread(p =>
           {
             Socket pSocket = (Socket)p;
             while (true)
             {
               try
               {
                 byte[] bufferDate = new byte[1024];
                 int realLen = pSocket.Receive(bufferDate);

                 if (realLen <= 0)
                 {
                   this.Invoke(addTextDelegate, pSocket.RemoteEndPoint.ToString() + "退出\r\n");

                   socketList.Remove(pSocket);
                   //客户端退出的时候会发送一个空字节
                   pSocket.Shutdown(SocketShutdown.Both);
                   pSocket.Close();

                   return;
                 }
                 string receiveStr = Encoding.Default.GetString(bufferDate, 0, realLen);
                 switch (receiveStr)
                 {
                   case "MEAS:VOLTage:ALL?\n":
                     proxSocket.Send(Encoding.Default.GetBytes(r.Next(16,25).ToString()+ ","+r.Next(16, 25).ToString()+","+ r.Next(16, 25).ToString()));
                     break;
                   case "MEAS:CURR:ALL?\n":
                     proxSocket.Send(Encoding.Default.GetBytes(r.Next(2, 5).ToString() + "," + r.Next(2, 5).ToString() + "," + r.Next(2, 5).ToString()));
                     break;
                   default:
                     break;
                 }
                 this.Invoke(addTextDelegate, receiveStr + "from" + pSocket.RemoteEndPoint.ToString() + "\r\n");
               }
               catch (Exception ex)
               {
                 this.Invoke(addTextDelegate, pSocket.RemoteEndPoint.ToString() + "异常退出\r\n");

                 socketList.Remove(pSocket);
                 pSocket.Shutdown(SocketShutdown.Both);
                 pSocket.Close();
                 return;
               }
             }
           })
           { IsBackground = true }.Start(proxSocket);
         }
       });
      thread.IsBackground = true;
      thread.Start(socket);
      
    }

    private void btnSend_Click(object sender, EventArgs e)
    {
      string str = txtSend.Text;
      byte[] data = Encoding.Default.GetBytes(str);
      foreach (var socket in socketList)
      {
        if (socket != null && socket.Connected)
        {
          socket.Send(data);
        }
      }
    }
  }

上位机实现客户端功能。具体如下:

1、字段和属性

public readonly IPEndPoint TagetIPEP;

public bool IsConnected { get; set; } = false;

private Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp) { /*ReceiveTimeout=1000,SendTimeout=1000*/};

private Thread recListenThread;

public string ReceiveStr { get; set; }

public byte[] ReceiveByte { get; set; }

TagetIPEP是服务器地址和端口。

IsConnected是连接的状态,这个比较重要,在发送和接收时,都要更加IsConnected进行,并更新IsConnected。

Socket用于和客户端通讯。

recListenThread是监听客户端消息的线程。

ReceiveStr和ReceiveByte用来存储客户端发来的消息。

2、方法函数连接方法:

public bool Connect()
    {
      try
      {
        socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)
        {
          //ReceiveTimeout = 1000,
          //SendTimeout=1000
        };

        //IAsyncResult cOnnResult= socket.BeginConnect(TagetIPEP.Address, TagetIPEP.Port, null, null);
        //connResult.AsyncWaitHandle.WaitOne(5000, true);
        //if (connResult.IsCompleted)
        //{
        socket.Connect(TagetIPEP.Address, TagetIPEP.Port);
        IsCOnnected= true;
          //开启接收监听

          recListenThread = new Thread(() =>
          {
            while (true)
            {
              try
              {
                ReceiveByte = new byte[1024];
                int realLen = socket.Receive(ReceiveByte);
                ReceiveStr = Encoding.Default.GetString(ReceiveByte, 0, realLen);
                ReceiveEvent();
                if (realLen <= 0)
                {
                  if (socket != null && socket.Connected)
                  {
                    //服务器退出
                    IsCOnnected= false;
                    Log.WriteLog("服务器退出!");
                    socket.Shutdown(SocketShutdown.Both);
                    socket.Close();
                    MessageBox.Show("连接断开!");
                  }
                  return;
                }
              }
              catch (Exception ex)
              {
                if (socket != null && socket.Connected)
                {
                  IsCOnnected= false;
                  Log.WriteLog("服务器异常退出!", ex);
                  socket.Shutdown(SocketShutdown.Both);
                  socket.Close();
                }
                return;
              }
            }
          })
          { IsBackground = true };
          recListenThread.Start();
          return true;
        //}

      }
      catch (Exception ex)
      {
        Log.WriteLog(TagetIPEP.Address + "连接失败", ex);
      }
      return false;
    }

连接函数返回值为bool类型,根据返回值判断连接是否成功连接。这里每次连接都实例化了一个socket,因为在执行socket.close()后,重新打开会失败,而断线重连会经常用到,没有找到更好的方法,干脆重新实例化socket。连接成功后,开启监听服务端消息的线程。这里使用了一个ReceiveEvent()事件,在接收到消息时会触发这个事件,刷新UI界面。

发送方法:

public bool Send(string msg)
    {
      byte[] sendMsg = Encoding.Default.GetBytes(msg);
      if (sendMsg.Length > 0&&IsConnected)
      {
        if (socket != null && socket.Connected)
        {
          try
          {
            socket.Send(sendMsg);
            return true;
          }
          catch (Exception ex)
          {
            IsCOnnected= false;
            Log.WriteLog("发送数据失败,目标地址" + TagetIPEP.Address, ex);
          }
        }
      }

      return false;

    }

关闭方法:

public void Close()
    {
      if (socket != null && socket.Connected)
      {
        IsCOnnected= false;
        recListenThread.Abort();
        Log.WriteLog("关闭连接!");
        socket.Shutdown(SocketShutdown.Both);
        socket.Close();
      }
    }

在出现异常时调用

消息接收事件:

public event Action ReceiveEvent;

每次接收消息时触发,获取属性ReceiveStr和ReceiveByte的值,刷新UI界面。

完整代码:

public class TCPClient
  {
    public TCPClient(/*IPEndPoint localIPEP,*/IPEndPoint targetIPEP)
    {
      //socket.Bind(localIPEP);
      TagetIPEP = targetIPEP;
      
    }

    public readonly IPEndPoint TagetIPEP;

    public bool IsConnected { get; set; } = false;

    private Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp) { /*ReceiveTimeout=1000,SendTimeout=1000*/};

    public bool Connect()
    {
      try
      {
        socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)
        {
          //ReceiveTimeout = 1000,
          //SendTimeout=1000
        };

        //IAsyncResult cOnnResult= socket.BeginConnect(TagetIPEP.Address, TagetIPEP.Port, null, null);
        //connResult.AsyncWaitHandle.WaitOne(5000, true);
        //if (connResult.IsCompleted)
        //{
        socket.Connect(TagetIPEP.Address, TagetIPEP.Port);
        IsCOnnected= true;
          //开启接收监听

          recListenThread = new Thread(() =>
          {
            while (true)
            {
              try
              {
                ReceiveByte = new byte[1024];
                int realLen = socket.Receive(ReceiveByte);
                ReceiveStr = Encoding.Default.GetString(ReceiveByte, 0, realLen);
                ReceiveEvent();
                if (realLen <= 0)
                {
                  if (socket != null && socket.Connected)
                  {
                    //服务器退出
                    IsCOnnected= false;
                    Log.WriteLog("服务器退出!");
                    socket.Shutdown(SocketShutdown.Both);
                    socket.Close();
                    MessageBox.Show("连接断开!");
                  }
                  return;
                }
              }
              catch (Exception ex)
              {
                if (socket != null && socket.Connected)
                {
                  IsCOnnected= false;
                  Log.WriteLog("服务器异常退出!", ex);
                  socket.Shutdown(SocketShutdown.Both);
                  socket.Close();
                }
                return;
              }
            }
          })
          { IsBackground = true };
          recListenThread.Start();
          return true;
        //}

      }
      catch (Exception ex)
      {
        Log.WriteLog(TagetIPEP.Address + "连接失败", ex);
      }
      return false;
    }

    public bool Send(string msg)
    {
      byte[] sendMsg = Encoding.Default.GetBytes(msg);
      if (sendMsg.Length > 0&&IsConnected)
      {
        if (socket != null && socket.Connected)
        {
          try
          {
            socket.Send(sendMsg);
            return true;
          }
          catch (Exception ex)
          {
            IsCOnnected= false;
            Log.WriteLog("发送数据失败,目标地址" + TagetIPEP.Address, ex);
          }
        }
      }

      return false;

    }

    public event Action ReceiveEvent;

    public string ReceiveStr { get; set; }

    public byte[] ReceiveByte { get; set; }

    public void Close()
    {
      if (socket != null && socket.Connected)
      {
        IsCOnnected= false;
        recListenThread.Abort();
        Log.WriteLog("关闭连接!");
        socket.Shutdown(SocketShutdown.Both);
        socket.Close();
      }
    }

    private Thread recListenThread;

  }

前台调用,声明Timer定时器,每个一秒触发一次。触发事件如下:

private string flag = "";
    private void QueryTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
    {
      Now = DateTime.Now;

      if (!tcp.Send("MEAS:VOLTage:ALL?\n"))
      {
        queryTimer.Enabled = false;
        StartCOntent= "开始";
        COnnContent= "连接";
        tcp.IsCOnnected= false;
        MessageBox.Show("查询失败!");
        return;
      }
      flag = "V";
      Thread.Sleep(50);

      if (!tcp.Send("MEAS:CURR:ALL?\n"))
      {
        queryTimer.Enabled = false;
        StartCOntent= "开始";
        COnnContent= "连接";
        tcp.IsCOnnected= false;
        MessageBox.Show("查询失败!");
        return;
      }
      flag = "C";

      #region 测试
      //angle += 18;
      //if (angle > 360)
      //{
      //  angle = 18;
      //}

      #endregion
    }

刷新UI界面的事件如下:

private void Tcp_ReceiveEvent()
    {
      Task.Run(() =>
      {
        Application.Current.Dispatcher.Invoke(() =>
        {
          RemoteIP = tcp.TagetIPEP.ToString();
          switch (flag)
          {
            case "V":
              VoltValue = Math.Round(Convert.ToDouble(tcp.ReceiveStr.Split(',')[0]), 3);
              break;
            case "C":
              CurrentValue = Math.Round(Convert.ToDouble(tcp.ReceiveStr.Split(',')[0]), 3);
              break;
            default:
              break;
          }

          #region 测试
          //VoltValue = Math.Round(Math.Sin((angle) * pi / 180) * 16 + 16, 3);
          //CurrentValue = Math.Round(Math.Sin((angle) * pi / 180) * 2.5 + 2.5, 3);
          #endregion

          VoltValues.Add(VoltValue);
          CurrentValues.Add(CurrentValue);

          if (VoltValues.Count > 30)
          {
            VoltValues.RemoveAt(0);
            CurrentValues.RemoveAt(0);
          }
        });
      });
    }

推荐阅读
  • 本文介绍了如何利用 Delphi 中的 IdTCPServer 和 IdTCPClient 控件实现高效的文件传输。这些控件在默认情况下采用阻塞模式,并且服务器端已经集成了多线程处理,能够支持任意大小的文件传输,无需担心数据包大小的限制。与传统的 ClientSocket 相比,Indy 控件提供了更为简洁和可靠的解决方案,特别适用于开发高性能的网络文件传输应用程序。 ... [详细]
  • Java Socket 关键参数详解与优化建议
    Java Socket 的 API 虽然被广泛使用,但其关键参数的用途却鲜为人知。本文详细解析了 Java Socket 中的重要参数,如 backlog 参数,它用于控制服务器等待连接请求的队列长度。此外,还探讨了其他参数如 SO_TIMEOUT、SO_REUSEADDR 等的配置方法及其对性能的影响,并提供了优化建议,帮助开发者提升网络通信的稳定性和效率。 ... [详细]
  • 深入解析Android 4.4中的Fence机制及其应用
    在Android 4.4中,Fence机制是处理缓冲区交换和同步问题的关键技术。该机制广泛应用于生产者-消费者模式中,确保了不同组件之间高效、安全的数据传输。通过深入解析Fence机制的工作原理和应用场景,本文探讨了其在系统性能优化和资源管理中的重要作用。 ... [详细]
  • Python 伦理黑客技术:深入探讨后门攻击(第三部分)
    在《Python 伦理黑客技术:深入探讨后门攻击(第三部分)》中,作者详细分析了后门攻击中的Socket问题。由于TCP协议基于流,难以确定消息批次的结束点,这给后门攻击的实现带来了挑战。为了解决这一问题,文章提出了一系列有效的技术方案,包括使用特定的分隔符和长度前缀,以确保数据包的准确传输和解析。这些方法不仅提高了攻击的隐蔽性和可靠性,还为安全研究人员提供了宝贵的参考。 ... [详细]
  • 使用Maven JAR插件将单个或多个文件及其依赖项合并为一个可引用的JAR包
    本文介绍了如何利用Maven中的maven-assembly-plugin插件将单个或多个Java文件及其依赖项打包成一个可引用的JAR文件。首先,需要创建一个新的Maven项目,并将待打包的Java文件复制到该项目中。通过配置maven-assembly-plugin,可以实现将所有文件及其依赖项合并为一个独立的JAR包,方便在其他项目中引用和使用。此外,该方法还支持自定义装配描述符,以满足不同场景下的需求。 ... [详细]
  • 本文详细介绍了一种利用 ESP8266 01S 模块构建 Web 服务器的成功实践方案。通过具体的代码示例和详细的步骤说明,帮助读者快速掌握该模块的使用方法。在疫情期间,作者重新审视并研究了这一未被充分利用的模块,最终成功实现了 Web 服务器的功能。本文不仅提供了完整的代码实现,还涵盖了调试过程中遇到的常见问题及其解决方法,为初学者提供了宝贵的参考。 ... [详细]
  • 在对WordPress Duplicator插件0.4.4版本的安全评估中,发现其存在跨站脚本(XSS)攻击漏洞。此漏洞可能被利用进行恶意操作,建议用户及时更新至最新版本以确保系统安全。测试方法仅限于安全研究和教学目的,使用时需自行承担风险。漏洞编号:HTB23162。 ... [详细]
  • 本指南介绍了如何在ASP.NET Web应用程序中利用C#和JavaScript实现基于指纹识别的登录系统。通过集成指纹识别技术,用户无需输入传统的登录ID即可完成身份验证,从而提升用户体验和安全性。我们将详细探讨如何配置和部署这一功能,确保系统的稳定性和可靠性。 ... [详细]
  • 本文深入解析了WCF Binding模型中的绑定元素,详细介绍了信道、信道管理器、信道监听器和信道工厂的概念与作用。从对象创建的角度来看,信道管理器负责信道的生成。具体而言,客户端的信道通过信道工厂进行实例化,而服务端则通过信道监听器来接收请求。文章还探讨了这些组件之间的交互机制及其在WCF通信中的重要性。 ... [详细]
  • Python 程序转换为 EXE 文件:详细解析 .py 脚本打包成独立可执行文件的方法与技巧
    在开发了几个简单的爬虫 Python 程序后,我决定将其封装成独立的可执行文件以便于分发和使用。为了实现这一目标,首先需要解决的是如何将 Python 脚本转换为 EXE 文件。在这个过程中,我选择了 Qt 作为 GUI 框架,因为之前对此并不熟悉,希望通过这个项目进一步学习和掌握 Qt 的基本用法。本文将详细介绍从 .py 脚本到 EXE 文件的整个过程,包括所需工具、具体步骤以及常见问题的解决方案。 ... [详细]
  • 在Android平台中,播放音频的采样率通常固定为44.1kHz,而录音的采样率则固定为8kHz。为了确保音频设备的正常工作,底层驱动必须预先设定这些固定的采样率。当上层应用提供的采样率与这些预设值不匹配时,需要通过重采样(resample)技术来调整采样率,以保证音频数据的正确处理和传输。本文将详细探讨FFMpeg在音频处理中的基础理论及重采样技术的应用。 ... [详细]
  • 本文将继续探讨 JavaScript 函数式编程的高级技巧及其实际应用。通过一个具体的寻路算法示例,我们将深入分析如何利用函数式编程的思想解决复杂问题。示例中,节点之间的连线代表路径,连线上的数字表示两点间的距离。我们将详细讲解如何通过递归和高阶函数等技术实现高效的寻路算法。 ... [详细]
  • 本文介绍了如何利用ObjectMapper实现JSON与JavaBean之间的高效转换。ObjectMapper是Jackson库的核心组件,能够便捷地将Java对象序列化为JSON格式,并支持从JSON、XML以及文件等多种数据源反序列化为Java对象。此外,还探讨了在实际应用中如何优化转换性能,以提升系统整体效率。 ... [详细]
  • 如何在C#中配置组合框的背景颜色? ... [详细]
  • 【问题】在Android开发中,当为EditText添加TextWatcher并实现onTextChanged方法时,会遇到一个问题:即使只对EditText进行一次修改(例如使用删除键删除一个字符),该方法也会被频繁触发。这不仅影响性能,还可能导致逻辑错误。本文将探讨这一问题的原因,并提供有效的解决方案,包括使用Handler或计时器来限制方法的调用频率,以及通过自定义TextWatcher来优化事件处理,从而提高应用的稳定性和用户体验。 ... [详细]
author-avatar
疯务情堂
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有