C#中UDP通信和TCP通信的差异

C#的UDP和TCP通信的详解

可以看到这个处理的基本步骤如下：    

  执行Receive函数，接收远程socket发送的信息；    

  把信息从字节转换到string；    

  处理该信息，然后进入下一个循环，继续等待socket发送新的信息。    

值得注意的有几个：    

  1：Receive函数。这个函数和Listener的Accept函数类似。在这个地方等待执行，如果没有新的消息，这个函数就不会执行下一句，一直等待。    

  2：接收的是字节流，需要转化成字符串    

  3：判断远程关闭联接的方式    

  4：如果对方的消息非常大，还得循环接收这个data。    

4：如何管理这些联接（thread）    

通过上边的程序，基本上可以建立一个侦听，并且处理联接会话。但是如何管理这些thread呢？不然大量产生thread可是一个灾难。    

管理的方法比较简单，在Listener里面我定义了一个静态的哈希表(static public Hashtable Connections=new Hashtable();)，存储Connection实例和它对应的Thread实例。而connection中也加入了一个最后联接时间的定义（private DateTime _lastConnectTime;）。在新链接建立的时候（Listener的Accept()之后）就把Connection实例和Thread实例存到哈希表中；在Connection的Receive的时候修改最后联接时间。这样我们就可以知道该Connection在哪里，并且会话是否活跃。    

然后在Winform程序里头可以管理这些会话了，设置设置超时。    

  

在网络环境下，我们最感兴趣的两个命名空间是System.Net和 System.Net.Sockets。System.Net命名空间通常与较高程的操作有关，例如download或upload，试用HTTP和其他协议进行Web请求等等，而System.Net.Sockets命名空间所包含的类通常与较低程的操作有关。如果要直接使用Sockets或者 TCP/IP之类的协议，这个命名空间的类是非常有用的。    

　　在.Net中，System.Net.Sockets 命名空间为需要严密控制网络访问的开发人员提供了 Windows Sockets (Winsock) 接口的托管实现。System.Net 命名空间中的所有其他网络访问类都建立在该套接字Socket实现之上，如TCPClient、TCPListener 和 UDPClient 类封装有关创建到 Internet 的 TCP 和 UDP 连接的详细信息；NetworkStream类则提供用于网络访问的基础数据流等，常见的许多Internet服务都可以见到Socket的踪影，如 Telnet、Http、Email、Echo等，这些服务尽管通讯协议Protocol的定义不同，但是其基础的传输都是采用的Socket。    

　　其实，Socket可以象流Stream一样被视为一个数据通道，这个通道架设在应用程序端（客户端）和远程服务器端之间，而后，数据的读取（接收）和写入（发送）均针对这个通道来进行。    

　　可见，在应用程序端或者服务器端创建了Socket对象之后，就可以使用Send/SentTo方法将数据发送到连接的Socket,或者使用Receive/ReceiveFrom方法接收来自连接Socket的数据。    

　　针对Socket编程，.NET 框架的 Socket 类是 Winsock32 API 提供的套接字服务的托管代码版本。其中为实现网络编程提供了大量的方法，大多数情况下，Socket 类方法只是将数据封送到它们的本机 Win32 副本中并处理任何必要的安全检查。如果你熟悉Winsock API函数，那么用Socket类编写网络程序会非常容易，当然，如果你不曾接触过，也不会太困难，跟随下面的解说，你会发觉使用Socket类开发 windows 网络应用程序原来有规可寻，它们在大多数情况下遵循大致相同的步骤。    

　　在使用之前，你需要首先创建Socket对象的实例，这可以通过Socket类的构造方法来实现：    

public Socket(AddressFamily addressFamily,SocketType socketType,ProtocolType protocolType);    

　　其中，addressFamily 参数指定 Socket 使用的寻址方案，socketType 参数指定 Socket 的类型，protocolType 参数指定 Socket 使用的协议。    

　　下面的示例语句创建一个 Socket，它可用于在基于 TCP/IP 的网络（如 Internet）上通讯。    

Socket temp = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);    

　　若要使用 UDP 而不是 TCP，需要更改协议类型，如下面的示例所示：    

Socket temp = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);    

　　一旦创建 Socket，在客户端，你将可以通过Connect方法连接到指定的服务器，并通过Send/SendTo方法向远程服务器发送数据，而后可以通过 Receive/ReceiveFrom从服务端接收数据；而在服务器端，你需要使用Bind方法绑定所指定的接口使Socket与一个本地终结点相联，并通过Listen方法侦听该接口上的请求，当侦听到用户端的连接时，调用Accept完成连接的操作，创建新的Socket以处理传入的连接请求。使用完 Socket 后，记住使用 Shutdown 方法禁用 Socket，并使用 Close 方法关闭 Socket。    

　　可以看出，以上许多方法包含EndPoint类型的参数，在Internet中，TCP/IP 使用一个网络地址和一个服务端口号来唯一标识设备。网络地址标识网络上的特定设备；端口号标识要连接到的该设备上的特定服务。网络地址和服务端口的组合称为终结点，在 .NET 框架中正是由 EndPoint 类表示这个终结点，它提供表示网络资源或服务的抽象，用以标志网络地址等信息。.Net同时也为每个受支持的地址族定义了 EndPoint 的子代；对于 IP 地址族，该类为 IPEndPoint。IPEndPoint 类包含应用程序连接到主机上的服务所需的主机和端口信息，通过组合服务的主机IP地址和端口号，IPEndPoint 类形成到服务的连接点。    

　　用到IPEndPoint类的时候就不可避免地涉及到计算机IP地址，System.Net命名空间中有两种类可以得到IP地址实例：    

　　IPAddress类：IPAddress 类包含计算机在 IP 网络上的地址。其Parse方法可将 IP 地址字符串转换为 IPAddress 实例。下面的语句创建一个 IPAddress 实例：    

IPAddress myIP = IPAddress.Parse("192.168.0.1");    

　　Dns 类：向使用 TCP/IP Internet 服务的应用程序提供域名服务。其Resolve 方法查询 DNS 服务器以将用户友好的域名（如"host.mydomain.com"）映射到数字形式的 Internet 地址（如 192.168.0.1）。Resolve方法 返回一个 IPHostEnty 实例，该实例包含所请求名称的地址和别名的列表。大多数情况下，可以使用 AddressList 数组中返回的第一个地址。下面的代码获取一个 IPAddress 实例，该实例包含服务器 host.mydomain.com 的 IP 地址。    

IPHostEntry ipHostInfo = Dns.Resolve("host.mydomain.com ");    

IPAddress ipAddress = ipHostInfo.AddressList[0];    

　　你也可以使用GetHostName方法得到IPHostEntry实例：    

IPHosntEntry hostInfo=Dns.GetHostByName("host.mydomain.com ")    

　　在使用以上方法时，你将可能需要处理以下几种异常：    

