在C#中,使用TCP/IP和多线程可以实现高性能的网络通信。以下是一个简单的示例,展示了如何创建一个TCP服务器和客户端,并使用多线程处理并发连接。
首先,我们需要创建一个TCP服务器:
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
namespace TcpServer
{
class Program
{
private static TcpListener _listener;
static void Main(string[] args)
{
_listener = new TcpListener(IPAddress.Any, 8080);
_listener.Start();
Console.WriteLine("Server is listening on port 8080...");
while (true)
{
TcpClient client = _listener.AcceptTcpClient();
Thread thread = new Thread(HandleClient);
thread.Start(client);
}
}
private static void HandleClient(object obj)
{
TcpClient client = (TcpClient)obj;
NetworkStream stream = client.GetStream();
byte[] buffer = new byte[1024];
int bytesRead = stream.Read(buffer, 0, buffer.Length);
string message = Encoding.ASCII.GetString(buffer, 0, bytesRead);
Console.WriteLine($"Received message: {message}");
string response = "Message received";
byte[] responseData = Encoding.ASCII.GetBytes(response);
stream.Write(responseData, 0, responseData.Length);
stream.Close();
client.Close();
}
}
}
接下来,我们创建一个TCP客户端:
using System;
using System.Net.Sockets;
using System.Text;
namespace TcpClient
{
class Program
{
static void Main(string[] args)
{
TcpClient client = new TcpClient("localhost", 8080);
NetworkStream stream = client.GetStream();
string message = "Hello, server!";
byte[] data = Encoding.ASCII.GetBytes(message);
stream.Write(data, 0, data.Length);
byte[] buffer = new byte[1024];
int bytesRead = stream.Read(buffer, 0, buffer.Length);
string response = Encoding.ASCII.GetString(buffer, 0, bytesRead);
Console.WriteLine($"Server response: {response}");
stream.Close();
client.Close();
}
}
}
在这个示例中,服务器使用TcpListener
类监听指定端口上的连接请求。当接收到新的连接请求时,服务器会创建一个新的线程来处理客户端的请求。客户端使用TcpClient
类连接到服务器,并发送一条消息。服务器接收到消息后,回复一条确认消息。
要运行此示例,请分别编译并运行服务器和客户端项目。你可以根据需要修改服务器和客户端的代码,以满足你的需求。