问题标签 [netmq]

在典型的 pub-sub 模式中，有一些客户端订阅了发布事件的服务器。在我的应用程序中，发布者持续发布异步事件。在我的客户中，他们有时会延迟处理这些事件。我的问题是是否有一种解决方法，客户端总是采用发布者发出的最新事件，而不是必须按顺序处理所有接收到的事件。

我正在使用一个没有 F# 文档的库，只有 C#。不熟悉 C# 我遇到了一些麻烦。通读 NetMQ的文档，有一行我在翻译时遇到了问题：

对于上下文，这是完整的示例：

具体来说，我不知道rep1.ReceiveReady += (s, a) =>在 C# 的上下文中是什么意思以及如何将其转换为 F#。有任何想法吗？谢谢。

几个月前，我选择 .NET 库来实现 ZeroMQ 通信，但我对zeromq.org上建议的库很少这一事实感到非常困惑。

同时我也学到了一些东西，所以我会在这里分享。有人可能会觉得这很有帮助。所以让我问自己：

NetMQ 和 clrzmq 有什么区别？

（虽然我会自己回答这个问题，但如果其他人在这个问题上有一些经验 - 欢迎替代答案！）

我正在尝试使用带有 NetMQ + 控制套接字的 XPUB/XSUB 模式实现集线器（以控制集线器的行为）。我使用代理、NetMqPoller，并想使用控制套接字。但无论我尝试什么 - 它都不起作用。这是我的代码，任何想法为什么它不起作用？

还有一种方法可以在每次 ctrlIn 套接字接收数据时运行：

现在简短说明：集线器（XPUB/XSUB）完美运行，即当我启动发布者和订阅者时 - 我可以看到消息在流动。但是控制套接字不起作用，我得到的只是其中的两条消息：

在那之后 - 控制套接字保持沉默，没有更多的字节流过它。有谁知道我错在哪里？或者也许任何人都可以指出一个可行的例子？我一直在寻找一个例子，但找不到任何控制插座工作的东西。

我可以通过使用简单的请求-回复让 c#（客户端）和 python（服务器）相互交谈。但是，我希望基于 c# asp.net 构建的 Web 应用程序稳定并且需要更多的客户端和服务器，因此我尝试使用扩展 REQ-REP 连接来连接 c# 和 python。

但是当我运行下面的代码时，它并没有作为代理完成它的工作并且什么也不输出。我在这里做错了什么？

5600 = c#客户端

5601 = 蟒蛇服务器

我可以通过使用简单的请求-回复让 c#（客户端）和 python（服务器）相互交谈。但是，我希望基于 c# asp.net 构建的 Web 应用程序稳定并且需要更多的客户端和服务器，因此我尝试使用带有 python 的 Router-Dealer 代理连接 c# 和 python。

我尝试先运行代理 python 脚本，然后运行 ​​c#（客户端），然后运行 ​​python（服务器）。但是，当我运行 python（服务器）时，它会给我一个“正在使用的地址”错误消息。

我是以错误的顺序运行它们还是代理 python 脚本有问题（如下所示）？

5602 = c#客户端

5603 = 蟒蛇服务器

我需要与两个应用程序通信，一个 C++ 中的服务器和一个 C# 客户端。

我正在尝试在服务器上使用 0MQ 和 binder C# NetMq 。我可以从客户端进行连接并将消息从客户端发送到服务器，但不能从另一个发送。客户端等待，并没有收到服务器的发送。

一些例子？

服务器：

客户：

这是我尝试实现然后扩展的发送和响应的简单示例。

我有以下模式：

多个线程正在向 ConcurrentQueue 发送消息，该 ConcurrentQueue 由单线程Dealer轮询，以便将消息发送到Router。

发送多条消息时会引发以下异常：

“SocketException - 无法完成非阻塞套接字操作”

这是使消息出队并将其发送给经销商的线程代码：

发送 MultipartMessage 时发生 SocketException

我试图增加 SendBuffer 大小和/或 SendHighWatermark 大小，但我仍然有同样的错误。

我是否需要处理此异常并重置套接字，或者我永远不应该在这种情况下？

我正在使用 NetMQ 套接字来执行客户端 - 服务器通信。我有一个监听端口 5555 的服务器和一个客户端，它是.bind()-s 的。

这是我的代码示例：

如果客户端没有找到任何侦听该端口的服务器，我想做的是与用户通信。

实际发生的情况是，如果没有服务器侦听该端口，则不会引发异常，并且.sendFrame()会调用并且应用程序崩溃。

是否有任何方法（例如异常或状态代码）可以通知我连接是否成功？

如果我发送请求（帧）B 并接收响应，同时我已经在等待前一个请求（A）的响应，则 B 任务中收到的响应实际上是对 A 请求的响应：

通过天真​​的匹配，我会在点 (*) 获得匹配请求 A--响应 B。

那么如何同步它们呢？即我想以响应 A 结束请求 A，并以响应 B 结束请求 B，无论处理每个请求需要多长时间。作为记录，我正在使用经销商路由器插座。

我正在考虑创建池请求 ( Dictionary)，并将任务完成令牌绑定到发送的每个请求。任务在池中创建新槽，发送请求并等待完成。在后台有一个任务一直在运行——一个接收器——它只是接收响应，将每个响应放在适当的槽中并将给定的任务令牌设置为已完成。我是在正确的轨道上，是我错了，还是已经在 NetMQ 中实现了？