　　SocketException异常：访问Socket时操作系统发生错误引发    

　　ArgumentNullException异常：参数为空引用引发    

　　ObjectDisposedException异常：Socket已经关闭引发    

　　在掌握上面得知识后，下面的代码将该服务器主机（ host.mydomain.com的 IP 地址与端口号组合，以便为连接创建远程终结点：    

IPEndPoint ipe = new IPEndPoint(ipAddress,11000);    

　　确定了远程设备的地址并选择了用于连接的端口后，应用程序可以尝试建立与远程设备的连接。下面的示例使用现有的 IPEndPoint 实例与远程设备连接，并捕获可能引发的异常：    

try    

{    

temp.Connect(ipe);//尝试连接    

}    

//处理参数为空引用异常    

catch(ArgumentNullException ae)    

{    

Console.WriteLine("ArgumentNullException : {0}", ae.ToString());    

}    

//处理操作系统异常    

catch(SocketException se)    

{    

Console.WriteLine("SocketException : {0}", se.ToString());    

}    

    

 
namespace UDPServer    
  
{    
  
    class Program    
  
    {    
  
        static void Main(string[] args)    
  
        {    
  
            int recv;    
  
            byte[] data = new byte[1024];    
  
            //构建TCP 服务器    
  
            //得到本机IP，设置TCP端口号             
  
            IPEndPoint ipep = new IPEndPoint(IPAddress.Any , 8001);    
  
            Socket newsock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram , ProtocolType.Udp);    
  
            //绑定网络地址    
  
            newsock.Bind(ipep);    
  
            Console.WriteLine("This is a Server, host name is {0}",Dns.GetHostName());    
  
            //等待客户机连接    
  
            Console.WriteLine("Waiting for a client...");    
  
            //得到客户机IP    
  
            IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);    
  
            EndPoint Remote = (EndPoint)(sender);    
  
            recv = newsock.ReceiveFrom(data, ref Remote);    
  
            Console .WriteLine ("Message received from {0}: ", Remote.ToString ());    
  
            Console .WriteLine (Encoding .ASCII .GetString (data ,0,recv ));    
  
            //客户机连接成功后，发送欢迎信息    
  
            string welcome = "Welcome ! ";    
  
            //字符串与字节数组相互转换    
  
            data  = Encoding .ASCII .GetBytes (welcome );    
  
            //发送信息    
  
            newsock .SendTo (data ,data.Length ,SocketFlags .None ,Remote );    
  
            while (true )    
  
            {    
  
                data =new byte [1024];    
  
                //发送接受信息    
  
                recv =newsock.ReceiveFrom(data ,ref Remote);    
  
                Console .WriteLine (Encoding .ASCII .GetString (data ,0,recv));    
  
                newsock .SendTo (data ,recv ,SocketFlags .None ,Remote );    
  
            }    
  
        }    
  
        }    
  
    }    
  
C# code   
using System;   
using System.Collections.Generic;   
using System.Linq;   
using System.Text;   
using System.Net;   
using System.Net.Sockets;   
namespace UDPClient   
{   
    class Program   
    {   
        static void Main(string[] args)   
        {   
            byte[] data = new byte[1024];   
            string input ,stringData;   
            //构建TCP 服务器   
            Console.WriteLine("This is a Client, host name is {0}", Dns.GetHostName());   
            //设置服务IP，设置TCP端口号   
            IPEndPoint ipep = new IPEndPoint(IPAddress .Parse ("127.0.0.1") , 8001);   
            //定义网络类型，数据连接类型和网络协议UDP   
            Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);   
            string welcome = "Hello! ";   
            data = Encoding.ASCII.GetBytes(welcome);   
            server.SendTo(data, data.Length, SocketFlags.None, ipep);   
            IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);   
            EndPoint Remote = (EndPoint)sender;   
            data = new byte[1024];   
            int recv = server.ReceiveFrom(data, ref Remote);   
            Console.WriteLine("Message received from {0}: ", Remote.ToString());   
            Console.WriteLine(Encoding .ASCII .GetString (data,0,recv));   
            while (true)   
            {   
                input = Console .ReadLine ();   
                if (input =="exit")   
                    break ;   
                server .SendTo (Encoding .ASCII .GetBytes (input ),Remote );   
                data = new byte [1024];   
                recv = server.ReceiveFrom(data, ref Remote);   
                stringData = Encoding.ASCII.GetString(data, 0, recv);   
                Console.WriteLine(stringData);   
            }   
            Console .WriteLine ("Stopping Client.");   
            server .Close ();               
        }   
        }   
    }    
  
C# code   
TCPClient   
/*TCPClient 类提供了一种使用 TCP 协议连接到某个端点的简化方法。它还通  *过 NetworkStream 对象展现在连接过程中读取或写入的数据。请参见下面从 *QuickStart 文档中摘录的日期/时间客户机示例。
*/   
//使用 C# 编写   
using System;   
using System.Net;   
using System.Net.Sockets;   
using System.IO;   
using System.Text;   
class Client   
{   
public static void Main(String[] args)   
{   
TCPClient tcpc = new TCPClient();   
Byte[] read = new Byte[32];   
if (args.Length != 1)   
{   
Console.WriteLine(“请在命令行中指定服务器名称”);   
return;   
}   
String server = args[0];   
// 验证服务器是否存在   
if (DNS.GetHostByName(server) == null)   
{   
Console.WriteLine(“找不到服务器：” + 服务器);   
return;   
}   
// 尝试连接到服务器   
if (tcpc.Connect(server, 13) == -1)   
{   
Console.WriteLine(“无法连接到服务器：” + 服务器);   
return;   
}   
// 获取流   
Stream s = tcpc.GetStream();   
// 读取流并将它转换为 ASCII 码形式   
int bytes = s.Read(read, 0, read.Length);   
String Time = Encoding.ASCII.GetString(read);   
// 显示数据   
Console.WriteLine(“已接收到的” + 字节 + “字节”);   
Console.WriteLine(“当前日期和时间是：” + 时间);   
tcpc.Close();   
}   
}   
TCPListener   
/*TCPListener 类便于在来自某个客户机的 TCP 连接的特定套接字上进行侦听的*工作。请参见下面包括在 QuickStart 文档中的日期/时间服务器示例。 
*/  
//使用 C# 编写   
using System;   
using System.Net;   
using System.Net.Sockets;   
using System.Text;   
class Server   
{   
public static void Main()   
{   
DateTime now;   
String strDateLine;   
Encoding ASCII = Encoding.ASCII;   
// 在端口 13 进行侦听   
TCPListener tcpl = new TCPListener(13);   
tcpl.Start();   
Console.WriteLine(“正在等待客户进行连接”);   
Console.WriteLine(“请按 Ctrl+c 退出...”);   
while (true)   
{   
// 接收会阻塞，直到有人连接上   
Socket s = tcpl.Accept();   
// 获取当前的日期和时间并将它连接成一个字符串   
now = DateTime.Now;   
strDateLine = now.ToShortDateString() + " " +   
now.ToLongTimeString();   
// 将该字符串转换成一个字节数组并发送它   
Byte[] byteDateLine =   
ASCII.GetBytes(strDateLine.ToCharArray());   
s.Send(byteDateLine, byteDateLine.Length, 0);   
Console.WriteLine(“发送” + strDateLine);   
}   
}   
}   
 
