2

アプリケーションを他のスレッドで同期的に実行すると、アプリケーションが非同期的に文字列を取得するのではないかと考えています。

実際には、BeginSend/BeginReceive の使用方法がわからないので、異なるスレッドで socket.Send(...)、socket.Receive(...) を使用して、アプリケーションで非同期接続をシミュレートします。

ところで、文字列がバッファのサイズよりも大きい場合はどうなりますか? クライアントにはtelnetを使用しましたが、telnetは実際にはキーボードから文字列を取得するとすぐに送信するため、実際にバッファーのサイズを超えることはできませんが、完全な文字列を送信する別のクライアントを使用した場合はどうなりますか? バッファが許可するよりも多く送信したことをプログラムに伝える方法はありますか ( recvsocketReceive の結果である変数を介して)。

コード：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Runtime.Remoting.Messaging;

namespace CSharp_Console_Application
{
    class Program
    {
        delegate Socket GetClients();
        static GetClients newClients;
        static List<Socket> clients;

        static ManualResetEvent allDone = new ManualResetEvent(false);

        static void Main(string[] args)
        {
            IPEndPoint serverIPEP = new IPEndPoint(IPAddress.Any, 9080);
            Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            serverSocket.Bind(serverIPEP);
            serverSocket.Listen(10);

            Console.WriteLine("Waiting for connections...");

            clients = new List<Socket>();

            newClients = () =>
                {
                    Socket clientSocket = serverSocket.Accept();
                    IPEndPoint clientIPEP = (IPEndPoint)clientSocket.RemoteEndPoint;

                    Console.WriteLine("Connected to {0}.", clientIPEP);

                    clients.Add(clientSocket);

                    SendString("Welcome to my server!", clientSocket);
                    return clientSocket;
                };

            while (true)
            {
                allDone.Reset();

                newClients.BeginInvoke((itfAR) =>
                    {
                        allDone.Set();

                        AsyncResult ar = (AsyncResult)itfAR;
                        GetClients invokedDelegate = (GetClients) ar.AsyncDelegate;

                        Socket clientSocket = invokedDelegate.EndInvoke(itfAR);
                        IPEndPoint clientIPEP = (IPEndPoint)clientSocket.RemoteEndPoint;

                        Console.WriteLine("Sent 'Welcome!' to {0}.", clientIPEP);

                        string currentString = "";
                        while (true)
                        {
                            currentString += ReceiveString(clientSocket);
                            if (currentString.Contains('\n'))
                            {
                                Console.Write(clientIPEP + " said: " + currentString);

                                List<Socket> clientsWithoutThis = new List<Socket>();
                                clientsWithoutThis.AddRange(clients);
                                clientsWithoutThis.Remove(clientSocket);
                                SendToAll(clientsWithoutThis, currentString);

                                currentString = "";
                            }
                        }
                    },
                    null);

                allDone.WaitOne();
            }
        }

        static void SendToAll(List<Socket> clients, string message)
        {
            byte[] data = new byte[1024];
            clients.ForEach(clientSocket =>
                {
                    IPEndPoint clientIPEP = (IPEndPoint)clientSocket.RemoteEndPoint;
                    data = Encoding.ASCII.GetBytes(clientIPEP + " said: " + message + "\r");
                    clientSocket.Send(data, data.Length, SocketFlags.None);
                });
        }

        static void SendString(string message, Socket clientSocket)
        {
            byte[] data = new byte[1024];
            data = Encoding.ASCII.GetBytes(message + "\n\r");
            clientSocket.Send(data, data.Length, SocketFlags.None);
        }

        static string ReceiveString(Socket clientSocket)
        {
            byte[] data = new byte[1024];
            int recv = clientSocket.Receive(data, data.Length, SocketFlags.None);

            if (recv < 1)
                return null;

            string receivedString = Encoding.ASCII.GetString(data, 0, recv);
            return receivedString;
        }
    }
}
4

1 に答える 1

0

このように、あなたManualResetEventは役に立たない傾向があります。メイン スレッドをブロックするとすぐにBeginInvoke、set(). そして、もう一度リセットして待機状態に設定しますが、別のBeginInvoke呼び出しがコードのブロックを解除し、他の呼び出しがBeginInvokeまだ実行されている可能性があります。したがって、最終的に複数の BeginInvoke スレッドが発生し、最終的には複数の例外またはメモリ不足エラーが発生します。

于 2013-06-26T10:57:19.723 に答える