C#中异步Socket通信编程代码实例

本文将在C#中Socket同步通信的基础上,分析和研究Socket异步编程的实现方法,目的是深入了解Socket编程的基本原理,增强对网络游戏开发相关内容的认识。

什么是Socket编程的异步是实现

所谓Socket编程的异步实现是指按照异步过程来实现Socket编程,那么什么是异步过程呢,我们把在完成了一次调用后通过状态、通知和回调来告知调用者的方式成为异步过程,换句话说,在异步过程中当调用一个方法时,调用者并不能够立刻得到结果,只有当这个方法调用完毕后调用者才能获得调用结果。这样做的好处是什么呢?答案是高效。相信大家还记得我们在《C#中Socket通信编程的同步实现》这篇文章中使用多线程来实现简单聊天的案例吧,在这个案例中我们需要开启两个线程来不断监听客户端的连接和客户端的消息,这样的效率肯定是很低的。那么现在好了,我们可以通过异步过程来解决这个问题,下面我们就来看看如何实现Socket的异步通信。

如何实现Socket异步通信

服务端

基本流程

1.创建套接字
2.绑定套接字的IP和端口号——Bind()
3.使套接字处于监听状态等待客户端的连接请求——Listen()
4.当请求到来后,使用BeginAccept()和EndAccept()方法接受请求,返回新的套接字
5.使用BeginSend()/EndSend和BeginReceive()/EndReceive()两组方法与客户端进行收发通信
6.返回,再次等待新的连接请求
7.关闭套接字

代码示例

using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;

namespace AsyncServer
{
  public class AsyncTCPServer
  {
    public void Start()
    {
      //创建套接字
      IPEndPoint ipe = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 6065);
      Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
      //绑定端口和IP
      socket.Bind(ipe);
      //设置监听
      socket.Listen(10);
      //连接客户端
      AsyncAccept(socket);
    }

    /// <summary>
    /// 连接到客户端
    /// </summary>
    /// <param name="socket"></param>
    private void AsyncAccept(Socket socket)
    {
      socket.BeginAccept(asyncResult =>
      {
        //获取客户端套接字
        Socket client = socket.EndAccept(asyncResult);
        Console.WriteLine(string.Format("客户端{0}请求连接...", client.RemoteEndPoint));
        AsyncSend(client, "服务器收到连接请求");
        AsyncSend(client, string.Format("欢迎你{0}",client.RemoteEndPoint));
        AsyncReveive(client);
      }, null);
    }

    /// <summary>
    /// 接收消息
    /// </summary>
    /// <param name="client"></param>
    private void AsyncReveive(Socket socket)
    {
      byte[] data = new byte[1024];
      try
      {
        //开始接收消息
        socket.BeginReceive(data, 0, data.Length, SocketFlags.None,
        asyncResult =>
        {
          int length = socket.EndReceive(asyncResult);
          Console.WriteLine(string.Format("客户端发送消息:{0}", Encoding.UTF8.GetString(data)));
        }, null);
      }
      catch (Exception ex)
      {
        Console.WriteLine(ex.Message);
      }
    }

    /// <summary>
    /// 发送消息
    /// </summary>
    /// <param name="client"></param>
    /// <param name="p"></param>
    private void AsyncSend(Socket client, string p)
    {
      if (client == null || p == string.Empty) return;
      //数据转码
      byte[] data = new byte[1024];
      data = Encoding.UTF8.GetBytes(p);
      try
      {
        //开始发送消息
        client.BeginSend(data, 0, data.Length, SocketFlags.None, asyncResult =>
        {
          //完成消息发送
          int length = client.EndSend(asyncResult);
          //输出消息
          Console.WriteLine(string.Format("服务器发出消息:{0}", p));
        }, null);
      }
      catch (Exception e)
      {
        Console.WriteLine(e.Message);
      }
    }
  }
}

客户端

基本流程

1.创建套接字并保证与服务器的端口一致
2.使用BeginConnect()和EndConnect()这组方法向服务端发送连接请求
3.使用BeginSend()/EndSend和BeginReceive()/EndReceive()两组方法与服务端进行收发通信
4.关闭套接字

代码示例

using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;

