如何向多线程聊天服务器中的所有客户端发送消息？

Question

很抱歉一遍又一遍地询问“相同”的事情。这是聊天的另一个版本。经过大量搜索，我终于找到了如何将客户列表（或至少我希望如此）传递给 Chat 函数。

但是我不知道这是否应该工作：

每次客户端连接时：

clients.Add(clientSocket);

var ctThread = new System.Threading.Thread(() => Chat(clients));

Chat 函数希望通过

正确接收客户端

public void Chat(List<TcpClient> clients)

然后写出来

 foreach (var client in clients)
    {
        writer.Write(message);
    } 

客户端有 2 个线程（不确定它们是否可以同时读/写）

    Thread ctThread = new Thread(Write);
    Thread ctThread2 = new Thread(Read);
    ctThread2.Start();
    ctThread.Start();

我是否正确地将客户列表传递给函数？它实际上可以正确发送消息吗？因为现在服务器没有响应我在客户端输入的任何内容。

完整代码：

服务器

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

namespace MultiServeris
{
    class Multiserveris
    {
        static void Main(string[] args)
        {
            TcpListener ServerSocket = new TcpListener(1000);         
            ServerSocket.Start();                                     
            List<TcpClient> clients = new List<TcpClient>();
            Console.WriteLine("Server started.");
            while (true)
            {
                TcpClient clientSocket = ServerSocket.AcceptTcpClient();
                handleClient client = new handleClient();
                clients.Add(clientSocket);
                client.startClient(clientSocket,clients);
            }
        }
    }

    public class handleClient
    {
        TcpClient clientSocket;                                 
        public void startClient(TcpClient inClientSocket, List<TcpClient> clients)
        {
            this.clientSocket = inClientSocket;
            var ctThread = new System.Threading.Thread(() => Chat(clients)); 
        }

        public void Chat(List<TcpClient> clients)
        {
            BinaryReader reader = new BinaryReader(clientSocket.GetStream());
            BinaryWriter writer = new BinaryWriter(clientSocket.GetStream());
            while (true)
            {
                string message = reader.ReadString();
                foreach (var client in clients)
                {
                    writer.Write(message);
                } 
            }
        }
    }
}

客户

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


namespace Klientas
{
    class Klientas
    {
        public static void Write()
        {
            while (true)
            {
                TcpClient clientSocket = new TcpClient("localhost", 1000);
                string str = Console.ReadLine();
                BinaryWriter writer = new BinaryWriter(clientSocket.GetStream());
                writer.Write(str);
            }
        }
        public static void Read()
        {
            while (true)
            {
                TcpClient clientSocket = new TcpClient("localhost", 1000);
                BinaryReader reader = new BinaryReader(clientSocket.GetStream());
                string message = reader.ReadString();
                Console.WriteLine(message);
            }
        }

        static void Main(string[] args){
            Thread ctThread = new Thread(Write);
            Thread ctThread2 = new Thread(Read);
            ctThread2.Start();
            ctThread.Start();
           }
    }
}

Answer 1

TCP 不是为广播而设计的，这就是为什么您必须遍历所有客户端的原因。更好的方法是使用支持广播的协议，使用 SignalR 框架，或者如果您希望裸机访问使用 UDP。这是一个很棒的 SignalR 聊天示例。

https://dhavalupadhyaya.wordpress.com/tag/signalr-chat-example/