Oceans11
15-01-2009, 11:54
Sto cominciando ad avventurarmi nella foltissima giungla di msdn, volevo provare trasmettere e ricevere un file in rete, tramite un applicazione ibrida (che mi fa sia da client che da server).
Il codice:public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
serverThread.RunWorkerAsync();
}
private void bBrowse_Click(object sender, EventArgs e)
{
openFileDialog1.ShowDialog();
tFile.Text = openFileDialog1.FileName;
}
private void bCancel_Click(object sender, EventArgs e)
{
clientThread.CancelAsync();
tIp.Text = "";
tFile.Text = "";
progressBar1.Value = 0;
}
private void bSend_Click(object sender, EventArgs e)
{
clientThread.RunWorkerAsync();
}
private void clientThread_DoWork(object sender, DoWorkEventArgs e)
{
sendFile();
if (clientThread.CancellationPending)
{
e.Cancel = true;
}
}
private void sendFile()
{
Socket senderSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
senderSocket.Bind(new IPEndPoint(IPAddress.Parse(tIp.Text), 9999));
FileStream fs = new FileStream(tFile.Text, FileMode.Open, FileAccess.Read);
long length = fs.Length;
BinaryReader br = new BinaryReader(fs);
byte[] buff = new byte[4096];
int size = 0;
int count = 0;
while (!clientThread.CancellationPending && (size = br.Read(buff, 0, buff.Length)) != 0)
{
senderSocket.Send(buff);
count += size;
int percentComplete =
(int)(((float)count * 100) / (float)length);
clientThread.ReportProgress(percentComplete);
}
br.Close();
senderSocket.Close();
}
private void clientThread_ProgressChanged(object sender, ProgressChangedEventArgs e)
{
tIp.Text = "" + e.ProgressPercentage;
progressBar1.Value = e.ProgressPercentage;
}
private void clientThread_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
operationResult(sender, e);
}
private void serverThread_DoWork(object sender, DoWorkEventArgs e)
{
IPEndPoint ipEnd = new IPEndPoint(IPAddress.Any, 9999);
Socket receiver = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
receiver.Bind(ipEnd);
receiver.Listen(0);
receiveFile(receiver.Accept());
receiver.Close();
}
private static void receiveFile(Socket client)
{
String filename = "file";
BinaryWriter bw = new BinaryWriter(new FileStream(filename, FileMode.Create,
FileAccess.Write));
byte[] buff = new byte[1024];
int count = -1;
while ((count = client.Receive(buff)) > 0)
{
bw.Write(buff, 0, count);
}
bw.Close();
}
private void serverThread_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
operationResult(sender, e);
}
private void operationResult(object sender, RunWorkerCompletedEventArgs e)
{
if (e.Cancelled)
{
MessageBox.Show("Operation was cancelled");
}
else if (e.Error != null)
{
string msg = String.Format("An error occurred: {0}", e.Error.Message);
MessageBox.Show(msg);
}
else
{
if (sender.Equals(clientThread))
{
MessageBox.Show("Uploading complete");
}
else
{
MessageBox.Show("Downloading complete");
}
}
}
}
L'errore: Di norma è consentito un solo utilizzo di ogni indirizzo di socket)
Quindi se ho capito il problema è che sto tentando di inviare a "me stesso" il file, quindi l'indirizzo del socket in entrata ed in uscita combaciano. Giusto?
Se sì, come posso testare l'applicazione in locale?
Sono ben accetti anche consigli su come ho scritto il programma, le classi che ho usato, etc; sto iniziando con il c# ora quindi ogni commento mi è utile!
Il codice:public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
serverThread.RunWorkerAsync();
}
private void bBrowse_Click(object sender, EventArgs e)
{
openFileDialog1.ShowDialog();
tFile.Text = openFileDialog1.FileName;
}
private void bCancel_Click(object sender, EventArgs e)
{
clientThread.CancelAsync();
tIp.Text = "";
tFile.Text = "";
progressBar1.Value = 0;
}
private void bSend_Click(object sender, EventArgs e)
{
clientThread.RunWorkerAsync();
}
private void clientThread_DoWork(object sender, DoWorkEventArgs e)
{
sendFile();
if (clientThread.CancellationPending)
{
e.Cancel = true;
}
}
private void sendFile()
{
Socket senderSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
senderSocket.Bind(new IPEndPoint(IPAddress.Parse(tIp.Text), 9999));
FileStream fs = new FileStream(tFile.Text, FileMode.Open, FileAccess.Read);
long length = fs.Length;
BinaryReader br = new BinaryReader(fs);
byte[] buff = new byte[4096];
int size = 0;
int count = 0;
while (!clientThread.CancellationPending && (size = br.Read(buff, 0, buff.Length)) != 0)
{
senderSocket.Send(buff);
count += size;
int percentComplete =
(int)(((float)count * 100) / (float)length);
clientThread.ReportProgress(percentComplete);
}
br.Close();
senderSocket.Close();
}
private void clientThread_ProgressChanged(object sender, ProgressChangedEventArgs e)
{
tIp.Text = "" + e.ProgressPercentage;
progressBar1.Value = e.ProgressPercentage;
}
private void clientThread_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
operationResult(sender, e);
}
private void serverThread_DoWork(object sender, DoWorkEventArgs e)
{
IPEndPoint ipEnd = new IPEndPoint(IPAddress.Any, 9999);
Socket receiver = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
receiver.Bind(ipEnd);
receiver.Listen(0);
receiveFile(receiver.Accept());
receiver.Close();
}
private static void receiveFile(Socket client)
{
String filename = "file";
BinaryWriter bw = new BinaryWriter(new FileStream(filename, FileMode.Create,
FileAccess.Write));
byte[] buff = new byte[1024];
int count = -1;
while ((count = client.Receive(buff)) > 0)
{
bw.Write(buff, 0, count);
}
bw.Close();
}
private void serverThread_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
operationResult(sender, e);
}
private void operationResult(object sender, RunWorkerCompletedEventArgs e)
{
if (e.Cancelled)
{
MessageBox.Show("Operation was cancelled");
}
else if (e.Error != null)
{
string msg = String.Format("An error occurred: {0}", e.Error.Message);
MessageBox.Show(msg);
}
else
{
if (sender.Equals(clientThread))
{
MessageBox.Show("Uploading complete");
}
else
{
MessageBox.Show("Downloading complete");
}
}
}
}
L'errore: Di norma è consentito un solo utilizzo di ogni indirizzo di socket)
Quindi se ho capito il problema è che sto tentando di inviare a "me stesso" il file, quindi l'indirizzo del socket in entrata ed in uscita combaciano. Giusto?
Se sì, come posso testare l'applicazione in locale?
Sono ben accetti anche consigli su come ho scritto il programma, le classi che ho usato, etc; sto iniziando con il c# ora quindi ogni commento mi è utile!