#region "Download: File transfer FROM ftp server"    
        /// <summary>    
        /// Copy a file from FTP server to local    
        /// </summary>    
        /// <param name="sourceFilename">Target filename, if required </param>    
        /// <param name="localFilename">Full path of the local file </param>    
        /// <returns> </returns>    
        /// <remarks>Target can be blank (use same filename), or just a filename    
        /// (assumes current directory) or a full path and filename </remarks>    
        public bool Download(string sourceFilename, string localFilename, bool PermitOverwrite)    
        {    
            //2. determine target file    
            FileInfo fi = new FileInfo(localFilename);    
            return this.Download(sourceFilename, fi, PermitOverwrite);    
        }    
        //Version taking an FtpFileInfo    
        public bool Download(FtpFileInfo file, string localFilename, bool permitOverwrite)    
        {    
            return this.Download(file.FullName, localFilename, permitOverwrite);    
        }    
        //Another version taking FtpFileInfo and FileInfo    
        public bool Download(FtpFileInfo file, FileInfo localFI, bool permitOverwrite)    
        {    
            return this.Download(file.FullName, localFI, permitOverwrite);    
        }    
        //Version taking string/FileInfo    
        public bool Download(string sourceFilename, FileInfo targetFI, bool permitOverwrite)    
        {    
            //1. check target    
            if (targetFI.Exists && !(permitOverwrite))    
            {    
                throw (new ApplicationException("Target file already exists"));    
            }    
            //2. check source    
            string target;    
            if (sourceFilename.Trim() == "")    
            {    
                throw (new ApplicationException("File not specified"));    
            }    
            else if (sourceFilename.Contains("/"))    
            {    
                //treat as a full path    
                target = AdjustDir(sourceFilename);    
            }    
            else    
            {    
                //treat as filename only, use current directory    
                target = CurrentDirectory + sourceFilename;    
            }    
            string URI = Hostname + target;    
            //3. perform copy    
            System.Net.FtpWebRequest ftp = GetRequest(URI);    
            //Set request to download a file in binary mode    
            ftp.Method = System.Net.WebRequestMethods.Ftp.DownloadFile;    
            ftp.UseBinary = true;    
            //open request and get response stream    
            using (FtpWebResponse response = (FtpWebResponse)ftp.GetResponse())    
            {    
                using (Stream responseStream = response.GetResponseStream())    
                {    
                    //loop to read & write to file    
                    using (FileStream fs = targetFI.OpenWrite())    
                    {    
                        try    
                        {    
                            byte[] buffer = new byte[2048];    
                            int read = 0;    
                            do    
                            {    
                                read = responseStream.Read(buffer, 0, buffer.Length);    
                                fs.Write(buffer, 0, read);    
                            } while (!(read == 0));    
                            responseStream.Close();    
                            fs.Flush();    
                            fs.Close();    
                        }    
                        catch (Exception)    
                        {    
                            //catch error and delete file only partially downloaded    
                            fs.Close();    
                            //delete target file as it's incomplete    
                            targetFI.Delete();    
                            throw;    
                        }    
                    }    
                    responseStream.Close();    
                }    
                response.Close();    
            }    
            return true;    
        }   
        #endregion    
  
简单的UDP收发.    
发送    
C# code   
                    try  
                    {   
                        Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);  //向此网段发广播包   
                          int UDPListenerPort = 8082;   
                        IPAddress broadcast = IPAddress.Parse("192.168.0.255"); //此处根据IP及子网掩码改为相应的广播IP   
                        string ts = "This is UPD string for sending";   
                        byte[] sendbuf = Encoding.ASCII.GetBytes(ts);   
                        IPEndPoint ep = new IPEndPoint(broadcast, UDPListenerPort);   
                        s.SendTo(sendbuf, ep);   
                    }   
                    catch (Exception e)   
                    {}   
接收    
C# code   
           UdpClient listener;   
            int UDPListenerPort = 8082;   
            IPEndPoint groupEP = new IPEndPoint(IPAddress.Any, UDPListenerPort);   
            try  
            {   
                while (true)   
                {   
                    byte[] bytes = listener.Receive(ref groupEP);   
                    string RecIP = groupEP.ToString().Substring(0, groupEP.ToString().IndexOf(":"));  //收到发送UPD端的IP   
                    string RecStr = Encoding.ASCII.GetString(bytes, 0, bytes.Length);   //收到的UPD字符串   
                }   
            }   
            catch  
            {}    
  
