Описание тега zeromq
ZeroMQ (ZMQ, 0MQ, ØMQ) is a high-performance, asynchronous, transport-class agnostic, messaging library, aimed at use in scalable, distributed and/or concurrent applications. It provides a message queue, but unlike message-oriented middleware, a ZeroMQ system can run without a dedicated message broker. License: LGPL with static linking exception
2
ответа
ZeroMQ, как подключиться к внешнему tcp сокету?
Подскажите, пожалуйста, как можно использовать для отправки сообщений ZeroMQ между двумя программами, расположенными на разных серверах, используя какой-то общий сокет? Со всеми локальными сокетами программа работает, но я не понимаю, как они распро…
24 янв '13 в 21:30
1
ответ
Poller из Java ZeroMQ потребляет все больше памяти в куче
У меня есть простое приложение, которое передает данные с одной машины на другую. По мере запуска приложения размер кучи медленно увеличивается. Поэтому я свалил кучу и проанализировал ее, и обнаружил, что zmq.poll.Poller стоит самый большой объем п…
26 мар '18 в 15:06
1
ответ
Подсчет количества соединений в сокете ZeroMQ
Есть ли способ подсчитать количество подключенных в данный момент клиентов в сокете zeromq? Если это невозможно, есть ли способ определить, к какому сокету не подключен клиент? Благодарю.
11 сен '12 в 10:54
0
ответов
Функция onPush() не срабатывает после нажатия на контроллер с помощью ZeroMQ в пакете Guinness of Symfony/Websocket в symfony2
config.yml gos_web_socket: topics: - @app.real_time.subscribe - @app.real_time.push server: port: 8000 #The port the socket server will listen on host: localhost #The host ip to bind to router: resources: - @AppBundle/Resources/config/pubsub/routing…
09 июн '16 в 11:07
1
ответ
Управляющая блокировка на массаж в кролике
Я пытаюсь использовать RabbitMq более нетрадиционным способом (хотя в этот момент я могу выбрать любую другую реализацию очереди сообщений, если это необходимо) мое приложение работает так, у меня есть одна очередь (я могу иметь больше, если нужно),…
26 окт '16 в 10:10
0
ответов
Преобразование zeromq между типами данных
Здравствуйте, я пытаюсь понять и научиться работать с ZeroMQ, и хотя это может быть основным, я не нашел способа это исправить. В этом коде я пытаюсь создать сервер для пересылки сообщений от одного клиента другому. Сервер скомпилирован просто отлич…
10 сен '13 в 02:14
0
ответов
Клиент socket.io получает неверные данные
У меня есть проект в реальном времени, который по какой-то причине мой клиент socket.io получает данные, отправленные с сервера неправильно. я не обязательно получаю сообщение об ошибке, когда я консоль, войдите, это, кажется, получает что-то просто…
05 авг '18 в 17:00
2
ответа
Как проснуться темы с ZeroMQ
Моя текущая программа получает сообщения через zmq. Поток просыпается время от времени и проверяет, что zmq получил последним. Теперь я хочу улучшить эту настройку и фактически обрабатывать каждое входящее сообщение, а не только последнее при пробуж…
19 июн '17 в 06:38
1
ответ
AttributeError: у объекта 'str' нет атрибута 'decode'
Я собираюсь установить библиотеку ZeroMQ на свой компьютер, используя установщик pip-пакетов. Я использую https://learning-0mq-with-pyzmq.readthedocs.org/en/latest/pyzmq/basics.html качестве справочного материала. После выполнения следующей команды:…
19 июн '15 в 11:17
3
ответа
Рекомендовать службу очереди сообщений с открытым исходным кодом
Кто-нибудь может порекомендовать мне очередь сообщений с открытым исходным кодом? как JMS, gearmand,zeroMq,Amazon SQS. Tt лучше всего удовлетворить следующие пункты (не обязательно): распределенный и масштабируемый. поддерживается асинхронное сообще…
04 май '12 в 01:54
2
ответа
Как решить проблему с потоками в ZeroMQ + Ruby?
Наткнуться на чтение ZeroMQ FAQ о безопасности потоков. Моя многопоточная программа продолжает зависать в странных местах внутри библиотеки ZeroMQ. Что я делаю неправильно? Розетки ZeroMQ не являются поточно-ориентированными. Это подробно описано в …
04 авг '16 в 17:15
1
ответ
pyzmq recv_json не может декодировать сообщение, отправленное send_json
Вот мой код с извлеченными посторонними вещами: coordinator.py context = zmq.Context() socket = context.socket(zmq.ROUTER) port = socket.bind_to_random_port(ZMQ_ADDRESS) poller = zmq.Poller() poller.register(socket, zmq.POLLIN) while True: event = p…
12 дек '15 в 16:41
2
ответа
Можно ли использовать zmq::poll() для архетипа сокета ZMQ_PAIR?
Можно ли использовать zmq::poll с разъемом типа ZMQ_PAIR? У меня есть следующий код: zmq::context_t ctx; // create an in-process publisher for testing purposes zmq::socket_t pub( ctx, ZMQ_PAIR ); pub.connect( "inproc://SelectTest_oneMessage" ); Send…
12 июн '17 в 22:21
1
ответ
ZeroMQ PULL получает все сообщения в очереди
У меня есть большое (~100) количество "клиентов" PUSH, которые периодически (~1/ с) отправляют сообщение на "сервер" PULL. Сервер обрабатывает сообщения в пакетном режиме со скоростью ~2 пакета в секунду. Размер пакета не является фиксированным - в …
15 май '17 в 13:36
1
ответ
Требуется ли для каждой очереди в ZeroMQ свой порт?
Мы стремимся построить фасад в nodejs, который будет принимать запросы от клиента, а затем обрабатывать запросы для ряда сервисов, используя шаблон запроса / ответа для ряда различных внутренних сервисов. Мы хотим, чтобы эти запросы удерживались в о…
21 фев '13 в 16:42
1
ответ
Обработка клавиатурных прерываний в асинхронном режиме zmq
Я делаю сервер ZeroMQ в pyzmq с помощью asyncio, Я пытаюсь изящно справиться с остановкой сервера, но документации по асинхронному модулю очень мало, и, похоже, нет простого способа справиться с остановкой текущего опроса / ожидания. Остановка цикла…
18 авг '16 в 13:20
0
ответов
Добавление новых рабочих потоков в zeromq под нагрузкой
Существует множество примеров предоставления многопоточного сервера в 0MQ, начиная с: http://zguide.zeromq.org/java:mtserver но во всем, что я видел, количество рабочих потоков устанавливается при запуске. Хотя добавлять рабочие потоки во время выпо…
07 окт '13 в 08:18
1
ответ
Создано больше тем, чем ожидалось
Вы можете найти программу здесь Я строю программу в рамках передачи сообщений 0MQ. Я пытаюсь реализовать то, что я написал здесь Программа составлена с g++ -std=c++11 test.cpp -o test -lzmq -lpthread, Чтобы запустить программу, передайте один пара…
30 май '17 в 12:49
2
ответа
Как я могу ограничить общее количество одновременных подключений подписчиков к конечной точке издателя ZeroMQ?
При создании службы pub-sub с использованием ZeroMQ в системе Linux, существует ли какой-либо способ принудительного ограничения одновременных абонентов? Например, я мог бы захотеть создать службу издателя ZeroMQ в системе с ограниченными ресурсами …
14 авг '14 в 02:16
1
ответ
Очереди сообщений для управления внешней программой на Python через Django
Я использовал в предыдущем проекте ZeroMQ для отправки сообщений между двумя разными программами Python на разных серверах. Теперь у меня есть программа, для которой я хотел бы использовать Django в качестве внешнего интерфейса. В большинстве случае…
04 янв '16 в 21:01