Сокеты

Поддержка сокетов. Предоставляет IPAddr и подтипы, TCPSocket, и UDPSocket.

connect([host], port::Integer) -> TCPSocket

Подключение к хосту host на порту port.

connect(path::AbstractString) -> PipeEndpoint

Подключение к именованной трубе / сокету доменной области UNIX по адресу path.

listen([addr, ]port::Integer; backlog::Integer=BACKLOG_DEFAULT) -> TCPServer

Прослушивание порта по адресу, указанному в addr. По умолчанию прослушивание только по localhost. Для прослушивания на всех интерфейсах передайте IPv4(0) или IPv6(0) соответственно. backlog определяет, сколько соединений может ожидать (не вызвав accept) сервер, прежде чем начнёт их отклонять. Значение по умолчанию backlog равно 511.

listen(path::AbstractString) -> PipeServer

Создание и прослушивание именованной трубы / сокета доменной области UNIX.

getaddrinfo(host::AbstractString, IPAddr=IPv4) -> IPAddr

Получает первый IP-адрес host заданного IPAddr типа. Использует реализацию getaddrinfo операционной системы, которая может выполнить поиск по DNS.

getipaddr() -> IPAddr

Получение IP-адреса локальной машины, отдавая предпочтение IPv4 перед IPv6. Бросает исключение, если адреса недоступны.

getipaddr(addr_type::Type{T}) where T<:IPAddr -> T

Получение IP-адреса локальной машины указанного типа. Бросает исключение, если адреса указанного типа недоступны.

Эта функция является обёрткой обратной совместимости для getipaddrs. Новые приложения должны использовать getipaddrs вместо неё.

Примеры

julia> getipaddr()
ip"192.168.1.28"

julia> getipaddr(IPv6)
ip"fe80::9731:35af:e1c5:6e49"

См. также getipaddrs.

getipaddrs(addr_type::Type{T}=IPAddr; loopback::Bool=false) where T<:IPAddr -> Vector{T}

Получение IP-адресов локальной машины.

Установка необязательного параметра addr_type в значение IPv4 или IPv6 приводит к возврату только адресов указанного типа.

Ключевое слово loopback определяет, включать ли петлевые адреса (например, ip"127.0.0.1", ip"::1").

Примеры

julia> getipaddrs()
5-element Array{IPAddr,1}:
 ip"198.51.100.17"
 ip"203.0.113.2"
 ip"2001:db8:8:4:445e:5fff:fe5d:5500"
 ip"2001:db8:8:4:c164:402e:7e3c:3668"
 ip"fe80::445e:5fff:fe5d:5500"

julia> getipaddrs(IPv6)
3-element Array{IPv6,1}:
 ip"2001:db8:8:4:445e:5fff:fe5d:5500"
 ip"2001:db8:8:4:c164:402e:7e3c:3668"
 ip"fe80::445e:5fff:fe5d:5500"

См. также islinklocaladdr.

islinklocaladdr(addr::IPAddr)

Проверяет, является ли IP-адрес адресом сети. Адреса сети не гарантируют уникальность за пределами сегмента сети, поэтому маршрутизаторы их не передают. Адреса сети берутся из блоков адресов 169.254.0.0/16 или fe80::/10.

Пример

filter(!islinklocaladdr, getipaddrs())

getalladdrinfo(host::AbstractString) -> Vector{IPAddr}

Получение всех IP-адресов host. Использует реализацию getaddrinfo операционной системы, которая может выполнить поиск по DNS.

Пример

julia> getalladdrinfo("google.com")
2-element Array{IPAddr,1}:
 ip"172.217.6.174"
 ip"2607:f8b0:4000:804::200e"

DNSError

Тип исключения, выбрасываемого при ошибке в поиске по DNS. Поле host указывает строку URL хоста. Поле code указывает код ошибки, основанный на libuv.

getnameinfo(host::IPAddr) -> String

Выполняет обратный поиск по IP-адресу для возврата имени хоста и службы с использованием реализации getnameinfo операционной системы.

Примеры

julia> getnameinfo(IPv4("8.8.8.8"))
"google-public-dns-a.google.com"

getsockname(sock::Union{TCPServer, TCPSocket}) -> (IPAddr, UInt16)

Получение IP-адреса и порта, к которому привязан данный сокет.

getpeername(sock::TCPSocket) -> (IPAddr, UInt16)

Получение IP-адреса и порта удалённого конечного пункта, к которому подключён данный сокет. Действительно только для подключённых TCP-сокетов.