C# code    
TCPClient    
TCPClient 类提供了一种使用 TCP 协议连接到某个端点的简化方法。它还通过 NetworkStream 对象展现在连接过程中读取或写入的数据。请参见下面从 QuickStart 文档中摘录的日期/时间客户机示例。    
使用 C# 编写    
using System;    
using System.Net;    
using System.Net.Sockets;    
using System.IO;    
using System.Text;    
class Client    
{    
public static void Main(String[] args)    
{    
TCPClient tcpc = new T…    
  
来一个Remoting的:    
C# code   
using System;    
namespace Remotable    
{    
    public class RemotableType : MarshalByRefObject    
    {    
        private string _internalString = "This is the RemotableType.";    
        public string StringMethod()    
        {    
            return _internalString;    
        }    
    }    
}    
using System;    
using System.Runtime.Remoting;    
namespace RemotingFirst    
{    
    public class Listener    
    {    
        public static void Main()    
        {    
            RemotingConfiguration.Configure("Listener.exe.config");    
            Console.WriteLine("Listening for requests. Press Enter to exit");    
            Console.ReadLine();    
        }    
    }    
}    
using System;    
using System.Runtime.Remoting;    
namespace Client    
{    
    public class Client    
    {    
        public static void Main()    
        {    
            RemotingConfiguration.Configure("Client.exe.config");    
            Remotable.RemotableType remoteObject = new Remotable.RemotableType();    
            Console.WriteLine(remoteObject.StringMethod());    
        }    
    }    
}    
Listener.exe.config    
<?xml version="1.0" encoding="utf-8" ?>    
<configuration>    
    <system.runtime.remoting>    
      <application>    
         <service>    
            <wellknown     
               mode="Singleton"     
               type="Remotable.RemotableType, RemotableType"     
               objectUri="RemotableType.rem"    
            />    
         </service>    
         <channels>    
            <channel ref="http" port="8989"/>    
         </channels>    
      </application>    
    </system.runtime.remoting>    
</configuration>    
  
实只要用到Socket联接，基本上就得使用Thread，是交叉使用的。    
C#封装的Socket用法基本上不算很复杂，只是不知道托管之后的Socket有没有其他性能或者安全上的问题。    
在C#里面能找到的最底层的操作也就是socket了，概念不做解释。    
程序模型如下：    
WinForm程序 ： 启动端口侦听；监视Socket联接情况；定期关闭不活动的联接；    
Listener：处理Socket的Accept函数，侦听新链接，建立新Thread来处理这些联接（Connection）。    
Connection：处理具体的每一个联接的会话。    
1：WinForm如何启动一个新的线程来启动Listener：    
      //start the server    
        private void btn_startServer_Click(object sender, EventArgs e)    
        {    
            //this.btn_startServer.Enabled = false;    
            Thread _createServer = new Thread(new ThreadStart(WaitForConnect));    
            _createServer.Start();    
        }    
        //wait all connections    
        private void WaitForConnect()    
        {    
            SocketListener listener = new SocketListener(Convert.ToInt32(this.txt_port.Text));    
            listener.StartListening();    
        }    
/*因为侦听联接是一个循环等待的函数，所以不可能在WinForm的线程里面直接**执行，不然Winform也就是无法继续任何操作了，所以才指定一个新的线程来**执行这个函数，启动侦听循环。    
*这一个新的线程是比较简单的，基本上没有启动的参数，直接指定处理函数就可**以了。    
*2：Listener如何启动循环侦听，并且启动新的带有参数的线程来处理Socket联*接会话。    
*先看如何建立侦听：（StartListening函数） 
*/   
IPEndPoint localEndPoint = new IPEndPoint(_ipAddress, _port);    
        // Create a TCP/IP socket.    
        Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);    
            // Bind the socket to the local endpoint and  listen for incoming connections.    
            try    
            {    
                listener.Bind(localEndPoint);    
                listener.Listen(20);//20 trucks    
                // Start listening for connections.    
                while (true)    
                {    
                  // here will be suspended while waiting for a new connection.    
                    Socket connection = listener.Accept();    
                    Logger.Log("Connect", connection.RemoteEndPoint.ToString());//log it, new connection    
                ……    
          }    
        }……    
//基本步骤比较简单：    
建立本机的IPEndPoint对象，表示以本机为服务器，在指定端口侦听；    
然后绑定到一个侦听Socket上；    
进入while循环，等待新的联接；    
如果有新的联接，那么建立新的socket来对应这个联接的会话。    
  值得注意的就是这一句联接代码：listener.Accept()。执行这一句的时候，程序就在这个地方等待，直到有新的联检请求的时候程序才会执行下一句。这是同步执行，当然也可以异步执行。    
  新的联接Socket建立了（Accept之后），对于这些新的socket该怎么办呢？他们依然是一个循环等待，所以依然需要建立新的Thread给这些Socket去处理会话（接收/发送消息），而这个Thread就要接收参数了。    
  Thread本身是不能接收参数的，为了让它可以接收参数，可以采用定义新类，添加参数作为属性的方法来解决。    
  因为每一个Socket是一个Connection周期，所以我定义了这么一个类public class Connection。这个类至少有这样一个构造函数public Connection(Socket socket); 之所以这么做，就是为了把Socket参数传给这个Connection对象，然后好让Listener启动这个Thread的时候，Thread可以知道他正在处理哪一个Socket。    
    具体处理的方法：（在Listener的StartListening函数，ocket connection = listener.Accept();之后）    
    Connection gpsCn = new Connection(connection);    
                    //each socket will be wait for data. keep the connection.    
                    Thread thread = new Thread(new ThreadStart(gpsCn.WaitForSendData));    
                    thread.Name = connection.RemoteEndPoint.ToString();    
                    thread.Start();    
如此一来，这个新的socket在Accept之后就在新的Thread中运行了。    
  3：Connection的会话处理    
  建立了新的Connection（也就是socket），远程就可以和这个socket进行会话了，无非就是send和receive。    
  现在先看看怎么写的这个线程运行的Connection. WaitForSendData函数    
    while (true)    
            {    
                bytes = new byte[1024];    
                string data = "";    
                //systm will be waiting the msg of receive envet. like Accept();    
                //here will be suspended while waiting for socket income msg.    
                int bytesRec = this._connection.Receive(bytes);    
                _lastConnectTime = DateTime.Now;    
                if (bytesRec == 0)//close envent    
                {    
                    Logger.Log("Close Connection", _connection.RemoteEndPoint.ToString());    
                    break;    
                }    
                data += Encoding.ASCII.GetString(bytes, 0, bytesRec);    
                //…….handle your data.    
            }    

　　需要知道的是：Socket 类支持两种基本模式：同步和异步。其区别在于：在同步模式中，对执行网络操作的函数（如 Send 和 Receive）的调用一直等到操作完成后才将控制返回给调用程序。在异步模式中，这些调用立即返回。    
综合运用以上阐述的使用Visual C#进行Socket网络程序开发的知识，下面的程序是一个简单的Socket通讯实例，client向server发送一段测试字符串，server接收并显示出来，给予client成功相应。    
//client端    
using System;    
using System.Text;    
using System.IO;    
using System.Net;    
using System.Net.Sockets;    
namespace socketsample    
{    
　class Class1    
　{    
　　static void Main()    
　　{    
　　　try    
　　　{    
　　　　int port = 2000;    
　　　　string host = "127.0.0.1";    
　　　　IPAddress ip = IPAddress.Parse(host);    
　　　　IPEndPoint ipe = new IPEndPoint(ip, port);    
　　　　Socket c = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);    
　　　　c.Connect(ipe);    
　　　　string sendStr = "hello!This is a socket test";    
　　　　byte[] bs = Encoding.ASCII.GetBytes(sendStr);    
　　　　c.Send(bs, bs.Length, 0);    
　　　　string recvStr = "";    
　　　　byte[] recvBytes = new byte[1024];    
　　　　int bytes;    
　　　　bytes = c.Receive(recvBytes, recvBytes.Length, 0);    
　　　　recvStr += Encoding.ASCII.GetString(recvBytes, 0, bytes);    
　　　　Console.WriteLine(recvStr);    
　　　　c.Close();    
　　　}    
　　　catch (ArgumentNullException e)    
　　　{    
　　　　Console.WriteLine("ArgumentNullException: {0}", e);    
　　　}    
　　　catch (SocketException e)    
　　　{    
　　　　Console.WriteLine("SocketException: {0}", e);    
　　　}    
　　　Console.ReadLine();    
　　}    
　}    
}    
//server端    
using System;    
using System.Text;    
using System.IO;    
using System.Net;    
using System.Net.Sockets;    
namespace Project1    
{    
　class Class2    
　{    
　　static void Main()    
　　{    
　　　try    
　　　{    
　　　　int port = 2000;    
　　　　string host = "127.0.0.1";    
　　　　IPAddress ip = IPAddress.Parse(host);    
　　　　IPEndPoint ipe = new IPEndPoint(ip, port);    
　　　　Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);    
　　　　s.Bind(ipe);    
　　　　s.Listen(0);    
　　　　Socket temp = s.Accept();    
　　　　string recvStr = "";    
　　　　byte[] recvBytes = new byte[1024];    
　　　　int bytes;    
　　　　bytes = temp.Receive(recvBytes, recvBytes.Length, 0);    
　　　　recvStr += Encoding.ASCII.GetString(recvBytes, 0, bytes);    
　　　　Console.WriteLine(recvStr);    
　　　　string sendStr = "Ok!Sucess!";    
　　　　byte[] bs = Encoding.ASCII.GetBytes(sendStr);    
　　　　temp.Send(bs, bs.Length, 0);    
　　　　temp.Shutdown(SocketShutdown.Both);    
　　　　temp.Close();    
　　　　s.Shutdown(SocketShutdown.Both);    
　　　　s.Close();    
　　　}    
　　　catch (ArgumentNullException e)    
　　　{    
　　　　Console.WriteLine("ArgumentNullException: {0}", e);    
　　　}    
　　　catch (SocketException e)    
　　　{    
　　　　Console.WriteLine("SocketException: {0}", e);    
　　　}    
　　　Console.ReadLine();    
　　}    
　}    
}    
　　   
  
