- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我设置了一个与 RabbitMQ 配合使用的公共(public)交通消费者服务,但我不知道如何提高消费者的速度 - 它似乎硬性限制为每秒接收 10 条消息。
我已尝试此处列出的步骤:https://groups.google.com/forum/#!msg/masstransit-discuss/plP4n2sixrY/xfORgTPqcwsJ ,但没有成功 - 将预取和并发消费者设置为 25 除了增加已确认的消息之外没有任何作用,但它不会增加下载消息的速率。
我的配置如下:
ServiceBusFactory.ConfigureDefaultSettings(x =>
{
x.SetConcurrentReceiverLimit(25);
x.SetConcurrentConsumerLimit(25);
});
_bus = ServiceBusFactory.New(
sbc =>
{
sbc.UseRabbitMq(x =>
x.ConfigureHost(
"rabbitmq://localhost/Dev/consume?prefetch=25",
y =>
{
y.SetUsername(config.Username);
y.SetPassword(config.Password);
}));
sbc.UseLog4Net();
sbc.ReceiveFrom("rabbitmq://localhost/Dev/consume?prefetch=25");
sbc.Subscribe(x => RegisterConsumers(x, container));
sbc.UseJsonSerializer();
sbc.SetConcurrentConsumerLimit(25);
});
我在两个地方设置并发消费者限制,因为我不确定是否需要在默认设置或总线配置中设置它,并且消费者是通过统一注册的 - 我省略了消费者订阅,因为所有订阅者都在接收。
我有点困惑是否还需要设置其他内容,或者是否需要更改设置配置的顺序。
非常感谢任何帮助。
最佳答案
在与这个问题度过了一个浪漫的夜晚并尝试了克里斯建议的不同方法之后,我发现您还需要做另一件事才能使其正常工作。
具体来说,是,您需要在消费者队列地址上设置预取:
sbc.UseRabbitMq(
f =>
f.ConfigureHost(
new Uri( "rabbitmq://guest:guest@localhost/masstransit_consumer" ),
c =>
{
} )
);
int pf = 20; // prefetch
// set consumer prefetch (required!)
sbc.ReceiveFrom( string.Format( "rabbitmq://guest:guest@localhost/masstransit_consumer?prefetch={0}", pf ) );
但这还不够。
关键可以在克里斯在他的答案下面的评论中提到的mtstress
工具的代码中找到。事实证明该工具调用:
int _t, _ct;
ThreadPool.GetMinThreads( out _t, out _ct );
ThreadPool.SetMinThreads( pf, _ct );
将此添加到我的代码中可以解决该问题。我想知道为什么 MSMQ 传输不需要这样做...
更新#1
经过进一步调查,我发现了可能的罪魁祸首。它位于 ServiceBusBuilderImpl
中。
有一种方法可以提高限制,即ConfigureThreadPool
。
这里的问题是它调用了CalculateRequiredThreads
,它应该返回所需线程的数量。不幸的是,后者在我的客户端 Windows 7 和 Windows Server 上都返回负值。因此,ConfigureThreadPool
实际上不执行任何操作,因为在调用 ThreadPool.SetMin/MaxThreads
时,负值将被忽略。
这个负值怎么办?看来 CalculateRequiredThreads
调用 ThreadPool.GetMinThreads
和 ThreadPool.GetAvailableThreads
并使用公式来得出所需线程的数量:
var requiredThreads = consumerThreads + (workerThreads - availableWorkerThreads);
这里的问题是,在我的机器上,这实际上是:
40 (my limit) + 8 (workerThreads) - 1023 (availableThreads)
当然会返回
-975
结论是:上面来自大众交通内部的代码似乎是错误的。当我提前手动提高限制时,ConfigureMinThreads 会尊重它(因为它仅在高于读取值时才设置限制)。
如果没有提前手动设置限制,则无法设置限制,因此代码会执行与默认线程池限制一样多的线程(在我的机器上似乎是 8)。
显然有人认为这个公式会产生
40 + 8 - 8
在默认情况下。为什么 GetMinThreads
和 GetAvailableThreads
返回如此不相关的值尚未确定......
更新#2
改变
static int CalculateRequiredThreads( int consumerThreads )
{
int workerThreads;
int completionPortThreads;
ThreadPool.GetMinThreads( out workerThreads, out completionPortThreads );
int availableWorkerThreads;
int availableCompletionPortThreads;
ThreadPool.GetAvailableThreads( out availableWorkerThreads, out availableCompletionPortThreads );
var requiredThreads = consumerThreads + ( workerThreads - availableWorkerThreads );
return requiredThreads;
}
至
static int CalculateRequiredThreads( int consumerThreads )
{
int workerThreads;
int completionPortThreads;
ThreadPool.GetMaxThreads( out workerThreads, out completionPortThreads );
int availableWorkerThreads;
int availableCompletionPortThreads;
ThreadPool.GetAvailableThreads( out availableWorkerThreads, out availableCompletionPortThreads );
var requiredThreads = consumerThreads + ( workerThreads - availableWorkerThreads );
return requiredThreads;
}
解决了问题。此处均返回 1023,并且公式的输出是正确的预期线程数。
关于rabbitmq - MassTransit 将消息速率上限限制为 10,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/23997190/
在典型的 Scala 上界示例中 abstract class Animal { def name: String } abstract class Pet extends Animal {} c
我有 tstzrange 类型的列(带时区范围的时间戳),我只需要更新此值的上限或下限(并保持包含/排除边界) 我设法改变了 (-infinity,infinity) 与 UPDATE table S
我很好奇 GCD 问题。我正在参加 Coursera 算法工具箱类(class),它指出问题的天真解决方案是: for d from 1 to a+b: if d|a and d|b:
我需要知道是否有东西在两个限制之间,但我在 Playground 上不断遇到相同的 2 个错误,而且我似乎无法在网上找到解决方案。知道如何在 Swift 中做到这一点吗? var upperLimit
什么是快速计算 (long int) ceiling(log_2(i)) 的方法,其中输入和输出是 64 位整数?有符号或无符号整数的解决方案是可以接受的。我怀疑最好的方法是类似于找到的方法 here
lower_bound 是什么意思。如果我不得不猜测,我会回答这个函数在小于请求值的最后一个元素处返回迭代器。但我看到lower_bound 几乎和upper_bound 一样。唯一的区别是在 upp
我有一个曾经是 TreeView 控件的菜单,但现在我想让每个项目更加直观,并向树中的每个对象添加更多信息。 我的第一个意图是制作一个代表项目的用户控件,并在运行时将它们添加到面板中。这是一个好方法吗
这个问题在这里已经有了答案: 关闭 10 年前。 Possible Duplicate: Limiting the max size of a HashMap in Java 当键数超过容量时,如何
我将 time_point 设置为下一个完整的五分钟,这很容易: template using minutes = std::chrono::duration, std::chrono::m
这个问题在这里已经有了答案: Upper bound vs lower bound for worst case running time of an algorithm (3 个答案) 关闭 7
这是代码。结果我得到“4 4”。不明白为什么不是“2 4”(根据下限和上限的定义)。 #include using namespace std; int main() { vector v
我必须检查一个包含平方根的不等式。为了避免由于 float 不准确和舍入导致的不正确结果,我使用 std::nextafter() 来获取上限/下限: #include // DBL_MAX #in
我想将一些小数点后两位的数字四舍五入为 1。然而我总是希望它能进入第一轮amount 列中的数字列表示例 140.08 = 140.1 141.63 = 141.7 如果我使用 round(141.6
我是 jfreechart 的菜鸟,我有一个应用程序可以创建一个运行良好的简单条形图。问题是,我希望所有图表显示 1 到 10 的范围。当图表中的最高值低于该值时,较低的值将成为图表的上限,并且将以不
我对支持向量机有一个担忧,即它们的分类分数:这些分类分数有上限吗?我认为不是,因为 SVM 只是一个超平面,而分数基本上是一个点到该超平面的距离。如果没有限制,一个点可以位于空间中的任何位置,因此距离
我有一个网页,我想将其设计为看起来像一本打开的书,中间有一个折痕/阴影。页面的高度不是固定的,而是灵活的,随着内容的增长而增长。 body 元素具有纸张纹理的背景图像,没有任何阴影。 对于阴影,我的设
如何在运行时更改 python for 循环的上限? 代码, from random import randint lower_limit = 0 higher_limit = 200 step_si
我正在尝试构建一个函数: 接受长度为 n 的正整数列表作为参数, 返回所有长度为 n 的列表,这些列表由具有以下属性的非负整数组成: 对于列表 lst 它认为对于所有索引 i,lst[i] ≤ upp
我正在尝试查询我的数据库 ratingsChoices= m$distinct({'answers'}) 但我收到了一个警告:错误:明显太大,16mb 上限 在 mongolite 中有解决这个错误的
我有一个 Mongodb 集合。简单地说,它有两列:用户和网址。它有 39274590 行。该表的键是 {user, url}。 使用 Java,我尝试列出不同的 url: MongoDBMana
我是一名优秀的程序员,十分优秀!