ZeroMQ非阻塞非排队推送 - c#

我正在对ZeroMQ使用C#包装程序,但这似乎更像是ZeroMQ的潜在问题。

有没有什么办法可以在不阻塞且不排队的情况下推送消息?如果服务器没有启动,我希望消息被永久处理而不会阻塞。

这是到目前为止我尝试过的设置:

1)

发送(阻止发送)

高水位标记= 0

(暂时)不会阻塞,但似乎在套接字连接到内存之前就在内存中排队(该进程的内存不断增加)。

2)

发送(无阻塞发送)

高水位= 1

这是比赛条件。如果我连续快速发送两条消息,则有时会超出高水位标记而抛出一条消息。

3)

轮询套接字以查看是否会阻塞。这实际上并没有帮助,因为我仍然必须在开始阻塞之前将一条(旧)消息放入队列中(如果我将HWM设置为1)。

具有高水位标记的非阻塞发送是不可取的,因为一旦服务器重新联机,它就会从客户端收到一堆旧消息。

阻止发送不起作用,因为我不想阻止。

参考方案

您似乎在寻找的只是PUB插座。此套接字类型从不阻止发送,并丢弃任何无法发送给订阅者的消息。参见本页:http://api.zeromq.org/3-2:zmq-socket。
附带说明,您不需要将此套接字用于“实际”发布/订阅,可以通过在端点上仅具有一个PUB和一个SUB套接字,将其用于两个节点之间的非阻塞通信。
重新连接后,服务器将不会收到“旧”消息,因为PUB套接字将丢弃服务器断开连接时无法发送的消息。尽管如此,我相信,尽管您无法避免一些内部ZMQ“排队”,但它对您的用例几乎没有影响。

zeromq:不允许使用unicode,请使用send_unicode - python

通过ROUTER SOCKET发送字符串时,zeromq python出现错误。字符串类型的消息可以成功接收,但有时,Unicode消息会引发异常"Type Error: unicode not allowed. use send_unicode".,尽管我一直在尝试使用msg.encode('utf-8')。但是我想不出一种克服它的方法…

LeetCode题解计算机为什么是基于二进制的?

可以是三进制么?二进制有什么好处?题解:为什么叫电子计算机?算盘应该没有二进制

LeetCode题解统计城市的所有灯泡

这个是我刚毕业的时候,一个真实的面试题,这是一个开放题。题目描述:想办法,将一个城市的所有灯泡数量统计出来。题解:费米估算法1、如果某个城市常驻人口有1000万2、假设每5人居住在一套房里,每套房有灯泡5只,那么住宅灯泡共有1000万只3、假设公众场所每10人共享一只灯泡,那么共有100万只4、主要的这两者相加就得出了1100万只当然实际上这是估算的,具体应…

LeetCode题解黑白圆盘

一个圆盘被涂上了黑白二色,两种颜色各占一个半圆。圆盘以一个未知的速度、按一个未知的方向旋转。你有一种特殊的相机可以让你即时观察到圆上的一个点的颜色。你需要多少个相机才能确定圆盘旋转的方向?题解:可以用一个相机即可

LeetCode题解圆上任取三点构成锐角三角形的概率

来自字节跳动的一道几何题题解:1/4