Класс ZMQ

(No version information available, might only be in Git)

Введение

Обзор классов

ZMQ {
/* Константы */
const integer SOCKET_PAIR ;
const integer SOCKET_PUB ;
const integer SOCKET_SUB ;
const integer SOCKET_REQ ;
const integer SOCKET_REP ;
const integer SOCKET_XREQ ;
const integer SOCKET_XREP ;
const integer SOCKET_PUSH ;
const integer SOCKET_PULL ;
const integer SOCKET_ROUTER ;
const integer SOCKET_DEALER ;
const integer SOCKET_XPUB ;
const integer SOCKET_XSUB ;
const integer SOCKET_STREAM ;
const integer SOCKOPT_HWM ;
const integer SOCKOPT_SNDHWM ;
const integer SOCKOPT_RCVHWM ;
const integer SOCKOPT_AFFINITY ;
const integer SOCKOPT_IDENTITY ;
const integer SOCKOPT_SUBSCRIBE ;
const integer SOCKOPT_UNSUBSCRIBE ;
const integer SOCKOPT_RATE ;
const integer SOCKOPT_RECOVERY_IVL ;
const integer SOCKOPT_RECONNECT_IVL ;
const integer SOCKOPT_RECONNECT_IVL_MAX ;
const integer SOCKOPT_MCAST_LOOP ;
const integer SOCKOPT_SNDBUF ;
const integer SOCKOPT_RCVBUF ;
const integer SOCKOPT_RCVMORE ;
const integer SOCKOPT_TYPE ;
const integer SOCKOPT_LINGER ;
const integer SOCKOPT_BACKLOG ;
const integer SOCKOPT_MAXMSGSIZE ;
const integer SOCKOPT_SNDTIMEO ;
const integer SOCKOPT_RCVTIMEO ;
const integer SOCKOPT_IPV4ONLY ;
const integer SOCKOPT_LAST_ENDPOINT ;
const integer SOCKOPT_TCP_KEEPALIVE_CNT ;
const integer SOCKOPT_TCP_ACCEPT_FILTER ;
const integer SOCKOPT_TCP_ACCEPT_FILTER ;
const integer SOCKOPT_XPUB_VERBOSE ;
const integer SOCKOPT_ROUTER_RAW ;
const integer SOCKOPT_IPV6 ;
const integer CTXOPT_MAX_SOCKETS ;
const integer POLL_IN ;
const integer POLL_OUT ;
const integer MODE_NOBLOCK ;
const integer MODE_DONTWAIT ;
const integer MODE_SNDMORE ;
const integer ERR_INTERNAL ;
const integer ERR_EAGAIN ;
const integer ERR_ENOTSUP ;
const integer ERR_EFSM ;
const integer ERR_ETERM ;
/* Methods */
private__construct ( void )
}

Предопределенные константы

Типы констант ZMQ

ZMQ::SOCKET_PAIR

Эксклюзивный парный шаблон

ZMQ::SOCKET_PUB

Сокет источника

ZMQ::SOCKET_SUB

Сокет подписчика

ZMQ::SOCKET_REQ

Сокет запроса

ZMQ::SOCKET_REP

Сокет ответа

ZMQ::SOCKET_XREQ

Псевдоним для SOCKET_DEALER

ZMQ::SOCKET_XREP

Псевдоним для SOCKET_ROUTER

ZMQ::SOCKET_PUSH

Сокет конвеера отправки

ZMQ::SOCKET_PULL

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

ZMQ::SOCKET_ROUTER

Расширенный REP-сокет, маршрутизирующий ответы потребителям

ZMQ::SOCKET_DEALER

Расширенный REP-сокет, осуществляющий балансировку нагрузки для всех связанных пар

ZMQ::SOCKET_XPUB

Аналогично SOCKET_PUB, за исключением того, что вы можете получать подписку как сообщения. Сообщение о подписке будет 0 (отписаться) или 1 (подписаться) с последующим содержимым сообщения

ZMQ::SOCKET_XSUB

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

ZMQ::SOCKET_STREAM

Используется для отсылки и приема данных по TCP от не-ØMQ клиентов. Доступно, если скомпилировано с ZeroMQ 4.x или выше (Значение: integer).

ZMQ::SOCKOPT_HWM

Верхняя граница для входящих и исходящих сообщений жестко ограничена максимальным количеством сообщений, которые ØMQ может держать в памяти для одного клиента, связанного с соответствующим сокетом. Установка данной опции для сокета будет влиять только на соединения, установленные после ее установки. В ZeroMQ 3.x это является оберткой для одновременной установки SNDHWM и RCVHWM. (Значение: integer).

ZMQ::SOCKOPT_SNDHWM

Опция ZMQ_SNDHWM должна устанавливать верхнюю границу для исходящих сообщений на конкретном сокете. Доступно, если собрано с ZeroMQ 3.x или выше (Значение: integer).

ZMQ::SOCKOPT_RCVHWM

Опция SOCKOPT_RCVHWM должна устанавливать верхнюю границу для входящих сообщений на конкретном сокете. Доступно, если собрано с ZeroMQ 3.x или выше (Значение: integer).

ZMQ::SOCKOPT_AFFINITY

Установить сходство потока ввода / вывода (Значение: integer)

ZMQ::SOCKOPT_IDENTITY

Установить идентификатор сокета (Значение: string)

ZMQ::SOCKOPT_SUBSCRIBE

Установить фильтр сообщений. Корректно для сокета подписчика (Значение: string)

ZMQ::SOCKOPT_UNSUBSCRIBE

Удалить фильтр сообщений. Корректно для сокета подписчика (Значение: string)

ZMQ::SOCKOPT_RATE

