Masstransit、RabbitMQ、具有多个实例的多个使用者
Masstransit是一个开源的分布式应用程序框架，用于构建基于消息传递的应用程序。它提供了一种简单而强大的方式来实现应用程序之间的解耦和可扩展性。
RabbitMQ是一个开源的消息代理软件，它实现了高级消息队列协议（AMQP）并提供可靠的消息传递机制。它支持多种消息模式，包括点对点、发布/订阅和请求/响应模式。
具有多个实例的多个使用者是指在分布式系统中，有多个实例同时使用消息队列来处理消息。这种架构可以提高系统的可靠性和可扩展性，因为每个实例都可以独立地处理消息，并且可以根据负载情况动态地添加或删除实例。
Masstransit和RabbitMQ可以结合使用，以构建具有多个实例的多个使用者的分布式应用程序。Masstransit提供了一个简单的接口来定义消息处理程序，并处理与RabbitMQ之间的通信细节。通过使用Masstransit和RabbitMQ，开发人员可以轻松地构建可靠的、可扩展的分布式应用程序。
在云计算领域，使用Masstransit和RabbitMQ可以实现异步消息处理、事件驱动架构和微服务架构。它们可以用于处理大量的并发请求，提高系统的吞吐量和响应能力。此外，它们还可以用于实现系统之间的解耦，使得系统更加灵活和可维护。
腾讯云提供了一些与消息队列相关的产品和服务，例如腾讯云消息队列（CMQ）和腾讯云云函数（SCF）。腾讯云消息队列是一种高可靠、高可用的消息队列服务，可以与Masstransit和RabbitMQ集成使用。腾讯云云函数是一种无服务器计算服务，可以用于处理消息队列中的消息，并触发相应的业务逻辑。
更多关于腾讯云消息队列和云函数的信息，请参考以下链接：
相关·内容
我可以创建一个workerservices来创建和配置n个RabbitMQ消费者，每个消费者都是自己的线程，用于应用内负载平衡。 我是Masstransit的新手，我不知道如何配置我想要的方式。我在configureservices中找到了使用消息类型队列的代码： // MassTransit-RabbitMQ Configuration
services.AddMassTransit(config => {
config.AddConsumer<BasketCheckoutConsumer>();
浏览 31提问于2021-09-02得票数 1
回答已采纳
我使用带有.NET的.NET (v7.1.6)通过RabbitMQ发布和使用消息
为了将使用者绑定到特定的队列，我以这种方式配置端点：
configurator.ReceiveEndpoint(
"QueueName",
cfg =>
{
cfg.ConfigureConsumer<MyConsumer>(context);
cfg.ExchangeType =
浏览 22提问于2021-05-31得票数 0
回答已采纳
MassTransit公开了用于添加队列和交换参数的函数，但我无法为使用者找到类似的功能。
我希望能够根据这里的RabbitMQ文档设置使用者的优先级(x优先级参数)：。
使用MassTransit可以吗？
浏览 0提问于2018-06-29得票数 1
回答已采纳
1回答
我正在尝试建立一个消息传递系统，并在多个应用程序上运行。我有一个运行RabbitMQ的实例，这似乎很好。我可以将多个订阅者/发布服务器连接到RabbitMQ实例，它们看起来很好。然后，我可以从一个发布服务器发布一条消息，但只有一个订阅服务器正在接收该消息。
我相信这与我排队的方式有关。我看过关于兔子，的教程，但我不知道这是否能转化为Masstransit库。
为了我的生命，我很难弄清楚我做错了什么。
NuGets：
MassTransit.Extensions.DependencyInjection 5.3.2
MassTransit.RabbitMQ 5.3.2
有人能帮忙吗
浏览 0提问于2019-03-12得票数 2
回答已采纳
我正尝试在2个总线实例的单元测试中使用InMemoryBus传输(相同的过程)。其中一个总线实例应该发布一个事件，而另一个则使用它。 我认为，我需要的是http://masstransit-project.com/MassTransit/usage/transports.html中记录的共享传输功能，但它似乎在5.2.1版中不再可用。有没有其他方法可以达到同样的效果？
浏览 13提问于2019-01-18得票数 0
回答已采纳
我创建了一个MassTransit快速启动程序来与本地主机RabbitMQ进行交互：
namespace ConsoleApp1
{
public static class Program
{
public class YourMessage
{
public string Text { get; set; }
}
public static async Task Main(params string[] args)
{
var bus = Bus.
浏览 2提问于2019-05-09得票数 4
回答已采纳
1回答
最初，我有一个单独的rabbitmq节点，可以很好地处理请求/响应客户端交互。
我现在正在切换到集群，并尝试运行完全相同的请求/响应操作。它以惊人的速度爆炸。
我已经设置了两个主机作为rabbitmq集群的一部分。我遇到了如此多的麻烦，以至于我又回到了使用masstransit 。
这似乎也有麻烦。我最终在我的请求服务上得到了一个重复出现的异常：
--- End of stack trace from previous location where exception was thrown --
at System.Runtime.CompilerServices.TaskAwaiter
浏览 1提问于2016-03-05得票数 2
我正在为每个使用者实例寻找一种方法来接收通过RabbitMQ通过MassTransit发布的消息。情况是，我们有多个微服务，需要在通知时使缓存失效。Pub-Sub在这个实例中不起作用，因为每个服务实例将有5个与其代码相同类型的消费者，因此只有一个人会在传统的PubSub中接收消息。
消息观察可以是一种选择，但这意味着消息永远不会被消耗，并且永远停留在总线上。
有人能建议在MassTransit上下文中使用的模式吗？
提前谢谢。
浏览 2提问于2018-04-03得票数 4
回答已采纳
如何为生产者和消费者在Masstransit使用rabbitmq传输时创建两个rabbitmq连接。为发布者和使用者分离连接，以实现高吞吐量。当发布服务器发送太多消息以供服务器处理时，RabbitMQ可以对TCP连接施加回压。如果您在同一个TCP连接上使用，服务器可能不会从客户端接收消息确认，从而影响使用性能。以较低的消耗速度，服务器将不堪重负。
浏览 3提问于2021-07-16得票数 0
回答已采纳
MessageType："PublishX“
消费者：
Type1ConsumerX
Type2ConsumerX
Type3ConsumerX
所有的消费者都必须立即捕捉消息，但同时在自己的内部消费。
例如，队列中有100个"PublishX“消息。Type1ConsumerX消耗了30条消息(同步)，Type2ConsumerX消耗了50条消息(同步)，Type3ConsumerX消耗了100条消息(同步)。我如何知道消息是由“所有类型的消费者”消费的？
RabbitMQ/MassTransit 能否将消息推送给消费者？
RabbitMQ/MassTransit消息
浏览 7提问于2015-03-22得票数 2
回答已采纳
我在RabbitMQ中使用MassTransit库。我希望将我的客户扩展到不同的机器中，但是我需要确保它们不会收到相同的消息。我将我的消费者部署在不同的服务器上，但他们得到了相同的消息。有没有办法解决这个问题？
浏览 22提问于2021-08-06得票数 0
回答已采纳
如何在使用者类中使用依赖项注入。我收到错误消息，因为“'Esb.Masstransit.RabbitMq.Application.IEventConsumerService‘类型不能用作泛型类型或方法'MassTransit.ConsumerExtensions.Consumer(MassTransit.IReceiveEndpointConfigurator，System.Action<MassTransit.ConsumeConfigurators.IConsumerConfigurator>)'.中的类型参数'TConsumer’没有从'
浏览 5提问于2020-09-10得票数 0
我正在尝试使用新的IJobConsumer，但该作业从未运行过。 在我正在测试的项目中，Mediator工作得很好，就像普通的(短期的)消费者一样。我唯一做不到的事情就是IJobConsumer。我不确定我是不是配置错了。 我是这样配置MassTransit的： services.AddMassTransit(x =>
{
x.AddServiceClient();
x.AddRabbitMqMessageScheduler();
浏览 12提问于2021-02-01得票数 0
2回答
我将MassTransit与RabbitMQ结合使用。
这是对发生的事情的总结。
ORDER SERVER是一个获取订单并发布(与MassTransit一起) Order消息的应用程序。
OrderProcessed.处理单元，它是一个应用程序，它使用订单消息并对其进行一些处理，然后发布。
因此，在这里，处理单元是消费和发布。
在博客、文档和论坛中，我看到每个应用程序都必须有一个队列，我这样做了，但是仍然有很多消息(大约%30)会进入错误队列，而--当在处理单元上使用两个队列时--它工作得很好。(意味着处理单元有一个具有不同队列的IServiceBus，仅用于消费，另一个仅用于
浏览 4提问于2013-07-02得票数 1
回答已采纳
1回答
在我的应用程序中配置错误用户时，我遇到了问题。问题是，所消耗的消息被传递到*_error_skipped队列，并且它不会完全消失。
下面是一个非常简单的例子。客户端应用程序接收失败的消息，并从test_error队列中消失，但它仍然存在于test_error_skipped队列中。
服务项目
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using GreenPipes;
using MassTransit;
using MassTransit.U
浏览 1提问于2018-07-13得票数 2
回答已采纳
在过去，我在RabbitMQ中使用MassTransit。最近，我需要实现处理Amazon简单队列服务(发送和消费消息)的基础架构。选择MassTransit而不是本机工具，以防将来队列提供程序会发生变化。然而，我一直在为配置而苦苦挣扎(没有太多的文档，特别是针对MassTransit V7和SQS7的文档)。
我想知道，是否可以配置MassTransit，使其在使用消息后将其从队列中删除？我看到的唯一与IAmazonSqsBusFactoryConfigurator相关的配置是AutoDelete，但我发现它与删除整个队列有关。
我的目标是实现一个windows服务，它将侦听队列，使用任何新
浏览 11提问于2021-07-02得票数 0
我正在尝试为我的应用程序设置MassTransit和RabbitMQ。
我使用的是CastleWindsor DI和.Net Framework4.7。
我在Program.cs中注册我的消费者和公共汽车的方式是：
container.AddMassTransit(x =>
{
x.AddBus(context => Bus.Factory.CreateUsingRabbitMq(cfg =>
{
var host = cfg.Host(configurationProvider.RabbitHostName);
x.AddC
浏览 2提问于2020-02-06得票数 1
回答已采纳
3.1.2 MassTransit.Autofac.3.1.1 MassTransit.RabbitMQ.3.1.1 RabbitMQ.Client.3.6.0 Topshelf.3.3.1
一个Top大陆架Windows服务创建一个总线实例，如下所示：
var builder = new ContainerBuilder();
builder.RegisterConsumers(Assembly.GetExecutingAssembly());
builder.Register<IBusControl>(context =>
{
re
浏览 3提问于2016-01-19得票数 0
回答已采纳
我正在使用MassTransit + RabbitMQ组合在Asp.Net核心应用程序中。有关配置部分如下：
public IBusControl CreateBus(IServiceProvider serviceProvider)
{
var options = serviceProvider.GetService<IConfiguration>().GetOptions<RabbitMqOptions>("rabbitmq");
return Bus.Factory.CreateUsingRabbitMq(cfg =>
浏览 13提问于2020-03-05得票数 3
回答已采纳
我想知道如何为在RabbitMQ的MassTransit消费者中引发异常的消息配置交换，以便稍后重播它们？这可能是开箱即用的吗？
浏览 45提问于2019-05-11得票数 0
回答已采纳
我正在构建一个基于微服务的应用程序，其中包含两个通过RabbitMQ代理进行通信的微服务。每当创建、更新或删除图书时，都会发布一个事件。从第一个微服务发布可以正常工作，但在另一个微服务中没有消耗任何内容。虽然队列已启动并正在运行，但没有任何内容被放入队列。我在使用Visual Studio2019的.Net应用程序中使用MassTransit和RabbitMQ。以下是我在Startup.cs中的配置代码 services.AddMassTransit(x =>
{
x.AddConsumer<BookCreationConsumer>
浏览 7提问于2021-09-03得票数 1
回答已采纳
我开始在dotnetcore中使用masstransit和rabbitmq。我研究了它的行为，并注意到它会自动创建交换和队列名称'bus-{computer name}-dotnet-xxxxxxxxxxxxxxx‘。我想知道它为什么创建以及它做了什么。我在rabbitmq仪表板中查看它。谢谢。
浏览 44提问于2019-01-31得票数 0
回答已采纳
下面是在ASP.net Core6.0API中开发的一个示例POC，它使用MassTransit和RabbitMQ来模拟使用MassTransit使用者的简单发布/订阅。然而，当代码被执行时，它会在RabbitMQ中创建2个交换和1个队列。
Program.cs
builder.Services.AddMassTransit(msConfig =>
{
msConfig.AddConsumers(Assembly.GetEntryAssembly());
msConfig.UsingRabbitMq((hostcontext, cfg) =>
{
浏览 11提问于2022-09-15得票数 0
1回答
我试图围绕我使用MassTransit创建的一些服务创建黑匣子集成测试。服务的要点是在MassTransit通道上接收消息，处理消息并在不同的MassTransit通道上发送消息(请注意，这不是请求应答语义，而是管道中的一个组件)：
IBusControl bus = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
var host = cfg.Host(new Uri("rabbitmq://localhost"),
h =>
{
h.Username("gu
浏览 1提问于2015-10-26得票数 3
回答已采纳
我正在尝试使用MassTransit的内存总线，并尝试修改由松散耦合的Labs 提供的示例，使其从使用RabbitMQ过渡到内存总线。但是，订阅者似乎没有收到消息。
我使用的是3.1.2版的MassTransit。
在Publisher中，我将总线创建更改为：
var bus = Bus.Factory.CreateUsingRabbitMq(x => x.Host(new Uri("rabbitmq://localhost/"), h => { }));
至：
var bus = Bus.Factory.CreateUsingInMemory(x => {
浏览 3提问于2016-01-04得票数 0
回答已采纳
我有一个简单的.NET工作者服务应用程序来测试MassTransit。我试着用下面的例子：
具体来说，我试图使用UseConcurrentMessageLimit()方法，但是e.Consumer部分高亮显示了一个错误，即“引用类型'IReceiveEndpointConfigurator‘声称它是在'MassTransit’中定义的，但是找不到它”。
我使用的是MassTransit 8.0.2。
我想知道是否有一些额外的NuGet包，我需要包括使这个工作。我尝试使用内存传输，SQS，RabbitMQ (如果它是特定于传输的话)，我总是得到相同的错误。
浏览 6提问于2022-05-05得票数 0
回答已采纳
1回答
我在用Masstransit+RabbitMQ。我的消费者之一实现了重试策略，我想知道是否有任何方法可以在错误队列中获得消息的重试？
另外，我想知道MT计数重试是如何进行的，因为我不想在使用RabbitMq服务器的消息头中找到任何相关信息。
谢谢。
浏览 4提问于2016-11-08得票数 4
回答已采纳
我正在阅读关于 in MassTransit RabbitMQ的文章，但我仍然不了解它到底是如何工作的。
假设我有4个消费者，并将队列配置为并发限制为1 config.UseConcurrencyLimit(1);。当生产者同时发送4条消息时，会发生什么？只有一条消息将在一个消费者中使用，而所有其他3条消息将被丢弃？
有人能解释一下它是怎么工作的吗？
浏览 14提问于2021-12-21得票数 0
回答已采纳
我有一个企业服务总线( Enterprise )，它使用Masstransit / RabbitMq在web项目中使用。我在MQ上使用模式进行RPC。
我正在一个总线中创建多个ReceiveEndpoint，它处理不同类型的消息。ESB还使用自定义配置文件来创建多个总线，因此我可以以某种方式在逻辑上实现Qos，甚至可以在独立服务器上通过网络不信任使用者，以或多或少地提高性能。
最近我看到我的一个消费者被封锁了。如果我向一个长期运行的使用者发送一些消息(每个消息需要大约5秒的工作时间)，那么看起来就像一个线程响应了我的请求，并同时发送了消息，等待前面的消息被消耗。
到目前为止，我设置了UseCo
浏览 5提问于2017-04-26得票数 0
回答已采纳
2回答
我在C#项目中使用Masstransit。
我有一个出版商和消费者服务，当两者都结束时，就没有问题了。但是如果消费者离线，发布的消息就不会进入队列，就会消失。
预期的行为是将消息保存在队列中，直到消费者启动为止，然后将它们发送给它。我在谷歌小组中发现了几个同样的问题，但我不清楚如何解决这个问题。
我觉得奇怪的是，这种功能并不是凭空提供的，因为据我理解，它是RabbitMQ和MT的主要目的。
我创建publisher总线的方式：
public static IBusControl CreateBus()
{
return Bus.Factory.CreateUsingRabbitMq(s
浏览 5提问于2017-08-02得票数 0
我有一个.NET 4.5.2服务通过MassTransit向RabbitMq发布消息。
以及使用这些消息的多个.NET Core2.1服务实例。
目前，.NET核心消费者服务的竞争实例窃取来自其他用户的消息。
，即第一个使用消息的用户将其从队列中删除，其余的服务实例将无法使用它。
我希望所有实例使用相同的消息。
我怎样才能做到这一点？
Publisher Service配置如下：
builder.Register(context =>
{
MessageCorrelation.UseCorrelationId<MyWrapp
浏览 0提问于2019-07-25得票数 11
回答已采纳
我想手动暂停一个特定的消费者合同一段特定的时间。
请注意，我不希望停止IServiceBus。
我可以用MassTransit (7.0.3版)和RabbitMQ (3.8.5版)来做到这一点吗？
浏览 1提问于2020-09-03得票数 2
回答已采纳
我们使用的是.Net核心/RabbitMQ/MassTransit，我有一个工作良好的ConsumerOrderCreatedEvent。
我希望有一个错误恢复机制，在该机制中，在应用程序启动时，我希望读取并删除错误队列中的消息。
是否可以在MassTransit中读取并删除错误队列中的消息？
浏览 3提问于2020-01-15得票数 0
回答已采纳
1回答
为了限制打开到数据库的连接的数量，我需要限制同步函数调用的数量。
MassTransit的UseConcurrentMessageLimit显然限制了每个主机实例同时处理的消息数量，这与来自host.json的maxConcurrentCalls相同吗？
Azure门户有App -> Maximum Scale Out ，这限制了将要创建的主机数量。
要将同步函数调用的次数限制为n，是否应该设置最大扩展量限制* UseConcurrentMessageLimit or maxCurrentCalls =n
我可以通过MassTransit或Azure函数配置中的一个参数来实现这一点吗？
浏览 6提问于2022-05-31得票数 1
回答已采纳
我在示例项目中使用MassTransit和RabbitMQ。我只是尝试发布一条消息，然后由两个分开的消费者使用它。但是每一次，只有一个消费者随机解雇！有什么问题吗？
这是发件人的方法。
await _publishEndpoint.Publish(new ConsultantFinishedEvent(50));
发布服务器中应用程序启动时的此配置：
#region Service Bus Config
public static IServiceCollection AddEventBus(this IServiceCollection services, IConfigurati
浏览 5提问于2021-09-13得票数 0
回答已采纳
1回答
我正在开发一个使用MassTransit和RabbitMQ在C#中使用消息的项目。
我正在构建一个原型，现在消费者项目是一个控制台应用程序。在主program.cs类中，我连接到总线并订阅以接受来自发布服务器的消息，如下所示：
var bus = BusInitializer.CreateBus("Subscriber", x =>
{
x.Subscribe(subs =>
{
subs.Consumer<UpdatedInform
浏览 2提问于2015-05-07得票数 2
回答已采纳
我有一个案例可以使用rabbitmq/api将远程主机的消息发布到rabbitmq，并且我希望将已发布消息的处理传递给MassTransit使用者。
正如我所注意到的，成功处理MassTransit使用者消息的“最小需要的属性”如下所示：
有效载荷
{
'messageId':'86fd0000-17e1-ac9e-4bde-08d3f1e8553e',
'correlationId':'86fd0000-17e1-ac9e-4165-08d3f1e8553e',
'conversationId&#
浏览 3提问于2016-10-12得票数 0
刚刚意识到，使用V6 of MassTransit，一条总线中对多个主机的支持被删除了。是否有不同的解决方案来实现它。
我们的用例是在两个不同的主机上侦听相同的队列。使用消息并仅使用RespondAsync进行响应，我的理解是它可以自动解析回原始默认响应队列。
谢谢,
浏览 2提问于2020-02-19得票数 0
回答已采纳
我有一个问题，使用错误消息，它没有处理。处理程序代码是：
internal class FaultConsumer : IConsumer<Fault<MyMessage>>
{
public Task Consume(ConsumeContext<Fault<MyMessage>> context)
{
var ctx = context;
var sourceMessage = ctx.Message.Message;
// ...
浏览 4提问于2016-05-14得票数 0
回答已采纳
1回答
我遵循，我试着做他在视频中说过的话，但是当我为Expiring the allocation安排一条消息时，它不起作用，当我仔细查看时，我注意到RabbitMq中的调度程序队列没有任何使用者，我试图解决这个问题，但我没有找到问题，这是我的状态机：
public class AllocationStateMachine : MassTransitStateMachine<AllocationState>
{
public AllocationStateMachine(ILogger<AllocationStateMachine> logger)
{
浏览 4提问于2022-05-03得票数 0
回答已采纳
只要我在visual studio中启动我的应用程序，就会收到SharedQueue closed错误。现在错误是非常频繁的。据我所知，我们没有对代码做任何修改&这段代码之前工作得很好。
我在网上看到过很多类似的错误帖子，但我没有发现任何有帮助的帖子。当异常发生时，它不会指向任何代码。有关更多信息，请参阅下面的错误：
下面是错误堆栈跟踪：
at RabbitMQ.Util.SharedQueue.EnsureIsOpen()
at RabbitMQ.Util.SharedQueue.Dequeue(Int32 millisecondsTimeout, Object&a
浏览 26提问于2015-06-05得票数 0
1回答
我正在开发客户端应用程序，它使用的是masstransit和rabbitmq。在应用程序启动时，我将创建具有唯一名称的新队列，以便通过masstransit(请求/响应模型)与服务器应用程序进行通信。在应用程序关闭时，我应该删除这个队列，但是如果客户端应用程序压缩队列，就会出现在rabbitmq上。
是否可以通过masstransit创建临时队列，当客户端断开队列时，rabbitmq将自动删除该队列？
浏览 1提问于2015-06-10得票数 3
回答已采纳
我使用的是.net核心2.1.0、Masstransit和Rabbitmq。
我的问题是，当从控制器发送消息时，消费者无法接收消息。
public static void ConfigureServices(IServiceCollection services, IConfiguration configuration)
{
var bus = Bus.Factory.CreateUsingRabbitMq(sbc =>
{
var host = sbc.Host(new Uri("rabbitmq://local
浏览 10提问于2018-09-05得票数 0
我试图使用UseDelayedExchangeMessageScheduler和rabbitmq_delayed_message_exchange插件发送预定的消息。我确实是这样设置公共汽车的：
public void StartUpBus()
{
_bus = Bus.Factory.CreateUsingRabbitMq(ConfigureBus);
_bus.Start();
}
private void ConfigureBus(IRabbitMqBusFactoryConfigurator busConfigurato
浏览 7提问于2020-04-19得票数 1
回答已采纳
我刚开始使用MassTransit，没有找到任何适合初学者的文档。我确实在中找到了一些示例代码，它显示了一个使用RabbitMQ的简单MassTransit发布/订阅示例
但是对于我的公司，我需要使用MSMQ。因此，我删除了RabbitMQ引用：
x.UseRabbitMq();
x.ReceiveFrom("rabbitmq://localhost/MtPubSubExample_" + queueName);
并将它们改为使用MSMQ：
x.UseMsmq();
x.ReceiveFrom("msmq://localhost/MtPubSubExample_"
浏览 5提问于2015-03-29得票数 3
回答已采纳
我看不出有什么可以说这是正常的行为，所以如果我是瞎子，请原谅。在使用带有请求响应的MassTransit时，我看到了一些奇怪的东西。
因此，我在一个服务上有多个使用者，它侦听不同的请求来执行简单的任务，比如从数据库抓取数据。
为了测试每个使用者，我创建了一个控制台应用程序，它为每个使用者执行一个请求并检查响应。
我注意到的是，第一个请求-响应工作正常，但是当代码运行时，下一个检查会收到响应，但是消息会被移动到跳过的队列中并删除。
这是第二次请求的杂凑日志。
发送
rabbitmq://192.168.0.25/Ksrs.Requests:ConceptByConceptNoRequest d9
浏览 3提问于2021-05-14得票数 0
回答已采纳
我在RabbitMQ中使用massTransit。使用massTransit发布消息将为我的消息类型创建一个交换。而masstransit使用者将创建到交换的队列和绑定。太好了，让事情变得简单。
在介绍massTransit之前，我使用rabbitMQ的api来创建队列、交换和绑定。我会让发布者和消费者运行相同的设置代码。因此，无论谁先运行所有队列，无论应用程序的哪一部分先运行，都将创建交换和绑定。当在开发环境中运行时，这是非常棒的。
我想知道是否可以用massTransit实现类似的事情？
浏览 1提问于2016-12-23得票数 1
我知道，使用MassTransit，您可以在消息上使用关联id，并且只能使用具有相同关联id的消息。
我在一个控制台应用程序中做到了这一点，但它不起作用，即使具有不同的关联id，它也可以获取所有消息。实际上，我的"CorrelationId“属性从未被调用过。
谢谢
浏览 0提问于2013-07-02得票数 0
回答已采纳
在我的ASP.NET核心控制器中，我使用IMediator.Send发送命令
await mediator.Send(new SubmitOrder());
SubmitOrder的使用者如下所示
public class SubmitOrderConsumer : IConsumer<SubmitOrder>
{
public async Task Consume( ConsumeContext<SubmitOrder> context )
{
var sendEndpoint = await context.GetSendEndpoi
浏览 6提问于2021-07-09得票数 1
我们使用的是MassTransit和RabbitMQ。在发布任何消息之前，是否有一种方法可以检查端点是否可用？如果servicebus不可用，我想设置我们的IoC以使用另一种策略，而且我不想在发布消息时捕获RabbitMQ.Client.Exceptions.BrockerUnreachableException。
浏览 6提问于2014-03-18得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
