Socket recv socket error

socket_recv — Получает данные из подсоединённого сокета

(PHP 4 >= 4.1.0, PHP 5, PHP 7)

socket_recv — Получает данные из подсоединённого сокета

Описание

Функция socket_recv() получает len байт данных в буфер buf из сокета socket . функция socket_recv() может быть использована для получения данных из подсоединённых сокетов. Дополнительно к этому, один или более флагов могут быть указаны для изменения поведения функции.

Параметр buf передаётся по ссылке, так что он должен быть указан в виде переменной в списке аргументов. Данные, прочитанные из сокета socket функцией socket_recv() , будут возвращены в параметре buf .

Список параметров

Параметр socket должен быть ресурсом сокета, предварительно созданным при помощи функции socket_create().

Полученные данные будут переданы в переменную, указанную в параметре buf . Если происходит ошибка, если соединение сброшено, или если данные недоступны, параметр buf будет установлен в NULL .

До len байт будет получено с удалённого хоста.

Значение параметра flags может быть любой комбинацией следующих флагов, соединённых при помощи двоичного оператора OR (|).

Possible values for flags

Возвращаемые значения

socket_recv() возвращает количество полученных байтов, или FALSE в случае ошибки. Фактический код ошибки может быть получен при помощи функции socket_last_error() . Этот код ошибки может быть передан функции socket_strerror() для получения текстового описания ошибки.

Примеры

Пример #1 Пример использования socket_recv()

Этот пример — просто вариант первого примера из статьи Примеры с использованием socket_recv() .

Соединение TCP/IP

/* Получить порт сервиса WWW. */
$service_port = getservbyname ( ‘www’ , ‘tcp’ );

/* Получить IP-адрес целевого хоста. */
$address = gethostbyname ( ‘www.example.com’ );

/* Создать сокет TCP/IP. */
$socket = socket_create ( AF_INET , SOCK_STREAM , SOL_TCP );
if ( $socket === false ) <
echo «Не удалось выполнить функцию socket_create(): причина: » . socket_strerror ( socket_last_error ()) . «n» ;
> else <
echo «OK.n» ;
>

echo «Попытка соединиться с хостом ‘ $address ‘ по порту ‘ $service_port ‘. » ;
$result = socket_connect ( $socket , $address , $service_port );
if ( $result === false ) <
echo «Не получилось выполнить функцию socket_connect().nПричина: ( $result ) » . socket_strerror ( socket_last_error ( $socket )) . «n» ;
> else <
echo «OK.n» ;
>

$in = «HEAD / HTTP/1.1rn» ;
$in .= «Host: www.example.comrn» ;
$in .= «Connection: Closernrn» ;
$out = » ;

echo «Отправка запроса HTTP HEAD. » ;
socket_write ( $socket , $in , strlen ( $in ));
echo «OK.n» ;

echo «Получение ответа:nn» ;
$buf = ‘Это мой буфер.’ ;
if ( false !== ( $bytes = socket_recv ( $socket , $buf , 2048 , MSG_WAITALL ))) <
echo «Прочитано $bytes байта из функции socket_recv(). Закрываем сокет. » ;
> else <
echo «Не получилось выполнить socket_recv(); причина: » . socket_strerror ( socket_last_error ( $socket )) . «n» ;
>
socket_close ( $socket );

Пример выше выведет что-то вроде следующего:

Источник

recv function (winsock.h)

The recv function receives data from a connected socket or a bound connectionless socket.

Syntax

Parameters

The descriptor that identifies a connected socket.

A pointer to the buffer to receive the incoming data.

The length, in bytes, of the buffer pointed to by the buf parameter.

A set of flags that influences the behavior of this function. See remarks below. See the Remarks section for details on the possible value for this parameter.

Return value

If no error occurs, recv returns the number of bytes received and the buffer pointed to by the buf parameter will contain this data received. If the connection has been gracefully closed, the return value is zero.

Otherwise, a value of SOCKET_ERROR is returned, and a specific error code can be retrieved by calling WSAGetLastError.

