C#——tcp通信

淩亂°似流年 2022-02-20 05:19 237阅读 0赞

发送方：
            public static bool sendMessage(string message)
            {
                IPAddress remoteIP = IPAddress.Parse("127.0.0.1");//远程主机IP
                int remotePort = 61620;//远程主机端口
    
                byte[] sendData = Encoding.Default.GetBytes(message);//获取要发送的字节数组
                TcpClient client = new TcpClient();//实例化TcpClient
                    try
                    {
                        client.Connect(remoteIP, remotePort);//连接远程主机
                        NetworkStream stream = client.GetStream();//获取网络流
                        stream.Write(sendData, 0, sendData.Length);//将数据写入网络流
                        stream.Close();//关闭网络流
                        client.Close();//关闭客户端
                        return true;
                     }
                    catch (System.Exception ex)
                    {
                        Console.WriteLine("连接超时，服务器没有响应！");//连接失败
                        Console.ReadKey();
                        return false;
                    }
         
            }
    
    接收方：
    public static void receiveMessage()
            {
                TcpClient client = null;
                NetworkStream stream = null;
                byte[] buffer = null;
                string receiveString = null;
    
                string hostName = Dns.GetHostName();   //获取本机名
                IPHostEntry localhost = Dns.GetHostByName(hostName);
                IPAddress localIP = localhost.AddressList[0];
    
                int localPort = 61620;
                TcpListener listener = new TcpListener(localIP, localPort);//用本地IP和端口实例化Listener
                listener.Start();//开始监听
           
               
                while(true)
                { 
                    try
                    {
                        client = listener.AcceptTcpClient();//接受一个Client
                        buffer = new byte[client.ReceiveBufferSize];
                        stream = client.GetStream();//获取网络流
                        stream.Read(buffer, 0, buffer.Length);//读取网络流中的数据
                        stream.Close();//关闭流
                        client.Close();//关闭Client
                        receiveString = Encoding.GetEncoding("UTF-8").GetString(buffer).Trim('\0');//转换成字符串
                        if (receiveString != null && receiveString.Trim() != "")
                        {
                            Console.WriteLine(receiveString);
                            pushMessage.push(receiveString);
    
                        }
                    }
                    catch(Exception e)
                    {
                        logger.Error(e.Message);
                    }
    
    
               }
    
            }