C#UDP的多路广播组的发送和接收    
下列范例使用 UdpClient，在通讯端口11000传送UDP 资料包至多点传送位址群组 224.268.100.2。它传送命令列上指定的信息字串。     
C# code    
using System;     
using System.Net;     
using System.Net.Sockets;     
using System.Text;     
public class UDPMulticastSender {     
private static IPAddress GroupAddress =     
IPAddress.Parse("224.168.100.2");     
private static int GroupPort = 11000;     
private static void Send( String message) {     
UdpClient sender = new UdpClient();     
IPEndPoint groupEP = new IPEndPoint(GroupAddress,GroupPort);     
try {     
Console.WriteLine("Sending datagram : {0}", message);     
byte[] bytes = Encoding.ASCII.GetBytes(message);     
sender.Send(bytes, bytes.Length, groupEP);     
sender.Close();     
} catch (Exception e) {     
Console.WriteLine(e.ToString());     
}     
}     
public static int Main(String[] args) {     
Send(args[0]);     
return 0;     
}     
}      
  
下列范例使用 UdpClient，在通讯端口  11000  监听广播到多点传送位址群组 224.168.100.2 的 UDP  资料包。它接收信息字串，并將信息写入主控台 (Console)。      
  
C# code    
  
using System;      
  
using System.Net;      
  
using System.Net.Sockets;      
  
using System.Text;      
  
public class UDPMulticastListener {      
  
private static readonly IPAddress GroupAddress =      
  
IPAddress.Parse("224.168.100.2");      
  
private const int GroupPort = 11000;      
  
private static void StartListener() {      
  
bool done = false;      
  
UdpClient listener = new UdpClient();      
  
IPEndPoint groupEP = new IPEndPoint(GroupAddress,GroupPort);      
  
try {      
  
listener.JoinMulticastGroup(GroupAddress);      
  
listener.Connect(groupEP);      
  
while (!done) {      
  
Console.WriteLine("Waiting for broadcast");      
  
byte[] bytes = listener.Receive( ref groupEP);      
  
Console.WriteLine("Received broadcast from {0} :\n {1}\n",      
  
groupEP.ToString(),      
  
Encoding.ASCII.GetString(bytes,0,bytes.Length));      
  
}      
  
listener.Close();      
  
} catch (Exception e) {      
  
Console.WriteLine(e.ToString());      
  
}      
  
}      
  
public static int Main(String[] args) {      
  
StartListener();      
  
return 0;      
  
}      
  
}    
  
using System;      
  
using System.Net;      
  
using System.Net.Sockets;      
  
using System.Text;      
  
public class UDPMulticastSender {      
  
private static IPAddress GroupAddress =      
  
IPAddress.Parse("224.168.100.2");      
  
private static int GroupPort = 11000;      
  
private static void Send( String message) {      
  
UdpClient sender = new UdpClient();      
  
IPEndPoint groupEP = new IPEndPoint(GroupAddress,GroupPort);      
  
try {      
  
Console.WriteLine("Sending datagram : {0}", message);      
  
byte[] bytes = Encoding.ASCII.GetBytes(message);      
  
sender.Send(bytes, bytes.Length, groupEP);      
  
sender.Close();      
  
} catch (Exception e) {      
  
Console.WriteLine(e.ToString());      
  
}      
  
}      
  
public static int Main(String[] args) {      
  
Send(args[0]);      
  
return 0;      
  
}      
  
}    
  
C# code    
  
try    
  
                {    
  
                    UdpClient udp=new UdpClient(new IPEndPoint(ipAddress,startPort+i));    
  
                    udp.Close();                        
  
                    unUsedPort=startPort+i;    
  
                    break;    
  
                }    
  
                catch    
  
                {    
  
                }    
  
using System;    
  
using System.Collections.Generic;    
  
using System.ComponentModel;    
  
using System.Data;    
  
using System.Drawing;    
  
using System.Text;    
  
using System.Windows.Forms;    
  
using System.Collections;    
  
using System.Collections.Specialized;    
  
using System.Threading;    
  
using System.Net.Sockets;    
  
using System.Net;    
  
using System.Runtime.Serialization;    
  
using System.Runtime.Serialization.Formatters.Binary;    
  
using System.IO;    
  
namespace 聊天工具服务器    
  
{    
  
    public partial class FormMain : Form    
  
    {    
  
        public FormMain()    
  
        {    
  
            InitializeComponent();    
  
        }   
 
        #region 字段定义    
  
        /// <summary>    
  
        /// 服务器程序使用的端口，默认为8888    
  
        /// </summary>    
  
        private int _port = 8888;    
  
        /// <summary>    
  
        /// 接收数据缓冲区大小2K    
  
        /// </summary>    
  
        private const int _maxPacket =2 * 1024;    
  
        /// <summary>    
  
        /// 服务器端的监听器    
  
        /// </summary>    
  
        private TcpListener _tcpl = null;    
  
        Thread _receiveThread;    
  
        /// <summary>    
  
        /// 保存所有客户端会话的哈希表    
  
        /// </summary>    
  
        private Hashtable _transmit_tb = new Hashtable();    
  
        /// <summary>    
  
        /// 当前文件路径    
  
        /// </summary>    
  
        string MyPath = null;    
  
        /// <summary>    
  
        /// 用户基本信息表，包括UserName，UserPwd，UserNich，UserImg，ZX，UserIp    
  
        /// </summary>    
  
