Поделиться через

Socket.Select Метод

  • Ссылка

Определение

Пространство имен:
System.Net.Sockets
Сборка:
System.Net.Sockets.dll
Сборка:
System.dll
Сборка:
netstandard.dll

Перегрузки

Select(IList, IList, IList, TimeSpan)

Определяет состояние одного или нескольких сокетов.
Select(IList, IList, IList, Int32)

Определяет состояние одного или нескольких сокетов.

Select(IList, IList, IList, TimeSpan)

Исходный код:
Socket.cs
Исходный код:
Socket.cs
Исходный код:
Socket.cs

Определяет состояние одного или нескольких сокетов.

public:
 static void Select(System::Collections::IList ^ checkRead, System::Collections::IList ^ checkWrite, System::Collections::IList ^ checkError, TimeSpan timeout);
public static void Select (System.Collections.IList? checkRead, System.Collections.IList? checkWrite, System.Collections.IList? checkError, TimeSpan timeout);
static member Select : System.Collections.IList * System.Collections.IList * System.Collections.IList * TimeSpan -> unit
Public Shared Sub Select (checkRead As IList, checkWrite As IList, checkError As IList, timeout As TimeSpan)

Параметры

checkRead
IList

IList экземпляров Socket для проверки удобочитаемости.

checkWrite
IList

IList экземпляров Socket для проверки возможности записи.

checkError
IList

IList экземпляров Socket для проверки ошибок.

timeout
TimeSpan

Значение времени ожидания. Значение, равное -1 микросекундам, указывает на бесконечное время ожидания.

Исключения

ArgumentNullException

Параметры checkRead, checkWriteи checkError являются null или пустыми. По крайней мере один из checkRead, checkWriteили checkError должен содержать по крайней мере один Socket.

ArgumentOutOfRangeException

Параметр checkRead, checkWriteили checkError содержит слишком много сокетов.

ArgumentOutOfRangeException

timeout было меньше -1 микросекунд или больше, чем MaxValue микросекундах

SocketException

Произошла ошибка при попытке доступа к сокету.

ObjectDisposedException

Один или несколько сокетов были удалены.

Применяется к

Select(IList, IList, IList, Int32)

Исходный код:
Socket.cs
Исходный код:
Socket.cs
Исходный код:
Socket.cs

Определяет состояние одного или нескольких сокетов.

public:
 static void Select(System::Collections::IList ^ checkRead, System::Collections::IList ^ checkWrite, System::Collections::IList ^ checkError, int microSeconds);
public static void Select (System.Collections.IList? checkRead, System.Collections.IList? checkWrite, System.Collections.IList? checkError, int microSeconds);
public static void Select (System.Collections.IList checkRead, System.Collections.IList checkWrite, System.Collections.IList checkError, int microSeconds);
static member Select : System.Collections.IList * System.Collections.IList * System.Collections.IList * int -> unit
Public Shared Sub Select (checkRead As IList, checkWrite As IList, checkError As IList, microSeconds As Integer)

Параметры

checkRead
IList

IList экземпляров Socket для проверки удобочитаемости.

checkWrite
IList

IList экземпляров Socket для проверки возможности записи.

checkError
IList

IList экземпляров Socket для проверки ошибок.

microSeconds
Int32

Значение времени ожидания в микросекундах. Значение -1 указывает бесконечное время ожидания.

Исключения

ArgumentNullException

Параметры checkRead, checkWriteи checkError являются null или пустыми. По крайней мере один из checkRead, checkWriteили checkError должен содержать по крайней мере один Socket.

SocketException

Произошла ошибка при попытке доступа к сокету.

ObjectDisposedException

.NET 5 и более поздних версий: один или несколько сокетов удаляются.

ArgumentOutOfRangeException

Параметр checkRead, checkWriteили checkError содержит слишком много сокетов.

Примеры

В следующем примере кода используется Select для определения того, какие сокеты прослушивают запрос на подключение.

      IPHostEntry^ lipa = Dns::Resolve( Dns::GetHostName() );
      
      //Gets three separate local endpoints.
      IPEndPoint^ lep1 = gcnew IPEndPoint( lipa->AddressList[ 0 ],11000 );
      IPEndPoint^ lep2 = gcnew IPEndPoint( lipa->AddressList[ 0 ],11001 );
      IPEndPoint^ lep3 = gcnew IPEndPoint( lipa->AddressList[ 0 ],11002 );
      
      //creates an array of endpoints.
      array<IPEndPoint^>^ipendpoints = gcnew array<IPEndPoint^>(3);
      ipendpoints[ 0 ] = lep1;
      ipendpoints[ 1 ] = lep2;
      ipendpoints[ 2 ] = lep3;
      
      //Creates three separate sockets.
      Socket^ s1 = gcnew Socket( lep1->Address->AddressFamily,SocketType::Stream,ProtocolType::Tcp );
      Socket^ s2 = gcnew Socket( lep2->Address->AddressFamily,SocketType::Stream,ProtocolType::Tcp );
      Socket^ s3 = gcnew Socket( lep3->Address->AddressFamily,SocketType::Stream,ProtocolType::Tcp );
      array<Socket^>^socketList = gcnew array<Socket^>(3);
      socketList[ 0 ] = s1;
      socketList[ 1 ] = s2;
      socketList[ 2 ] = s3;
      
      //Binds and Listens on all sockets in the array of sockets.
      for ( int i = 0; i < 3; i++ )
      {
         socketList[ i ]->Bind( ipendpoints[ i ] );
         socketList[ i ]->Listen( 1000 );

      }
      
      //Calls Select to determine which sockets are ready for reading.
      Socket::Select( safe_cast<IList^>(socketList), nullptr, nullptr, 1000 );
      
      //Reads on the sockets returned by Select.
      array<Byte>^buffer = gcnew array<Byte>(1024);
      String^ outString;
      for ( Int32 j = 0; j < (socketList->Length - 1); j++ )
      {
         socketList[ j ]->Receive( buffer );
         outString =  "Socket ";
         outString->Concat( j.ToString(),  " has the message", Encoding::ASCII->GetString( buffer ) );
         Console::WriteLine( outString );

      }
   }

};