Установить скорость для сокетов групповой рассылки (pgm) (Значение: integer >= 0)

ZMQ::SOCKOPT_RECOVERY_IVL

Установить интервал восстановления для сокетов групповой рассылки (Значение: integer >= 0)

ZMQ::SOCKOPT_RECONNECT_IVL

Установить начальный интервал пересоединения (Значение: integer >= 0)

ZMQ::SOCKOPT_RECONNECT_IVL_MAX

Установить максимальный интервал пересоединения (Значение: integer >= 0)

ZMQ::SOCKOPT_MCAST_LOOP

Контроль закольцовки групповой рассылки (Значение: integer >= 0)

ZMQ::SOCKOPT_SNDBUF

Установить размер буфера передачи ядра (Значение: integer >= 0)

ZMQ::SOCKOPT_RCVBUF

Установить размер буфера приема ядра (Значение: integer >= 0)

ZMQ::SOCKOPT_RCVMORE

Получить многосоставные сообщения (Значение: integer)

ZMQ::SOCKOPT_TYPE

Получить тип сокета. Корректно для getSockOpt (Значение: integer)

ZMQ::SOCKOPT_LINGER

Линейное значение сокета. Определяет, как долго сокет блокирует попытки очистки сообщений после его закрытия. (Значение: integer)

ZMQ::SOCKOPT_BACKLOG

Опция SOCKOPT_BACKLOG устанавливает максимальную длину очереди клиентского соединения для указанного сокета. Работает только с транспортом ориентированным на соединение. (Значение: integer)

ZMQ::SOCKOPT_MAXMSGSIZE

Ограничивает максимальный размер входящего сообщения. -1 означает, что ограничений нет. Доступно, если собрано с ZeroMQ 3.x и выше (Значение: integer)

ZMQ::SOCKOPT_SNDTIMEO

Устанавливает таймаут для операции отправки на сокете. -1 означает отсутствие ограничений. Доступно, если собрано с ZeroMQ 3.x и выше (Значение: integer)

ZMQ::SOCKOPT_RCVTIMEO

Устанавливает таймаут для операции приема на сокете. -1 означает отсутствие ограничений. Доступно, если собрано с ZeroMQ 3.x и выше (Значение: integer)

ZMQ::SOCKOPT_IPV4ONLY

Если равно 1, то запрещает IPV6. Доступно, если собрано с ZeroMQ 3.x (Значение: integer)

ZMQ::SOCKOPT_LAST_ENDPOINT

Извлекает последнего присоединившегося клиента. Для использования с * wildcard-портами. Доступно, если собрано с ZeroMQ 3.x и выше (Значение: string)

ZMQ::SOCKOPT_TCP_KEEPALIVE_IDLE

Время простоя для отправки TCP-keepalive. Доступно, если собрано с ZeroMQ 3.x и выше (Значение: integer)

ZMQ::SOCKOPT_TCP_KEEPALIVE_CNT

Подсчитать время для TCP-keepalive. Доступно, если собрано с ZeroMQ 3.x и выше (Значение: integer)

ZMQ::SOCKOPT_TCP_KEEPALIVE_INTVL

Интервал для TCP-keepalive. Доступно, если собрано с ZeroMQ 3.x и выше (Значение: integer)

ZMQ::SOCKOPT_DELAY_ATTACH_ON_CONNECT

Послать строку CIDR для сверки с входящим соединением по TCP. Доступно, если собрано с ZeroMQ 3.x и выше (Значение: string)

ZMQ::SOCKOPT_TCP_ACCEPT_FILTER

Послать строку CIDR для сверки с входящим соединением по TCP. Доступно, если собрано с ZeroMQ 3.x и выше (Значение: string)

ZMQ::SOCKOPT_XPUB_VERBOSE

Установить XPUB для приема сообщения приложения для каждого экземпляра подписчика. Доступно, если собрано с ZeroMQ 3.x и выше (Значение: string)

ZMQ::SOCKOPT_ROUTER_RAW

Если 1, то устанавливает для ROUTER режим "без обработки". В режиме "без обработки", если используется транспорт tcp://, сокет будет читать и писать без использования фреймов ZeroMQ. Доступно, если собрано с ZeroMQ 4.0 и выше (Значение: string)

ZMQ::SOCKOPT_IPV6

Разрешает IPV6. Доступно, если собрано с ZeroMQ 4.0 и выше (Значение: string)

ZMQ::CTXOPT_MAX_SOCKETS

Ограничение сокета на контекст. Доступно, если собрано с ZeroMQ 3.x и выше (Значение: integer)

ZMQ::POLL_IN

Опросить на предмет входящих данных

ZMQ::POLL_OUT

Опросить на предмет исходящих данных

ZMQ::MODE_NOBLOCK

Неблокирующая работа. Объявлено устаревшим, используйте ZMQ::MODE_DONTWAIT

ZMQ::MODE_DONTWAIT

Неблокирующая работа

ZMQ::MODE_SNDMORE

Послать многосоставное сообщение

ZMQ::DEVICE_FORWARDER

Устройство пересылки

ZMQ::DEVICE_QUEUE

Устройство очереди

ZMQ::DEVICE_STREAMER

Устройство потокового вещания

ZMQ::ERR_INTERNAL

Внутренняя ошибка расширения ZMQ

ZMQ::ERR_EAGAIN

Подразумевает, что операция будет блокироваться при использовании ZMQ::MODE_DONTWAIT

ZMQ::ERR_ENOTSUP

Операция не поддерживается типом сокета

ZMQ::ERR_EFSM

Операция не будет выполнена, поскольку сокет находится в некорректном состоянии

ZMQ::ERR_ETERM

Контекст был прерван

Содержание