namespace AsyncClient
{
  public class AsyncTCPClient
  {
    /// <summary>
    /// 连接到服务器
    /// </summary>
    public void AsynConnect()
    {
      //端口及IP
      IPEndPoint ipe = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 6065);
      //创建套接字
      Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
      //开始连接到服务器
      client.BeginConnect(ipe, asyncResult =>
      {
        client.EndConnect(asyncResult);
        //向服务器发送消息
        AsynSend(client,"你好我是客户端");
        AsynSend(client, "第一条消息");
        AsynSend(client, "第二条消息");
        //接受消息
        AsynRecive(client);
      }, null);
    }

    /// <summary>
    /// 发送消息
    /// </summary>
    /// <param name="socket"></param>
    /// <param name="message"></param>
    public void AsynSend(Socket socket, string message)
    {
      if (socket == null || message == string.Empty) return;
      //编码
      byte[] data = Encoding.UTF8.GetBytes(message);
      try
      {
        socket.BeginSend(data, 0, data.Length, SocketFlags.None, asyncResult =>
        {
          //完成发送消息
          int length = socket.EndSend(asyncResult);
          Console.WriteLine(string.Format("客户端发送消息:{0}", message));
        }, null);
      }
      catch (Exception ex)
      {
        Console.WriteLine("异常信息:{0}", ex.Message);
      }
    }

    /// <summary>
    /// 接收消息
    /// </summary>
    /// <param name="socket"></param>
    public void AsynRecive(Socket socket)
    {
      byte[] data = new byte[1024];
      try
      {
        //开始接收数据
        socket.BeginReceive(data, 0, data.Length, SocketFlags.None,
        asyncResult =>
        {
          int length = socket.EndReceive(asyncResult);
          Console.WriteLine(string.Format("收到服务器消息:{0}", Encoding.UTF8.GetString(data)));
          AsynRecive(socket);
        }, null);
      }
      catch (Exception ex)
      {
        Console.WriteLine("异常信息:", ex.Message);
      }
    }
  }
}

从总体上来讲Socket异步编程的逻辑性更加明确了,因为我们只需要为每一个过程写好回调函数就好了。那么这个示例的效果如何呢?我们来看看它的演示效果:

总结

和Socket同步编程的案例相比,今天的这个案例可能只是对Socket异步编程内容的一个简单应用,因为博主到现在为止都还没有写出一个可以进行交互聊天的程序来。在Socket的异步编程中,服务端不需要为一个客户端单独创建一个线程来维护其连接,可是这样带来的一个问题就是博主不知道该如何实现一个多客户端的异步编程的实例。如果有朋友知道如何实现的话,还希望能够告诉我,毕竟学习就是一个相互促进的过程啊。好了,最后想说的是博主这段时间研究Socket异步编程中关于异步方法调用的写法问题。我们知道Socket异步编程中的方法是成对出现的,每一个方法都有一个回调函数,对于回调函数,这里有两种写法,以BeginConnect方法为例:

复制代码 代码如下:

m_Socket.BeginConnect(this.m_ipEndPoint,
        new AsyncCallback(this.ConnectCallBack),
        this.m_Socket);//其中ConnectCallBack是一个回调函数

或者

复制代码 代码如下:

m_Socket.BeginConnect(this.m_ipEndPoint,asyncResult=>
{
    //在这里添加更多代码
},null)

博主为什么要在这里说这两种写法呢,有两个原因:

* 第二种写法更为简洁,无需去构造容器传递Socket和消息,因为它们都是局部变量。如果我们使用第一种方法,因为主函数和回调函数是两个不同的函数,因此如果想要共享变量就需要通过IAsyncResult接口来访问容器中的值,这样显然增加了我们的工作量。

* 第二种写法更为优雅,这似乎是C#语言中某种高级语法,具体叫什么我忘了,反正在Linq中经常看到这种写法的影子。

综合以上两个观点,博主还是建议大家使用第二种写法,博主打算有空的话将之前写的程序再重新写一遍,看看能不能找出代码中的问题。好了,今天的内容就是这样了,谢谢大家,希望大家喜欢!

时间: 2015-03-26

C#实现的Socket服务器端、客户端代码分享

