代码之家 › 专栏 › 技术社区 › Toad

如何限制C应用程序中来自ActiveMQ的消息量?

nms activemq message-queue .net c#

Toad · 技术社区 · 14 年前

我在一个.NET程序中使用ActiveMQ,我被消息事件淹没了。

简而言之,当我得到一个队列事件“onmessage(IMessage receiveDMSG)”时,我将该消息放入一个内部队列,x个线程从中执行它们的操作。

起初,我在创建会话时使用了“acknowledgementMode.autoAcknowledge”,因此我猜测队列中的所有消息都被吸走并放入内存队列(这很危险,因为发生崩溃时,所有信息都会丢失)。

因此,我在创建会话时使用了:“acknowledgementMode.clientAcknowledge”,当工作人员准备好消息时,它会对消息调用“commit()”方法。但是,仍然会从队列中吸出所有消息。

我如何配置它:只有x条消息正在被处理,或者在一个内部队列中,而不是所有的消息都立即被“下载”?

2 回复 | 直到 14 年前

flq 14 年前

你在.NET 4.0上吗?您可以使用BlockingCollection。将其设置为可能包含的最大值。一旦一个线程试图放入一个多余的元素,添加操作将阻塞,直到集合再次低于阈值。

也许这可以用于节流?

RX框架中还有一个用于节流的API,但我不知道它是如何实现的。如果您将队列源实现为可观察的,那么这个API将对您可用,但我不知道这是否符合您的需要。

Tim Bish 14 年前

您可以设置客户端预取,以控制客户端将发送多少消息。当会话处于自动确认状态时,客户机只有在消息通过onmessage回调或同步接收发送到应用程序后才会确认消息。默认情况下,客户机将从代理预取1000条消息,如果客户机停机,这些消息将重新传递给另一个客户机,这是一个队列,否则对于主题,它们将被丢弃,因为主题是基于广播的频道。如果将预取设置为1,那么客户端将只从服务器发送一条消息,然后每次OnMessage回调完成时,都会发送一条新消息,因为客户端将确认该消息,即会话处于自动确认模式。

有关所有选项,请参阅NMS配置页: http://activemq.apache.org/nms/configuring.html

当做

提姆。 fussesource.com网站

推荐文章

Emopusta · 从后端到前端的图像路径不工作

2 年前

Simon Worth · 是否可以使用SqlClient自动获取查询字符串中定义的参数列表

2 年前

Asdrubal Hernandez · Linq查询特定数组索引出错

2 年前

Jet813 · 当类型为字符串时,来自Webhook的JSON帖子为null

2 年前

asdhkjahjsdjkhjklasdhjhasDKJhl · 有没有办法检测c#中的鼠标侧键按下?

2 年前

Niyazi Babayev · 如何在表达式中动态应用表达式?

2 年前

Dansih · .Net核心自定义身份验证方案

2 年前

qqqqqqq NValchev · 我怎样才能经营一家公司。容器中的NET Web API?

2 年前

lolorekkk · 面板插入。NET WinForm

2 年前

enguy007 · StreamWriter在文件末尾的新行添加额外字符

2 年前