Описание тега netmq
Собственная библиотека.NET для обмена сообщениями ZeroMQ.
1
ответ
Не удается повторно использовать конечную точку после удаления сокета NetMQ
В моем приложении я создаю и удаляю сокеты NetMQ. Я заметил, что не могу связываться с конечной точкой в течение некоторого времени после удаления предыдущего сокета, связанного с этой конечной точкой. Минимальный пример: const string endpoint = "…
14 июл '16 в 09:16
1
ответ
Гарантия отправки запроса ZMQ
Я не могу найти нигде в руководстве или RFC, если при использовании сокетов REQ / REP, предположим, что я успешно отправил сообщение через сокет REQ, это гарантирует, что сокет REP получил сообщение? Если нет, то как вы вводите надежность одного кли…
30 мар '18 в 12:36
2
ответа
Poller на RouterSocket в NetMQ
У меня есть RequestSocket на стороне клиента, отправляющий запросы на сервер. Сервер должен иметь возможность обрабатывать запросы параллельно, поэтому я использовал RouterSocket с поллером. Я не уверен, что это лучшая реализация, так как он использ…
04 авг '15 в 11:22
1
ответ
Почему NetMQ DealerSocket в Mono не отправляет сообщения на сервер в Debian Wheezy, а в Windows?
У меня есть проблемы с NetMQ 4.0.0.1 на Mono 4.8 на Debian Wheezy. Где сокет Дилер не отправляет никаких сообщений, пока я не перестану звонить, чтобы отправить новое сообщение. Когда буду ставить Thread.Sleep( 1000 ) между созданием задач с чем все…
29 мар '17 в 13:04
0
ответов
NetMQ RouterSocket перестает отвечать через некоторое время
Среда NetMQ Version: 4.0.0.1 Operating System: Windows Server 2014 .NET Version: .NET 4.7 вопрос У меня есть служба Windows, которая принимает запросы от.NET Web API. Сервис создает экземпляр RouterSocket, чтобы он мог получать много сообщений со сл…
02 авг '18 в 21:41
2
ответа
NetMQ, почему для Req-Rep нужен "SendReady"?
У меня есть проблема, которую мне удалось исправить... Однако я немного обеспокоен, так как не очень понимаю, почему решение сработало; Я использую NetMQ и, в частности, модуль NetMQ, который имеет несколько сокетов, один из которых - пара REQ-REP. …
14 июн '16 в 06:54
0
ответов
NetMQ PUSH сокет блокируется на неопределенный срок, когда он достигает HWM
Я использую NetMQ (Nuget 3.3.2.2) в.NET 4.5, и у меня есть один быстрый процесс генератора с сокетом PUSH и один медленный потребительский процесс, использующий сокет PULL. Если я отправляю достаточно сообщений, чтобы попасть в отправляющий HWM, про…
03 янв '16 в 09:12
1
ответ
Исключения при использовании NetMQ из powershell
Я использую библиотеку NetMQ от Powershell, но получаю следующее исключение. Среда NetMQ Version: NetMQ.4.0.0.1 Operating System: Windows Server 2012 .NET Version: 4 Я использую это из PowerShell: $pubSocket = New-Object NetMQ.Sockets.ResponseSocket…
15 мар '17 в 18:07
1
ответ
Как отладить FaultException "Не удается закрыть неинициализированную Msg"?
У меня происходит сбой приложения из-за необработанного исключения "Не удается закрыть неинициализированную Msg". Вероятно, это связано с доступом к сокету из нескольких потоков. И у меня есть проблема отладки этой проблемы, потому что, когда я расс…
26 июл '17 в 10:20
0
ответов
Почему клиент не может получить сообщение от сервера с платформой NetMQ?
В последнее время я использую NetMQ для отправки или получения сообщения между сервером и клиентом. Коды сервера, такие как: void Main() { CreatePullAndPushSocket(); Task.Factory.StartNew(()=> { while (true) { Thread.Sleep(1); if (Pull != null) {…
22 ноя '18 в 09:56
1
ответ
Как отправить ACK-сообщение клиенту с сервера, используя NetMQ
Я использую NetMQ для отправки сообщений от многих клиентов на сервер, который получает сообщения и обрабатывает их. Если я использую шаблон pub/sub , я могу (ab) использовать сокет подписчика и использовать его для сервера, а клиенты будут издателя…
31 мар '17 в 00:23
2
ответа
Можно ли использовать транспорт ZeroMQ (NetMQ) TCP между издателем и подписчиком в одном процессе?
Я думаю, что вопрос говорит обо всем на самом деле. Для некоторой предыстории у меня есть подписчик, для которого я пытаюсь написать несколько тестов. Чтобы сделать это, я раскручиваю издателя из теста, указывая tcp://localhost:[port] как адрес. Ког…
23 май '18 в 13:58
1
ответ
Как перевести метод ReceiveReady в NetMQ из C# в F#
Я работаю с библиотекой, которая не имеет документации F#, только C#. Не имея знакомства с C#, у меня возникли небольшие проблемы. Читая документацию по NetMQ, у меня есть проблема с переводом: Для контекста, вот полный пример: using (var rep1 = new…
30 июл '16 в 23:43
1
ответ
ZeroMQ поток / совет задачи
У меня есть задача, которая запускает этот метод для моего шаблона Sub/Pub. Проблема, которую я вижу, состоит в том, что этот цикл будет зависать, пока данные не будут получены. Если я хочу изменить тему или IP, я не могу завершить эту задачу. Если …
12 дек '18 в 07:24
1
ответ
Опубликовать сообщение с помощью PublisherSocket в C# UWP не получено в Python
Я пытаюсь передать сообщения с NetMQ в C# UWP на python. Питон действует как подписчик, а C# как издатель. Когда я использую C# .Net Core, я вижу сообщения, попадающие на подписчика Python, но когда я использую C# UWP, ничего не происходит, хотя код…
20 фев '19 в 16:02
1
ответ
NetMQ повторно использовать тот же сокет
Возможно ли как-то запустить, например, 2 издателя на одном и том же порту или, например, издателя и подписчика одновременно (оба с префиксом>tcp://)?
25 авг '17 в 11:11
1
ответ
Что такое NetMQ API для получения в пользовательском буфере, чтобы избежать создания нового байтового массива в каждом кадре / сообщении?
У меня есть следующий код: while (!isCancellationRequested) { byte[] frameBytes = socket.ReceiveFrameBytes(); MyData data = new MyData(); data.Deserialize(frameBytes); // send the data somewhere somehow... } То, что я хочу сделать, но я не могу найт…
06 фев '17 в 14:05
1
ответ
Как происходит распределение портов за кулисами в zmq?
Я некоторое время изучал zmq и реализовал упрощенный документ - чтобы имитировать мой дизайн инфраструктуры - используя его (в частности, используя оболочку NetMQ), с отличными результатами. Моя ситуация такова: В будущем я планирую запустить нескол…
10 авг '15 в 13:37
2
ответа
ZeroMQ / NetMQ: PushSocket.SendFrame не работает
Я пытаюсь отправить сообщение типа "забей и забудь" с помощью NetMQ. Меня не волнует ожидание ответа. Это для ведения журнала, и меня больше интересует производительность, чем уверенность в том, что мое сообщение было получено, и я особенно не хочу,…
07 июн '16 в 01:55
1
ответ
ZeroMq/NetMQ Не удается найти расширение ReceiveFrameBytes из ReceivingSocketExtensions
При публикации / подписке в NetMQ как я могу получить байты. Я пытаюсь использовать расширение byte[] ReceiveFrameBytes() из ReceivingSocketExtensions, но я просто не вижу его intellisense. Я использую NetMQ, который является пространством имен конт…
28 авг '15 в 11:16