Отправка сообщений через ZMQ

Question

[TANK_IST]

Нужно ли поддерживать жизнь этого скрипта:

$context = new ZMQContext($id, $mess);
$socket = $context->getSocket(ZMQ::SOCKET_PUSH, 'pusher');
$socket->connect("tcp://localhost:5555");
$socket->send($id.'>'.$mess);

как это я делаю с этим:

$context = new React\ZMQ\Context($loop);
$pull = $context->getSocket(ZMQ::SOCKET_PULL);
$pull->bind('tcp://127.0.0.1:5555');
$pull->on('message', array($pusher, 'onSend'));

Или его нужно вызывать каждый раз когда он нужен?

Comments

[Spirit Absolute]

У меня в $context и $socket пустые объекты ZMQContext и ZMQSocket... Ошибок никаких нет. Библиотека zmq подключена...

Answer 1

[papahoolio]

Второй скрипт создает сервер ØMQ на 5555 порту. Логично, что если этот скрипт умрет, то и сервера на 5555 не будет. Поэтому надо чтобы второй скрипт работал непрерывно.

Первый скрипт открывает соединение с сервером ØMQ (клиент) и отправляет сообщение. Надо ли ему дальше жить? Судя по коду нет - он единождый отправил и свою работу выполнил. А если не по коду - who knows.

Comments

[TANK_IST]

Не знаете ли Вы как узнать доставлено ли сообщение пользователю? Я так понял что ZMQSocket::recv это делает, но у меня при его использовании получается ошибка

[N]

Вот тут на словах принцип хорошо чел объяснил...

Цитирую

Забудьте большую часть низкоуровневых конструкций сокетов и забот. Думайте выше в небе. ZeroMQ представляет собой концепцию обмена сообщениями более высокого уровня. Таким образом, у вас возникнут проблемы с большинством проблем сокета-io.

Подробнее об этих принципах ZMQ читайте в стилях дизайна Pieter Hintjens и его богатой ресурсами книге "Code Connected, Vol.1".

Тем не менее, решение полностью находится под вашим контролем.

Решение

Создайте специфический для задачи multi-zmq-socket/multi-zmq-pattern (несколько zmq-примитивов, используемых и организованных вашей логикой уровня приложения) как формальное коммуникационное общение с конкретной задачей.

Убедитесь, что добавляет его PID в сообщение.

Повторите/авторизуйте через другой регистр/auth-socket-шаблон с предварительно зарегистрированным sender со стороны receiver, чтобы избежать поддельной атаки под фальшивым/украденным PID -идентивом.

Адаптируйте свою политику контроля доступа в соответствии с вашими проблемами, используйте и внедрите любой уровень формальных протоколов квитирования безопасности для проверки подлинности или обмена ключами, чтобы повысить безопасность вашей политики контроля доступа до достаточных сильных сторон (включая MIL- STD).

Есть у кого какие опыты более менее с примерами по современному?)