C#中 用socket实现两个客户端的聊天功能
时间: 2023-08-20 13:07:28 浏览: 64
好的,下面是一个简单的 C# socket 聊天示例代码,其中使用了 TCP 协议。
服务端代码:
```csharp
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
namespace SocketServer
{
class Program
{
static void Main(string[] args)
{
IPEndPoint localEndPoint = new IPEndPoint(IPAddress.Any, 1234);
TcpListener listener = new TcpListener(localEndPoint);
listener.Start();
Console.WriteLine("Server started, waiting for client to connect...");
TcpClient client = listener.AcceptTcpClient();
Console.WriteLine("Client connected: " + client.Client.RemoteEndPoint.ToString());
NetworkStream stream = client.GetStream();
byte[] buffer = new byte[1024];
while (true)
{
int bytesRead = stream.Read(buffer, 0, buffer.Length);
string message = Encoding.ASCII.GetString(buffer, 0, bytesRead);
Console.WriteLine("Received message: " + message);
if (message == "quit")
break;
Console.Write("Enter your message: ");
string replyMessage = Console.ReadLine();
byte[] replyBuffer = Encoding.ASCII.GetBytes(replyMessage);
stream.Write(replyBuffer, 0, replyBuffer.Length);
}
stream.Close();
client.Close();
listener.Stop();
}
}
}
```
客户端代码:
```csharp
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
namespace SocketClient
{
class Program
{
static void Main(string[] args)
{
IPEndPoint remoteEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 1234);
TcpClient client = new TcpClient();
client.Connect(remoteEndPoint);
Console.WriteLine("Connected to server: " + client.Client.RemoteEndPoint.ToString());
NetworkStream stream = client.GetStream();
byte[] buffer = new byte[1024];
while (true)
{
Console.Write("Enter your message: ");
string message = Console.ReadLine();
byte[] messageBuffer = Encoding.ASCII.GetBytes(message);
stream.Write(messageBuffer, 0, messageBuffer.Length);
int bytesRead = stream.Read(buffer, 0, buffer.Length);
string replyMessage = Encoding.ASCII.GetString(buffer, 0, bytesRead);
Console.WriteLine("Received message: " + replyMessage);
if (message == "quit")
break;
}
stream.Close();
client.Close();
}
}
}
```
以上代码演示了一个简单的 TCP socket 聊天程序,运行服务端程序,然后运行两个客户端程序,可以在客户端之间进行消息的收发和交互。