У меня есть подписка на «hello world» jeromq PUSH-PULL клиент и сервер. Только после того, как я установил значения High Water Mark, я могу передавать сообщения без потери сообщений. import org.jeromq.ZMQ; public class TestTcpServer {...

Я думаю, что что-то не так с моим zmq.jar, поэтому я попытался с jeroMQ, но у меня та же проблема. Это мой метод: private boolean submitEvent(String ioMessage) { log.info("SEND"); ZMQ.Context context = ZMQ.context(); ZMQ.Socket...

У нас есть приложение Java, которое действует как сервер. Клиентские приложения (написанные на C#) взаимодействуют с ним с помощью ZeroMQ. Мы (в основном) следуем модели Ленивого Пирата. На сервере есть сокет Router, реализованный следующим...

У меня есть приложение tomcat7, которое взаимодействует с другим моим приложением, используя конечную точку IPC с JeroMQ в Java. Существует схема клиент-сервер, и клиент некоторое время ждет ответа от сервера, и если он не получает ответ, происходит...

Мне нужно установить связь между процессом Scala (JeroMQ) и процессом C (ZeroMQ). Процесс Scala должен отправлять большие массивы (100 миллионов чисел с плавающей запятой на массив). Сначала это преобразуется в строку JSON, и, как вы можете видеть...

У меня есть базовое java-приложение Maven, которое я создал, и оно зависит от JeroMQ, который является полной Java-реализацией ZeroMQ. Поскольку мне также нужно обернуть это java-приложение как службу Windows, я решил использовать Apache Commons...

В C ++ ZMQ Publisher я упаковываю строку в message_t следующим образом: int main() { zmq::context_t context(1); zmq::socket_t socket(context, ZMQ_PUB); socket.bind("tcp://*:5555"); socket.setsockopt(ZMQ_CONFLATE, 1);...

Я использую Jeromq в многопоточной среде, как показано ниже. Ниже приведен мой код, в котором конструктор SocketManager сначала подключается ко всем доступным сокетам, и я помещаю их в карту liveSocketsByDatacenter в методе connectToZMQSockets ....

Я пытаюсь использовать jeromq для проекта Android. Мне нужно подключиться к другому дилерскому устройству. Вот мой код: ZContext zcontext = new ZContext(1); ZMQ.Socket zsocket = zcontext.createSocket(ZMQ.DEALER); String identity = "S61_phone";...

Используя JeroMQ в Matlab, мое соединение с подписчиком обрывается, когда я пытаюсь recv отправить сообщение. Я проверил это с помощью Wireshark. Я также отмечаю, что закрытие TCP-соединения инициируется моим портом подписки, а не портом...

Сколько данных можно записать в один ZFrame(). (Без добавления нескольких Zframes() в ZMsg).