C# TCP通讯示例

dotnet编程大全

专注C# WPF编程，dotnet编程大全

示例目的：使用控制台项目模板分别新建一个服务器和一个客户端，实现两两通讯

1. 新建服务器项目

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)
                var serverIPEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 13000); // 当前服务器使用的ip和端口
                TcpListener tcpListener = new TcpListener(serverIPEndPoint);
                tcpListener.Start();
                Console.WriteLine("服务端已启用......"); // 阻塞线程的执行，直到一个客户端连接
                tcpClient = tcpListener.AcceptTcpClient();
                Console.WriteLine("已连接.");
                stream = tcpClient.GetStream();          // 创建用于发送和接受数据的NetworkStream
                #region 开启线程保持通讯
                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 SendMsg()
            string message = string.Empty;
            byte[] messageBytes;
                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个字节长度，可修改
            int count = 0;
                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. 新建客户端项目

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)
                var clientIPEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 4196); // 当前客户端使用的ip和端口
                tcpClient = new TcpClient(clientIPEndPoint);
                var serverIPEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 13000); // 当前服务器使用的ip和端口
                tcpClient.Connect(serverIPEndPoint);    // 连接服务器
                var isConnected = tcpClient.Connected;
                Console.WriteLine("客户端已启用......");
                stream = tcpClient.GetStream();         // 创建用于发送和接受数据的NetworkStream
                #region 开启线程保持通讯
                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个字节长度，可修改
            int count = 0;
                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>
        /// 发送消息
        /// </summary>
        static void SendMsg()
            string message = string.Empty;
            byte[] messageBytes;
                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();