IPAddr

Абстрактный супертип для IP-адресов. IPv4 и IPv6 являются подтипами этого.

IPv4(host::Integer) -> IPv4

Возвращает объект IPv4 из IP-адреса host в формате Integer.

Примеры

julia> IPv4(3223256218)
ip"192.30.252.154"

IPv6(host::Integer) -> IPv6

Возвращает объект IPv6 из IP-адреса host в формате Integer.

Примеры

julia> IPv6(3223256218)
ip"::c01e:fc9a"

@ip_str str -> IPAddr

Парсинг str как IP-адреса.

Примеры

julia> ip"127.0.0.1"
ip"127.0.0.1"

julia> @ip_str "2001:db8:0:0:0:0:2:1"
ip"2001:db8::2:1"

TCPSocket(; delay=true)

Открытие TCP-сокета с использованием libuv. Если delay имеет значение true, libuv откладывает создание файла описания сокета до первого вызова bind. TCPSocket имеет различные поля для обозначения состояния сокета и его буферов отправки/приёма.

UDPSocket()

Открытие UDP-сокета с использованием libuv. UDPSocket имеет различные поля для обозначения состояния сокета.

accept(server[, client])

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

listenany([host::IPAddr,] port_hint; backlog::Integer=BACKLOG_DEFAULT) -> (UInt16, TCPServer)

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

bind(socket::Union{TCPServer, UDPSocket, TCPSocket}, host::IPAddr, port::Integer; ipv6only=false, reuseaddr=false, kws...)

Привязка socket к данному host:port. Обратите внимание, что 0.0.0.0 будет прослушивать все устройства.

• Параметр ipv6only отключает режим двойной стековой архитектуры. Если ipv6only=true, создаётся только IPv6 стек.
• Если reuseaddr=true, несколько потоков или процессов могут привязываться к одному адресу без ошибки, если все они установят reuseaddr=true, но только последний, кто привяжется, получит любые данные.

bind(chnl::Channel, task::Task)

Связывание срока службы chnl с задачей. Channel chnl автоматически закрывается при завершении задачи. Любое необработанное исключение в задаче передаётся всем ожидающим на chnl.

Объект chnl может быть явно закрыт независимо от завершения задачи. Завершение задач не влияет на уже закрытые объекты Channel.

Когда канал привязан к нескольким задачам, первая завершившаяся задача закроет канал. Когда несколько каналов привязаны к одной задаче, завершение задачи закроет все привязанные каналы.

Примеры

julia> c = Channel(0);

julia> task = @async foreach(i->put!(c, i), 1:4);

julia> bind(c,task);

julia> for i in c
           @show i
       end;
i = 1
i = 2
i = 3
i = 4

julia> isopen(c)
false

julia> c = Channel(0);

julia> task = @async (put!(c, 1); error("foo"));

julia> bind(c, task);

julia> take!(c)
1

julia> put!(c, 1);
ERROR: TaskFailedException
Stacktrace:
[...]
    nested task error: foo
[...]

send(socket::UDPSocket, host::IPAddr, port::Integer, msg)

Отправка msg по socket в host:port.

recv(socket::UDPSocket)

Чтение UDP-пакета из указанного сокета и возврат полученных байтов. Этот вызов блокирующий.

recvfrom(socket::UDPSocket) -> (host_port, data)

Чтение UDP-пакета из указанного сокета, возвращая кортеж из (host_port, data), где host_port будет InetAddr{IPv4} или InetAddr{IPv6}, соответственно.

setopt(sock::UDPSocket; multicast_loop=nothing, multicast_ttl=nothing, enable_broadcast=nothing, ttl=nothing)

Установить параметры сокета UDP.

• multicast_loop: петля обратной связи для мультимедийных пакетов (по умолчанию: true).
• multicast_ttl: TTL для мультимедийных пакетов (по умолчанию: nothing).
• enable_broadcast: флаг должен быть установлен в true, если сокет будет использоваться для широковещательных сообщений, в противном случае система UDP вернёт ошибку доступа (по умолчанию: false).
• ttl: Время жизни пакетов, отправленных по сокету (по умолчанию: nothing).

nagle(socket::Union{TCPServer, TCPSocket}, enable::Bool)

Включает или отключает алгоритм Нагля на данном TCP-сервере или сокете.

quickack(socket::Union{TCPServer, TCPSocket}, enable::Bool)

На системах Linux TCP_QUICKACK отключается или включается на socket.