示例目的：使用控制臺項目模板分別新建一個(gè)服務(wù)器和一個(gè)客戶(hù)端，實(shí)現兩兩通訊
1. 新建服務(wù)器項目
using System;using System.Net;using System.Net.Sockets;using System.Text;using System.Threading;
namespace server{ class Program { static TcpClient tcpClient; static NetworkStream stream; static void Main(string[] args) { try { var serverIPEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 13000); // 當前服務(wù)器使用的ip和端口 TcpListener tcpListener = new TcpListener(serverIPEndPoint); tcpListener.Start(); Console.WriteLine("服務(wù)端已啟用......"); // 阻塞線(xiàn)程的執行，直到一個(gè)客戶(hù)端連接 tcpClient = tcpListener.AcceptTcpClient(); Console.WriteLine("已連接."); stream = tcpClient.GetStream(); // 創(chuàng )建用于發(fā)送和接受數據的NetworkStream
#region 開(kāi)啟線(xiàn)程保持通訊 var t1 = new Thread(ReceiveMsg); t1.Start(); var t2 = new Thread(SendMsg); t2.Start(); #endregion } catch (Exception ex) { Console.WriteLine(ex.Message); Console.ReadKey(); }
}
/// <summary> /// 發(fā)送消息 /// </summary> static void SendMsg() { string message = string.Empty; byte[] messageBytes; try { while (true) { message = Console.ReadLine().ToString(); // 獲取控制臺字符串 messageBytes = Encoding.UTF8.GetBytes(message); // 將消息編碼成字符串數組 stream.Write(messageBytes, 0, messageBytes.Length); } } catch (Exception ex) { Console.WriteLine(ex.Message); Console.ReadKey(); }
}
/// <summary> /// 接收消息 /// </summary> static void ReceiveMsg() { byte[] buffer = new byte[1024]; // 預設最大接受1024個(gè)字節長(cháng)度，可修改 int count = 0; try { while ((count = stream.Read(buffer, 0, buffer.Length)) != 0) { Console.WriteLine($"{tcpClient.Client.LocalEndPoint.ToString()}:{Encoding.UTF8.GetString(buffer, 0, count)}"); } } catch (Exception ex) { Console.WriteLine(ex.Message); Console.ReadKey(); }
} }}
2. 新建客戶(hù)端項目
using System;using System.Net;using System.Net.Sockets;using System.Text;using System.Threading;
namespace client{ class Program { static TcpClient tcpClient; static NetworkStream stream; static void Main(string[] args) { try { var clientIPEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 4196); // 當前客戶(hù)端使用的ip和端口 tcpClient = new TcpClient(clientIPEndPoint); var serverIPEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 13000); // 當前服務(wù)器使用的ip和端口 tcpClient.Connect(serverIPEndPoint); // 連接服務(wù)器 var isConnected = tcpClient.Connected; Console.WriteLine("客戶(hù)端已啟用......"); stream = tcpClient.GetStream(); // 創(chuàng )建用于發(fā)送和接受數據的NetworkStream
#region 開(kāi)啟線(xiàn)程保持通訊 var t1 = new Thread(ReceiveMsg); t1.Start(); var t2 = new Thread(SendMsg); t2.Start(); #endregion } catch (Exception ex) { Console.WriteLine(ex.Message); Console.ReadKey(); } }
/// <summary> /// 接收消息 /// </summary> static void ReceiveMsg() { byte[] buffer = new byte[1024]; // 預設最大接受1024個(gè)字節長(cháng)度，可修改 int count = 0; try { while ((count = stream.Read(buffer, 0, buffer.Length)) != 0) { Console.WriteLine($"{tcpClient.Client.LocalEndPoint.ToString()}:{Encoding.UTF8.GetString(buffer, 0, count)}"); } } catch (Exception ex) { Console.WriteLine(ex.Message); Console.ReadKey(); }
}
/// <summary> /// 發(fā)送消息 /// </summary> static void SendMsg() { string message = string.Empty; byte[] messageBytes; try { while (true) { message = Console.ReadLine().ToString(); // 獲取控制臺字符串 messageBytes = Encoding.UTF8.GetBytes(message); // 將消息編碼成字符串數組 stream.Write(messageBytes, 0, messageBytes.Length); } } catch (Exception ex) { Console.WriteLine(ex.Message); Console.ReadKey(); }
} }}
3.先啟動(dòng)服務(wù)器，再啟動(dòng)客戶(hù)端，查看效果
聯(lián)系客服
