Описание тега jeromq

JeroMQ is a pure Java implementation of libzmq
1 ответ

Poller из Java ZeroMQ потребляет все больше памяти в куче

У меня есть простое приложение, которое передает данные с одной машины на другую. По мере запуска приложения размер кучи медленно увеличивается. Поэтому я свалил кучу и проанализировал ее, и обнаружил, что zmq.poll.Poller стоит самый большой объем п…
26 мар '18 в 15:06
1 ответ

Безопасно ли использовать сокет ZMQ в Actor, работающем на PinnedDispatcher?

Насколько я могу судить из документации, сокеты ZeroMQ не должны использоваться (например, считываться / записываться) из разных потоков. Это, в свою очередь, мешает мне использовать сокет ZMQ в Akka Actor, работающем в диспетчере по умолчанию (нет …
11 апр '18 в 11:42
0 ответов

Почему jeromq push send не прошел через промежуток времени

Я пытаюсь использовать шаблон push/pull с jeromq(0.3.2). В начале это работает хорошо. но через некоторое время. сторона push не отправляет сообщения и не блокируется там. Я не знаю почему. Я установил параметр sendTimeout и напечатал номер ошибки с…
06 июн '14 в 05:20
1 ответ

java.lang.ClassNotFoundException: org.zeromq.ZContext при попытке запустить службу Windows

У меня есть базовое Java-приложение Maven, которое я создал, и оно зависит от JeroMQ, который является полной реализацией Java ZeroMQ. Поскольку мне также нужно обернуть это Java-приложение в качестве службы Windows, я решил использовать Apache Comm…
14 апр '16 в 19:21
2 ответа

JeroMq сбрасывает сообщения - как это предотвратить?

У меня есть следующий "привет мир" jeromq PUSH-PULL клиент и сервер. Только после того, как я установлю значения High Water Mark, я смогу передавать без потери сообщений. import org.jeromq.ZMQ; public class TestTcpServer { public static void main(St…
04 ноя '12 в 18:59
1 ответ

Тема не прогрессирует мимо ZMQ.context(1)

Я пытаюсь реализовать простой пример паба, где у меня есть сервер, и я публикую периодические уведомления о доступности для клиентов. Это выполняется как часть службы Windows - в комплекте с InnoSetup и launch4j и Apache procrun/prunsrv. Поток не вы…
25 июл '14 в 09:57
2 ответа

Зачем нужен JeroMQ, если он может использовать JZMQ?

Простой вопрос Почему "портировать" zmq на java и назвать его JeroMQ - хорошая идея?
26 сен '13 в 19:31
1 ответ

Используя JeroMQ через TCP, есть ли способ получить IP отправителя?

Наше приложение использует JeroMQ 0.4.3 для отправки сообщений между клиентским приложением и API. (используя кривое шифрование с ZAuth). Мы получаем клиентские сообщения от ROUTER сокет в нашем брокере (шаблон MDP). Как лучше всего узнать IP-адрес …
21 дек '17 в 19:51
1 ответ

Регистрация нескольких процессов в ZeroMQ Appender

У меня есть несколько процессов, запущенных на нескольких машинах, используя log4j (2.11). Мне нужно объединить сообщения регистрации для отображения на внешнем интерфейсе, и я хотел бы, чтобы каждый процесс использовал ZeroMQ Appender для публикаци…
28 июн '18 в 23:01
0 ответов

Время от времени JeroMQ выдает "IOException. Открыто слишком много файлов"

У меня есть приложение tomcat7, которое связывается с другим моим приложением, используя конечную точку IPC с JeroMQ в Java. Существует схема клиент-сервер, и клиент когда-нибудь ждет ответа от сервера, и если он не получает ответ, происходит сбой в…
18 авг '15 в 21:57
1 ответ

Как создать необработанный сокет с ZeroMQ в Java?

Я пытаюсь перенести сервер ZeroMq Hello World Http на Java из C. В этом фрагменте кода router Сокет настроен на чтение необработанных данных, но я не могу понять, как это сделать в Java... zsocket_set_router_raw (router, 1); На основании руководства…
18 май '13 в 01:01
1 ответ

Jeromq максимальный сокет открыл выпуск

У меня есть server в Яве, которые получают json файл и отправить его в программу на C jeromq, До прошлой недели я только что проверил это с несколькими JSON. Я не отправлял много json до сих пор, у меня есть другой компонент для их отправки. Glassfi…
19 авг '14 в 09:39
2 ответа

Пропущенные события ZMQ распространяются в jeromq scala

Я новичок в ZeroMQ и, кажется, теряю сообщения в цикле в моем begin() метод. Мне интересно, если я пропускаю кусок, где я не в очереди сообщений или что-то? Когда я вызываю событие на моем издателе, которое отправляет два сообщения моему подписчику …
22 апр '18 в 19:53
1 ответ

ZeroMQ дает скудные результаты

Я тестирую ZeroMQ и получаю только 1227 - 1276 сообщений в секунду. Я прочитал, однако, что они должны быть в 100 раз больше этой суммы. Что я делаю неправильно? Есть ли какая-либо конфигурация, которую я могу указать, чтобы это исправить? Я использ…
17 сен '14 в 07:41
1 ответ

java.lang.ArrayIndexOutOfBoundsException: 256 с версией jeromq 0.3.6

Я использую Jeromq в многопоточной среде, как показано ниже. Ниже мой код, в котором конструктор SocketManager сначала подключается ко всем доступным розеткам, и я помещаю их в liveSocketsByDatacenter карта в connectToZMQSockets метод. После этого я…
02 ноя '17 в 21:00
1 ответ

Приложение Android висит на subscriber.recv()

Я пишу приложение для Android, которое получает непрерывный поток данных. Я установил соединение внутри работающего так: Runnable runnable = new Runnable() { public void run() { ZMQ.Context context = ZMQ.context(1); ZMQ.Socket subscriber = context.s…
21 июл '15 в 18:41
1 ответ

Apache Camel: подключение к серверу ZeroMQ

Я пытаюсь подключиться к ZeroMQ сервер, использующий apache camel, Я использую camel-zeromq компонент, предоставленный camel-extra проект, но кажется, что для этого требуется предыдущая установка родного ZeroMQ библиотека в системе. Кто-нибудь знает…
02 мар '16 в 17:05
0 ответов

ZeroMQ на удивление медленный

В настоящее время я выполняю тест задержки для некоторых коммуникационных промежуточных программ и обнаружил, что ZeroMQ REQ а также REP розетки на удивление медленные. Например, я ожидал, что ZeroMQ будет быстрее, чем ZeroC Ice. Для полноты вот рез…
01 янв '18 в 23:26
2 ответа

Как подключить очереди к ZeroMQ PUB/SUB

Учтите следующее: набор из 3 логических сервисов: S1, S2 а также S3 два экземпляра каждого сервиса работают, поэтому у нас есть следующие процессы: S1P1, S1P2, S2P1, S2P2, S3P1, S3P2 ZeroMQ брокер работает в одном процессе и доступен всем сервисным …
10 мар '16 в 21:28
1 ответ

Вызвать HTTP GET через zeromq

После прочтения результатов теста zeromq мне стало интересно, могу ли я попробовать получить доступ к API ReSTFul через HTTP-вызовы GET через zeromq. Я хочу проверить, может ли zeromq предоставить механизм Low-Latency Request-Reply по сравнению с др…
01 дек '15 в 05:47