小编som*_*lse的帖子

假设我有一台PUB服务器,它zmq_send()是SUB客户端的实时消息.如果客户端很忙并且zmq_recv()消息不够快,则消息将在客户端(和/或服务器)中缓冲.

如果缓冲区变得太大(高水位线),则将丢弃NEW消息.对于实时消息,这与人们想要的相反.应该删除旧消息以使其成为新消息.

有办法做到这一点吗？

理想情况下,我希望SUB客户端的接收队列为空或仅包含最新消息.当收到新消息时,它将替换旧消息.(我想这里的问题是客户端会zmq_recv()在队列为空时阻塞,浪费时间这样做.)

那么实时饲料通常如何实施ZeroMQ呢？

我有一个PUB服务器。它如何知道订阅了哪些过滤器，以便服务器知道它必须创建哪些数据？一旦没有客户端感兴趣，

服务器就不需要创建数据。SUB

假设可能的过滤器集很大（或无限），但订阅者在任何给定时间都只订阅其中的几个。

示例：假设SUB客户仅订阅纽约和巴黎的几个区号的天气源数据。那么PUB服务器就不必为世界上每个其他城市的每个其他区号创建天气数据，然后再次将其全部丢弃。

如何找出PUB服务器中所有订阅的过滤器？

如果没有简单的方法，我该如何用其他方法解决这个问题？

我正在使用 boost::string_view。(www.boost.org/doc/libs/1_61_0/boost/utility/string_view.hpp)

它有一个 const char* ptr_ 和一个 unsigned int len_ 数据成员。在调试它的麻烦时，默认可视化器将显示字符 ptr_ 的字符数多于长度（因为 string_view 不是空终止的）。

我尝试通过查看 std::string 可视化器来创建自己的可视化器。如果我对长度进行硬编码（比如 4），我可以获得要显示的字符串，但是我无法让它使用实际的长度变量。任何帮助表示赞赏。破碎的例子：

<?xml version="1.0" encoding="utf-8"?>
<AutoVisualizer xmlns="http://schemas.microsoft.com/vstudio/debugger/natvis/2010">
  <Type Name="boost::basic_string_view&lt;char,*&gt;" Priority="High">
    <DisplayString>{ptr_,4}</DisplayString> //works...
    <DisplayString>{ptr_,len_}</DisplayString> //doesnt work...
  </Type>
</AutoVisualizer>

我用concurrency::task从ppltasks.h巨资我的代码库.

我想找到一个等待的队列,我可以在那里做" co_await my_queue.pop()".有人实施过吗？

详细信息:我有一个生产者线程将元素推送到队列,另一个接收器线程将等待并在元素到达队列时唤醒.此接收线程可能会等待/唤醒以同时处理其他任务(使用pplpp :: when_any).

我不想要一个带有接口的队列,我必须轮询一个try_pop方法,因为它很慢,我不想要一个blocking_pop方法,因为这意味着我不能同时处理其他准备好的任务.

如何反序列化以下内容.问题是变量名是一个数字.那么应该如何定义MyClass呢？

json_str:
{"23521952": {"b": [], "o": []}, "23521953": {"b": [], "o": []}}

class MyClass {     //? };

var var = JsonConvert.DeserializeObject<MyClass>(json_str);