netmq

0열

1답변

일반적인 pub 하위 패턴에는 이벤트를 게시하는 서버를 구독하는 클라이언트가 있습니다. 내 응용 프로그램에서 게시자는 비동기 적으로 발생하는 이벤트를 지속적으로 게시합니다. 내 고객들은 때로는 그 사건들을 처리하는데 지체가 있습니다. 내 질문은 고객이 항상 모든 수신 된 이벤트를 순차적으로 처리해야하는 것을 반대하는 게시자가 보낸 최신 이벤트를 처리하는 작

1열

2답변

ZeroMQ/NetMQ : PushSocket.SendFrame이 작동하지 않습니다.

NetMQ를 사용하여 "fire-and-forget"유형의 메시지를 보내려고합니다. 나는 응답을 기다리는 것에 신경 쓰지 않는다. 이것은 로깅을위한 것이며, 내 메시지가 수신되었다는 것보다 성능에 더 신경을 썼다. 특히 로깅 서버가 다운 된 경우 웹 응용 프로그램이 멈추길 원하지 않는다. 이 클라이언트 코드는 중요한 경우 웹 API 응용 프로그램에 있습니다

0열

1답변

사용 가능한 메시지에도 불구하고 Socket.ReceiveReady가 실행되지 않습니다.

NetMQ 3.3.0.11을 탐색하기 시작했으며 Poller를 사용하여 문제가 발생했습니다. 폴러가 약 1 초 동안 폴링 한 다음 중지하고 1 초 동안 폴링을 다시 시작하기 전에 다른 작업을 수행 할 수 있도록하는 등의 작업을 시도합니다. var poller = new Poller (client) { PollTimeout = 10 }; while (tr

2열

1답변

NetMQ에서 ReceiveReady 메서드를 C#에서 F #

F # 문서가없는 라이브러리로 작업하고 있는데 C# 만 사용하고 있습니다. C#에 익숙하지 않아서 약간의 문제가 있습니다. NetMQ에 대한 documentation을 통해 읽기, 내가 문제 번역하는 데 한 줄이 : 나는 rep1.ReceiveReady += (s, a) =>이 무엇을 의미하는지 모르는, 특히 using (var rep1 = new Resp

0열

1답변

XSub/Xpub 패턴의 컨트롤 소켓 사용 예가있는 NetMQ 프록시?

허브 동작을 제어하기 위해 NetMQ + 제어 소켓이있는 XPUB/XSUB 패턴이있는 허브를 구현하려고합니다. 나는 프록시, NetMqPoller를 사용하고 제어 소켓을 사용하고 싶다. 그러나 무엇을 시도해도 작동하지 않습니다. 여기 내 코드, 어떤 아이디어가 작동하지 않는 이유는 무엇입니까? Using xpubSocket As New XPublisherS

1열

1답변

AsyncIO.ForceDotNet.Force는()

환경 생산에서 OS Windows XP에서 메모리 누수가 발생합니다. NET 프레임 워크 3.5 NetMQ : 3.3.1 AsyncIO : 0.1.18 언어 : C# Windows XP SP3에서 간단한 REQ REP 소켓을 사용하여 NetMQ 응용 프로그램을 실행할 필요가 있습니다. 우리는 문제 # 412에서 Windows XP에서 AsyncIO.Forc

0열

1답변

NetMQ 확장 요청 - C# 및 Python을 사용하여 응답

간단한 요청 - 응답을 사용하여 C# (클라이언트)와 python (서버)간에 대화 할 수 있습니다. 그러나 C# asp.net을 기반으로하는 웹 응용 프로그램을 안정적으로 만들고 더 많은 클라이언트와 서버가 필요하므로 확장 REQ-REP 연결을 사용하여 C# 및 Python 연결을 시도했습니다. 그러나 아래 코드를 실행하면 브로커로 작업하지 않고 아무 것

0열

1답변

C# 및 python을 사용하여 Router-Dealer 프록시와 메시지 보내기

간단한 요청 - 응답을 사용하여 C# (클라이언트)와 python (서버)간에 대화 할 수 있습니다. 그러나 C# asp.net을 기반으로하는 웹 응용 프로그램을 안정적으로 만들고 더 많은 클라이언트와 서버가 필요하므로 Python과 함께 Router-Dealer Proxy를 사용하여 C# 및 Python을 연결하려고 시도했습니다. 프록시 파이썬 스크립트를

1열

1답변

NetMQ 소켓 폐기 후 끝점을 다시 사용할 수 없습니다.

내 응용 프로그램에서 NetMQ 소켓을 만들고 폐기합니다. 그 끝점에 바인딩 된 이전 소켓 처분 후 얼마 동안 끝점에 바인딩 할 수 없다는 것을 알았습니다. 최소한의 예 : const string endpoint = "tcp://127.0.0.1:1234"; using (var publisher = new PublisherSocket()) pu

1열

1답변

비동기 Majordomo 패턴 (Netmq)

저는 Netmq를 사용하여 프론트 엔드와 백엔드간에 안정적이고 빠르고 높은 통신을 구현하고 있습니다. 통신 흐름 : - 클라이언트가 (xmpp 클라이언트, 웹 소켓 또는 기타 클라이언트 유형을 연결하고) 백엔드에 메시지를 보내고이 메시지는 특정 유형의 작업자 (xmpp 디스패처 프로세스 xmpp 메시지) - 발송자가 (예 : xmpp 발송자)를 연결하고 특