Пишу сервер + клиент, чтобы отсылать файлы ( для начала хоть Image ) по UDP , потом хотел аудио-файлы.
***** какая-то  в обмениваться простыми сообщениями - без проблем, дело до передачи файла долшло, так 
Ну так вот, трабла очень прикольная
запускаю сервер, ждет файла, в клиенте отсылаю, начинается прием, НО издается странный звук ( с материнки )
Получаю этот еррор
System.Net.Sockets.SocketException was unhandled
Message="An existing connection was forcibly closed by the remote host"
Source="System"
ErrorCode=10054
NativeErrorCode=10054
StackTrace:
at System.Net.Sockets.Socket.ReceiveFrom(Byte[] buffer, Int32 offset, Int32 size, SocketFlags socketFlags, EndPoint& remoteEP)
at System.Net.Sockets.Socket.ReceiveFrom(Byte[] buffer, EndPoint& remoteEP)
at SimpleUdpSrvr.Main()
InnerException:
Сервер:
| Код |
public class SimpleUdpSrvr
{
public static void Main()
{
int recv;
byte[] data = new byte[102400000000000];
Thread t = new Thread(new ThreadStart(picsend));
t.IsBackground.CompareTo(true);
t.Start();
IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 8050);
Socket newsock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
newsock.Bind(ipep);
Console.WriteLine("Waiting for a client...");
IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);
EndPoint Remote = (EndPoint)(sender);
recv = newsock.ReceiveFrom(data, ref Remote);
Console.WriteLine("Message received from {0}:", Remote.ToString());
Console.WriteLine(Encoding.ASCII.GetString(data, 0, recv));
string welcome = "Welcome to my test server";
data = Encoding.ASCII.GetBytes(welcome);
newsock.SendTo(data, data.Length, SocketFlags.None, Remote);
while(true)
{
data = new byte[102400000000000];
recv = newsock.ReceiveFrom(data, ref Remote);
Console.WriteLine(Encoding.ASCII.GetString(data, 0, recv));
newsock.SendTo(data, recv, SocketFlags.None, Remote);
}
}
public static void picsend()
{
UdpClient receive;
IPEndPoint receivept = null;
receive = new UdpClient(8051);
do
{
try
{
byte[] pic = receive.Receive(ref receivept);
using (MemoryStream ms = new MemoryStream(pic, 0, pic.Length))
{
ms.Write(pic, 0, pic.Length);
Image im = Image.FromStream(ms, true);
}
}
catch (Exception ex)
{
MessageBox.Show(ex.ToString());
}
} while (true);
}
}
|
Клиент
| Код |
namespace WindowsFormsApplication1
{
public partial class Form1 : Form
{
UdpClient send, receive;
IPEndPoint sendpt, receivept;
Thread t;
public Form1()
{
InitializeComponent();
t = new Thread(new ThreadStart(picsend));
t.IsBackground.CompareTo(true);
t.Start();
}
[DllImport("winmm.dll", EntryPoint = "mciSendStringA", CharSet = CharSet.Ansi, SetLastError = true, ExactSpelling = true)]
private static extern int mciSendString(string lpstrCommand, string lpstrReturnString, int uReturnLength, int hwndCallback);
private void button1_Click(object sender, EventArgs e)
{
mciSendString("open new Type waveaudio Alias recsound", "", 0, 0);
mciSendString("record recsound", "", 0, 0);
}
private void button2_Click(object sender, EventArgs e)
{
mciSendString("save recsound c:\\record.wav", "", 0, 0);
mciSendString("close recsound ", "", 0, 0);
}
private void button3_Click(object sender, EventArgs e)
{
OpenFileDialog mydialog = new OpenFileDialog();
if (mydialog.ShowDialog() == DialogResult.OK)
{
string path = mydialog.FileName;
FileStream fs = new FileStream(path, FileMode.Open, FileAccess.Read);
BinaryReader br = new BinaryReader(fs);
byte[] data = br.ReadBytes(Convert.ToInt16(fs.Length));
send = new UdpClient();
sendpt = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8050);
send.Send(data, data.Length, sendpt);
send.Close();
}
}
public void picsend()
{
receive = new UdpClient(8049);
do
{
try
{
byte[] pic = receive.Receive(ref receivept);
using (MemoryStream ms = new MemoryStream(pic, 0, pic.Length))
{
ms.Write(pic, 0, pic.Length);
Image im = Image.FromStream(ms, true);
pictureBox1.Image = im;
}
}
catch (Exception ex)
{
MessageBox.Show(ex.ToString());
}
} while (true);
}
}
}
|
|
