socket

Сетевой интерфейс низкого уровня

Этот модуль обеспечивает доступ к интерфейсу сокета socket BSD. Он доступен во всех современных системах Unix, Windows, MacOS и, возможно, на дополнительных платформах.

Некоторое поведение может зависеть от платформы, поскольку выполняются вызовы API сокетов операционной системы.

Интерфейс Python представляет собой прямую транслитерацию системного вызова Unix и интерфейса библиотеки для сокетов в объектно-ориентированный стиль Python: функция socket () возвращает объект сокета, методы которого реализуют различные системные вызовы сокетов. Типы параметров несколько более высокоуровневые, чем в интерфейсе C: как и в случае операций чтения () и записи () с файлами Python, распределение буфера при операциях приема происходит автоматически, а длина буфера неявна при операциях отправки.

См. также:

Модуль socketserver - классы, упрощающие написание сетевых серверов.

Модуль ssl - оболочка TLS/SSL для объектов сокета.

Семейство сокетов

В зависимости от системы и параметров сборки этот модуль поддерживает различные семейства сокетов.

Формат адреса, необходимый для конкретного объекта сокета, выбирается автоматически на основе семейства адресов, указанного при создании объекта сокета. Адреса сокетов представлены следующим образом:

• AF_UNIX - сокеты для межпроцессного взаимодействия UNIX-машин

• AF_INET - сокеты сетевого протокола IPv4

• AF_INET6 - сокеты сетевого протокола IPv6

• AF_NETLINK - сокеты для передачи информации между ядром системы и процессами

• AF_TIPC - сокеты TIPC, протокола, не основанного на IP (кластерная среда)

• AF_CAN - сокеты промышленной сети CAN

• PF_SYSTEM - сокеты для передачи информации между ядром системы и процессами

• AF_BLUETOOTH - сокеты для передачи информации в сети Bluetooth

• AF_ALG - интерфейс сокетов в Linux для криптографии ядра

• AF_VSOCK - сокеты для связи виртуальных машин с их хостами

• AF_PACKET - низкоуровневый интерфейс непосредственно для сетевых устройств

• AF_QIPCRTR - интерфейс сокетов для сопроцессоров Qualcomm в Linux

• IPPROTO_UDPLITE - вариант UDP с указанием какая часть покрывается контрольной суммой

Если вы используете имя хоста в части хоста адреса сокета IPv4/v6, программа может показывать недетерминированное поведение, поскольку Python использует первый адрес, возвращенный из разрешения DNS. Адрес сокета будет по-разному преобразован в фактический адрес IPv4/v6, в зависимости от результатов разрешения DNS и/или конфигурации хоста. Для детерминированного поведения используйте числовой адрес в части хоста.

Все ошибки вызывают исключения. Могут возникать обычные исключения для недопустимых типов аргументов и условий нехватки памяти; начиная с Python 3.3, ошибки, связанные с семантикой сокета или адреса, вызывают OSError или один из его подклассов (они использовались для повышения socket.error).

Неблокирующий режим поддерживается через setblocking (). Обобщение этого на основе тайм-аутов поддерживается через settimeout ().

Содержимое модуля

Модуль socket экспортирует следующие элементы.

Исключения

• socket.error exception - устаревший псевдоним OSError
• socket.herror exception

• socket.gaierror exception

• socket.timeout exception - исключение возникает, когда тайм-аут происходит в сокете

Константы

• socket.AF_UNIX

• socket.AF_INET

• socket.AF_INET6

• socket.SOCK_STREAM

• не заполнено...

• socket.CAN_BCM

• не заполнено...

Функции

Создание сокетов

Все следующие функции создают объекты сокетов.

• socket.socket () - создает новый сокет
• socket.socketpair ()

• socket.create_connection ()

• socket.create_server ()

• socket.has_dualstack_ipv6 ()

• socket.fromfd ()

• socket.fromshare ()

• socket.SocketType

Другие функции

Модуль socket также предлагает различные сетевые услуги:

• socket.close () - закрывает дескриптор файла сокета
• socket.getaddrinfo () - преобразует аргументы в кортеж с данными для создания сокета
• socket.getfqdn () - возвращает полное доменное имя
• socket.gethostbyname () - преобразует имя хоста в формат адреса IPv4
• socket.gethostbyname_ex () - преобразует имя хоста в расширенный формат адреса IPv4
• socket.gethostname () - возвращает строку с именем хоста, где выполняется Python
• socket.gethostbyaddr () - преобразует адрес формата IPv4/v6 в расширенное имя хоста
• socket.getnameinfo () - преобразует адрес сокета в кортеж хост/порт
• socket.getprotobyname () - преобразует имя интернет-протокола в константу для socket()
• socket.getservbyname () - преобразует имя интернет-службы и имя протокола в номер порта
• socket.getservbyport () - преобразует номер интернет-порта и имя протокола в имя службы
• socket.ntohl () - преобразует 32-битные целые числа из сети в порядок байтов хоста
• socket.ntohs ()

• socket.htonl () - преобразует 32-битные целые числа из хоста в сетевой порядок байтов
• socket.htons ()

• socket.inet_aton ()

• socket.inet_ntoa ()

• socket.inet_pton ()

• socket.inet_ntop ()

• socket.CMSG_LEN ()

• socket.CMSG_SPACE ()

• socket.getdeafulttimeout ()

• socket.setdefaulttimeout ()

• socket.sethostname ()

• socket.if_nameindex ()

• socket.if_nametoindex ()

• socket.if_indextoname ()

Объекты сокетов

У объектов socket есть следующие методы. За исключением makefile (), они соответствуют системным вызовам Unix, применимым к сокетам.

Изменено в версии 3.2: добавлена поддержка протокола диспетчера контекста. Выход из диспетчера контекста эквивалентен вызову close ().

• socket.accept () - принимает соединение
• socket.bind () - привязывает сокет к адресу
• socket.close () - помечает сокет закрытым
• socket.connect () - подключается к удаленному сокету по заданному адресу
• socket.connect_ex ()

• socket.detach ()

• socket.dup ()

• socket.fileno ()

• socket.get_inheritable ()

• socket.getpeername ()

• socket.getsockname ()

• socket.getsockopt ()

• socket.getblocking ()

• socket.gettimeout ()

• socket.ioctl ()

• socket.listen () - разрешает серверу принимать заданное количество соединений
• socket.makefile () - возвращает объект файла, связанный с сокетом
• socket.recv () - получает данные из сокета
• socket.recvfrom ()

• socket.recvmsg ()

• socket.recvmsg_into ()

• socket.recvfrom_into ()

• socket.recv_into ()

• socket.send () - отправляет данные в сокет
• socket.sendall () - отправляет все данные в сокет принудительно
• socket.sendto ()

• socket.sendmsg ()

• socket.sendmsg_afalg ()

• socket.send_fds ()

• socket.recv_fds ()

• socket.sendfile ()

• socket.set_inheritable ()

• socket.setblocking () - устанавливает блокирующий или неблокирующий режим сокета
• socket.settimeout () - устанавливает тайм-аут для блокировки операций сокета
• socket.setsockopt ()

• socket.shutdown ()

• socket.share ()

• socket.family

• socket.type

• socket.proto

Примечания относительно тайм-аутов сокетов

Объект сокета может находиться в одном из трех режимов: блокирующий, неблокирующий или тайм-аут. По умолчанию сокеты всегда создаются в режиме блокировки, но это можно изменить, вызвав setdefaulttimeout ().

• В режиме блокировки blocking mode операции блокируются до завершения или система не возвращает ошибку (например, истекло время ожидания соединения).

• В неблокирующем режиме non-blocking mode операции завершаются неудачно (с ошибкой, которая, к сожалению, зависит от системы), если они не могут быть выполнены немедленно: функции из модуля select могут использоваться, чтобы узнать, когда и доступен ли сокет для чтения или записи.
• В режиме тайм-аута timeout mode операции завершаются ошибкой, если они не могут быть завершены в течение тайм-аута, указанного для сокета (они вызывают исключение тайм-аута timeout exception) или если система возвращает ошибку.

На уровне операционной системы сокеты в режиме тайм-аута внутренне устанавливаются в неблокирующий режим. Кроме того, режимы блокировки и тайм-аута используются совместно дескрипторами файлов и объектами сокетов, которые относятся к одной и той же конечной точке сети. Эта деталь реализации может иметь видимые последствия, если, например, вы решили использовать fileno () сокета.

