1

私のサーバークラス:

namespace Net_Send_File
{
    class Server
    {


        private TcpListener listener;
        private IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 15550);
        private bool active;
        string  arg;
       // private Socket xxx;

        public Server()
        {
            Console.Clear();
            Console.Title = "Server";
            Main();
        }

        private void Main()
        {
            listener = new TcpListener(ipep);

            try
            {
                listener.Start();
                active = true;

                ListenForConnections();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                Console.ReadLine();

            }
        }

        private void ListenForConnections()
        {
            Console.Clear();
            Console.WriteLine("Listening for connections...");

            while (active)
            {
                TcpClient client = listener.AcceptTcpClient();
                Console.BackgroundColor = ConsoleColor.Green;
                Console.WriteLine("Connection @ {0}", TCPIP(client));

                new Thread(new ParameterizedThreadStart(HandleClientData)).Start(client);

            }
        }

        private void HandleClientData(object _c)
        {
            TcpClient c = (TcpClient)_c;
            string ipaddr = TCPIP(c);

            NetworkStream s = c.GetStream();
            // I tried this byte[] buffer = new byte[c.ReceiveBufferSize]; It throws an Exeption. 
            byte[] buffer = new byte[1024];

            int bytesRead;

            while (active)
            {
                bytesRead = 0;

                try
                {

                        bytesRead = s.Read(buffer, 0, buffer.Length/2);

                }
                catch (Exception ex)
                {
                    Console.WriteLine("Socket error @ {0}:\r\n{1}", ipaddr, ex.Message);
                    Console.ReadLine();
                    break;
                }

                if (bytesRead == 0)
                {
                    Console.BackgroundColor = ConsoleColor.Red;
                    Console.WriteLine("Disconnected @ {0}", ipaddr);
                    //new Thread(new ParameterizedThreadStart.ListenForConnections);
                    break;
                }

                string dataStr = Encoding.ASCII.GetString(buffer, 0, buffer.Length);

                using (var fs = File.OpenWrite("test.txt"))
                {
                    fs.Write(buffer, 0, buffer.Length);
                    fs.Close();
                }
            }
        }

        private string TCPIP(TcpClient c)
        {
            return ((IPEndPoint)c.Client.RemoteEndPoint).Address.ToString();
        }

    };

私のクライアントクラス:

        class Client
    {
        private TcpClient client;
       // private TcpClient client1;
        private IPEndPoint ipep;
        private int port;


        public Client()
        {
            Console.Clear();
            Console.Title = "Client";
            bool error = false;

            while (true)
            {
                Console.WriteLine("IPEndPoint: ");
                string input = Console.ReadLine();

                if (!input.Contains(':'))
                {
                    Console.WriteLine("IPEndPoint in bad format");
                    break;
                }

                string[] s1 = input.Split(':');
                IPAddress ipaddr;

                if (!IPAddress.TryParse(s1[0], out ipaddr) || !int.TryParse(s1[1], out port))
                {
                    Console.WriteLine("IPEndPoint in bad format");
                    Console.ReadLine();
                    error = true;
                    break;
                }

                ipep = new IPEndPoint(ipaddr, port);

                try
                {
                    client = new TcpClient();
                    client.Connect(ipep);
                    Console.WriteLine("client 1 is Ready!");

                    //client1 = new TcpClient();
                    //client1.Connect(ipep);
                    //Console.WriteLine("client 2 is Ready!");
                }
                catch (Exception ex)
                {
                    Console.WriteLine("Unable to connect\r\nReason: {0}", ex.Message);
                    Console.ReadLine();
                    error = true;
                }

                break;
            }

            while (!error)
            {
                Console.Clear();
                Console.WriteLine("File path: ");
                string filePath = Console.ReadLine();

                if (File.Exists(filePath) == false)
                {
                    Console.WriteLine("File does not exist\r\nPress ENTER to try again");
                    Console.ReadLine();
                }

                byte[] buffer;
                using (var fs = File.OpenRead(filePath))
                {
                    buffer = new byte[fs.Length];
                    fs.Read(buffer, 0, buffer.Length);
                    Int64 a = client.SendBufferSize; ;
                    fs.Close();
                }

                if (SendData(buffer))
                {
               // client.SendBufferSize(buffer);

                    //int a = client.SendBufferSize; ;

                    Console.WriteLine("File sent\r\nFile size: {0} KB", (buffer.Length / 1024));


                    //a.SetLength((buffer.Length / 1024));

                    Console.ReadLine();
                }

                break;
            }
        }

        private bool SendData(byte[] data)
        {
            try
            {
                using (NetworkStream ns = client.GetStream())
                {
                    ns.Write(data, 0, data.Length);
                    ns.Close();
                }

                return true;
            }
            catch (Exception ex)
            {
                Console.WriteLine("Unable to send file\r\nReason: {0}\r\nDetailed:\r\n{1}", ex.Message, ex.ToString());
                Console.ReadLine();

                return false;
            }
        }
    }

}
}

まず第一に、私のコードがひどくコメントされていることをお詫び申し上げます。または、正直に言うと、ほとんどコメントはありません。

サーバークラス、と呼ばれるメソッドの下にprivate void HandleClient Data(object _)バッファがあります。バッファはバイト[1024]に設定されています。クライアントから (テスト ファイルの) bufferSize を受信したい場合は、Server buffer = を ClientBuffer に設定し、その後ファイルを受信します。私は60MBのテストファイルを持っています。クライアントからサーバーにバッファ サイズを送信しようとしましたが、うまくいきません。誰かが私にできることとその方法を教えてもらえますか?

前もって感謝します

4

1 に答える 1