我正在创建一个 Azure 服务总线主题(订阅)的消费者,它只存储一些统计信息。发送到主题的消息包含一个相当大的主体,由另一个消费者在同一主题的第二个订阅中处理。
由于统计消费者可以一次性处理大量消息,我想知道是否可以接收大量消息但在与服务总线通信时省略主体以提高性能并一次性接收更多消息.
我目前正在这样做:
this.messageReceiver = new MessageReceiver(conn, path);
...
await messageReceiver.ReceiveAsync(10, TimeSpan.FromSeconds(5));
它工作得非常好,但如果能够接收 100 条或更多消息,而不必担心在网络上移动大消息,那就太好了。
在有人建议之前,我已经知道我可以要求对主题订阅进行计数等。我仍然需要该Message
对象,因为它包含UserProperties
字典中用于计算统计信息的条目。