Сокеты

Sockets.connectМетод

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

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

Sockets.connectМетод

connect(path::AbstractString) -> PipeEndpoint

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

Sockets.listenМетод

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

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

Sockets.listenМетод

listen(path::AbstractString) -> PipeServer

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

Sockets.getaddrinfoФункция

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

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

Sockets.getipaddrФункция

getipaddr() -> IPAddr

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

Примеры

julia> getipaddr()
ip"192.168.1.28"

Sockets.getalladdrinfoФункция

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"

Sockets.getnameinfoФункция

getnameinfo(host::IPAddr) -> String

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

Примеры

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

Sockets.getsocknameФункция

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

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

Sockets.getpeernameФункция

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

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

Sockets.IPv4Тип

IPv4(host::Integer) -> IPv4

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

julia> IPv4(3223256218)
ip"192.30.252.154"

Sockets.IPv6Тип

IPv6(host::Integer) -> IPv6

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

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

Sockets.TCPSocketТип

TCPSocket(; delay=true)

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

Sockets.UDPSocketТип

UDPSocket()

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

Sockets.acceptФункция

accept(server[,client])

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

Sockets.listenanyФункция

listenany([host::IPAddr,] port_hint) -> (UInt16, TCPServer)

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

Base.bindФункция

bind(socket::Union{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: foo
Stacktrace:
[...]

Sockets.sendФункция

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

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

Sockets.recvФункция

recv(socket::UDPSocket)

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

Sockets.recvfromФункция

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

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

Sockets.setoptФункция

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).