        DataTable TabUser = new DataTable();    
  
        /// <summary>    
  
        /// 用户消息表，保存用户不在线时的消息    
  
        /// </summary>    
  
        DataTable TabUserMessage = new DataTable();   
 
        #endregion    
  
        /// <summary>    
  
        /// 序列化在线列表，向客户端返回序列化后的字节数组    
  
        /// </summary>    
  
        /// <returns>序列化后的字节数组 </returns>    
  
        private byte[] SerializeOnlineList()    
  
        {    
  
            StringCollection onlineList = new StringCollection();    
  
            foreach (object o in _transmit_tb.Keys)    
  
            {    
  
                onlineList.Add(o as string);    
  
            }    
  
            IFormatter format = new BinaryFormatter();    
  
            MemoryStream stream = new MemoryStream();    
  
            format.Serialize(stream, onlineList);    
  
            byte[] ret = stream.ToArray();    
  
            stream.Close();    
  
            return ret;    
  
        }    
  
        /// <summary>    
  
        /// 序列化好友列表，向客户端返回序列化后的datatable    
  
        /// </summary>    
  
        /// <returns>序列化后的字节数组 </returns>    
  
        private bool SerializeFriendList(object obj, Socket clientSkt)    
  
        {    
  
            DataTable TabmyFriend = new DataTable();    
  
            TabmyFriend.TableName = obj as string;    
  
            try {    
  
                TabmyFriend.ReadXml(MyPath + "\\UserFriend\\" + TabmyFriend.TableName + ".xml");    
  
                TabmyFriend.Columns.Add("UserImg", typeof(String));    
  
                TabmyFriend.Columns.Add("UserNich", typeof(String));    
  
                TabmyFriend.Columns.Add("ZX", typeof(Boolean));    
  
                TabmyFriend.Columns.Add("UserIp", typeof(String));    
  
                foreach (DataRow myrow in TabmyFriend.Rows)    
  
                {    
  
                    DataRow[] DataRows = TabUser.Select(" UserName = '" + myrow["UserName"].ToString() + "'");    
  
                    if (DataRows.Length > 0)    
  
                    {    
  
                        myrow["UserImg"] = DataRows[0]["UserImg"].ToString();    
  
                        myrow["UserNich"] = DataRows[0]["UserNich"].ToString();    
  
                      try    
  
                      {    
  
                            myrow["ZX"] = (bool)DataRows[0]["ZX"];    
  
                            myrow["UserIp"] = DataRows[0]["UserIp"].ToString();    
  
                      }       
  
                      catch    
  
                        {    
  
                            myrow["ZX"] = false;    
  
                            myrow["UserIp"] = "";    
  
                        }    
  
                    }    
  
                }    
  
            }    
  
            catch    
  
            {    
  
                TabmyFriend.Columns.Add("UserName", typeof(String));    
  
                TabmyFriend.Columns.Add("UserImg", typeof(String));    
  
                TabmyFriend.Columns.Add("ZX", typeof(Boolean));    
  
                TabmyFriend.Columns.Add("UserIp", typeof(String));    
  
            }    
  
            IFormatter format = new BinaryFormatter();    
  
            MemoryStream stream = new MemoryStream();    
  
            format.Serialize(stream, TabmyFriend);    
  
            stream.Position = 0;    
  
            byte[] ret = new byte[_maxPacket];    
  
            int count = 0;    
  
            count = stream.Read(ret, 0, _maxPacket);    
  
            //先发送响应信号，用户客户机的判断    
  
            clientSkt.Send(Encoding.Unicode.GetBytes("cmd::RequestFriendList"));    
  
            while (count >0)    
  
            {    
  
                clientSkt.Send(ret);    
  
                count =  stream.Read(ret, 0, _maxPacket);    
  
              }    
  
            //发送结束信号    
  
              clientSkt.Send(Encoding.Unicode.GetBytes("Find::RequestFriendListEnd"));      
  
              stream.Close();    
  
            return true ;    
  
        }    
  
        private void FormMain_Load(object sender, EventArgs e)    
  
        {    
  
            MyPath = Application.StartupPath;    
  
            Read_User();    
  
            ReadTabUserMessage();    
  
            _receiveThread = new Thread(new ThreadStart(StartUp));    
  
            _receiveThread.Start();    
  
        }    
  
        /// <summary>    
  
        /// 读取所有用户信息    
  
        /// </summary>    
  
        private void Read_User()    
  
        {    
  
            try    
  
            {    
  
                TabUser.ReadXml(MyPath + "\\User.xml");    
  
            }    
  
            catch    
  
            {    
  
                TabUser.TableName = "User";    
  
                TabUser.Columns.Add("UserName", typeof(String));    
  
                TabUser.Columns.Add("UserPwd", typeof(String));    
  
                TabUser.Columns.Add("UserNich", typeof(String));    
  
                TabUser.Columns.Add("UserImg", typeof(String));    
  
            }    
  
            TabUser.Columns.Add("ZX", typeof(Boolean));    
  
            TabUser.Columns.Add("UserIp", typeof(String));    
  
        }    
  
        /// <summary>    
  
        /// 新用户上/下线后，更新其好友的（好友列表）    
  
        /// </summary>    
  
        /// <param name="UserName"> </param>    
  
        /// <param name="OnLine"> </param>    
  
        /// <param name="IpAddress"> </param>    
  
        private void UpdateFriendList(string UserName, bool OnLine, string IpAddress)    
  
