CakeFest 2024: The Official CakePHP Conference

Класс ZMQ

(PECL zmq >= 0.5.0)

Введение

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

class ZMQ {
/* Константы */
const int POLL_IN;
const int POLL_OUT;
const int ERR_EFSM;
const int ERR_ETERM;
/* Методы */
private __construct()
}

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

Типы констант 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 или выше (Значение: int).

ZMQ::SOCKOPT_HWM

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

ZMQ::SOCKOPT_SNDHWM

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

ZMQ::SOCKOPT_RCVHWM

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

ZMQ::SOCKOPT_AFFINITY

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

ZMQ::SOCKOPT_IDENTITY

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

ZMQ::SOCKOPT_SUBSCRIBE

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

ZMQ::SOCKOPT_UNSUBSCRIBE

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

ZMQ::SOCKOPT_RATE

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

ZMQ::SOCKOPT_RECOVERY_IVL

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

ZMQ::SOCKOPT_RECONNECT_IVL

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

ZMQ::SOCKOPT_RECONNECT_IVL_MAX

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

ZMQ::SOCKOPT_MCAST_LOOP

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

ZMQ::SOCKOPT_SNDBUF

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

ZMQ::SOCKOPT_RCVBUF

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

ZMQ::SOCKOPT_RCVMORE

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

ZMQ::SOCKOPT_TYPE

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

ZMQ::SOCKOPT_LINGER

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

ZMQ::SOCKOPT_BACKLOG

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

ZMQ::SOCKOPT_MAXMSGSIZE

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

ZMQ::SOCKOPT_SNDTIMEO

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

ZMQ::SOCKOPT_RCVTIMEO

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

ZMQ::SOCKOPT_IPV4ONLY

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

ZMQ::SOCKOPT_LAST_ENDPOINT

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

ZMQ::SOCKOPT_TCP_KEEPALIVE_IDLE

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

ZMQ::SOCKOPT_TCP_KEEPALIVE_CNT

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

ZMQ::SOCKOPT_TCP_KEEPALIVE_INTVL

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

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 и выше (Значение: int)

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

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

Содержание

add a note

User Contributed Notes

There are no user contributed notes for this page.
To Top