Тайм-ауты и метод connect

Операция connect () также зависит от установки тайм-аута, и в целом рекомендуется вызвать settimeout () перед вызовом connect () или передать параметр тайм-аута в create_connection (). Однако системный сетевой стек может также возвращать собственную ошибку тайм-аута соединения независимо от любого параметра тайм-аута сокета Python.

Тайм-ауты и метод accept

Если getdefaulttimeout () не равно None, сокеты, возвращаемые методом accept (), наследуют этот тайм-аут. В противном случае поведение зависит от настроек прослушивающего сокета:

• если прослушивающий сокет находится в режиме блокировки blocking mode или в режиме тайм-аута timeout mode, сокет, возвращаемый функцией accept (), находится в режиме блокировки blocking mode;
• если прослушивающий сокет находится в неблокирующем режиме non-blocking mode, то, находится ли сокет, возвращаемый accept (), в блокирующем или неблокирующем режиме, зависит от операционной системы. Если вы хотите обеспечить кросс-платформенное поведение, рекомендуется вручную переопределить этот параметр.

Примеры

Вот четыре минимальных примера программ, использующих протокол TCP/IP: сервер, который отображает все данные, которые он получает обратно (обслуживая только одного клиента), и клиент, использующий его. Обратите внимание, что сервер должен выполнять последовательность socket (), bind (), listen (), accept () (возможно, повторяя accept () для обслуживания более чем одного клиента), в то время как клиенту требуется только последовательность socket (), connect (). Также обратите внимание, что сервер не выполняет sendall () / recv () на сокете, который он прослушивает, а на новом сокете, возвращаемом accept ().

Первые два примера поддерживают только IPv4.

# Программа эхо-сервера
import socket

HOST = ''                 # Символическое имя, означающее все доступные интерфейсы
PORT = 50007              # Произвольный непривилегированный порт
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    s.bind((HOST, PORT))
    s.listen(1)
    conn, addr = s.accept()
    with conn:
        print('Connected by', addr)
        while True:
            data = conn.recv(1024)
            if not data: break
            conn.sendall(data)

# Программа эхо-клиента
import socket

HOST = 'daring.cwi.nl'    # Удаленный хост
PORT = 50007              # Тот же порт, что и сервер
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    s.connect((HOST, PORT))
    s.sendall(b'Hello, world')
    data = s.recv(1024)
print('Received', repr(data))

Следующие два примера идентичны двум приведенным выше, но поддерживают как IPv4, так и IPv6. Сторона сервера будет прослушивать первое доступное семейство адресов (вместо этого она должна слушать оба). В большинстве систем, поддерживающих IPv6, IPv6 будет иметь приоритет, и сервер может не принимать трафик IPv4. Клиентская сторона попытается подключиться ко всем адресам, полученным в результате разрешения имен, и отправит трафик на первый успешно подключенный.

# Программа эхо-сервера
import socket
import sys

HOST = None               # Символическое имя, означающее все доступные интерфейсы
PORT = 50007              # Произвольный непривилегированный порт
s = None
for res in socket.getaddrinfo(HOST, PORT, socket.AF_UNSPEC,
                              socket.SOCK_STREAM, 0, socket.AI_PASSIVE):
    af, socktype, proto, canonname, sa = res
    try:
        s = socket.socket(af, socktype, proto)
    except OSError as msg:
        s = None
        continue
    try:
        s.bind(sa)
        s.listen(1)
    except OSError as msg:
        s.close()
        s = None
        continue
    break
if s is None:
    print('could not open socket')
    sys.exit(1)
conn, addr = s.accept()
with conn:
    print('Connected by', addr)
    while True:
        data = conn.recv(1024)
        if not data: break
        conn.send(data)

# Программа эхо-клиента
import socket
import sys

HOST = 'daring.cwi.nl'    # Удаленный хост
PORT = 50007              # Тот же порт, что и сервер
s = None
for res in socket.getaddrinfo(HOST, PORT, socket.AF_UNSPEC, socket.SOCK_STREAM):
    af, socktype, proto, canonname, sa = res
    try:
        s = socket.socket(af, socktype, proto)
    except OSError as msg:
        s = None
        continue
    try:
        s.connect(sa)
    except OSError as msg:
        s.close()
        s = None
        continue
    break
