PHP Conference Nagoya 2025

Класс 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

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

Содержание

Добавить

Примечания пользователей

Пользователи ещё не добавляли примечания для страницы
To Top