我正在尝试学习 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();
    }
任何帮助将不胜感激。

最佳答案

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

下面的代码对我有用。之前阅读 TODO 部分。

去做:

  • 加入表单Textbox、ListBox、Button,公开:
    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);
        }
    }
    

    截图:

    关于c# - 我将如何持续监听带有 GUI 的端口?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/9533013/

    10-09 06:14
    查看更多