c# - 我将如何持续监听带有 GUI 的端口？

Question

我正在尝试学习 TCP 服务器/客户端交互。我想知道如何使用 GUI 一直监听端口。目前我正在使用这段代码:

    private void Form1_Load(object sender, EventArgs e)
    {
        CreateServer();
    }

    void CreateServer()
    {
        TcpListener tcp = new TcpListener(25565);
        tcp.Start();

        Thread t = new Thread(() =>
        {

            while (true)
            {
                var tcpClient = tcp.AcceptTcpClient();

                ThreadPool.QueueUserWorkItem((_) =>
                {
                    Socket s = tcp.AcceptSocket();
                    
                    console.Invoke((MethodInvoker)delegate { console.Text += "Connection esatblished: " + s.RemoteEndPoint + Environment.NewLine; });

                    byte[] b = new byte[100];
                    int k = s.Receive(b);


                    for (int i = 0; i < k; i++)
                    {
                        console.Text += Convert.ToChar(b[i]);
                        incoming += Convert.ToChar(b[i]);
                    }

                    MessageBox.Show(incoming);

                    console.Invoke((MethodInvoker)delegate { console.Text += incoming + Environment.NewLine; });

                    list.Invoke((MethodInvoker)delegate { list.Items.Add(incoming); });

                    ASCIIEncoding asen = new ASCIIEncoding();
                    s.Send(asen.GetBytes("\n"));

                    tcpClient.Close();
                }, null);
            }
        });
        t.IsBackground = true;
        t.Start();
    }

如有任何帮助，我们将不胜感激。

Answer 1

简短回答 - 在单独的线程/任务 (TPL) 中运行 TCP 监听器。 对于完整的工作解决方案，您还必须使用特殊技术将对 UI 的任何更改从单独的线程分派(dispatch)到主线程，这取决于您使用的框架，我的意思是 WPF/WinForms/whatever。

下面的代码很适合我。阅读之前的 TODO 部分。

待办事项:

• 添加到表单文本框、列表框、按钮，公开:

  public System.Windows.Forms.TextBox console;
  public System.Windows.Forms.ListBox incommingMessages;
  private System.Windows.Forms.Button sendSampleDataButton;
  

---

入口点:

private static Form1 form;

[STAThread]
static void Main()
{
    Application.EnableVisualStyles();
    Application.SetCompatibleTextRenderingDefault(false);

    form = new Form1();
    form.Load += OnFormLoad;
    Application.Run(form);
}

private static void OnFormLoad(object sender, EventArgs e)
{
    CreateServer();
}

---

服务器:

private static void CreateServer()
{
    var tcp = new TcpListener(IPAddress.Any, 25565);
    tcp.Start();

    var listeningThread = new Thread(() =>
    {
        while (true)
        {
            var tcpClient = tcp.AcceptTcpClient();
            ThreadPool.QueueUserWorkItem(param =>                                                            
            {                        
                NetworkStream stream = tcpClient.GetStream();
                string incomming;                        
                byte[] bytes = new byte[1024];
                int i = stream.Read(bytes, 0, bytes.Length);                                                
                incomming = System.Text.Encoding.ASCII.GetString(bytes, 0, i);
                form.console.Invoke(
                (MethodInvoker)delegate
                    {
                        form.console.Text += String.Format(
                            "{0} Connection esatblished: {1}{2}", 
                            DateTime.Now,
                            tcpClient.Client.RemoteEndPoint,
                            Environment.NewLine);
                    });

                MessageBox.Show(String.Format("Received: {0}", incomming));
                form.incommingMessages.Invoke((MethodInvoker)(() => form.incommingMessages.Items.Add(incomming)));
                tcpClient.Close();
            }, null);
        }
    });

    listeningThread.IsBackground = true;
    listeningThread.Start();
}

---

客户端

private void button1_Click(object sender, EventArgs e)
{
    Connect("localhost", "hello localhost " + Guid.NewGuid());
}

static void Connect(String server, String message)
{
    try
    {               
        Int32 port = 25565;
        TcpClient client = new TcpClient(server, port);             
        Byte[] data = System.Text.Encoding.ASCII.GetBytes(message);
        NetworkStream stream = client.GetStream();

        // Send the message to the connected TcpServer. 
        stream.Write(data, 0, data.Length);                                
        stream.Close();
        client.Close();
    }
    catch (ArgumentNullException e)
    {
        Debug.WriteLine("ArgumentNullException: {0}", e);
    }
    catch (SocketException e)
    {
        Debug.WriteLine("SocketException: {0}", e);
    }          
}

---

截图: