C# 如何将多个客户端连接到同一台服务器？

Question

我在客户端服务器端工作，对 .net 和 C# 不太熟悉，想知道如何将多个客户端连接到同一台服务器。如果可以的话，我宁愿继续使用 TcpClient。

    using System;
    using System.Collections.Generic;
    using System.ComponentModel;
    using System.Data;
    using System.Drawing;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using System.Windows.Forms;
    using System.Net;
    using System.Net.Sockets;
    using System.IO;
    using Microsoft.VisualBasic;
    using System.Runtime.Serialization.Formatters.Binary;
    using System.Threading;

  namespace TFServerClient
   {
      public partial class Form1 : Form
    {
      private TcpClient client;
      public StreamReader STR;
      public StreamWriter STW;
      public string receive;
      public String text_to_send;
      TcpListener listener;

    public Form1()
    {
        InitializeComponent();

        IPAddress[] localIP = Dns.GetHostAddresses(Dns.GetHostName()); //gets my IP
        foreach(IPAddress address in localIP)
        {
            if(address.AddressFamily == AddressFamily.InterNetwork)
            {
                txtIPServer.Text = address.ToString();
            }
        }
    }

    private void btnStartServer_Click(object sender, EventArgs e)
    {
        ListenBackground.RunWorkerAsync();
    }

    private void ReceiveData_DoWork(object sender, DoWorkEventArgs e)
    {
        while(client.Connected)
        {
            try
            {
                receive = STR.ReadLine();
                this.txtChat.Invoke(new MethodInvoker(delegate () { txtChat.AppendText("You: " + receive + "\n"); }));
                receive = "";
            }
            catch (Exception x)
            {
                MessageBox.Show(x.Message.ToString());
            }
        }
    }

    private void SendData_DoWork(object sender, DoWorkEventArgs e)
    {
        if(client.Connected)
        {
            STW.WriteLine(text_to_send);
            this.txtChat.Invoke(new MethodInvoker(delegate () { txtChat.AppendText("Me: " + text_to_send + "\n"); }));
        }
        else
        {
            MessageBox.Show("Send failed");
        }
        SendData.CancelAsync();
    }

    private async void ListenBackground_DoWork(object sender, DoWorkEventArgs e)
    {
        this.txtChat.Invoke(new MethodInvoker(delegate () { txtChat.AppendText("Awaiting Connection...\n"); }));
        client = listener.AcceptTcpClient();
        this.txtChat.Invoke(new MethodInvoker(delegate () { txtChat.AppendText("Client Connected.\n"); }));
        STR = new StreamReader(client.GetStream());
        STW = new StreamWriter(client.GetStream());
        STW.AutoFlush = true;

        ReceiveData.RunWorkerAsync(); //Start recieving data in background
        SendData.WorkerSupportsCancellation = true; //able to cancel thread
    }

    private void btnConnect_Click(object sender, EventArgs e)
    {
        client = new TcpClient();
        IPEndPoint IP_End = new IPEndPoint(IPAddress.Parse(txtIPClient.Text), int.Parse(txtPortClient.Text));

        try {
            client.Connect(IP_End);
            if(client.Connected)
            {
                txtChat.AppendText("Connected To Server " + "\n");
                STW = new StreamWriter(client.GetStream());
                STR = new StreamReader(client.GetStream());
                STW.AutoFlush = true;

                ReceiveData.RunWorkerAsync(); //Start recieving data in background
                SendData.WorkerSupportsCancellation = true; //able to cancel thread
            }
        } catch(Exception x)
        {
            MessageBox.Show(x.Message.ToString());
        }
    }

    private void btnSend_Click(object sender, EventArgs e)
    {
        if(txtMessage.Text != "")
        {
            text_to_send = txtMessage.Text;
            SendData.RunWorkerAsync();
        }
        txtMessage.Text = "";
    }
}
}

Answer 1

听起来您只需要对服务器端代码进行多线程处理，类似于以下内容：

listener = new TcpListener(ipAddress, portNumber);
listener.Start();

while (true)
{
    var client = listener.AcceptTcpClient();
    var thread = new Thread(new ThreadStart(() => SOME ACTION));
}

传递给 ThreadStart 构造函数的委托将处理创建流读取器和流写入器。它还应该执行您想要执行的任何服务器端业务逻辑。

AcceptTcpClient 方法是一种阻塞方法，因此只有在每次收到来自客户端的 TCP 请求时才会创建一个新的 Thread 实例。

可以找到此类操作的示例：

Here@csharp.net-informations.com

Here@codeproject.com

警告：在 codeproject.com 查看与文章相关的下载内容即表示您同意服务条款和文章的许可。许可证是代码项目开放许可证 (CPOL)

Answer 2

有一个非常棒的免费库，名为 NetSockets，您可以使用它。 (https://netsockets.codeplex.com/)

该库是 TCP 和多线程的，这里是如何使用它：

• 服务器端：

创建服务器：

static NetObjectServer server = new NetObjectServer();

启动服务器：

server.Start(IPAddress.Any, 7482);

事件处理程序：

server.OnClientAccepted += server_OnClientAccepted;

server.OnClientConnected += server_OnClientConnected;

server.OnClientDisconnected += server_OnClientDisconnected;

server.OnClientRejected += server_OnClientRejected;

server.OnReceived += server_OnReceived;

server.OnStarted += server_OnStarted;

server.OnStopped += server_OnStopped;

• 客户端：

创建客户端：

static readonly NetObjectClient client = new NetObjectClient();

事件处理程序：

client.OnConnected += client_OnConnected;

client.OnDisconnected += client_OnDisconnected;

client.OnReceived += client_OnReceived;

连接：

client.TryConnect("127.0.0.1",7482);

此信息取自 Joseph Bisaillon 的博客 (http://www.josephbisaillon.com/)