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://www.csdahua.cn/qtweb/news20/325770.html

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

广告

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