zoukankan      html  css  js  c++  java
  • .net平台下socket异步通讯

      1,首先添加两个windows窗体项目,一个作为服务端server,一个作为客户端Client
      2,然后添加服务端代码,添加命名空间,界面上添加TextBox控件
      using System.Net;
      using System.Net.Sockets;
      3,FormLoad方法添加代码
      private void Form1_Load(object sender, EventArgs e)
      {
      IPEndPoint epServer = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 7878);//IP地址和端口号
      Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//定义socket
      socket.Bind(epServer);//绑定
      socket.Listen(10);//监听
      socket.BeginAccept(new AsyncCallback(RecVing), socket);//异步接收,回调方法为RecVing
      }
      4,添加回调方法代码
      private void RecVing(IAsyncResult rec_socket)
      {
      string cmdstr = "";
      Socket sc = (Socket)rec_socket.AsyncState;
      Socket socket = sc.EndAccept(rec_socket);
      byte[] bytes = new byte[1024];
      int i = socket.Receive(bytes);
      cmdstr = Encoding.UTF8.GetString(bytes, 0, i);
      showstrs(cmdstr);
      sc.BeginAccept(new AsyncCallback(RecVing), sc);
      }
      5,添加showstrs方法,
      定义委托private delegate void shixudong_invoke(string invokefun);
      private void showstrs(string recv_strs)
      {
      if (recv_strs.Length != 0)
      {
      if (this.InvokeRequired)
      {
      shixudong_invoke invoke = new shixudong_invoke(showstrs);
      this.Invoke(invoke, (object)recv_strs);
      }
      else
      {
      textBox1.Text = recv_strs;
      }
      }
      }
      6,到此为止,服务端已经添加完毕
      7,客户端代码,首先跟服务端一样,添加命名空间,在界面上添加button事件
      private void button1_Click(object sender, EventArgs e)
      {
      IPEndPoint IPEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 7878);//IP,端口号
      Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
      socket.BeginConnect(IPEndPoint, new AsyncCallback(Sending), socket);//回调方法Sending
      }
      8,添加回调方法,代码如下
      private void Sending(IAsyncResult rec_socket)
      {
      Socket socket = (Socket)rec_socket.AsyncState;
      try托福答案
      {
      if (socket.Connected)
      {
      byte[] msgBuff = Encoding.UTF8.GetBytes(textBox1.Text);
      socket.Send(msgBuff);
      //socket.Accept();
      }
      else
      {
      Console.WriteLine("Error!", "Error!");
      }
      }
      catch
      {
      Console.WriteLine("Error!", "Error!");
      }
      }
      9,到此为止,客户端代码已经完成,调试的时候先启动服务端,然后启动客户端

  • 相关阅读:
    门头沟PHP,java编程兴趣小组欢迎大家的加入。
    mysql数据库怎么存入emoji表情,更改utf8mb4后为什么出现全是问号
    Laravel发送邮件配置-问题解决
    php版本低更换php版本-问题以解决
    极光客户互动云java post请求
    【问题解决】增加https后 phpcms 分页错误
    阿里云阿里免费ssl wap网站在手机微信、手机浏览器无法访问
    Kali Linux on Android # 实测:小米2s离线安装Kali Linux
    3-1 LVS-NAT集群
    使用LVM方式安装Ubuntu 16.04
  • 原文地址:https://www.cnblogs.com/haosola/p/3724529.html
Copyright © 2011-2022 走看看