int main()
{
   return 0;
}

IPHostEntry ipHostEntry = Dns.Resolve(Dns.GetHostName());
IPAddress ipAddress = ipHostEntry.AddressList[0];

Socket socket0 = null;
Socket socket1 = null;
Socket socket2 = null;
Socket socket3 = null;
Socket socket4 = null;
Socket socket5 = null;

ArrayList listenList = new ArrayList();
listenList.Add(socket0);
listenList.Add(socket1);
listenList.Add(socket2);

ArrayList acceptList = new ArrayList();
acceptList.Add(socket3);
acceptList.Add(socket4);
acceptList.Add(socket5);

for( int i = 0; i < 3; i++ )
{
  listenList[i] = new Socket(AddressFamily.InterNetwork,
                             SocketType.Stream,
                             ProtocolType.Tcp);
  ((Socket)listenList[i]).Bind(new IPEndPoint(ipAddress, 11000 + i));
  ((Socket)listenList[i]).Listen(10);
}

// Only the sockets that contain a connection request
// will remain in listenList after Select returns.

Socket.Select(listenList, null, null, 1000);

for( int i = 0; i < listenList.Count; i++ )
{
  acceptList[i] = ((Socket)listenList[i]).Accept();
}

Dim ipHostEntry As IPHostEntry = Dns.Resolve(Dns.GetHostName())
Dim ipAddress As IPAddress = ipHostEntry.AddressList(0)

Dim socket0 As Socket = Nothing
Dim socket1 As Socket = Nothing
Dim socket2 As Socket = Nothing
Dim socket3 As Socket = Nothing
Dim socket4 As Socket = Nothing
Dim socket5 As Socket = Nothing

Dim listenList As New ArrayList()
listenList.Add(socket0)
listenList.Add(socket1)
listenList.Add(socket2)

Dim acceptList As New ArrayList()
acceptList.Add(socket3)
acceptList.Add(socket4)
acceptList.Add(socket5)

Dim i As Integer
For i = 0 To 2
   listenList(i) = New Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)
   CType(listenList(i), Socket).Bind(New IPEndPoint(ipAddress, 11000 + i))
   CType(listenList(i), Socket).Listen(10)
Next i

'Only the sockets that contain a connection request
'will remain in listenList after Select returns.
Socket.Select(listenList, Nothing, Nothing, 1000)

For i = 0 To listenList.Count - 1
   acceptList(i) = CType(listenList(i), Socket).Accept()
Next i

Комментарии

Select — это статический метод, который определяет состояние одного или нескольких экземпляров Socket. Прежде чем использовать метод Select, необходимо поместить один или несколько сокетов в IList. Проверьте удобочитаемость путем вызова Select с помощью IList в качестве параметра checkRead. Чтобы проверить сокеты для записи, используйте параметр checkWrite. Для обнаружения условий ошибки используйте checkError. После вызова SelectIList будут заполнены только теми сокетами, которые удовлетворяют условиям.

Если вы находитесь в состоянии прослушивания, удобочитаемость означает, что вызов Accept будет успешно выполнен без блокировки. Если вы уже приняли подключение, возможность чтения означает, что данные доступны для чтения. В таких случаях все операции получения будут успешно выполнены без блокировки. Удобочитаемость также может указывать, завершилось ли удаленное Socket подключение; В этом случае вызов Receive возвращается немедленно, при этом возвращается ноль байтов.

Select возвращается, когда по крайней мере один из интересующих сокетов (сокеты в checkRead, checkWriteи checkError списках) соответствует заданным критериям или превышен параметр microSeconds, независимо от того, что происходит первым. Установка microSeconds для -1 указывает бесконечное время ожидания.

Если вы выполняете неблокировку вызова Connect, возможность записи означает, что вы успешно подключены. Если у вас уже установлено подключение, возможность записи означает, что все операции отправки будут успешно выполнены без блокировки.

Если вы выполнили неблокирующий вызов Connect, параметр checkerror определяет сокеты, которые не подключены успешно.

Заметка

Используйте метод Poll, если требуется только определить состояние одного Socket.

Заметка

Этот метод не может обнаружить определенные типы проблем подключения, например сломанный сетевой кабель, или что удаленный узел был закрыт неграмотно. Для обнаружения таких ошибок необходимо попытаться отправить или получить данные.

Заметка

Если вы получаете SocketException, используйте свойство SocketException.ErrorCode для получения определенного кода ошибки. Получив этот код, обратитесь к коду ошибки сокетов Windows версии 2, документации по подробному описанию ошибки.

См. также раздел

Применяется к