Search code examples
c#filestreamtcpclienttcpserver

File Stream from 3 servers


I'm creating a manager gui to select a music or movie file from server. This selected file will be downloaded from this server to my client folder. How can I make it with 3 servers working together with sharing chunks on themselves?

I am doing this using C# Winforms on Visual Studio. I have implement it with 1 server and it is working. But when I try to connect 2nd or 3nd server on different port, client program freezes and no byte transfers. I have tried multithreading but couldn't connect on multiple servers, again.

Client

using System;
using System.IO;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace CiDoMa
{
    public partial class Form1 : Form
    {
        string fileName, fileInitName;

        public Form1()
        {
            InitializeComponent();
        }

        private void Music_button_Click(object sender, EventArgs e)
        {

            fileInitName = fileName_textbox.Text;

            if (fileInitName.Contains(".mp3"))
            {
                fileName = "Music/" + fileInitName;
            }

            else if (fileInitName.Contains(".mp4"))
            {
                fileName = "Movie/" + fileInitName;
            }
            progressBar1.Value = 0;
            IPEndPoint ipep1 = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9050);
            IPEndPoint ipep2 = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9060);
            IPEndPoint ipep3 = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9070);

            Socket server0 = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            server0.Connect(ipep1);
            byte[] data = new byte[1024];
            data = Encoding.ASCII.GetBytes(fileName);
            server0.Send(data, data.Length, SocketFlags.None);

            using (FileStream to = new FileStream("../../" + fileName, FileMode.OpenOrCreate, FileAccess.ReadWrite))
                {
                    byte[] buffer = new byte[1024];
                    int rcv = 1;
                    while (rcv!=0)
                    {
                        rcv = server0.Receive(buffer, 1024, SocketFlags.None);
                        to.Write(buffer, 0, buffer.Length);
                    }
                    progressBar1.Value += 100;
                }

            server0.Shutdown(SocketShutdown.Both);
            server0.Close();
        }
    }
}

Server

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.IO;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;


namespace CiDoMaServer
{
    public partial class Form1 : Form
    {
        string fileName = "";
        IPEndPoint ipep, ipep2, ipep3;
        int rcv;
        public Form1()
        {
            InitializeComponent();
        }

        private void Form1_Load(object sender, EventArgs e)
        {

        }

        private void Server_init_Click(object sender, EventArgs e)
        {
            ipep = new IPEndPoint(IPAddress.Any,
                9050);
            ipep2 = new IPEndPoint(IPAddress.Any,
                9060);
            ipep3 = new IPEndPoint(IPAddress.Any,
                9070);
            IPEndPoint[] ipPoints = new IPEndPoint[3] { ipep, ipep2, ipep3 };

            Socket[] scon = new Socket[3];
            Socket[] server = new Socket[3];

            for (int i = 0; i < scon.Length; i++)
            {
                scon[i] = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                scon[i].Bind(ipPoints[i]);
                //scon[i].Listen(10);
                //server[i] = scon[i].Accept();
            }
            scon[0].Listen(10);
            server[0] = scon[0].Accept();
            byte[] data = new byte[1024];
            rcv = server[0].Receive(data, data.Length, SocketFlags.None);
            fileName = Encoding.ASCII.GetString(data);

            while (rcv != 0) {
            using (FileStream from = new FileStream("../../" + fileName, FileMode.Open, FileAccess.Read))
            {
                int readCount;
                byte[] buffer = new byte[1024];
                while ((readCount = from.Read(buffer, 0, 1024)) != 0)
                {
                    server[0].Send(buffer, 1024, SocketFlags.None);
                }
                }
            }
            server[0].Close();
            scon[0].Close();

            /*for(int i=0; i<scon.Length; i++) { 
                server[i].Close();
                scon[i].Close();
            }*/
        }
    }
}

Solution

  • If you are creating a server to serve multi client as a same time, your server should support asynchronous and multi threading. And it not easy to handle multi thread thus I thought it is the reason why you failed with multi threading but you can try to make it better

    About example you can take a look at this example source code

    and asynchronous socket

    Hope it helpful with you