Я пытаюсь написать небольшую программу, построенную из сервера и некоторых клиентов. сервер будет передавать / отправлять текстовое сообщение клиентам (клиенту не разрешено отправлять обратно на сервер, все клиенты должны получать одно и то же текстовое сообщение с сервера). Я видел здесь несколько вопросов по этому вопросу и по сети, но не нашел точного решения, которое я ищу. большинство решений заключалось в создании потока для каждого клиента. но давайте предположим, что я не всегда знаю, сколько клиентов будут слушать в определенное время. может быть 2, а может быть 30. Я знаю, что есть способ создать пул потоков и позволить .NET справиться с назначением потоков, но у меня никогда не было хорошей практики с этим, и мои знания о многопоточности никуда не годятся. на данный момент у меня есть простая программа Sever to Client, которая работает, как и ожидалось, но опять же, только с одним клиентом. так вот мой код:
Сервер:
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows;
namespace NetMessageServerWpf
{
public partial class MainWindow : Window
{
TcpClient client;
public MainWindow()
{
InitializeComponent();
this.tcpListener = new TcpListener(IPAddress.Any, 3000);
this.listenThread = new Thread(new ThreadStart(ListenForClients));
this.listenThread.Start();
}
private void btnSend_Click(object sender, RoutedEventArgs e)
{
if(client == null || !client.Connected)
client = this.tcpListener.AcceptTcpClient();
msg = txtMessage.Text;
SendTCP(client);
}
public TcpListener tcpListener;
public Thread listenThread;
private string msg;
private void ListenForClients()
{
this.tcpListener.Start();
}
public void SendTCP(TcpClient tcpClient)
{
NetworkStream clientStream = tcpClient.GetStream();
ASCIIEncoding encoder = new ASCIIEncoding();
byte[] buffer = encoder.GetBytes(this.msg);
clientStream.Write(buffer, 0, buffer.Length);
clientStream.Flush();
}
}
}
Клиент:
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
namespace NetClientSideWpf
{
class Client : Base
{
private string messageString;
public string MessageString
{
get { return messageString; }
set
{
messageString = value;
OnPropertyChanged("MessageString");
}
}
public Client()
{
ConnectToServer();
}
public void ConnectToServer()
{
TcpClient client = new TcpClient();
IPEndPoint serverEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 3000);
client.Connect(serverEndPoint);
NetworkStream clientStream = client.GetStream();
Thread ServerThread = new Thread(new ParameterizedThreadStart(HandleClientComm));
ServerThread.Start(client);
}
private void HandleClientComm(object client)
{
TcpClient tcpClient = (TcpClient)client;
NetworkStream clientStream = tcpClient.GetStream();
byte[] message = new byte[4096];
int bytesRead;
while (true)
{
bytesRead = 0;
try
{
bytesRead = clientStream.Read(message, 0, 4096);
}
catch
{
break;
}
if (bytesRead == 0)
{
break;
}
ASCIIEncoding encoder = new ASCIIEncoding();
MessageString = encoder.GetString(message, 0, bytesRead);
}
}
}
}
любая помощь сделает! :)