The recv function is used to read incoming data on connection-oriented sockets, or connectionless sockets. When using a connection-oriented protocol, the sockets must be connected before calling recv. When using a connectionless protocol, the sockets must be bound before calling recv.

The local address of the socket must be known. For server applications, use an explicit bind function or an implicit accept or WSAAccept function. Explicit binding is discouraged for client applications. For client applications, the socket can become bound implicitly to a local address using connect, WSAConnect, sendto, WSASendTo, or WSAJoinLeaf.

For connected or connectionless sockets, the recv function restricts the addresses from which received messages are accepted. The function only returns messages from the remote address specified in the connection. Messages from other addresses are (silently) discarded.

For connection-oriented sockets (type SOCK_STREAM for example), calling recv will return as much data as is currently available—up to the size of the buffer specified. If the socket has been configured for in-line reception of OOB data (socket option SO_OOBINLINE) and OOB data is yet unread, only OOB data will be returned. The application can use the ioctlsocket or WSAIoctlSIOCATMARK command to determine whether any more OOB data remains to be read.

For connectionless sockets (type SOCK_DGRAM or other message-oriented sockets), data is extracted from the first enqueued datagram (message) from the destination address specified by the connect function.

If the datagram or message is larger than the buffer specified, the buffer is filled with the first part of the datagram, and recv generates the error WSAEMSGSIZE. For unreliable protocols (for example, UDP) the excess data is lost; for reliable protocols, the data is retained by the service provider until it is successfully read by calling recv with a large enough buffer.

If no incoming data is available at the socket, the recv call blocks and waits for data to arrive according to the blocking rules defined for WSARecv with the MSG_PARTIAL flag not set unless the socket is nonblocking. In this case, a value of SOCKET_ERROR is returned with the error code set to WSAEWOULDBLOCK. The select, WSAAsyncSelect, or WSAEventSelect functions can be used to determine when more data arrives.

If the socket is connection oriented and the remote side has shut down the connection gracefully, and all data has been received, a recv will complete immediately with zero bytes received. If the connection has been reset, a recv will fail with the error WSAECONNRESET.

The flags parameter can be used to influence the behavior of the function invocation beyond the options specified for the associated socket. The semantics of this function are determined by the socket options and the flags parameter. The possible value of flags parameter is constructed by using the bitwise OR operator with any of the following values.

В

Example Code

Example Code

WindowsВ PhoneВ 8: This function is supported for Windows Phone Store apps on WindowsВ PhoneВ 8 and later.

WindowsВ 8.1 and Windows ServerВ 2012В R2: This function is supported for Windows Store apps on WindowsВ 8.1, Windows ServerВ 2012В R2, and later.

Источник

Функция recv (winsock.h)

Функция recv получает данные из подключенного сокета или связанного сокета без подключения.

Синтаксис

Параметры

Дескриптор, идентифицирующий подключенный сокет.

Указатель на буфер для получения входящих данных.

Длина буфера в байтах, на который указывает параметр buf .

Набор флагов, влияющих на поведение этой функции. См. примечания ниже. Дополнительные сведения о возможном значении этого параметра см. в разделе «Примечания».

Возвращаемое значение

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

В противном случае возвращается значение SOCKET_ERROR, и можно получить определенный код ошибки путем вызова WSAGetLastError.

Комментарии

Функция recv используется для чтения входящих данных в сокетах, ориентированных на подключение, или для сокетов без подключения. При использовании протокола, ориентированного на подключение, сокеты должны быть подключены перед вызовом recv. При использовании протокола без подключения сокеты должны быть привязаны перед вызовом recv.

Локальный адрес сокета должен быть известен. Для серверных приложений используйте явную функцию привязки или неявную функцию accept или WSAAccept . Явная привязка не рекомендуется для клиентских приложений. Для клиентских приложений сокет может быть привязан неявно к локальному адресу с помощью подключения, WSAConnect, sendto, WSASendTo или WSAJoinLeaf.

Для подключенных или несоединяемых сокетов функция recv ограничивает адреса, от которых принимаются полученные сообщения. Функция возвращает сообщения только из удаленного адреса, указанного в соединении. Сообщения с других адресов (автоматически) удаляются.

