C#异步传输字符串客户端的实现

C#异步传输字符串客户端的实现与服务端类似，我们首先对TcpClient进行一个简单的包装，使它的使用更加方便一些，因为它是服务端的客户，所以我们将类的名称命名为ServerClient：

 
 
 

  
  
  
public class ServerClient { 
  
  
  
private const int BufferSize = 8192; 
  
  
  
private byte[] buffer; 
  
  
  
private TcpClient client; 
  
  
  
private NetworkStream streamToServer; 
  
  
  
private string msg = "Welcome to TraceFact.Net!"; 
  
  
  
 //C#异步传输字符串客户端的实现
  
  
  
public ServerClient() { 
  
  
  
try { 
  
  
  
client = new TcpClient(); 
  
  
  
client.Connect("localhost", 8500);   
  
  
  
// 与服务器连接 
  
  
  
} catch (Exception ex) { 
  
  
  
Console.WriteLine(ex.Message); 
  
  
  
return; 
  
  
  
} 
  
  
  
buffer = new byte[BufferSize]; 
  
  
  
 //C#异步传输字符串客户端的实现
  
  
  
// 打印连接到的服务端信息 
  
  
  
Console.WriteLine("Server Connected！{0} --> {1}", 
  
  
  
client.Client.LocalEndPoint, 
  
  
  
 client.Client.RemoteEndPoint); 
  
  
  

  
  
  
streamToServer = client.GetStream(); 
  
  
  
} 
  
  
  

  
  
  
// 连续发送三条消息到服务端 
  
  
  
public void SendMessage(string msg) { 
  
  
  

  
  
  
msg = String.Format("[length={0}]{1}", 
  
  
  
 msg.Length, msg); 
  
  
  

  
  
  
for (int i = 0; i <= 2; i++) { 
  
  
  
byte[] temp = Encoding.Unicode.GetBytes(msg);   
  
  
  
 // 获得缓存 
  
  
  
try { 
  
  
  
streamToServer.Write(temp, 0, temp.Length);  
  
  
  
// 发往服务器 
  
  
  
Console.WriteLine("Sent: {0}", msg); 
  
  
  
} catch (Exception ex) { 
  
  
  
Console.WriteLine(ex.Message); 
  
  
  
break; 
  
  
  
} 
  
  
  
} 
  
  
  
 //C#异步传输字符串客户端的实现
  
  
  
lock (streamToServer) { 
  
  
  
AsyncCallback callBack =  
  
  
  
new AsyncCallback(ReadComplete); 
  
  
  
streamToServer.BeginRead( 
  
  
  
buffer, 0, BufferSize, callBack, null); 
  
  
  
} 
  
  
  
} 
  
  
  

  
  
  
public void SendMessage() { 
  
  
  
SendMessage(this.msg); 
  
  
  
} 
  
  
  

  
  
  
// 读取完成时的回调方法 
  
  
  
private void ReadComplete(IAsyncResult ar) { 
  
  
  
int bytesRead; 
  
  
  

  
  
  
try { 
  
  
  
lock (streamToServer) { 
  
  
  
bytesRead = streamToServer.EndRead(ar); 
  
  
  
} 
  
  
  
if (bytesRead == 0) throw new
  
  
  
 Exception("读取到0字节"); 
  
  
  

  
  
  
string msg = Encoding.Unicode.GetString(buffer, 0, bytesRead); 
  
  
  
Console.WriteLine("Received: {0}", msg); 
  
  
  
Array.Clear(buffer, 0, buffer.Length);   
  
  
  
// 清空缓存，避免脏读 
  
  
  

  
  
  
lock (streamToServer) { 
  
  
  
AsyncCallback callBack =  
  
  
  
new AsyncCallback(ReadComplete); 
  
  
  
streamToServer.BeginRead(buffer, 
  
  
  
 0, BufferSize, callBack, null); 
  
  
  
} 
  
  
  
} catch (Exception ex) { 
  
  
  

  
  
  
if(streamToServer!=null) 
  
  
  
streamToServer.Dispose(); 
  
  
  
client.Close(); 
  
  
  

  
  
  
Console.WriteLine(ex.Message); 
  
  
  
} 
  
  
  
}  //C#异步传输字符串客户端的实现
  
  
  
} 
 
 
 

在上面的SendMessage()方法中，我们让它连续发送了三条同样的消息，这么仅仅是为了测试，因为异步操作同样会出现上面说过的：服务器将客户端的请求拆开了的情况。最后我们在Main()方法中创建这个类型的实例，然后调用SendMessage()方法进行测试：

 
 
 

  
  
  
class Client { 
  
  
  
static void Main(string[] args) { 
  
  
  
ConsoleKey key; 
  
  
  

  
  
  
ServerClient client = new ServerClient(); 
  
  
  
client.SendMessage(); 
  
  
  

  
  
  
Console.WriteLine("\n\n输入\"Q\"键退出。"); 
  
  
  
do { 
  
  
  
key = Console.ReadKey(true).Key; 
  
  
  
} while (key != ConsoleKey.Q); 
  
  
  
} 
  
  
  
} 
 
 
 

是不是感觉很清爽？因为良好的代码重构，使得程序在复杂程度提高的情况下依然可以在一定程度上保持良好的阅读性。

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

当前文章：C#异步传输字符串客户端的实现
新闻来源：http://cdxtjz.cn/article/djojeph.html