if s is None:
    print('could not open socket')
    sys.exit(1)
with s:
    s.sendall(b'Hello, world')
    data = s.recv(1024)
print('Received', repr(data))

В следующем примере показано, как написать очень простой сетевой сниффер с необработанными сокетами в Windows. В примере требуются права администратора для изменения интерфейса:

import socket

# публичный сетевой интерфейс
HOST = socket.gethostbyname(socket.gethostname())

# создать необработанный сокет и привязать его к общедоступному интерфейсу
s = socket.socket(socket.AF_INET, socket.SOCK_RAW, socket.IPPROTO_IP)
s.bind((HOST, 0))

# Включить заголовки IP
s.setsockopt(socket.IPPROTO_IP, socket.IP_HDRINCL, 1)

# получить все пакеты
s.ioctl(socket.SIO_RCVALL, socket.RCVALL_ON)

# получить пакет
print(s.recvfrom(65565))

# отключен беспорядочный режим
s.ioctl(socket.SIO_RCVALL, socket.RCVALL_OFF)

В следующем примере показано, как использовать интерфейс сокета для связи с сетью CAN с использованием протокола сырых сокетов. Чтобы вместо этого использовать CAN с протоколом диспетчера вещания, откройте сокет с помощью:

socket.socket(socket.AF_CAN, socket.SOCK_DGRAM, socket.CAN_BCM)

После привязки (CAN_RAW) или подключения (CAN_BCM) сокета вы можете использовать операции socket.send () и socket.recv () (и их аналоги) для объекта сокета как обычно.

В этом последнем примере могут потребоваться особые привилегии:

import socket
import struct


# Упаковка/распаковка CAN-фреймов (см. 'Struct can_frame' в <linux / can.h>)

can_frame_fmt = "=IB3x8s"
can_frame_size = struct.calcsize(can_frame_fmt)

def build_can_frame(can_id, data):
    can_dlc = len(data)
    data = data.ljust(8, b'\x00')
    return struct.pack(can_frame_fmt, can_id, can_dlc, data)

def dissect_can_frame(frame):
    can_id, can_dlc, data = struct.unpack(can_frame_fmt, frame)
    return (can_id, can_dlc, data[:can_dlc])


# создать необработанный сокет и привязать его к интерфейсу 'vcan0'
s = socket.socket(socket.AF_CAN, socket.SOCK_RAW, socket.CAN_RAW)
s.bind(('vcan0',))

while True:
    cf, addr = s.recvfrom(can_frame_size)

    print('Received: can_id=%x, can_dlc=%x, data=%s' % dissect_can_frame(cf))

    try:
        s.send(cf)
    except OSError:
        print('Error sending CAN frame')

    try:
        s.send(build_can_frame(0x01, b'\x01\x02\x03'))
    except OSError:
        print('Error sending CAN frame')

Выполнение примера несколько раз со слишком малой задержкой между выполнениями может привести к этой ошибке:

OSError: [Errno 98] Address already in use

Это связано с тем, что предыдущее выполнение оставило сокет в состоянии TIME_WAIT и не может быть немедленно использовано повторно.

Чтобы предотвратить это, нужно установить флаг сокета socket.SO_REUSEADDR:

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.bind((HOST, PORT))

флаг SO_REUSEADDR указывает ядру повторно использовать локальный сокет в состоянии TIME_WAIT, не дожидаясь истечения его естественного тайм-аута.

См.также: Введение в программирование сокетов (на C) можно найти в следующих статьях:

• Вводное руководство по межпроцессному взаимодействию 4.3BSD от Стюарта Сечреста

• Расширенный учебник по межпроцессному взаимодействию 4.3BSD, Сэмюэл Дж. Леффлер и др.

оба в Руководстве программиста UNIX, Дополнительные документы 1 (разделы PS1: 7 и PS1: 8). Справочные материалы, относящиеся к конкретной платформе, по различным системным вызовам, связанным с сокетами, также являются ценным источником информации о деталях семантики сокетов. Для Unix см. Справочные страницы; для Windows см. спецификацию WinSock (или Winsock 2). Для интерфейсов API, поддерживающих IPv6, читатели могут захотеть обратиться к RFC 3493 под названием «Расширения базового интерфейса сокетов для IPv6».