Для сокетов, ориентированных на подключение (например, тип SOCK_STREAM), вызов recv вернет столько данных, сколько доступно в данный момент, вплоть до указанного размера буфера. Если сокет настроен для встроенного приема данных OOB (параметр сокета SO_OOBINLINE) и данные OOB еще нечитаны, будут возвращены только данные OOB. Приложение может использовать команду ioctlsocket или WSAIoctlSIOCATMARK, чтобы определить, остается ли считывать все больше данных OOB.

Для сокетов без подключения (тип SOCK_DGRAM или другие сокеты, ориентированные на сообщения), данные извлекаются из первой диаграммы данных в очереди (сообщения) из адреса назначения, указанного функцией connect .

Если датаграмма или сообщение больше указанного буфера, буфер заполняется первой частью датаграммы и выпрямляет ошибку WSAEMSGSIZE. Для ненадежных протоколов (например, UDP) лишние данные теряются; для надежных протоколов данные сохраняются поставщиком услуг до тех пор, пока не будет успешно прочитано путем вызова recv с достаточно большим буфером.

Если входящие данные не доступны в сокете, прямоугольник вызывает блоки и ожидает поступления данных в соответствии с правилами блокировки, определенными для WSARecv с флагом MSG_PARTIAL не задан, если сокет не блокируется. В этом случае возвращается значение SOCKET_ERROR с кодом ошибки, установленным для WSAEWOULDBLOCK. Функции select, WSAsyncSelect или WSAEventSelect можно использовать для определения времени поступления дополнительных данных.

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

Параметр флагов можно использовать для влияния на поведение вызова функции за пределами параметров, указанных для связанного сокета. Семантика этой функции определяется параметрами сокета и параметром флагов . Возможное значение параметра flags создается с помощью побитового оператора OR со следующими значениями.

Пример кода

Пример кода

Windows Phone 8. Эта функция поддерживается для приложений Магазина Windows Phone в Windows Phone 8 и более поздних версий.

Windows 8.1 и Windows Server 2012 R2: эта функция поддерживается для приложений Магазина Windows на Windows 8.1, Windows Server 2012 R2 и более поздних версий.

Источник

In the case of a non blocking socket that has no data available, recv will throw the socket.error exception and the value of the exception will have the errno of either EAGAIN or EWOULDBLOCK. Example:

import sys
import socket
import fcntl, os
import errno
from time import sleep

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(('127.0.0.1',9999))
fcntl.fcntl(s, fcntl.F_SETFL, os.O_NONBLOCK)

while True:
    try:
        msg = s.recv(4096)
    except socket.error, e:
        err = e.args[0]
        if err == errno.EAGAIN or err == errno.EWOULDBLOCK:
            sleep(1)
            print 'No data available'
            continue
        else:
            # a "real" error occurred
            print e
            sys.exit(1)
    else:
        # got a message, do something :)

The situation is a little different in the case where you’ve enabled non-blocking behavior via a time out with socket.settimeout(n) or socket.setblocking(False). In this case a socket.error is stil raised, but in the case of a time out, the accompanying value of the exception is always a string set to ‘timed out’. So, to handle this case you can do:

import sys
import socket
from time import sleep

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(('127.0.0.1',9999))
s.settimeout(2)

while True:
    try:
        msg = s.recv(4096)
    except socket.timeout, e:
        err = e.args[0]
        # this next if/else is a bit redundant, but illustrates how the
        # timeout exception is setup
        if err == 'timed out':
            sleep(1)
            print 'recv timed out, retry later'
            continue
        else:
            print e
            sys.exit(1)
    except socket.error, e:
        # Something else happened, handle error, exit, etc.
        print e
        sys.exit(1)
    else:
        if len(msg) == 0:
            print 'orderly shutdown on server end'
            sys.exit(0)
        else:
            # got a message do something :)

As indicated in the comments, this is also a more portable solution since it doesn’t depend on OS specific functionality to put the socket into non-blockng mode.

See recv(2) and python socket for more details.

функция recv

int recv( SOCKET s, char FAR *buf, int len, int flags);

