отправлять видео файлы на сервер с нескольких клиентов - PullRequest
Новая
       25

отправлять видео файлы на сервер с нескольких клиентов

1 голос
/ 07 декабря 2011

Я использую этот код клиент / сервер, который я нашел в сети для связи:

клиент: 

    public void Send(string name, string path)
    {
        try
        {
            IPAddress[] ipAddress = Dns.GetHostAddresses("address");
            IPEndPoint ipEnd = new IPEndPoint(ipAddress[0], 5656);
            Socket clientSock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP);

            string fileName = "somefile";
            string filePath = path;
            byte[] fileNameByte = Encoding.ASCII.GetBytes(fileName);

            byte[] fileData = File.ReadAllBytes(System.IO.Path.Combine(filePath, fileName)); 
            byte[] clientData = new byte[4 + fileNameByte.Length + fileData.Length];
            byte[] fileNameLen = BitConverter.GetBytes(fileNameByte.Length);

            fileNameLen.CopyTo(clientData, 0);
            fileNameByte.CopyTo(clientData, 4);
            fileData.CopyTo(clientData, 4 + fileNameByte.Length);

            clientSock.Connect(ipEnd);
            clientSock.Send(clientData);
            MessageBox.Show("file has been send: " + fileName);

            clientSock.Close();
        }
        catch (Exception ex)
        {
            Console.WriteLine("File Sending fail." + ex.Message);
        }
    }

Сервер: 

public void Receive()
    {
        try
        {
            lblInfo.Content = "That program can transfer small file. I've test up to 850kb file";
            IPEndPoint ipEnd = new IPEndPoint(IPAddress.Any, 5656);
            Socket sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP);
            sock.Bind(ipEnd);
            sock.Listen(100);
            Socket clientSock = sock.Accept();
            // 1024 * 25.000 = 25mb max that can be received at once with this program.
            byte[] clientData = new byte[1024 * 25000];
            string receivedPath = Environment.GetFolderPath(Environment.SpecialFolder.DesktopDirectory) + "\\";

            int receivedBytesLen = clientSock.Receive(clientData);

            int fileNameLen = BitConverter.ToInt32(clientData, 0);
            string fileName = Encoding.ASCII.GetString(clientData, 4, fileNameLen);

            lblInfo.Content = "Client: connected & File started received.";

            BinaryWriter bWrite = new BinaryWriter(File.Open(receivedPath + fileName, FileMode.Append)); ;
            bWrite.Write(clientData, 4 + fileNameLen, receivedBytesLen - 4 - fileNameLen);

            lblInfo.Content = "File: received & saved at path: " + receivedPath;

            bWrite.Close();
            clientSock.Close();
        }
        catch (Exception ex)
        {
            lblInfo.Content = "File Receiving fail." + ex.Message;
        }
    }

этот код отлично работает для 1 клиента, который передает файл на сервер. Мне было интересно, как я могу изменить этот код, чтобы он мог общаться с несколькими клиентами, которые могут отправлять файлы на сервер?

также, код сервера «зависает» на Socket clientSock = sock.Accept(); и ждет, пока не получит что-то. Было бы хорошо, если бы был «слушатель», который прослушивает новые поступающие файлы и затем циклически просматривает код, вместо того, чтобы бесконечно ждать в этой строке.

Я новичок в клиент-серверном программировании и все уши к другим предложениям.

1 Ответ

0 голосов
/ 07 декабря 2011

Здесь у вас есть объяснения для создания ваших петель для новых соединений:

http://msdn.microsoft.com/en-us/library/dz10xcwh.aspx

IPEndPoint ipEnd = new IPEndPoint(IPAddress.Any, 5656);
Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP);
listener.Bind(ipEnd);
listener.Listen(100);

Console.WriteLine("Waiting for a connection...");
Socket handler = listener.Accept();

while (true)
{
    // 1024 * 25.000 = 25mb max that can be received at once with this program.
    byte[] clientData = new byte[1024 * 25000];
    string receivedPath = Environment.GetFolderPath(Environment.SpecialFolder.DesktopDirectory) + "\\";

    int bytesRec = handler.Receive(clientData);
    int fileNameLen = BitConverter.ToInt32(clientData, 0);
    string fileName = Encoding.ASCII.GetString(clientData, 4, fileNameLen);

    BinaryWriter bWrite = new BinaryWriter(File.Open(receivedPath + fileName, FileMode.Append)); ;
    bWrite.Write(clientData, 4 + fileNameLen, bytesRec - 4 - fileNameLen);
    bWrite.Close();
}

//dont forget to close handler at server shutdown
//handler.Shutdown(SocketShutdown.Both);
//handler.Close();
...