用Reactive Extensions实现一个简单的EchoServer

在昨天的随笔Reactive Extensions学习里，我写了个简单的stream异步读操作的扩展封装。今天我用它来实现了一个简单的EchoServer： 

 
       
  // 
  一个简单的异步echo server 
  
 
       
  static 
    
  void 
   Main( 
  string 
  [] args)
    {
        var listener  
  = 
    
  new 
   TcpListener( 
  new 
   IPEndPoint(IPAddress.Loopback,  
  3000 
  ));
            
        listener.Start();
         
  while 
   ( 
  true 
  )
        {
            var client  
  = 
   listener.AcceptTcpClient();

            var stream  
  = 
   client.GetStream();
            var writer  
  = 
    
  new 
   StreamWriter(stream) { AutoFlush  
  = 
    
  true 
   };
            var buffer  
  = 
    
  new 
    
  byte 
  [ 
  1024 
  ];

            stream.ReadLinesAsync(buffer)
                .Select(line  
  => 
    
  " 
  >>>  
  " 
    
  + 
   line)
                .Finally(client.Close)
                .Subscribe(writer.WriteLine);
        }
    } 
 

 

代码非常精简，比起以前的异步架构来说精简了不少。后续有时间的话再尝试用它重写一下以前的MSN客户端看看效果怎么样。