Описание параметра

1. Первый параметр указывает дескриптор получающего сокета;
2. Второй параметр указывает буфер, который используется для хранения данных, полученных функцией recv;
3. Третий параметр указывает длину буфера;
4. Четвертый параметр обычно устанавливается на ноль.

Процесс выполнения функции recv синхронного сокета

Когда приложение вызывает функцию recv:

1. Сначала recv ожидает передачи данных в буфере отправки SOCKET по протоколу.доставитьПри отправке данных в сПроизошла ошибка сетиЗатем функция recv возвращаетSOCKET_ERROR；
2. Если сОтправить буфервНет данныхилиДанные были успешно отправлены по протоколуПосле recvСначала проверьте приемный буфер сокета s；
3. Если сПриемный буфервНет данныхилиПротокол получения данныхТогда recv былПодождитеПока протокол не получил данные;
4. Когда протокол завершил получение данных, функция recvПриемный буферДанные вскопировать в буферДюйм (Обратите внимание, что данные, полученные протоколом, могут быть больше, чем длина буфера, поэтому в этом случае функцию recv необходимо вызывать несколько раз, чтобы скопировать данные в приемный буфер функции s. RecvПросто скопируйте данныеФактический прием данных осуществляется протоколом.) Функция recv возвращает количество байтов, которые она фактически скопировала. Если ошибки recv при копировании, то он возвращаетSOCKET_ERROR；
5. Если функция recv находится вОтказ сети при ожидании протокола для получения данныхВверх, то этоВозвращает 0.

Сокет по умолчанию является блокирующим. Нет никакого различия между блокирующими и неблокирующими возвращаемыми значениями recv, оба<0 ошибка = 0 соединение закрыто> 0 получен размер данных.

Возвращаемое значение

1. После успешного выполнения возвращается количество полученных байтов.
2. Возвращает 0, если другой конец закрыт.
3. -1 при ошибке, errno устанавливается в одно из следующих значений:

• EAGAIN: Сокет был помечен как неблокирующий, и операция приема заблокирована или время ожидания приема истекло
• EBADF: Sock не является допустимым дескриптором
• ECONNREFUSE: Удаленный хост блокирует сетевое соединение
• EFAULT: Ошибка доступа к памяти
• EINTR: Операция была прервана сигналом
• EINVAL: Неверный параметр
• ENOMEM: Недостаточно памяти
• ENOTCONN: Сокет, связанный с ориентированным на соединение, еще не был подключен
• ENOTSOCK: Индекс сокета не является сокетом. Когда возвращаемое значение равно 0, соединение закрывается нормально.

специальные

Когда возвращаемое значение <0 и (errno == EINTR || errno == EWOULDBLOCK || errno == EAGAIN), соединение считается нормальным и прием продолжается.

EAGAIN, EWOULDBLOCK, EINTR и неблокирование

• EWOULDBLOCK: Для неблокирующего режима нет необходимости читать или писать снова
• EINTR: Указывает на то, что операция была вызвана прерыванием и должна быть снова прочитана / записана.

Если происходит EINTR, то есть значение errno равно 4, ошибка описывает прерванный системный вызов, и операция должна продолжаться.

• EAGAIN: Linux-неблокирующее программирование сокетов обрабатывает ошибки EAGAIN

Ресурс, временно недоступный, часто возникает при получении данных в неблокирующем сокете в Linux, а код ошибки равен 11 (EAGAIN). Буквально, это подсказка, чтобы попробовать еще раз. Эта ошибка часто возникает, когда приложение выполняет некоторые неблокирующие операции (над файлами или сокетами). Эта ошибка не нарушит синхронизацию сокета, независимо от этого, следующий цикл может быть восстановлен.

Для неблокирующих сокетов EAGAIN не является ошибкой. В VxWorks и Windows имя EAGAIN — EWOULDBLOCK.

Например, откройте файл / socket / FIFO с флагом O_NONBLOCK, если вы выполняете операции чтения непрерывно и данные не могут быть прочитаны. На этом этапе программа не будет блокироваться, пока данные не будут готовы к возврату. Функция чтения вернет ошибку EAGAIN, указывающую, что у вашего приложения нет данных для чтения. Повторите попытку позже.

