networkstream read and write

本文关键字:write and read networkstream | 更新日期: 2023-09-27 18:28:54

祝一切顺利

我正在复习一些网络编程,以便用一个更大的应用程序来实现,但对于基础知识,我将在这个链接的帮助下创建一个简单的网络聊天服务器客户端应用程序

应该发生什么:

当接收到来自客户端的数据时,消息框弹出,显示一个带有端口的套接字连接到我的PC ip地址,但

问题:

显示发送的消息的消息框是空的(又名"),我不明白我做错了什么。

建议?

对此进行了研究,但我认为这不适合我的情况具有缓冲区的网络流

客户端(发送数据)

        const int _PORT = 80;
        public Form1()
        {
            InitializeComponent();
        }
        private void sendText(string _reciever_ip, string _MESSAGE)
        {
            TcpClient _sender = new TcpClient(_reciever_ip, _PORT);
            try
            {
                Stream s = _sender.GetStream();
                StreamWriter sw = new StreamWriter(s);
                sw.WriteLine(_MESSAGE);
                s.Close();
            }
            catch (Exception x)
            {
                MessageBox.Show(x.ToString());
            }
            _sender.Close();
        }
        private void button2_Click(object sender, EventArgs e)
        {
            sendText(inputT_IP.Text, inputT_Msg.Text);
        }

服务器(接收数据)

    const int _PORT = 80;
    static List<string> _ipaddress_list = new List<string>();
    public Form1()
    {
        InitializeComponent();
    }
    private void recieveText(string _IPADDRESS)
    {
        //open a listener for a tcp client, to the same for UDp client
        TcpListener _reciever_client = new     TcpListener(IPAddress.Parse(_IPADDRESS), _PORT); //how would you listen for a     connection from any port?
        _reciever_client.Start();
        while (true)
        {
            Socket _listener_socket = _reciever_client.AcceptSocket();
            try
            {
                MessageBox.Show("Recieving from : " +     _listener_socket.RemoteEndPoint.ToString());
                Stream _net_stream = new NetworkStream(_listener_socket);
                StreamReader sr = new StreamReader(_net_stream);
                MessageBox.Show(sr.ReadLine());
                //richTextBox1.AppendText();
            }
            catch (Exception x)
            {
                MessageBox.Show(x.ToString());
            }
            _listener_socket.Close();
        }
    }
    void GetLocalIPAddress()
    {
        var host = Dns.GetHostEntry(Dns.GetHostName());
        foreach (var ip in host.AddressList)
        {
            if (ip.AddressFamily == AddressFamily.InterNetwork)
            {
                _ipaddress_list.Add(ip.ToString());
            }
        }
    }
    private void button1_Click(object sender, EventArgs e)
    {
        GetLocalIPAddress();
        foreach (string item in _ipaddress_list)
        {
            (new Thread(() => recieveText(item))).Start();
        }
    }

networkstream read and write

StreamWriter缓冲写入,因此您的代码;

Stream s = _sender.GetStream();
StreamWriter sw = new StreamWriter(s);
sw.WriteLine(_MESSAGE);
s.Close();

实际写入StreamWriter的内存缓冲区,并在数据从StreamWriter传递到网络之前关闭套接字。

如果您关闭StreamWriter;

Stream s = _sender.GetStream();
StreamWriter sw = new StreamWriter(s);
sw.WriteLine(_MESSAGE);
sw.Close();

Close()实际上会将缓冲区刷新到基础套接字,然后在发送数据后关闭基础套接字。