在C#中,实现异步通信通常使用async
和await
关键字。这些关键字允许你编写异步代码,从而不阻塞主线程。这里有一个简单的示例,展示了如何使用async
和await
实现异步通信:
首先,确保你的项目引用了System.Net.Sockets
命名空间,因为我们将使用TCP套接字进行通信。
创建一个名为AsyncCommunication
的类,并在其中定义一个名为StartAsyncCommunication
的方法:
using System;
using System.Net.Sockets;
using System.Threading.Tasks;
namespace AsyncCommunication
{
class Program
{
static async Task Main(string[] args)
{
await StartAsyncCommunication("127.0.0.1", 12345);
}
static async Task StartAsyncCommunication(string serverAddress, int serverPort)
{
using (var client = new TcpClient())
{
await client.ConnectAsync(serverAddress, serverPort);
Console.WriteLine("Connected to server.");
// Send and receive data asynchronously
await SendAndReceiveData(client);
}
Console.WriteLine("Disconnected from server.");
}
static async Task SendAndReceiveData(TcpClient client)
{
// Send data to the server
var message = "Hello, server!";
var data = Encoding.ASCII.GetBytes(message);
await client.GetStream().WriteAsync(data, 0, data.Length);
// Receive data from the server
var receivedData = new byte[1024];
var receivedBytes = await client.GetStream().ReadAsync(receivedData, 0, receivedData.Length);
// Convert received data to a string
var receivedMessage = Encoding.ASCII.GetString(receivedBytes);
Console.WriteLine("Received from server: " + receivedMessage);
}
}
}
在这个示例中,我们创建了一个TCP客户端,连接到指定的服务器地址和端口。然后,我们使用SendAndReceiveData
方法异步发送和接收数据。这个方法首先将一条消息发送到服务器,然后等待从服务器接收数据。接收到的数据被转换为字符串并输出到控制台。
注意,我们在Main
方法和StartAsyncCommunication
方法上使用了async
关键字,这样我们就可以在这些方法中使用await
关键字等待异步操作完成。这使得我们的代码不会阻塞主线程,从而提高了应用程序的性能。