C# SOCKET发送和接收例子

Socket 客户端    using System;  using System.Collections.Generic;  using System.Linq;  using System.Text;    using System.Net;  using System.Net.Sockets;      namespace A0140_SocketClient.Sample  {        /// <summary>      /// 这个类为一个 Socket 客户端的例子.      /// 这个类简单的 连接到 Socket 服务器，并发送一段消息。      /// 然后读取来自服务器的反馈      /// 最后结束程序.      ///      /// 服务端输出：      /// 开始侦听 8088 端口……      /// 接收到客户的连接      /// 接收到来自客户端的数据为：Hello Socket Server!      ///      /// 客户端输出：      /// 向服务器发送到了:Hello Socket Server!      /// 从服务器接收到了:Hello Socket Server!      ///      /// </summary>      class StockClient      {            /// <summary>          /// 字符编码处理.          /// </summary>          private static readonly Encoding ASCII;              /// <summary>          /// 用于 发送/接收的端口.          /// </summary>          private const int PORT = 8088;              private const String SEND_MESSAGE = "Hello Socket Server!";              static StockClient()          {              ASCII = Encoding.ASCII;          }            public void SendMessage()          {              // 构造用于发送的 字节缓冲.              Byte[] sendBytes = ASCII.GetBytes(SEND_MESSAGE);                // 构造用于接收的 字节缓冲.              Byte[] recvBytes = new Byte[256];                // IP地址.              IPAddress localAddr = IPAddress.Parse("127.0.0.1");                // 接入点.              IPEndPoint ephost = new IPEndPoint(localAddr, PORT);                  // 第一个参数：AddressFamily = 指定 Socket 类的实例可以使用的寻址方案。              //     Unspecified 未指定地址族。              //     InterNetwork IP 版本 4 的地址。              //     InterNetworkV6 IP 版本 6 的地址。              //              // 第二个参数：SocketType = 指定 Socket 类的实例表示的套接字类型。              //     Stream 一个套接字类型，支持可靠、双向、基于连接的字节流，而不重复数据，也不保留边界。              //            此类型的 Socket 与单个对方主机通信，并且在通信开始之前需要建立远程主机连接。              //            此套接字类型使用传输控制协议 (Tcp)，AddressFamily 可以是 InterNetwork，也可以是 InterNetworkV6。              //              // 第三个参数：ProtocolType = 指定 Socket 类支持的协议。              //     Tcp 传输控制协议 (TCP)。              Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);                try              {                  // 尝试连接主机.                  s.Connect(ephost);                      Console.WriteLine("向服务器发送到了:{0}", SEND_MESSAGE);                    // 向主机发送数据.                  s.Send(sendBytes, sendBytes.Length, SocketFlags.None);                    // 接收服务器的应答.                  Int32 bytes = s.Receive(recvBytes, recvBytes.Length, SocketFlags.None);                      StringBuilder buff = new StringBuilder();                    while (bytes > 0)                  {                      // 将缓冲的字节数组，装换为字符串.                      String str = ASCII.GetString(recvBytes, 0, bytes);                      // 加入字符串缓存                      buff.Append(str);                      // 再次接受，看看后面还有没有数据.                      bytes = s.Receive(recvBytes, recvBytes.Length, SocketFlags.None);                  }                    Console.WriteLine("从服务器接收到了:{0}", buff.ToString());                  }              catch (Exception ex)              {                  Console.WriteLine("连接/发送/接收过程中，发生了错误！");                  Console.WriteLine(ex.Message);                  Console.WriteLine(ex.StackTrace);              }              finally              {                  s.Close();              }          }      }  }        Socket 服务端    using System;  using System.IO;  using System.Net;  using System.Net.Sockets;  using System.Collections.Generic;  using System.Linq;  using System.Text;    using System.Threading;    namespace A0130_SocketServer.Sample  {        /// <summary>      /// Socket 服务端例子      ///       /// 这个例子仅仅处理一个 客户端的访问， 处理完毕后退出.      ///       ///       /// 服务端的输出为：      ///       /// 开始侦听 8088 端口……      /// 接收到客户的连接      /// 接收到来自客户端的数据为：1      ///       ///       ///       /// 客户端的输入为：      ///       /// telnet 127.0.0.1 8088      /// 1      /// 失去了跟主机的连接。      ///       ///       /// </summary>      class SocketServer      {            /// <summary>          /// 字符编码处理.          /// </summary>          private static readonly Encoding ASCII;              /// <summary>          /// 用于 监听的端口.          /// </summary>          private const int PORT = 8088;              static SocketServer()          {              ASCII = Encoding.ASCII;          }            public void StartServer()          {              TcpListener myListener = null;              try              {                  // IP地址.                  IPAddress localAddr = IPAddress.Parse("127.0.0.1");                    // 在 8088 端口 开一个侦听.                  myListener = new TcpListener(localAddr, PORT);                    // 开始侦听.                  myListener.Start();                  Console.WriteLine("开始侦听 {0} 端口……", PORT);                    // 程序在这里暂停， 等待客户端的接入.                  Socket mySocket = myListener.AcceptSocket();                    // 如果执行到这里，说明接收到了客户的连接.                  Console.WriteLine("接收到客户的连接");                    // 字节缓冲.                  Byte[] recvBytes = new Byte[256];                    // 读取数据到缓冲区当中                  Int32 bytes = mySocket.Receive(recvBytes, recvBytes.Length, SocketFlags.None);                    // 将缓冲区当中的 byte 数组，转化为 字符串.                  String str = ASCII.GetString(recvBytes, 0, bytes);                    Console.WriteLine("接收到来自客户端的数据为：{0}", str);                    // 将读取到的数据，发送回给客户端.                  mySocket.Send(recvBytes, bytes, SocketFlags.None);                  // 休眠5秒.                  Thread.Sleep(5000);                  // 关闭 Socket                  mySocket.Close();                }              catch (SocketException e)              {                  Console.WriteLine("SocketException: {0}", e);              }              finally              {                    myListener.Stop();              }          }      }  }
热门搜索

C# SOCKET发送和接收例子