В другом примере, когда системный вызов (такой как fork) не выполняется из-за нехватки ресурсов (например, виртуальной памяти), верните EAGAIN, чтобы запросить повторный вызов (возможно, в следующий раз это произойдет).

Ссылка:

https://segmentfault.com/a/1190000003780387

https://blog.csdn.net/haluoluo211/article/details/48381649

https://blog.csdn.net/wm_1991/article/details/51858997

<h2>TCP/IP Connection</h2>
OK.
Попытка соединиться с хостом '208.77.188.166' on port '80'...OK.
Отправка запроса HTTP HEAD...OK.
Получение ответа:

Прочитано 123 байта из функции socket_recv(). Закрываем сокет...HTTP/1.1 200 OK
Date: Mon, 14 Sep 2009 08:56:36 GMT
Server: Apache/2.2.3 (Red Hat)
Last-Modified: Tue, 15 Nov 2005 13:24:10 GMT
ETag: "b80f4-1b6-80bfd280"
Accept-Ranges: bytes
Content-Length: 438
Connection: close
Content-Type: text/html; charset=UTF-8

OK.

Вернуться к: Сокетные Функции

 By default a socket is configured so that sending or receiving data blocks, stopping program execution until the socket is ready (setblocking(1)). Calls to send() wait for buffer space to be available for the outgoing data, and calls to recv() wait for the other program to send data that can be read. This form of I/O operation is easy to understand, but can lead to inefficient operation and even deadlocks, if both programs end up waiting for the other to send or receive data.

There are a few ways to work around this situation. One is to use a separate thread for communicating with each socket. This can introduce other complexities, though, with communication between the threads.

Another option is to change the socket to not block at all, and return immediately if it is not ready to handle the operation. Use the setblocking() method to change the blocking flag for a socket. The default value is 1, which means to block. Passing a value of 0 turns off blocking. If the socket is has blocking turned off and it is not ready for the operation, then socket.error is raised.

A compromise solution is to set a timeout value for socket operations. Use settimeout() to change the timeout of a socket to a floating point value representing the number of seconds to block before deciding the socket is not ready for the operation. When the timeout expires, a timeout exception is raised.

In the case of a non blocking socket that has no data available, recv
will throw the socket.error exception and the value of the exception
will have the errno of either EAGAIN or EWOULDBLOCK.

import sys
import socket
import fcntl, os
import errno
from time import sleep

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(('127.0.0.1',9999))
fcntl.fcntl(s, fcntl.F_SETFL, os.O_NONBLOCK)

while True:
    try:
        msg = s.recv(4096)
    except socket.error, e:
        err = e.args[0]
        if err == errno.EAGAIN or err == errno.EWOULDBLOCK:
            sleep(1)
            print 'No data available'
            continue
        else:
            # a "real" error occurred
            print e
            sys.exit(1)
    else:
        # got a message, do something :)

The situation is a little different in the case where you’ve enabled non-blocking behavior via a time out with s.settimeout(n)

import sys
import socket
from time import sleep

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(('127.0.0.1',9999))
s.settimeout(2)

while True:
    try:
        msg = s.recv(4096)
    except socket.timeout, e:
        err = e.args[0]
        # this next if/else is a bit redundant, but illustrates how the
        # timeout exception is setup
        if err == 'timed out':
            sleep(1)
            print 'recv timed out, retry later'
            continue
        else:
            print e
            sys.exit(1)
    except socket.error, e:
        # Something else happened, handle error, exit, etc.
        print e
        sys.exit(1)
    else:
        if len(msg) == 0:
            print 'orderly shutdown on server end'
            sys.exit(0)
        else:
            # got a message do something :) 

But remember The socket.makefile() docs say, «the socket must be in blocking mode.

sock.settimeout(None)

Another method:

import select

mysocket.setblocking(0)

ready = select.select([mysocket], [], [], timeout_in_seconds)
if ready[0]:
    data = mysocket.recv(4096)