首页 > TAG信息列表 > MassTransit
基于MassTransit.RabbitMQ的延时消息队列
1 nuget包 <PackageReference Include="MassTransit.RabbitMQ" Version="8.0.2" /> 注意事项 本次使用的是docker来运行RabbitMQ 命令是： docker run -d -p 15672:15672 -p 5672:5672 -p 5671:5671 --hostname my-rabbitmq --name my-rabbitmq-container rabbitmq:3NetCore微服务实现事务一致性masstransit之saga使用
demo如下,一个订单处理的小例子: 首先看看结果很简单： 核心代码如下: using MassTransit; using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.Logging; using OrderProcessor.Event; using ServiceModel; using ServiceModel.Command; using ServiceAspNetCore&MassTransit Courier实现分布式事务
在之前的一篇博文中，CAP框架可以方便我们实现非实时、异步场景下的最终一致性，而有些用例总是无法避免的需要在实时、同步场景下进行，可以借助Saga事务来解决这一困扰。在一些博文和仓库中也搜寻到了.Net下实现Saga模式的解决方案MassTransit，这就省得自己再造轮子了。 分布式事务 分MassTransit中Request&Response基本使用
MassTransit 是一个自由、开源、轻量级的消息总线基于.Net框架, 用于创建分布式应用程序。方便搭建基于消息的松耦合异步通信的应用程序和服务。MassTransit 在现有消息传输上提供了一组广泛的功能, 从而使开发人员能够友好地使用基于消息的会话模式异步连接服务。基于消息的C#-Masstransit临时队列
我正在开发使用masstransit和Rabbitmq的客户端应用程序.在应用程序启动时,我正在创建具有唯一名称的新队列,以通过masstransit(请求/响应模型)与服务器应用程序进行通信.在关闭应用程序时,我应该删除此队列,但是如果客户端应用程序崩溃,rabbitmq上将出现队列. 是否可以通过masstranc#-具有Azure Service Bus的MassTransit 3创建队列
我正在将应用程序从使用MT3和RabbitMQ转换为使用Azure Service Bus,MassTransit在Azure中配置队列的方式与对RMQ的配置方式不同,并且文档内容比较淡(here)我想看看是否有人解决了这个问题 我将MT 3.4和Microsoft.ServiceBus 3.0用于TokenProvider,我有一个创建总线的实用程序类(此ec#-使用MassTransit重新传递RabbitMq消息时保留标头
目的：重新传递消息时,我需要跟踪标题. 组态： > RabbitMQ 3.7.9> Erlang 21.2>大众运输5.1.5> Quartz数据库的MySql 8.0 我尝试过的没有成功的事情： 第一次尝试： await context.Redeliver(TimeSpan.FromSeconds(5), (consumeCtx, sendCtx) => { if (consumeCtx.Headers.TryGetHeaderc# – MassTransit如何处理RabbitMQ下降
为了处理间歇性的RabbitMQ连接问题或RabbitMQ完全失效,将MassTransit配置为容错的正确方法是什么？我在两台不同的机器之间设置了一个RabbitMQ集群,并配置了HA,以便镜像所有内容.我还在主动/被动模式下设置了F5负载均衡器,以便将所有流量定向到主节点,但如果运行状况检查失败,则会故c# – 使用RabbitMQ的MassTransit – RecieveFrom的地址
我们在测试环境中配置了RabbitMQ的主动/主动群集. 我们使用指定ReceiveFrom的MassTransit进行连接(“rabbitmq：// cluster_machine_a / some_queue？ha = true”). 显然,这是利用特定的集群节点,因此不提供故障转移. 通知MassTransit有关群集节点的正确方法是什么,以便发生故障转移？ Rac# – 在没有管理权限策略的情况下,是否可以将MassTransit 3与Azure Service Bus一起使用？
我花了几天时间测试MassTransit 3.1.2,看看我们是否可以在我们的应用程序中使用Azure Service Bus. 我使用MassTransit.AzureServiceBus(3.1.2)为两个控制台应用程序做了一个示例：一个发布者和一个suscriber. 它运作良好.当我启动应用程序时,Azure上的命名空间上会自动创建实体(队列c# – 带有SQL Server数据库传输的MassTransit
对于我的客户,我们正在调查MassTransit的使用. MassTransit似乎主要围绕RabbitMQ进行消息传输.由于客户端的“内部结构限制”,我们坚持使用SQL Server数据库作为任何持久性. MassTransport如何与SQL Server一起用作消息的传输机制？解决方法:SQL Server不是传输,它只存储消息.没有经c# – 一段时间后在RabbitMQ中获取OutOfMemory
我使用RabbitMQ与C#,MassTransit,Autofac. 我有一个预定的(5秒)工作来消耗队列. 这项工作大约2个小时,然后突然停止.当我搜索日志时,我发现了这个： Scope —> An exception occurred during bus creation (See inner exception for det ails.) —> MassTransit.ConfigurationExc# – 单元测试使用异步调用的MassTransit消费者
我们正在使用MassTransit异步消息传递(在RabbitMQ之上)来实现我们的微服务架构. 我们遇到了测试消费者的问题,而这些消费者又会进 下面的示例显示了一个简单的MassTransit使用者,它使用RestSharp进行出站调用并使用ExecuteAsync异步方法. public class VerifyPhoneNumberConsumerc# – MassTransit：添加标题以发布管道
我正在使用MassTransit 3.2.4,我正在尝试为我发布的消息添加一些标题信息,但设置标题的代码似乎永远不会运行.我不确定为什么这不起作用. var bus = Bus.Factory.CreateUsingRabbitMq(config => { var host = config.Host(new Uri("rabbitmq://localhost/"), h {}); confic# – MassTransit – 更新客户端消息
我没有太多使用MSMQ的经验,有人建议我看看MassTransit来帮助实现解决方案,但我很难弄清楚使用MassTransit MSMQ是否适合这项工作. 我们有一个由多个用户使用的WPF应用程序(3.5).持久性是从应用程序(通过NHibernate)到数据库完成的.到目前为止,用户会定期刷新视图,以确保他们拥有最c# – 如果没有订阅者,RabbitMQ消息会保持多长时间？
我正在使用MassTransit和RabbitMQ创建一个简单的发布者/订阅者.Publisher具有以下代码来初始化总线： /** create the bus */ var bus = Bus.Factory.CreateUsingRabbitMq(cfg => { var host = cfg.Host(new Uri("rabbitmq://localhost/"), h => { h.Username("guesc# – MassTransit和Simple Injector
我正在审查MassTransit Distributed Application Framework for .NET.根据网站MassTransit has been built from the beginning with the concept of an IoC container being involved,并为少数更“主流”的IoC容器提供支持库.有(目前)NuGet包可用于Autofac,StructureMap,Castle Wi