c# - UDP ソケット ReceiveFrom()

Question

多くの失敗した調査の後、私はこのフォーラムに助けを求めました。

私は複数のクライアント udp サーバーを作成することを計画していますが、私の渇望は、クライアントごとに 1 つのスレッドをブロック メソッドで持つことでした: reciveFrom()。サーバーに送信されたデータを見逃さないため。

受信したデータをリストに追加し、再度データを受信するテストサーバーを作成しました。これは、データが失われるかどうかを確認するためのテストです。

テスト クライアントは、異なるデータを持つ 6 つのソケットで構成されています。ユーザーが「すべて送信」ボタンをクリックすると、サーバーにデータが送信されます。このボタンは、クライアントとその senddata メソッドを繰り返す foreach にリンクしています。このボタンを約 6 回押しますが、サーバー リストはメッセージを 1 つも見逃すことはありません。

私の質問は、reciveFrom() メソッドが非常に高速であるため、データが欠落していることを確認するためにクライアントに複数のスレッドが必要であるか、またはこの reciveFrom() メソッドは完璧であり、すべてのパケットを取得しますか?

namespace TestServer
{
    class Server
    {
        List<Data> storage = new List<Data>();

        public Server()
        {
            byte[] data = new byte[1024];
            int recv;

            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
            IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 9050);
            socket.Bind(ipep);

            IPEndPoint sender = new IPEndPoint(IPAddress.Any,0);
            EndPoint remote = (EndPoint)sender;

            while (1==1)
            {
                data = new byte[1024];
                recv = socket.ReceiveFrom(data, ref remote);
                storage.Add(new Data(recv,data));

            }  
        }
    }

    struct Data
    {
        int recv;
        byte[] data;

        public Data(int recv, byte[] data)
        {
            this.recv = recv;
            this.data = data;
        }
    }
}

///////////////////////////////////クライアント////////////// ////////////////////////

public partial class Form1 : Form
{
    Client[] clients = new Client[6];
    TextBox[] txtServerPort = new TextBox[6];
    TextBox[] txtServerIP = new TextBox[6];

    public Form1()
    {
        InitializeComponent();

        clients[0] = new Client();
        clients[1] = new Client();
        clients[2] = new Client();
        clients[3] = new Client();
        clients[4] = new Client();
        clients[5] = new Client();

        txtServerPort[0] = txtServerPortClient1;
        txtServerPort[1] = txtServerPortClient2;
        txtServerPort[2] = txtServerPortClient3;
        txtServerPort[3] = txtServerPortClient4;
        txtServerPort[4] = txtServerPortClient5;
        txtServerPort[5] = txtServerPortClient6;

        txtServerIP[0] = txtServerIPClient1;
        txtServerIP[1] = txtServerIPClient2;
        txtServerIP[2] = txtServerIPClient3;
        txtServerIP[3] = txtServerIPClient4;
        txtServerIP[4] = txtServerIPClient5;
        txtServerIP[5] = txtServerIPClient6;

    }

    private void btnSendDataClient1_Click(object sender, EventArgs e)
    {
        clients[0].SendData();
    }

    private void btnSendDataClient2_Click(object sender, EventArgs e)
    {
        clients[1].SendData();
    }

    private void btnSendDataClient3_Click(object sender, EventArgs e)
    {
        clients[2].SendData();
    }

    private void btnSendDataClient4_Click(object sender, EventArgs e)
    {
        clients[3].SendData();
    }

    private void btnSendDataClient5_Click(object sender, EventArgs e)
    {
        clients[4].SendData();
    }

    private void btnSendDataClient6_Click(object sender, EventArgs e)
    {
        clients[5].SendData();
    }
    private void btnClientsSendData_Click(object sender, EventArgs e)
    {
        foreach (Client c in clients)
        {
            c.SendData();
        }
    }

    private void txtServerIPClient1_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(0);
    }
    private void txtServerIPClient2_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(1);
    }
    private void txtServerIPClient3_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(2);
    }
    private void txtServerIPClient4_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(3);
    }
    private void txtServerIPClient5_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(4);
    }
    private void txtServerIPClient6_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(5);
    }


    private void txtServerPortClient1_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(0);
    }
    private void txtServerPortClient2_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(1);
    }

    private void txtServerPortClient3_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(2);
    }

    private void txtServerPortClient4_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(3);
    }

    private void txtServerPortClient5_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(4);
    }

    private void txtServerPortClient6_TextChanged(object sender, EventArgs e)
    {
        UpdateServerInformation(5);
    }


    private void UpdateServerInformation(int index)
    {
        if (txtServerPort[index].Text.Length > 0)
        {
            if (txtServerIP[index].Text.Length > 0)
            {
                clients[index].SetServer(txtServerIP[index].Text, int.Parse(txtServerPort[index].Text));
            }
        }

    }


    private void txtDataClient1_TextChanged(object sender, EventArgs e)
    {
        clients[0].SetData(txtDataClient1.Text);
    }

    private void txtDataClient2_TextChanged(object sender, EventArgs e)
    {
        clients[1].SetData(txtDataClient2.Text);
    }

    private void txtDataClient3_TextChanged(object sender, EventArgs e)
    {
        clients[2].SetData(txtDataClient3.Text);
    }

    private void txtDataClient4_TextChanged(object sender, EventArgs e)
    {
        clients[3].SetData(txtDataClient4.Text);
    }

    private void txtDataClient5_TextChanged(object sender, EventArgs e)
    {
        clients[4].SetData(txtDataClient5.Text);
    }

    private void txtDataClient6_TextChanged(object sender, EventArgs e)
    {
        clients[5].SetData(txtDataClient6.Text);
    }






}

struct ServerInformation
{
    IPEndPoint ipep;

    public ServerInformation(string ip, int port)
    {
        ipep = new IPEndPoint(IPAddress.Parse(ip), port);
    }

    public IPEndPoint GetIPEndPoint()
    {
        return ipep;
    }
}

class Client
{
    ServerInformation server;
    Socket socket;

    byte[] data;

    public Client() 
    { 
        this.data = new byte[1024]; socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); 
    }

    public void SetServer(string ip, int port)
    {
        server = new ServerInformation(ip, port);
    }

    public void SetData(string data)
    {
        this.data = new byte[1024];
        this.data = Encoding.ASCII.GetBytes(data);
    }

    public void SendData()
    {
        socket.SendTo(data,data.Length,SocketFlags.None, server.GetIPEndPoint());
    }

}