Форум РадиоКот

Кислый писал(а):может в любой момент прислать данные, и клииент должен успеть их принять.

Кислый писал(а):Если пришедший пакет требует ответа, то ответить не медля.

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;

namespace l2packet
{
class SocketAsyncClient
{
public Socket client;

public byte[] in_data = new byte[0xFFFF];
public byte[] out_data = new byte[0xFFFF];


public SocketAsyncClient()
{
this.connect (ref client);
while (true) {
this.s_read ();

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


public void connect(ref Socket sock)
{
sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try
{
Console.WriteLine("Сокет успешно создан");
client.Connect("127.0.0.1", 2106);
Console.WriteLine("Соединение успешно установлено");
}
catch (SocketException ex)
{
Console.WriteLine("Ошибка при работе с сокетами: " + ex.Message);
}
}


public int s_read()
{
byte[] data = new byte[1024];
// … заполнение массива data опущено
SocketAsyncEventArgs async_e = new SocketAsyncEventArgs();
async_e.SetBuffer(data, 0, 1024);
async_e.Completed += SocketAsyncCompleted;
client.ReceiveAsync(async_e);
Console.WriteLine("Нажмите любую клавишу");
Console.ReadKey();
Console.WriteLine ("Приняты байты : {0} {1}", data [0], data [1]);
return 0;
}

public int s_send()
{
byte[] data = new byte[1024];
// … заполнение массива data опущено
SocketAsyncEventArgs async_e = new SocketAsyncEventArgs();
async_e.SetBuffer(data, 0, 1024);
async_e.Completed += SocketAsyncCompleted;
client.SendAsync(async_e);
return 0;
}

void SocketAsyncCompleted(object o, SocketAsyncEventArgs e)
{
if(e.LastOperation == SocketAsyncOperation.Send)
{
if(e.SocketError == SocketError.Success)
Console.WriteLine("Передача выполнена успешна");
else
Console.WriteLine("При передаче произошла ошибка");
}
if(e.LastOperation == SocketAsyncOperation.Receive)
{
if(e.SocketError == SocketError.Success)
Console.WriteLine("Прием выполнен успешно");

else
Console.WriteLine("При приеме произошла ошибка");
}
}


}
}

Кислый писал(а):Я и хочу использовать неблокирующие сокеты.

SocketAsyncEventArgs async_e = new SocketAsyncEventArgs();

Кислый писал(а):обьясните, почему если нет задержки, обусловленной Console.ReadKey();, то код возвращает пустой массив.

Кислый писал(а):Асинхронные = неблокирующие

urry писал(а):Каждый новый сокет обмена открывается в своем потоке - это правило хорошего тона

urry, должно быть потому, что у меня клиент.

Что за ересь?

urry писал(а):Посмотрите количество потоков вашего браузера - любого

urry писал(а):многопотоковый вывод быстрее.

urry писал(а):никто не мешает наступить на грабли самостоятельно.

urry писал(а):Свой вариант в 1 потоке я показал в начале ветки, ваш ?

urry писал(а):Каждый новый сокет обмена открывается в своем потоке - это правило хорошего тона