如何使用masstransit拥有多个相互竞争的rabbitmq消费者
MassTransit是一个开源的分布式应用消息传递框架，用于构建基于消息传递的应用程序。它使用RabbitMQ作为消息传输机制，可以在多个消费者之间实现消息的并发处理。
要使用MassTransit拥有多个相互竞争的RabbitMQ消费者，可以按照以下步骤进行：
- 创建RabbitMQ连接：首先，需要创建与RabbitMQ的连接。可以使用MassTransit提供的RabbitMQ连接字符串来建立连接，例如：
- 创建RabbitMQ连接：首先，需要创建与RabbitMQ的连接。可以使用MassTransit提供的RabbitMQ连接字符串来建立连接，例如：
- 这段代码创建了一个使用默认本地RabbitMQ实例的连接。
- 定义消息消费者：接下来，需要定义消息的消费者。可以创建多个消费者，每个消费者监听不同的队列，并且这些消费者可以相互竞争地处理消息。例如，创建两个消费者：
- 定义消息消费者：接下来，需要定义消息的消费者。可以创建多个消费者，每个消费者监听不同的队列，并且这些消费者可以相互竞争地处理消息。例如，创建两个消费者：
- 这里的
OrderPlaced是一个示例消息类型。 - 注册消费者：在创建RabbitMQ连接后，需要将消费者注册到总线上：
- 注册消费者：在创建RabbitMQ连接后，需要将消费者注册到总线上：
- 这里使用了
ConnectReceiveEndpoint方法将消费者注册到名为order_queue的队列上。 - 启动总线：最后，需要启动总线以开始监听队列并处理消息：
- 启动总线：最后，需要启动总线以开始监听队列并处理消息：
- 至此，多个相互竞争的RabbitMQ消费者已经可以通过MassTransit进行消息处理了。
需要注意的是，MassTransit还提供了其他高级功能，如消息序列化、消息重试、消息过滤等。可以根据具体需求来配置和使用这些功能。
关于MassTransit的更多详细信息和用法，可以参考腾讯云提供的MassTransit文档：
- 腾讯云产品介绍：MassTransit - 分布式应用消息传递框架
- MassTransit官方文档：https://masstransit-project.com/
相关·内容
我刚刚创建了一个API，其中来自API的请求将使用请求/响应模式通过MassTransit/RabbitMQ转发到后端服务。我们现在正在考虑将其推向生产，并希望在不同的服务上运行应用程序的多个实例(包括API和服务)，并使用负载均衡器在它们之间分发请求。
这使我们处于这样一个位置，如果由于任何原因其中一台服务器被移出池，我们可能会丢失所有消息。我正在考虑在服务器之间创建一个RabbitMQ集群(每个服务器都有一个本地安装)，并且想知道如何在这个实例中设置竞争的消费者。
RabbitMQ或MassTransit是否会处理此问题，以便只有一个消费者会收到请求，还是所有消费者都会收到请求并尝试响应？
浏览 0提问于2012-06-17得票数 1
回答已采纳
我使用带有.NET的.NET (v7.1.6)通过RabbitMQ发布和使用消息
为了将使用者绑定到特定的队列，我以这种方式配置端点：
configurator.ReceiveEndpoint(
"QueueName",
cfg =>
{
cfg.ConfigureConsumer<MyConsumer>(context);
cfg.ExchangeType =
浏览 22提问于2021-05-31得票数 0
回答已采纳
与直接在上构建相比，在上构建有什么好处
我相信MassTransit提供的一个好处是“类型”交换(按接口/类型发布/订阅)，因此消息的内容是结构化的，而普通的RabbitMQ交换的消息内容是非结构化的文本/ blob。
MassTransit还提供了哪些其他好处？
浏览 0提问于2012-09-06得票数 44
回答已采纳
我可以创建一个workerservices来创建和配置n个RabbitMQ消费者，每个消费者都是自己的线程，用于应用内负载平衡。 我是Masstransit的新手，我不知道如何配置我想要的方式。我在configureservices中找到了使用消息类型队列的代码： // MassTransit-RabbitMQ Configuration
services.AddMassTransit(config => {
config.AddConsumer<BasketCheckoutConsumer>();
浏览 31提问于2021-09-02得票数 1
回答已采纳
MessageType："PublishX“
消费者：
Type1ConsumerX
Type2ConsumerX
Type3ConsumerX
所有的消费者都必须立即捕捉消息，但同时在自己的内部消费。
例如，队列中有100个"PublishX“消息。Type1ConsumerX消耗了30条消息(同步)，Type2ConsumerX消耗了50条消息(同步)，Type3ConsumerX消耗了100条消息(同步)。我如何知道消息是由“所有类型的消费者”消费的？
RabbitMQ/MassTransit 能否将消息推送给消费者？
RabbitMQ/MassTransit消息
浏览 7提问于2015-03-22得票数 2
回答已采纳
我已经用MassTransit实现了一个简单的发布者/消费者集合，我想让消费者从同一队列中读取消息。但是，当我运行它时，我看到很大一部分消息被发送到错误队列，而不是被使用。根据我所看到的讨论(，)，使用RabbitMQ应该非常非常简单(只需指向相同的队列)，但它不起作用。是否需要设置其他配置？
这是我的出版商
public class YourMessage { public string Text { get; set; } }
public class Program
{
public static void Main()
{
Console.WriteLi
浏览 0提问于2012-05-09得票数 7
回答已采纳
1回答
我正在尝试建立一个消息传递系统，并在多个应用程序上运行。我有一个运行RabbitMQ的实例，这似乎很好。我可以将多个订阅者/发布服务器连接到RabbitMQ实例，它们看起来很好。然后，我可以从一个发布服务器发布一条消息，但只有一个订阅服务器正在接收该消息。
我相信这与我排队的方式有关。我看过关于兔子，的教程，但我不知道这是否能转化为Masstransit库。
为了我的生命，我很难弄清楚我做错了什么。
NuGets：
MassTransit.Extensions.DependencyInjection 5.3.2
MassTransit.RabbitMQ 5.3.2
有人能帮忙吗
浏览 0提问于2019-03-12得票数 2
回答已采纳
我在RabbitMQ中使用MassTransit库。我希望将我的客户扩展到不同的机器中，但是我需要确保它们不会收到相同的消息。我将我的消费者部署在不同的服务器上，但他们得到了相同的消息。有没有办法解决这个问题？
浏览 22提问于2021-08-06得票数 0
回答已采纳
1回答
这些都是Masstransit的新成员，目前正在为一个更大的项目进行评估，并想知道是否有人能帮助更好地理解以下挑战：
“负载平衡环境中事件的单个使用者”
在生产中，我们的服务将运行多个实例以实现可伸缩性和故障转移，并成为更大的微服务生态系统的一部分。总体架构基于参考实现，其中不同的微服务通过“集成事件”相互通信。当将IntegrationEvent发布到其他服务(我认为应该像Masstransit / 中所描述的那样)时，我如何确保在特定的微服务中只有一个实例正在处理该事件，但当然，事件到达了所有依赖于事件的微系统？当我们基于Azure函数完成类似的解决方案时，这个需求已经通过使用"S
浏览 1提问于2021-03-01得票数 1
如何将MassTransit配置为在失败之前重试context.Publish()，例如，当RabbitMQ服务器暂时不可用时？
浏览 1提问于2017-06-07得票数 3
回答已采纳
如果我的问题很愚蠢，很抱歉，我是新来MassTransit的。 我的系统由一个服务器和多个客户端设备组成。我想从服务器向特定的客户端或一组客户端发送消息。据我所知，IBusControl.Publish将消息发送给所有订阅者，而IBusControl.Send将消息发送给唯一的订阅者。 如何使用MassTransit实现这一点？我的传输是RabbitMQ / Azure服务总线。 谢谢!
浏览 39提问于2019-03-13得票数 1
回答已采纳
2回答
我正在向使用RabbitMQ连接用不同语言编写的服务的人寻求建议。目前，我的组织只在C#中使用C#，而且都运行得很好。为了在RabbitMQ提供的基础上提供一些更好的附加功能，我们实现了MassTransit。MassTransit在RabbitMQ上提供了一些巨大的好处(抽象出RabbitMQ的细节，处理“有害”消息，重试，序列化，提供大量的消息传递模式等等)。但是，主要的缺点是它将您锁定为使用.NET；它只将反序列化处理为.NET类。这限制了我们创建用非.NET语言编写的服务的能力。当然，我们可以将用RESTful编写的C#端点进行表面处理，以允许其他服务连接，但这并不理想，因为其他服务应
浏览 0提问于2018-03-02得票数 2
如何在使用者类中使用依赖项注入。我收到错误消息，因为“'Esb.Masstransit.RabbitMq.Application.IEventConsumerService‘类型不能用作泛型类型或方法'MassTransit.ConsumerExtensions.Consumer(MassTransit.IReceiveEndpointConfigurator，System.Action<MassTransit.ConsumeConfigurators.IConsumerConfigurator>)'.中的类型参数'TConsumer’没有从'
浏览 5提问于2020-09-10得票数 0
我使用MassTransit和RabbitMQ 仲裁队列进行应用程序集成。我用
var endpoint = await _bus.GetSendEndpoint(new Uri("exchange:TestCommand"));
await endpoint.Send(command1, stoppingToken);
如果“接收者应用程序”从未启动，队列将不会被创建，所有发送的消息都将丢失。
如果我在发送时使用前缀queue：
var endpoint = await _bus.GetSendEndpoint(new Uri("queue:TestCommand&#
浏览 1提问于2022-03-14得票数 0
回答已采纳
在RabbitMq中使用CircuitBreaker时，如下所示：
sbc.ReceiveEndpoint(host, "IDocumentImported_Warehouses.Nls", ep => {
ep.Consumer(() => _container.Resolve<DocumentConsumer>());
ep.PrefetchCount = 1;
ep.UseCircuitBreaker(cb => {
cb.ResetInterval = TimeSpan.Fr
浏览 1提问于2017-06-14得票数 2
1回答
我正在构建一个应用程序来使用来自RabbitMQ的高容量(流)消息。情况如下：
发布服务器发布实时匹配数据的有RabbitMQ，这意味着数据量非常快(每秒100次)，RabbitMQ中的最大队列长度为500 ，意味着如果用户不能很快地接收消息，消息将丢失
以下是我的疑问
：对于上述场景，哪种模式/体系结构/工具最适合？(非常快地使用消息)
MassTransit会满足上述要求吗？
浏览 2提问于2021-10-24得票数 3
回答已采纳
我在net core 3.1中使用masstransit/rabbitmq。我有一个dispatcher服务，当消息可用时，它会将消息发送到worker服务。每个worker服务在前面都有一个rabbitmq队列，该队列是在服务启动时创建的。我希望确保当worker服务停止时，队列(和交换)需要被删除。当我在配置(Program.cs)中设置标志AutoDelete时，我可以让它工作：
services.AddMassTransit(x =>
{
x.AddBus(provider => Bus.Factory.CreateU
浏览 5提问于2021-06-02得票数 0
回答已采纳
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
回答已采纳
我在RabbitMQ中使用massTransit。使用massTransit发布消息将为我的消息类型创建一个交换。而masstransit使用者将创建到交换的队列和绑定。太好了，让事情变得简单。
在介绍massTransit之前，我使用rabbitMQ的api来创建队列、交换和绑定。我会让发布者和消费者运行相同的设置代码。因此，无论谁先运行所有队列，无论应用程序的哪一部分先运行，都将创建交换和绑定。当在开发环境中运行时，这是非常棒的。
我想知道是否可以用massTransit实现类似的事情？
浏览 1提问于2016-12-23得票数 1
我看不出有什么可以说这是正常的行为，所以如果我是瞎子，请原谅。在使用带有请求响应的MassTransit时，我看到了一些奇怪的东西。
因此，我在一个服务上有多个使用者，它侦听不同的请求来执行简单的任务，比如从数据库抓取数据。
为了测试每个使用者，我创建了一个控制台应用程序，它为每个使用者执行一个请求并检查响应。
我注意到的是，第一个请求-响应工作正常，但是当代码运行时，下一个检查会收到响应，但是消息会被移动到跳过的队列中并删除。
这是第二次请求的杂凑日志。
发送
rabbitmq://192.168.0.25/Ksrs.Requests:ConceptByConceptNoRequest d9
浏览 3提问于2021-05-14得票数 0
回答已采纳
我在没有RabbitMQ的情况下用Kafka测试MassTransit 我需要一个IBusControl，我可以使用bus.UsingInMemory()吗？使用Kafka ITopicProducers安全吗？像调度/传奇这样的特性是否适用于Kafka或InMemory bus？
浏览 8提问于2020-10-11得票数 0
请您建议-如果我需要最大限度的系统间/语言兼容性，而主服务器将在.NET上实现，我可以使用NServiceBus或MassTransit，还是使用纯RabbitMQ更好？NServiceBus或MassTransit会给出相当好的抽象级别，但不同解决方案和环境之间的轻松通信是至关重要的。我现在想更多地使用纯RabbitMQ，但是如果我考虑错了，我会很感激地指出一些利弊。
浏览 4提问于2017-04-19得票数 1
回答已采纳
我已经通过MassTransit (使用RabbitMQ)实现了一个竞争的消费者模式，作为处理单个命令的结果，需要发布另外三个命令。我想在“全有或全无”(事务型)发布中这样做，其中"all“将确保三个消息成功地发送到RabbitMQ，或者”none“，其中我的3个事件都不会发送到RabbitMQ，即使发布失败的第三个也是如此。
到目前为止，我只是简单地调用message.Respond(new MyNewCommandHere(){...})，但是我没有在那里或IServiceBus实例上看到批量接口。
所以..。有没有可能以某种方式进行批量发布，或者其他一些推荐的方式来实现这种事务性
浏览 0提问于2013-11-15得票数 1
1回答
我在一个MassTransit核心6 web应用程序上使用RabbitMQ和.net。我的目标是使一个应用程序的几个实例保持同步，在不同的设备上运行。应用程序需要能够发布/使用消息。
当一个站点发布某件东西时，它会被广播到所有的站点队列中(同时，它本身也会简单地丢弃消息)。
为了做到这一点，我配置了带有工厂后缀的MassTransit队列名:例如norm- queue -CV、norm MB。我还将使用者配置为绑定到一个通用的扇出交换名称(norm- exchange )。
在这里，我的配置摘要：
public void ConfigureServices(IServiceCollection
浏览 6提问于2022-08-01得票数 0
回答已采纳
1回答
我尝试通过masstransit实现rabbitmq，如指令https://masstransit-project.com/usage/transports/rabbitmq.html#cloudamqp中所示。 但是总线(IBusControl)没有工厂方法。 Bus.Factory.CreateUsingRabbitMq MassTransit，MassTransit.RabbitMQ - 6.2.0版本。 你知道我忘了包括什么吗？
浏览 19提问于2020-05-02得票数 0
回答已采纳
3回答
我有一个简单的出版商是用MassTransit做的。我正在间隔内发送消息，并能够使用.NET客户端使用MassTransit接收消息。但是当我试图观察Python中的一些东西时，它是无声的。有没有一种从Python或其他语言中使用MassTransit的方法？值得赞赏的例子。
出版商：
builder.Register(c => ServiceBusFactory.New(sbc => {
sbc.UseRabbitMq();
sbc.UseBsonSerializer();
sbc.UseLog4Net();
sbc.ReceiveFrom(&#
浏览 0提问于2014-01-27得票数 9
回答已采纳
我同时使用MassTransit 7.1.4.0和RabbitMQ 3.8.7。
我有一个消费者，它只是抛出一个异常，我还有一个故障消费者，它Console.WriteLine一个故障发生的事实。
不调用故障使用者。我还尝试使用故障消费者定义。同样，这也不起作用。
下面是整个程序。
using System;
using System.Threading.Tasks;
using GreenPipes;
using MassTransit;
using MassTransit.ConsumeConfigurators;
using MassTra
浏览 0提问于2021-02-08得票数 1
2回答
我将MassTransit与RabbitMQ结合使用。
这是对发生的事情的总结。
ORDER SERVER是一个获取订单并发布(与MassTransit一起) Order消息的应用程序。
OrderProcessed.处理单元，它是一个应用程序，它使用订单消息并对其进行一些处理，然后发布。
因此，在这里，处理单元是消费和发布。
在博客、文档和论坛中，我看到每个应用程序都必须有一个队列，我这样做了，但是仍然有很多消息(大约%30)会进入错误队列，而--当在处理单元上使用两个队列时--它工作得很好。(意味着处理单元有一个具有不同队列的IServiceBus，仅用于消费，另一个仅用于
浏览 4提问于2013-07-02得票数 1
回答已采纳
1回答
我用RabbitMq总线创建了服务。现在，我正在尝试在公共汽车上添加活动(我尝试了我找到的每一个注册选项)
private void ConfigureBus(IServiceCollectionConfigurator configurator)
{
configurator.AddActivity(typeof(StepAcitivity));
configurator.AddActivitiesFromNamespaceContaining<StepAcitivity>();
configurator.AddAc
浏览 1提问于2020-07-06得票数 0
我的问题更多的是建筑而非程序，但我认为它符合S.O的T&C标准。
我们有一份申请，负责发送大量电子邮件.该架构由以下几个部分组成：
用户通过receivers发送请求，以准备电子邮件具有: HTML内容、发件人、receivers列表的电子邮件。
此时，第二个步骤由MassTransit处理程序执行：
这是必需的，因为在第一步中，创建了一个电子邮件模板，它可能生成30,000封电子邮件。对于每一封电子邮件，都会向RabbitMQ发送一条特定的消息，并将电子邮件单独发送出去。
我们需要的是模板的历史和模板发送的所有电子邮件。由于我们的平台发送了数以百万计的电子邮件
浏览 5提问于2020-05-01得票数 0
回答已采纳
我正在阅读关于 in MassTransit RabbitMQ的文章，但我仍然不了解它到底是如何工作的。
假设我有4个消费者，并将队列配置为并发限制为1 config.UseConcurrencyLimit(1);。当生产者同时发送4条消息时，会发生什么？只有一条消息将在一个消费者中使用，而所有其他3条消息将被丢弃？
有人能解释一下它是怎么工作的吗？
浏览 14提问于2021-12-21得票数 0
回答已采纳
我有一个只有一个应用服务器的环境。我有一些需要一段时间才能服务的消息(比如10秒左右)，我希望通过配置多个运行代码的使用者应用程序实例来处理这些消息来提高吞吐量。我读过关于“竞争消费者”模式的文章，并认为在使用MassTransit时应该避免这种情况。根据MassTransit docs ，每个接收端点应该有一个唯一的队列名。我很难理解如何将这个建议映射到我的环境中。是否有可能让消费者的N个实例运行，每个实例都接收相同的消息，但只有其中一个实例实际上会对其起作用?换句话说，我们可以在多个队列而不是一个队列中实现“竞争消费者”模式吗？
还是我看错了？我真的需要研究一下“发送”方法而不是“发布”方
浏览 3提问于2016-08-03得票数 2
回答已采纳
我正在尝试使用MassTransit和RabbitMq实现简单的pub/sub。我正在使用点net 4.8版本来实现它。我已经创建了两个控制台应用程序项目(分别用于pub和sub)，我无法通过MassTransit将消息发布到队列中，但是如果我直接使用RabbitMq.CLient nuget，我可以发送和接收消息。
请查找我的发行者和订阅者类如下: Publisher.cs：
using System;
using Contracts;
using MassTransit;
using MassTransit.Log4NetIntegration.Logging;
namespace Pu
浏览 2提问于2021-04-29得票数 0
我有一个利用MassTransit和RabbitMQ作为消息总线的ASP.NET项目，我正在尝试实现MassTransit Saga，我想使用Saga的ScheduleTimeout功能，这需要MassTransit.RuntimeServices (TimeoutService)。
然而，随着我逐渐了解到，MassTransit的NuGet安装并不包含RuntimeServices，这在我看来似乎很愚蠢，但是哦，好吧。
因此，我尝试将MassTransit.RuntimeServices和MassTransit.RuntimeServices.Database直接包含在我的项目中，这导致了许
浏览 2提问于2013-08-09得票数 0
究竟什么是消费者传奇，它与自动代名词有什么不同？我知道自动化是一个独立的库，由MassTransit使用。
浏览 1提问于2021-01-14得票数 3
回答已采纳
这是日志 MassTransit.RabbitMqTransport.Integration.ConnectionContextFactory.CreateConnection(ISupervisor supervisor)
[02:51:48 DBG] Connect: guest@localhost:5672/
[02:51:48 WRN] Connection Failed: rabbitmq://localhost/
RabbitMQ.Client.Exceptions.BrokerUnreachableException: None of the specified endpoin
浏览 74提问于2021-11-17得票数 0
我使用MassTransit作为我的消息传递框架，运行在Azure Service Bus之上。我从WebJob内部运行MassTransit (尽管我认为这无关紧要)
现在，我正在尝试让MassTransit同时处理多个消息，因为我现在正在处理单独需要一段时间才能处理的消息。因此，为了提高性能，我不希望逐条处理每条消息。
例如，我尝试将MaxConcurrentCalls设置为30，但似乎没有成功。消息仍然被我的消费者一个接一个地接收。
我也尝试将PrefetchCount设置为5等，但它不会改变任何东西。
我做错了什么？非常感谢您的任何帮助。
浏览 0提问于2016-09-30得票数 0
我目前正在构建一个使用MassTransit和RabbitMQ作为我的消息层的系统。我正在尝试找到一种方法，让一个消费者在总线上监听所有类型的所有消息。这是为了我们的审计日志框架，我们想要记录通过消息总线的所有事件。
在MassTransit中有没有办法做到这一点？
浏览 2提问于2015-12-18得票数 7
我使用的是MassTransit和RabbitMQ，我想利用RabbitMQ虚拟主机。我所在组织中的其他应用程序(不使用MassTransit)有为环境设置虚拟主机的约定，即"myapp“和"myappUAT”。我需要遵循这个约定，但我不知道如何在我的MassTransit uri中指定虚拟主机。
这个是可能的吗？如果是这样的话，我怎么做呢？
浏览 1提问于2013-07-25得票数 7
回答已采纳
我是使用消息代理的初学者。
我们有一个票务服务，它有多个子服务。主管服务在web的帮助下获得请求，并将它们发送到子服务。
任何请求都有一个标头，用于检测命令类型(如预订、退款、可用性等)。我们使用json来序列化对象。
现在，如何通过MassTransit将各种消息类型(不同的对象)从发布服务器(如我们的监管系统)发送，使用户可以轻松地使用它？
通常，是否可以在MassTransit和rabbitMQ中发送不同的消息类型？
每个使用者只有一个队列来处理接收到的消息。
谢谢
更新
https://dotnetcodr.com/2016/08/02/messaging-with-rabbi
浏览 3提问于2017-04-15得票数 6
回答已采纳
我试图从我的CloudAMQP应用程序中使用带有AppHarbor狐猴的Masstransit，但是我收到了例外情况：
“没有一个指定的端点是可到达的”
这是如何配置Masstransit的：
Bus.Initialize(sbc =>
{
sbc.UseRabbitMq();
sbc.UseRabbitMqRouting();
sbc.ReceiveFrom("rabbitmq://***
浏览 2提问于2012-10-26得票数 1
回答已采纳
我使用的是带有RabbitMq的MassTransit 3.0。我想知道我的队列是否为空，因为如果是，我需要从db中删除临时表。我不知道如何查看队列是否为空。
var inventoryBus = new InventoryBus(new RabbitServiceConfig());
inventoryBus.Instance.Start();
inventoryBus.Instance.ConnectConsumer<InventoryConsumer>();
==========消费者===============
public class InventoryConsumer
浏览 0提问于2016-11-26得票数 0
当RabbitMQ关闭时，默认情况下(我认为) Masstransit尝试无限连接，并得到“guest连接失败: Broker不可达:RabbitMQ@localhost:5672/”错误。 RabbitMQ一上线，Masstransit就开始工作了。有没有什么办法可以限制重试的次数？因此，Masstransit将停止重新尝试连接RabbitMQ。
浏览 16提问于2020-07-03得票数 2
回答已采纳
如果消息是从不同的消息发送源(本例中为MassTransit客户端)发送的，那么RabbitMQ如何从RabbitMQ中提取消息？
这些消息共享相同的C#消息契约，并作为json进行序列化。
我收到的当前错误是masstransit解析错误..。
浏览 4提问于2015-02-12得票数 5
我使用的是MassTransit 7.3.0和Autofac和RabbitMq。
到目前为止，我满足于所有服务使用每个服务的单个队列/端点。
我注册的消费者基本上是这样的：
builder.AddMassTransit(massTransit =>
{
mt.AddConsumers(consumerAssembly);
massTransit.UsingRabbitMq((ctx, cfg) =>
{
cfg.Host(config.HostName, "/", h =>
{
浏览 9提问于2022-05-14得票数 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
回答已采纳
我使用的是MassTransit和RaabbitMQ，当我试图发送消息时，我会得到以下错误：
rabbitmq://localhost/FilesVersioning => An exception was thrown during Send
at MassTransit.Transports.Endpoint.Send[T](ISendContext`1 context) in d:\BuildAgent-02\work\aa063b4295dfc097\src\MassTransit\Transports\Endpoint.cs:line 116
at MassTransit
浏览 1提问于2014-03-26得票数 0
回答已采纳
我正在为每个使用者实例寻找一种方法来接收通过RabbitMQ通过MassTransit发布的消息。情况是，我们有多个微服务，需要在通知时使缓存失效。Pub-Sub在这个实例中不起作用，因为每个服务实例将有5个与其代码相同类型的消费者，因此只有一个人会在传统的PubSub中接收消息。
消息观察可以是一种选择，但这意味着消息永远不会被消耗，并且永远停留在总线上。
有人能建议在MassTransit上下文中使用的模式吗？
提前谢谢。
浏览 2提问于2018-04-03得票数 4
回答已采纳
我创建了一个使用MassTransit和RabbitMQ进行通信的微服务应用程序。
每个微服务都是使用干净的体系结构开发的，因此我们在每个微服务中都有MediatR。
是否也可以使用MassTransit进行内部通信？因此，我可以对所有服务使用相同的签名，并且当我想公开要使用的服务时，它可以轻松地完成。因此，MediatR用于内部通信，RabbitMQ用于内部通信，整个宇宙都在MassTransit系统上.
我的问题是如何配置使用者，以便一些用户可以用于内部通信(通过)，还有一些可以用于外部通信(通过RabbitMQ)，并且很容易地将它们从内部更改为外部。
例如，Update2，这里是my M
浏览 13提问于2020-05-29得票数 8
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
云直播活动推荐
腾讯云开发者
