|
Некорректная передача сообщения
#39246323
Ссылка:
Ссылка на сообщение:
Ссылка с названием темы:
|
|
|
|
код ошибок не выдает но и не загружает файл
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
109.
110.
111.
112.
113.
114.
115.
116.
117.
118.
119.
120.
121.
122.
123.
124.
125.
126.
127.
128.
129.
130.
131.
132.
133.
134.
135.
136.
137.
138.
139.
140.
141.
142.
143.
144.
145.
146.
147.
148.
149.
150.
151.
152.
153.
154.
155.
156.
157.
158.
159.
160.
161.
162.
163.
164.
165.
166.
167.
168.
const string soob = "001";
const string info = "002";
const string fail = "003";
private void btnServer_Click(object sender, EventArgs e)//кнопка сервер
{
Server = new TcpListener(IPAddress.Any, 6785);
Server.Start();
thServer = new Thread(() =>
{
remoteClient = Server.AcceptTcpClient();
SendData(soob, GetLocDir());
byte[] buffer = new byte[2048];
while (remoteClient.Connected)
{
Array.Clear(buffer, 0, buffer.Length);
remoteClient.GetStream().Read(buffer, 0, buffer.Length);
string strData = Encoding.Default.GetString(buffer);
int b = strData.IndexOf("\0");
b = b - 3;
var messege = strData.Substring(0, 3);
strData = strData.Substring(3, b);
this.Invoke((Action)(() =>
{
if (messege == soob)
{
try
{
string poddir = String.Join("/", Directory.GetDirectories(strData));/////подправить отображение
string file = String.Join("/", Directory.GetFiles(strData));/////подправить отображение
SendData(soob, poddir + file);
}
catch (Exception) { }
}
else if (messege == info)
{
FileInfo inf = new FileInfo(strData);
string ad = inf.Name;
string gh = Convert.ToString(inf.Length);
string ifa = ad + "@" + gh;
SendData(info, ifa);
BinaryFormatter bf = new BinaryFormatter();
MemoryStream ms = new MemoryStream();
bf.Serialize(ms, inf);
ms.Position = 0;
byte[] infobuffer = new byte[ms.Length];
int r = ms.Read(infobuffer, 0, infobuffer.Length);
ms.Close();
// байты главного заголовка
byte[] header = new byte[infobuffer.Length];
// Общий массив байтов
byte[] total = new byte[header.Length + infobuffer.Length + inf.Length];
Buffer.BlockCopy(header, 0, total, 0, header.Length);
Buffer.BlockCopy(infobuffer, 0, total, header.Length, infobuffer.Length);
// Добавим содержимое файла в общий массив сетевых данных
FileStream fs = new FileStream(strData, FileMode.Open, FileAccess.Read);
fs.Read(total, header.Length + infobuffer.Length, Convert.ToInt32(inf.Length));
fs.Close();
// Отправим данные подключенным клиентам
if (localClient != null && localClient.Connected)
{
NetworkStream ns = localClient.GetStream();
// Так как данный метод вызывается в отдельном потоке рациональней использовать синхронный метод отправки
ns.Write(total, 0, total.Length);
}
else if (remoteClient != null && remoteClient.Connected)
{
NetworkStream ns = remoteClient.GetStream();
ns.Write(total, 0, total.Length);
}
}
}));
}
});
thServer.Start();
}
private void btnConnect_Click(object sender, EventArgs e)//кнопка клиент
{
localClient = new TcpClient();
localClient.Connect("127.0.0.1", 6785);
thClient = new Thread(() =>
{
byte[] buffer = new byte[1024];
while (localClient.Connected)
{
Array.Clear(buffer, 0, buffer.Length);
localClient.GetStream().Read(buffer, 0, 1024);
string strData = Encoding.Default.GetString(buffer);
int b = strData.IndexOf("\0");
b = b - 3;
var messege = strData.Substring(0, 3);
strData = strData.Substring(3, b);
this.Invoke((Action)(() =>
{
if (messege == soob)
{
listView1.Clear();
string[] tx = strData.Split('/');
foreach (string s in tx)
{
listView1.Items.Add(s, 1);
ls.Add(s);
}
}
else if (messege == info)
{
string[] tx = strData.Split('@');
string nam = tx[0];
int size = Convert.ToInt32(tx[1]+5);
textBox1.Text = tx[0];
textBox2.Text = tx[1];
try
{
NetworkStream ns = localClient.GetStream();
// Из главного заголовка получим размер массива байтов информационного объекта
string header = tx[1];
int leninfo = int.Parse(header);
// Получим и десериализуем объект с подробной информацией
// о содержании получаемого сетевого пакета
MemoryStream ms = new MemoryStream(leninfo);
byte[] temp = new byte[leninfo];
int r = ns.Read(temp, 0, temp.Length);
ms.Write(temp, 0, r);
BinaryFormatter bf = new BinaryFormatter();
ms.Position = 0;
//ar = bf.Deserialize(ms);
ms.Close();
// Создадим файл на основе полученной информации и массива байтов следующих за объектом информации
FileStream fs = new FileStream(nam, FileMode.Create,
FileAccess.ReadWrite, FileShare.ReadWrite, size);
do
{
temp = new byte[size];
r = ns.Read(temp, 0, temp.Length);
// Записываем строго столько байтов сколько прочтено методом Read()
fs.Write(temp, 0, r);
// Как только получены все байты файла, останавливаем цикл,
// иначе он заблокируется в ожидании новых сетевых данных
if (fs.Length == size)
{
fs.Close();
break;
}
}
while (r > 0);
}
catch (Exception) { }
}
}));
}
});
thClient.Start();
SendData(soob, GetLocDir());
}
|
|
|
