我可以使用XSUB/XPUB-zeromq模式并为每条消息添加时间戳/序列号吗



我正在使用zeromq创建一个通用的动态图设置。我已经有了XPUB/XSUB设置,但我想知道是否有一种zmq方法可以将序列号/时间戳添加到代理生成的每个消息中,以便拥有一个唯一排序的事件"磁带"?

Q"……但我想知道是否有zmq方法可以将…添加到每条消息中…?">

不,没有。ZeroMQ的方法是使用零拷贝和(几乎(零延迟来完成此操作。

对于您所希望的用例,这种方式是不存在的。


解决方案?可交付:

创建一个转换节点,每个消息将在其中进行相应的转换(添加了SEQ编号,并挂起了TimeSTAMP数据{pre|ap}-(。这样的步骤需要实现这样的节点,并处理所有这样的步骤,每个事件都有任何例外。

现成的API文档zmq_proxy()根本没有、也不能、也不应该涵盖这些特定要求,因为它是为其他目的而设计的(并使用零拷贝来实现最高效的直通+ev.高效的MITM-logger服务模式(。

最新更新