        {    
  
            DataTable TabmyFriend = new DataTable();    
  
            TabmyFriend.TableName = UserName;    
  
            string svrlog = null;    
  
            string []UserInformation = new string[2];//UserName + "$" + IpAddress;    
  
            UserInformation[0] = UserName;    
  
            UserInformation[1] = IpAddress;    
  
            IFormatter format = new BinaryFormatter();    
  
            MemoryStream stream = new MemoryStream();    
  
            format.Serialize(stream, UserInformation);    
  
            byte[] ret = stream.ToArray();    
  
            stream.Close();    
  
            if (OnLine)    
  
            {    
  
                svrlog = "cmd::RequestAddFriendList";    
  
            }    
  
            else    
  
            {    
  
                svrlog = "cmd::RequestRemoveFriendList";    
  
                DataRow[] DataRows = TabUser.Select(" UserName = '" + UserName + "'");    
  
                if (DataRows.Length > 0)    
  
                {    
  
                    DataRows[0]["ZX"] = false;    
  
                    DataRows[0]["UserIp"] = "";    
  
                }    
  
            }    
  
            try    
  
            {    
  
                TabmyFriend.ReadXml(MyPath + "\\UserFriend\\" + TabmyFriend.TableName + ".xml");    
  
                foreach (DataRow myrow in TabmyFriend.Rows)    
  
                {    
  
                    if(_transmit_tb.ContainsKey(myrow["UserName"].ToString()))    
  
                    {    
  
                        Socket _clientSkt = _transmit_tb[myrow["UserName"].ToString()] as Socket;    
  
                      _clientSkt.Send(Encoding.Unicode.GetBytes(svrlog));    
  
                      _clientSkt.Send(ret);    
  
                    }    
  
                }    
  
            }    
  
            catch    
  
            { }    
  
        }    
  
[code=C#][/code /// <summary>    
  
        /// 线程执行体,转发消息    
  
        /// </summary>    
  
        /// <param name="obj">传递给线程执行体的用户名，用以与用户通信 </param>    
  
        private void ThreadFunc(object obj)    
  
        {    
  
            //通过转发表得到当前用户套接字    
  
            Socket clientSkt = _transmit_tb[obj] as Socket;    
  
          //主循环    
  
            while (true)    
  
            {    
  
                try    
  
                {    
  
         //接受第一个数据包。    
  
        //由于程序逻辑结构简单，所以在这里对客户机发送的第一个包内容作逐一判断，    
  
        //这里的实现不够优雅，但不失为此简单模型的一个解决之道。    
  
                    byte[] packetBuff = new byte[_maxPacket];    
  
                    clientSkt.Receive(packetBuff);    
  
                    string _str = Encoding.Unicode.GetString(packetBuff).TrimEnd('\0');    
  
                    //如果是发给不在线好友的信息    
  
                    if (_str.StartsWith("cmd::FriendMessage"))    
  
                    {    
  
                        string UserName = _str.Substring("cmd::FriendMessage".Length, 20).Trim();    
  
                        string MessageS = _str.Substring("cmd::FriendMessage".Length + 20, _str.Length - "cmd::FriendMessage".Length - 20);    
  
                        SaveMessage(obj as string, UserName, MessageS);    
  
                        continue;    
  
                    }    
  
                    //如果是离线请求    
  
                    if (_str.StartsWith("cmd::RequestLogout"))    
  
                    {    
  
                        _transmit_tb.Remove(obj);    
  
                        UpdateFriendList((string)obj, false, "");    
  
                      //  string svrlog = string.Format("[系统消息]用户 {0} 在 {1} 已断开... 当前在线人数: {2}\r\n\r\n", obj, DateTime.Now, _transmit_tb.Count);    
  
                      //  Console.WriteLine(svrlog);    
  
                        //向所有客户机发送系统消息    
  
                        //foreach (DictionaryEntry de in _transmit_tb)    
  
                        //{    
  
                        //    string _clientName = de.Key as string;    
  
                        //    Socket _clientSkt = de.Value as Socket;    
  
                        //    _clientSkt.Send(Encoding.Unicode.GetBytes(svrlog));    
  
                        //}    
  
                        Thread.CurrentThread.Abort();    
  
                    }    
  
                    //如果是请求好友列表    
  
                    if (_str.StartsWith("cmd::RequestFriendList"))    
  
                    {    
  
                        SerializeFriendList(obj, clientSkt);                         
  
                        // 将该用户不在线时的信息发送给用户    
  
                        DataTable TabMessage = ReadMessage(obj as string);    
  
                        if (TabMessage != null)    
  
                        {    
  
              foreach (DataRow myrow in TabMessage.Rows)    
  
            {    
               if (myrow["SendUserName"].ToString() == "System::Message")    
  
        {    
  
                                        clientSkt.Send(Encoding.Unicode.GetBytes(myrow["Message"].ToString()));    
  
                                }    
  
                                else    
  
                                {    
  
                                    clientSkt.Send(Encoding.Unicode.GetBytes("cmd::FriendMessage" + myrow["SendUserName"].ToString().PadRight(20, ' ') + myrow["Message"].ToString()));    
  
                                }    
  
                            }    
  
                        }    
  
                        //这里不需要再继续接受后继数据包了，跳出当前循环体。    
  
                        continue;    
  
                    }    
  
                    ////如果是请求好友列表    
  
                    //if (_str.StartsWith("cmd::RequestOnLineList"))    
  
                    //{    
  
                    //    byte[] onlineBuff = SerializeOnlineList();    
  
                    //    //先发送响应信号，用户客户机的判断    
  
                    //    clientSkt.Send(Encoding.Unicode.GetBytes("cmd::RequestOnLineList"));    
  
                    //    clientSkt.Send(onlineBuff);    
  
                    //    //这里不需要再继续接受后继数据包了，跳出当前循环体。    
  
                    //    continue;    
  
                    //}    
  
                    //查找用户    
  
                    if (_str.StartsWith("Find::FindFriend"))    
  
                    {    
  
                        DataTable TabFind = TabUser.Clone();    
  
                        DataRow [] FindRow =null  ;    
  
                        string UserName = _str.Substring("Find::FindFriend".Length, _str.Length - "Find::FindFriend".Length);    
  
                        if (UserName.Equals("Find::WhoOnLine"))    
  
                        { //看谁在线    
  
                            FindRow = TabUser.Select(" ZX = 1");    
  
                        }    
  
                        else//精确查找    
  
                        {    
  
                            FindRow = TabUser.Select("UserName = '" + UserName + "'");    
  
                        }    
  
                        foreach (DataRow myrow in FindRow)    
  
                        {    
  
                            TabFind.ImportRow(myrow);    
  
                        }    
  
                        clientSkt.Send(Encoding.Unicode.GetBytes("Find::FindFriend"));    
  
                        IFormatter format = new BinaryFormatter();    
  
                        MemoryStream stream = new MemoryStream();    
  
                        format.Serialize(stream, TabFind);    
  
                        stream.Position = 0;    
  
                        byte[] ret = new byte[_maxPacket];    
  
                        int count = 0;    
  
                        count = stream.Read(ret, 0, _maxPacket);    
  
                        while (count >0)    
  
                        {    
  
                            clientSkt.Send(ret);    
  
                          count =  stream.Read(ret, 0, _maxPacket);    
  
                        }    
  
                        clientSkt.Send(Encoding.Unicode.GetBytes("Find::FindFriendEnd"));      
  
                        stream.Close();    
  
                        TabFind = null;    
  
                        FindRow = null;    
  
//这里不需要再继续接受后继数据包了，跳出当前循环体。    
  
                        continue;    
  
                    }    
  
                    //请求添加好友    
  
                    if (_str.StartsWith("Find::AddFriendAsk"))    
  
                    {    
  
                        string UserName = _str.Substring("Find::AddFriendAsk".Length, _str.Length - "Find::AddFriendAsk".Length);    
  
                        //通过转发表查找接收方的套接字    
  
                        if (_transmit_tb.Count != 0 && _transmit_tb.ContainsKey(UserName))    
  
                        {    
  
                            Socket receiverSkt = _transmit_tb[UserName] as Socket;    
  
                            receiverSkt.Send(Encoding.Unicode.GetBytes("Find::AddFriendAsk" + obj as string));    
  
                        }    
  
                        //这里不需要再继续接受后继数据包了，跳出当前循环体。    
  
                        continue;    
  
                    }    
  
                    //回复答应添加好友    
  
                    if (_str.StartsWith("Find::AddFriendYes"))    
  
                    {    
  
                        string UserName = _str.Substring("Find::AddFriendYes".Length, _str.Length - "Find::AddFriendYes".Length);    
  
                      //// 保存数据    
  
                        DataTable TabmyFriend = new DataTable() ;    
  
                        //保存该用户    
  
                        TabmyFriend.ReadXml(MyPath + "\\UserFriend\\" +  obj as string + ".xml");    
  
                        DataRow newRow = TabmyFriend.NewRow();    
  
                        newRow["UserName"] = UserName;    
  
                        TabmyFriend.Rows.Add(newRow);    
  
                        TabmyFriend.WriteXml(MyPath + "\\UserFriend\\" + obj as string + ".xml", XmlWriteMode.WriteSchema, false);    
  
                        //保存其好友    
  
                        TabmyFriend = new DataTable();    
  
                        TabmyFriend.ReadXml(MyPath + "\\UserFriend\\" + UserName + ".xml");    
  
                        DataRow newRow1 = TabmyFriend.NewRow();    
  
                        newRow1["UserName"] = obj as string;    
  
                        TabmyFriend.Rows.Add(newRow1);    
  
                        TabmyFriend.WriteXml(MyPath + "\\UserFriend\\" + UserName + ".xml", XmlWriteMode.WriteSchema, false);    
  
                        TabmyFriend = null;    
  
              //更新好友列表    
  
                        SerializeFriendList(obj, clientSkt);    
  
上面发了服务器端,没发客户端,现在补上!不知道写的好不好,见笑了    
  
C# code    
  
public partial class Form1 : Form    
  
    {    
  
        private TcpClient client;    
  
        private bool isExit = false;    
  
        private NetworkStream networkStream;    
  
        private EventWaitHandle allDone = new EventWaitHandle(false, EventResetMode.ManualReset);   
 
        #region 用于一个线程操作另一个线程的控件    
  
        private delegate void SetListBoxCallback(string str);    
  
        private SetListBoxCallback setListBoxCallBack;    
  
        private delegate void SetRichTextBoxCallback(string str);    
  
        private SetRichTextBoxCallback setRichTextBoxCallBack;   
 
        #endregion    
  
        public Form1()    
  
        {    
  
            InitializeComponent();    
  
            listBoxStatus.HorizontalScrollbar = true;    
  
            setListBoxCallBack = new SetListBoxCallback(SetListBox);    
  
            setRichTextBoxCallBack = new SetRichTextBoxCallback(SetReceiveText);    
  
        }    
  
        //状态显示    
  
        private void SetListBox(string str)    
  
        {    
  
            listBoxStatus.Items.Add(str);    
  
            listBoxStatus.SelectedIndex = listBoxStatus.Items.Count - 1;    
  
            listBoxStatus.ClearSelected();    
  
        }    
  
        //接收客户端信息    
  
        private void SetReceiveText(string str)    
  
        {    
  
            richTextBoxReceive.AppendText(str);    
  
        }    
  
        //连接服务器....    
  
        private void buttonConnet_Click(object sender, EventArgs e)    
  
        {    
  
            client = new TcpClient(AddressFamily.InterNetwork);    
  
            //得到服务器IP    
  
            IPAddress ip= IPAddress.Parse("127.0.0.1");    
  
            //创建一个委托,并知名在异步操作完成时执行的方法    
  
            AsyncCallback callback = new AsyncCallback(RequestCallBack);    
  
            allDone.Reset();    
  
            client.BeginConnect(ip, 7100, RequestCallBack, client);    
  
        }    
  
        private void RequestCallBack(IAsyncResult ar)    
  
        {    
  
            allDone.Set();    
  
            try    
  
            {    
  
                client = (TcpClient)ar.AsyncState;    
  
                client.EndConnect(ar);    
  
                listBoxStatus.Invoke(setListBoxCallBack, string.Format("与服务器{0}连接成功", client.Client.RemoteEndPoint));    
  
                networkStream = client.GetStream();    
  
                ReadObject readObject = new ReadObject(networkStream, client.ReceiveBufferSize);    
  
                networkStream.BeginRead(readObject.bytes, 0, readObject.bytes.Length, ReadCallBack, readObject);    
  
            }    
  
            catch (Exception e1)    
  
            {    
  
                listBoxStatus.Invoke(setListBoxCallBack, e1.Message);    
  
                return;    
  
            }    
  
        }    
  
        //异步操作完成时执行的回调调用的方法    
  
        private void ReadCallBack(IAsyncResult ar)    
  
        {    
  
            try    
  
            {    
  
                ReadObject ro = (ReadObject)ar.AsyncState;    
  
                int count = ro.netStream.EndRead(ar);    
  
                richTextBoxReceive.Invoke(setRichTextBoxCallBack, System.Text.Encoding.UTF8.GetString(ro.bytes, 0, count));    
  
                if (isExit == false)    
  
                {    
  
                    ro = new ReadObject(networkStream, client.ReceiveBufferSize);    
  
                    networkStream.BeginRead(ro.bytes, 0, ro.bytes.Length, ReadCallBack, ro);    
  
                }    
  
            }    
  
            catch (Exception e2)    
  
            {    
  
                listBoxStatus.Invoke(setListBoxCallBack, e2.Message);    
  
                return;    
  
            }    
  
        }    
  
        //发送数据    
  
        private void SendString(string str)    
  
        {    
  
            try    
  
            {    
  
                byte[] by = System.Text.Encoding.UTF8.GetBytes(str+"\r\n");    
  
                networkStream.BeginWrite(by, 0, by.Length, new AsyncCallback(SendCallBack), networkStream);    
  
                networkStream.Flush();    
  
            }catch(Exception e3){    
  
                listBoxStatus.Invoke(setListBoxCallBack, e3.Message);    
  
                return;    
  
            }    
  
        }    
  
        //发送数据回调的方法    
  
        private void SendCallBack(IAsyncResult ar)    
  
        {    
  
            try    
  
            {    
  
                networkStream.EndWrite(ar);    
  
            }    
  
            catch (Exception e4)    
  
            {    
  
                listBoxStatus.Invoke(setListBoxCallBack, e4.Message);    
  
                return;    
  
            }    
  
        }    
  
        private void buttonSend_Click(object sender, EventArgs e)    
  
        {    
  
            SendString(richTextBoxSend.Text);    
  
            richTextBoxSend.Clear();    
  
        }    
  
        private void Form1_FormClosing(object sender, FormClosingEventArgs e)    
  
        {    
  
            isExit = true;    
  
            allDone.Set();    
  
        }    
  
    }   

 

<!--EndFragment-->