Winforms、调用和有问题的按钮

Question

我正在尝试构建一个聊天，基本上我使用了调用函数什么是线程。
我能够读取服务器发送给我的内容，但我只能写入一次。我正在尝试完成此操作，但不确定每次服务器如何写入服务器：
（考虑到我之前在控制台应用程序表单中写过此内容并且服务器工作正常......即问题不在于服务器）。

public partial class Form1 : Form
{
    public Form1()
    {
        InitializeComponent();
        Button btn1 = new Button();
        btn1.Click += button1_Click;
    }
    StreamReader sr;
    StreamWriter sw;
    TcpClient connection;
    private void Form1_Load(object sender, EventArgs e)
    {
        connection = new TcpClient("127.0.0.1", 5000);
        sr = new StreamReader(connection.GetStream());
        sw = new StreamWriter(connection.GetStream());

    }

    private void button2_Click(object sender, EventArgs e)
    {

        Thread t2 = new Thread(Reader);
        t2.Start(connection);
    }

    string msg;
    public void Reader(object o)
    {

        TcpClient con = o as TcpClient;
        if (con == null)
            return;
        while (true)
        {
             msg = sr.ReadLine();

             Invoke(new Action(Output));
        }
    }

    public void Output()
    {
        ChatScreen.Text = msg;//set the message on the screen
    }
    string textinput;

    private void button1_Click(object sender, EventArgs e)
    {
        textinput = InputLine.Text;
        sw.WriteLine(textinput);// this thing, writes once, multiple clicks wont send a new line to the server :(..the problem is in this button
        sw.Flush();

    }


}

我想做的是连接按钮，以便它能够进行多次单击..例如 btn.Click()..或者在 WriteLine 上运行一个带有调用的线程（但我的直觉说，让按钮单击几次将使程序运行

Answer 1

当您关闭表单时，您需要停止线程进程，如果在尝试执行调用时不停止，它将失败，因为表单已被释放并且不能用于执行调用。您可以重写 dispose 方法来停止读取器线程，也可以在 onclose 方法上执行此操作。或者，您可以检查读取器进程，控制是否可用（未释放），如果不可用，则完成读取过程。

您应该防止读取器进程也被启动多次，以防止错误，因此您需要在线程运行时禁用该按钮。

编辑：

您可以使用类似以下代码的内容来读取多行并在关闭表单时停止线程。

   private bool mbIsRunning = true;

   private void Form1_Closing(object sender, System.ComponentModel.CancelEventArgs e)
   {
      lock (this)
      {
         mbIsRunning= false;
      }
   }

   private bool IsRunning
   {
        get
        { 
            lock(this)
            {
                return mbIsRunning;
            }
        }
    }


    string msg;
    public void Reader(object o)
    {

        TcpClient con = o as TcpClient;
        if (con == null)
            return;
        while (IsRunning)
        {
             msg = reader.ReadLine(); 
             string line;
             while( (line = reader.ReadLine()) != null )
             {
                msg = msg + Enviroment.NewLine + line;
             }

             Invoke(new Action(Output));
        }
    }

Answer 2

运行你的代码，我收到一堆错误 - 来自 TcpClient 抛出异常等等。
但是，假设您尚未发布所有代码，我建议您在所有函数周围放置一个 try...catch，然后在 catch 中设置断点以查看问题所在。检查异常 - 异常应该只在特殊情况下抛出 - 所以你的代码应该在不这样做的情况下真正工作。

Answer 3

我在我的服务器代码上进行连接：

    using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.IO;
using System.Threading;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            TcpListener server = new TcpListener(IPAddress.Any, 5000);
            server.Start();
            Console.WriteLine("Server started");
            string word = "";
            savedObject saved = new savedObject();

            while (true)
            {
                TcpClient connection = server.AcceptTcpClient();
                Console.WriteLine("connection accepted");
                ThreadPool.QueueUserWorkItem(saved.ProssecClient, connection);
            }
        }
    }
}





class savedObject
{
    Dictionary<string, StreamWriter> dic = new Dictionary<string, StreamWriter>();
    StreamReader[] sr1 = new StreamReader[100];
    StreamWriter[] sw1 = new StreamWriter[100];
    string[] name = new string[100];
    int m;
    int a;
    int g;
    string word;

    public string AllWords(string sit)
    {
        word += sit + "  ";// here i concat them
        return word;
    }


    public string word2()
    {
        return word;
    }



    public void ProssecClient(object o)
    {


        TcpClient connection = o as TcpClient;
        if (connection == null)
        {
            return;
        }
        StreamReader sr = new StreamReader(connection.GetStream());
        StreamWriter sw = new StreamWriter(connection.GetStream());
        sr1[a++] = new StreamReader(connection.GetStream());
        sw1[m++] = new StreamWriter(connection.GetStream());
        string word2 = "";
        sw.WriteLine("Please, fill your name: ");
        name[g++] = sr.ReadLine();

        if (name[g] != null && sw1[m] != null)
        {
            dic.Add(name[g], sw1[m]);
        }
        try
        {
            while (true)
            {
                int i = 0;
                word2 = AllWords(sr.ReadLine());

                for (i = 0; i < 3; i++)
                {
                    if (sw1[i] != null)
                    {
                        sw1[i].WriteLine( name[i] + ":  " + word2);// here is the words that are sent..

                        sw1[i].Flush();

                    }

                }

            }
        }
        catch { Console.WriteLine("client left"); }
    }

}