问题标签 [netmq]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
c# - NetMQ Pub Sub 最近
在典型的 pub-sub 模式中，有一些客户端订阅了发布事件的服务器。在我的应用程序中，发布者持续发布异步事件。在我的客户中，他们有时会延迟处理这些事件。我的问题是是否有一种解决方法，客户端总是采用发布者发出的最新事件，而不是必须按顺序处理所有接收到的事件。
c# - 如何将 NetMQ 中的 ReceiveReady 方法从 C# 转换为 F#
我正在使用一个没有 F# 文档的库，只有 C#。不熟悉 C# 我遇到了一些麻烦。通读 NetMQ的文档，有一行我在翻译时遇到了问题：
对于上下文，这是完整的示例：
具体来说，我不知道rep1.ReceiveReady += (s, a) =>在 C# 的上下文中是什么意思以及如何将其转换为 F#。有任何想法吗？谢谢。
zeromq - NetMQ 与 clrzmq
几个月前，我选择 .NET 库来实现 ZeroMQ 通信，但我对zeromq.org上建议的库很少这一事实感到非常困惑。
同时我也学到了一些东西，所以我会在这里分享。有人可能会觉得这很有帮助。所以让我问自己：
NetMQ 和 clrzmq 有什么区别？
（虽然我会自己回答这个问题，但如果其他人在这个问题上有一些经验 - 欢迎替代答案！）
.net - NetMQ 代理与 XSub/Xpub 模式中的控制套接字使用示例？
我正在尝试使用带有 NetMQ + 控制套接字的 XPUB/XSUB 模式实现集线器（以控制集线器的行为）。我使用代理、NetMqPoller，并想使用控制套接字。但无论我尝试什么 - 它都不起作用。这是我的代码，任何想法为什么它不起作用？
还有一种方法可以在每次 ctrlIn 套接字接收数据时运行：
现在简短说明：集线器（XPUB/XSUB）完美运行，即当我启动发布者和订阅者时 - 我可以看到消息在流动。但是控制套接字不起作用，我得到的只是其中的两条消息：
在那之后 - 控制套接字保持沉默，没有更多的字节流过它。有谁知道我错在哪里？或者也许任何人都可以指出一个可行的例子？我一直在寻找一个例子，但找不到任何控制插座工作的东西。
c# - 使用 c# 和 python 的 NetMQ 扩展请求-回复
我可以通过使用简单的请求-回复让 c#（客户端）和 python（服务器）相互交谈。但是，我希望基于 c# asp.net 构建的 Web 应用程序稳定并且需要更多的客户端和服务器，因此我尝试使用扩展 REQ-REP 连接来连接 c# 和 python。
但是当我运行下面的代码时，它并没有作为代理完成它的工作并且什么也不输出。我在这里做错了什么？
5600 = c#客户端
5601 = 蟒蛇服务器
c# - 使用 C# 和 python 使用 Router-Dealer 代理发送消息
我可以通过使用简单的请求-回复让 c#（客户端）和 python（服务器）相互交谈。但是，我希望基于 c# asp.net 构建的 Web 应用程序稳定并且需要更多的客户端和服务器，因此我尝试使用带有 python 的 Router-Dealer 代理连接 c# 和 python。
我尝试先运行代理 python 脚本，然后运行 c#（客户端），然后运行 python（服务器）。但是，当我运行 python（服务器）时，它会给我一个“正在使用的地址”错误消息。
我是以错误的顺序运行它们还是代理 python 脚本有问题（如下所示）？
5602 = c#客户端
5603 = 蟒蛇服务器
c# - 0MQ和NetMQ之间的通信
我需要与两个应用程序通信，一个 C++ 中的服务器和一个 C# 客户端。
我正在尝试在服务器上使用 0MQ 和 binder C# NetMq 。我可以从客户端进行连接并将消息从客户端发送到服务器，但不能从另一个发送。客户端等待，并没有收到服务器的发送。
一些例子？
服务器：
客户：
这是我尝试实现然后扩展的发送和响应的简单示例。
c# - ZMQ NetMQ - 无法完成非阻塞套接字操作
我有以下模式：
多个线程正在向 ConcurrentQueue 发送消息，该 ConcurrentQueue 由单线程Dealer轮询，以便将消息发送到Router。
发送多条消息时会引发以下异常：
“SocketException - 无法完成非阻塞套接字操作”
这是使消息出队并将其发送给经销商的线程代码：
发送 MultipartMessage 时发生 SocketException
我试图增加 SendBuffer 大小和/或 SendHighWatermark 大小，但我仍然有同样的错误。
我是否需要处理此异常并重置套接字，或者我永远不应该在这种情况下？
.net - 如何确定客户端套接字的连接状态？
我正在使用 NetMQ 套接字来执行客户端 - 服务器通信。我有一个监听端口 5555 的服务器和一个客户端，它是.bind()-s 的。
这是我的代码示例：
如果客户端没有找到任何侦听该端口的服务器，我想做的是与用户通信。
实际发生的情况是，如果没有服务器侦听该端口，则不会引发异常，并且.sendFrame()会调用并且应用程序崩溃。
是否有任何方法（例如异常或状态代码）可以通知我连接是否成功？
c# - 如何在客户端同步发送和接收帧？
如果我发送请求（帧）B 并接收响应，同时我已经在等待前一个请求（A）的响应，则 B 任务中收到的响应实际上是对 A 请求的响应：
通过天真的匹配，我会在点 (*) 获得匹配请求 A--响应 B。
那么如何同步它们呢？即我想以响应 A 结束请求 A，并以响应 B 结束请求 B，无论处理每个请求需要多长时间。作为记录，我正在使用经销商路由器插座。
我正在考虑创建池请求 ( Dictionary)，并将任务完成令牌绑定到发送的每个请求。任务在池中创建新槽，发送请求并等待完成。在后台有一个任务一直在运行——一个接收器——它只是接收响应，将每个响应放在适当的槽中并将给定的任务令牌设置为已完成。我是在正确的轨道上，是我错了，还是已经在 NetMQ 中实现了？