Возникла необходмость передавать большой объем данных (XML) через сокет. Сервер начинает передачу при приеме определенной команды - например, "getxmldata":
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.
static readonly Encoding encoding = Encoding.GetEncoding(1251);
void StartAccepting()
{
var ipAddress = IPAddress.Parse(Properties.Settings.Default.IPAddress);
var localEndPoint = new IPEndPoint(ipAddress, Properties.Settings.Default.IPPort);
using(var listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
{
listener.Bind(localEndPoint);
listener.Listen(10);
var handler = listener.Accept();
while (true)
{
var sb = new StringBuilder();
var dataPresent = false;
while (handler.Available != 0)
{
var bytes = new byte[1024];
var received = handler.Receive(bytes);
var text = encoding.GetString(bytes, 0, received);
sb.Append(text);
dataPresent = true;
}
if (!dataPresent) continue;
if ("getxmldata".Equals(sb.ToString().Trim('\0').Trim(), StringComparison.OrdinalIgnoreCase))
SendXml(handler);
}
}
}
static void SendXml(Socket handler)
{
var xdBytes = encoding.GetBytes(GetXmlData());
const int bufferLength = 1024;
var position = 0;
while(position<xdBytes.Length)
{
handler.Send(xdBytes, position,
position+bufferLength<xdBytes.Length ? bufferLength : xdBytes.Length-position,
SocketFlags.None);
position += bufferLength;
}
}
Клиент, подключившись к серверу, и отправив команду, начинает прием XML:
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.
static readonly byte[] getDataMessage = Encoding.GetEncoding(1251).GetBytes("getxmldata");
static readonly Encoding transferEncoding = Encoding.GetEncoding(1251);
const int DataTimeout = 500;
void StartTcpClient()
{
using(var client = new TcpClient())
{
var asyncResult = client.BeginConnect(
IPAddress.Parse(Properties.Settings.Default.IPAddress),
Properties.Settings.Default.IPPort,
null, null);
if (!asyncResult.AsyncWaitHandle.WaitOne(TimeSpan.FromSeconds(10.0)))
throw new Exception("Превышено время ожидания отклика");
client.EndConnect(asyncResult);
using(var stream = client.GetStream())
{
stream.Write(getDataMessage, 0, getDataMessage.Length);
var sw = new Stopwatch();
sw.Start();
while(!stream.DataAvailable) // Между отсылкой сообщения, и появлением данных
if (sw.Elapsed>DataTimeout) // есть некоторый промежуток, в котором stream.DataAvailable==false
break;
sw.Stop();
var sb = new StringBuilder();
var dataPresent = false;
while(stream.DataAvailable)
{
var buffer = new byte[1024];
var received = stream.Read(buffer, 0, buffer.Length);
var text = transferEncoding.GetString(buffer, 0, received);
sb.Append(text);
dataPresent = true;
}
if (dataPresent)
File.WriteAllText(Properties.Settings.Default.DataFile, sb.ToString());
}
}
}
На небольших объемах данных все работает прекрасно, но вот на больших (для тестирования использовался XML, в виде файла весящий 4,5 Мб) происходит следующее: во время отсылки данных сервером в промежутке между очередным Socket.Send, у клиента в цикле получения stream.DataAvailable становится равным False (хотя на сервере все еще крутится цикл отправки данных), клиент выходит из цикла приема данных (получив лишь часть XML - где-то 1/3), и закрывает соединение с сервером, в результате чего последний вылетает по SocketException (Удаленный хост принудительно разорвал существующее подключение) при попытке отослать очередную порцию данных.
Хотел сделать проверку в цикле на stream.DataAvailable тоже в течение какого-то промежутка (аналогично проверке после отсылки команды) - но может получиться так, что клиент отошлет две подряд команды достаточно быстро, и клиентский цикл, не дополучив до конца первый XML, начнет его дозаписывать данными начала второго XML - это не устраивает абсолютно. Второй вариант - дополнять данные маркером окончания передачи (каким-нибудь [EOF]), и проверять его наличие в очередной порции данных - но тогда при сбое сервера в процессе передачи клиенский цикл приема данных зависнет. Как тут лучше сделать?