服务端: using System; using System.Collections.Generic; using System.Net; using System.Net.Sockets; using System.Text; namespace Server { class Program { static void Main(string[] args) { Socket server = new Socket(AddressFamily.InterNetwork, SocketType

C#实现Socket通信的解决方法

本文以实例详述了C#实现Socket通信的解决方法,具体实现步骤如下: 1.首先打开VS新建两个控制台应用程序: ConsoleApplication_socketServer和ConsoleApplication_socketClient.   2.在ConsoleApplication_socketClient中输入以下代码: using System; using System.Collections.Generic; using System.Linq; using System.Tex

C#开发之Socket网络编程TCP/IP层次模型、端口及报文等探讨

1.TCP/IP层次模型 当然这里我们只讨论重要的四层 01,应用层(Application):应用层是个很广泛的概念,有一些基本相同的系统级TCP/IP应用以及应用协议,也有许多的企业应用和互联网应用.http协议在应用层运行. 02,传输层(Tanspot):传输层包括UDP和TCP,UDP几乎不对报文进行检查,而TCP提供传输保证. 03,网络层(Netwok):网络层协议由一系列协议组成,包括ICMP.IGMP.RIP.OSPF.IP(v4,v6)等. 04,链路层(Link):又称为物

C#中Socket通信用法实例详解

本文实例讲述了C#中Socket通信用法.分享给大家供大家参考.具体如下: 一.UDP方式: 服务器端代码: static void Main(string[] args) { int recv; byte[] data = new byte[1024]; IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 9050);//定义一网络端点 Socket newsock = new Socket(AddressFamily.InterNetwork, S

C# Socket网络编程实例

本文实例讲述了C# Socket网络编程技巧.分享给大家供大家参考.具体分析如下: 客户端要连接服务器:首先要知道服务器的IP地址.而服务器里有很多的应用程序,每一个应用程序对应一个端口号 所以客户端想要与服务器中的某个应用程序进行通信就必须要知道那个应用程序的所在服务器的IP地址,及应用程序所对应的端口号 TCP协议:安全稳定,一般不会发生数据丢失,但是效率低.利用TCP发生数据一般经过3次握手(所有效率低,自己百度三次握手) UDP协议:快速,效率高,但是不稳定,容易发生数据丢失(没有经过三

C#使用Socket发送和接收TCP数据实例

本文实例讲述了Asp.net中C#使用Socket发送和接收TCP数据的方法,分享给大家供大家参考.具体实现方法如下: 具体程序代码如下: 复制代码 代码如下: using System; using System.Collections.Generic; using System.Net; using System.Net.Sockets; using System.Text; namespace ConsoleApplication1 {     public static class So

c#(Socket)异步套接字代码示例

异步客户端套接字示例 下面的示例程序创建一个连接到服务器的客户端.该客户端是用异步套接字生成的,因此在等待服务器返回响应时不挂起客户端应用程序的执行.该应用程序将字符串发送到服务器,然后在控制台显示该服务器返回的字符串. C# using System; using System.Net; using System.Net.Sockets; using System.Threading; using System.Text; // State object for receiving data 

C#多线程数组模拟socket

本文实例为大家分享了C#多线程数组模拟socket的具体代码,供大家参考,具体内容如下 代码如下 //实例化线程组 Thread[] clientThreads = new Thread[numThread]; for (int i = 0; i < numThread; i++) { clientThreads[i] = new Thread(new ParameterizedThreadStart(SocketClient)); clientThreads[i].Start(i); } 多线

C#使用Socket实现发送和接收图片的方法

本文实例讲述了C#使用Socket实现发送和接收图片的方法.分享给大家供大家参考.具体如下: using System; using System.Collections.Generic; using System.Text; using System.Net.Sockets; using System.Net; using System.IO; namespace ConsoleApplication1 { Class Program { static void Main (String[]

c#(Socket)同步套接字代码示例

同步客户端套接字示例 下面的示例程序创建一个连接到服务器的客户端.该客户端是用同步套接字生成的,因此挂起客户端应用程序的执行,直到服务器返回响应为止.该应用程序将字符串发送到服务器,然后在控制台显示该服务器返回的字符串. C# using System; using System.Net; using System.Net.Sockets; using System.Text; public class SynchronousSocketClient { public static void S

java多线程之线程同步七种方式代码示例

为何要使用同步?  java允许多线程并发控制,当多个线程同时操作一个可共享的资源变量时(如数据的增删改查),     将会导致数据不准确,相互之间产生冲突,因此加入同步锁以避免在该线程没有完成操作之前,被其他线程的调用,     从而保证了该变量的唯一性和准确性. 1.同步方法  即有synchronized关键字修饰的方法.     由于java的每个对象都有一个内置锁,当用此关键字修饰方法时,     内置锁会保护整个方法.在调用该方法前,需要获得内置锁,否则就处于阻塞状态.     代码

python原始套接字编程示例分享

下面开始构造HTTP数据包, IP层和TCP层使用python的Impacket库,http内容自行填写. 复制代码 代码如下: #!/usr/bin/env python #-------------------------------------------------------------------------------# Name:     raw_http.py# Purpose:       construct a raw http get packet## Author:  

Python网络编程之TCP套接字简单用法示例

本文实例讲述了Python网络编程之TCP套接字简单用法.分享给大家供大家参考,具体如下: 上学期学的计算机网络,因为之前还未学习python,而java则一知半解,C写起来又麻烦,所以一直都没有真正实现过TCP套接字编程. 最近学习了python,而用它来写套接字又十分方便简单,所以当然要试一试咯. 下面根据代码来介绍一下最简单的tcp程序,由客户端输入数据,发送给服务器,服务器加上时间后返回给客户端 #!/usr/bin/python 'test TCP server' from socke

Python网络编程 Python套接字编程

Python 提供了两个级别访问的网络服务. 低级别的网络服务支持基本的 Socket,它提供了标准的 BSD Sockets API,可以访问底层操作系统Socket接口的全部方法. 高级别的网络服务模块 SocketServer, 它提供了服务器中心类,可以简化网络服务器的开发. 什么是 Socket? Socket又称"套接字",应用程序通常通过"套接字"向网络发出请求或者应答网络请求,使主机间或者一台计算机上的进程间可以通讯. socket()函数 Pyth

Node.js开发之套接字(socket)编程入门示例

本文实例讲述了Node.js套接字(socket)编程.分享给大家供大家参考,具体如下: Node.js的net模块提供了socket编程接口,方便我们利用较为底层的套接字接口来实现应用协议.这次我们看一个简单的回显服务器示例,包括服务端和客户端的代码. 代码 分服务器和客户端两部分来说吧. server代码分析 server.js: var net = require("net"); // server is an instance of net.Server // sock is

Python 网络编程之TCP客户端/服务端功能示例【基于socket套接字】

本文实例讲述了Python 网络编程之TCP客户端/服务端功能.分享给大家供大家参考,具体如下: demo.py(TCP客户端): import socket def main(): # 1. 创建tcp的套接字 tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 2. 链接服务器 # tcp_socket.connect(("192.168.33.11", 7890)) server_ip = input(

Python 网络编程之UDP发送接收数据功能示例【基于socket套接字】

本文实例讲述了Python 网络编程之UDP发送接收数据功能.分享给大家供大家参考,具体如下: demo.py(UDP发送数据): import socket # 导入socket模块 def main(): # 创建一个udp套接字 udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # 绑定本机ip和端口号 (发送数据时,如果不绑定,系统会随机分配端口号.接收数据时,一般需要手动绑定ip和端口) udp_socket.b

python socket网络编程步骤详解(socket套接字使用)

一.套接字套接字是为特定网络协议(例如TCP/IP,ICMP/IP,UDP/IP等)套件对上的网络应用程序提供者提供当前可移植标准的对象.它们允许程序接受并进行连接,如发送和接受数据.为了建立通信通道,网络通信的每个端点拥有一个套接字对象极为重要.套接字为BSD UNIX系统核心的一部分,而且他们也被许多其他类似UNIX的操作系统包括Linux所采纳.许多非BSD UNIX系统(如ms-dos,windows,os/2,mac os及大部分主机环境)都以库形式提供对套接字的支持.三种最流行的套接