C#异步传输字符串服务端的实现

C#异步传输字符串服务端的实现当程序越来越复杂的时候，就需要越来越高的抽象，所以从现在起我们不再把所有的代码全部都扔进Main()里，这次我创建了一个RemoteClient类，它对于服务端获取到的TcpClient进行了一个包装：

网站建设哪家好，找创新互联！专注于网页设计、网站建设、微信开发、微信小程序、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了兴县免费建站欢迎大家使用！

C#异步传输字符串服务端的实现实例：

 
 
 
  
  
  public class RemoteClient {  
  
  
  private TcpClient client;  
  
  
  private NetworkStream streamToClient;  
  
  
  private const int BufferSize = 8192;  
  
  
  private byte[] buffer;  
  
  
  private RequestHandler handler;  
  
  
   //C#异步传输字符串服务端的实现
  
  
  public RemoteClient(TcpClient client) {  
  
  
  this.client = client;  
  
  
   
  
  
  // 打印连接到的客户端信息  
  
  
  Console.WriteLine("\nClient Connected！{0} <-- {1}",  
  
  
  client.Client.LocalEndPoint,  
  
  
   client.Client.RemoteEndPoint);  
  
  
   
  
  
  // 获得流  
  
  
  streamToClient = client.GetStream();  
  
  
  buffer = new byte[BufferSize];  
  
  
   
  
  
  // 设置RequestHandler  
  
  
  handler = new RequestHandler();  
  
  
   
  
  
  // 在构造函数中就开始准备读取  
  
  
  AsyncCallback callBack =   
  
  
  new AsyncCallback(ReadComplete);  
  
  
  streamToClient.BeginRead(buffer,   
  
  
  0, BufferSize, callBack, null);  
  
  
  }  
  
  
   
  
  
  // 再读取完成时进行回调  
  
  
  private void ReadComplete(IAsyncResult ar) {  
  
  
  int bytesRead = 0;  
  
  
  try {  
  
  
  lock (streamToClient) {  
  
  
  bytesRead = streamToClient.EndRead(ar);  
  
  
  Console.WriteLine("Reading data, {0} bytes ...", bytesRead);  
  
  
  }  
  
  
  if (bytesRead == 0) throw new Exception("读取到0字节");  
  
  
   //C#异步传输字符串服务端的实现
  
  
  string msg = Encoding.Unicode.GetString(buffer, 0, bytesRead);  
  
  
  Array.Clear(buffer,0,buffer.Length);  
  
  
  // 清空缓存，避免脏读  
  
  
   
  
  
  string[] msgArray = handler.GetActualString(msg);   
  
  
    // 获取实际的字符串  
  
  
   
  
  
  // 遍历获得到的字符串  
  
  
  foreach (string m in msgArray) {  
  
  
  Console.WriteLine("Received: {0}", m);  
  
  
  string back = m.ToUpper();  
  
  
   
  
  
  // 将得到的字符串改为大写并重新发送  
  
  
  byte[] temp = Encoding.Unicode.GetBytes(back);  
  
  
  streamToClient.Write(temp, 0, temp.Length);  
  
  
  streamToClient.Flush();  
  
  
  Console.WriteLine("Sent: {0}", back);  
  
  
  }     //C#异步传输字符串服务端的实现
  
  
   
  
  
  // 再次调用BeginRead()，完成时调用自身，形成无限循环  
  
  
  lock (streamToClient) {  
  
  
  AsyncCallback callBack =  
  
  
   new AsyncCallback(ReadComplete);  
  
  
  streamToClient.BeginRead(buffer,   
  
  
  0, BufferSize, callBack, null);  
  
  
  }  
  
  
  } catch(Exception ex) {  
  
  
  if(streamToClient!=null)  
  
  
  streamToClient.Dispose();  
  
  
  client.Close();  
  
  
  Console.WriteLine(ex.Message);    
  
  
  // 捕获异常时退出程序    
  
  
  }  
  
  
  }  
  
  
  }

随后，我们在主程序中仅仅创建TcpListener类型实例，由于RemoteClient类在构造函数中已经完成了初始化的工作，所以我们在下面的while循环中我们甚至不需要调用任何方法：

 
 
 
  
  
  class Server {  
  
  
  static void Main(string[] args) {  
  
  
  Console.WriteLine("Server is running ... ");  
  
  
  IPAddress ip = new IPAddress(new byte[] { 127, 0, 0, 1 });  
  
  
  TcpListener listener = new TcpListener(ip, 8500);  
  
  
   
  
  
  listener.Start();   // 开始侦听  
  
  
  Console.WriteLine("Start Listening ...");  
  
  
   
  
  
  while (true) {  
  
  
  // 获取一个连接，同步方法，在此处中断  
  
  
  TcpClient client = listener.AcceptTcpClient();    
  
  
  RemoteClient wapper = new RemoteClient(client);  
  
  
  }  
  
  
  }  //C#异步传输字符串服务端的实现
  
  
  }

好了，服务端的实现现在就完成了。

C#异步传输字符串服务端的实现方面内容就向你介绍到这里，希望对你了解和学习C#异步传输字符串有所帮助。

【编辑推荐】

委托实现C#异步调用浅析
浅析C#中异步和多线程的区别
C# Socket通信三大问题详解
C#异步调用四大方法详解
C#网络编程消息发送问题浅析

本文名称：C#异步传输字符串服务端的实现
网站链接：http://www.shufengxianlan.com/qtweb/news1/187501.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容