saga相关内容
我有一个MassTransport Saga,可以很好地处理已为其配置了Saga的Bus(Azure Service Bus)上下文中的事件、活动等。 在其中一种状态下,我需要将消息发送到另一条不同的总线(另一条Azure服务总线)。这在使用MultiBus时工作得很好。但是,在下一步中,我希望从该单独的总线接收主题消息并对其做出反应。 在MassTransport Saga中支持自动
..
为了使传奇代码保持简单,我创建了在触发传奇事件时执行的活动.现在,我想使用MT的测试工具为传奇创建测试.我还需要模拟这些活动的依赖关系.在MT 7.0.2中如何做到这一点? 这个问题类似于在这里找到的一个问题:如何使用MassTransit测试工具进行测试使用构造函数依赖注入的消费者吗? 下面是一些伪代码来举例说明我的用例: 公共类SomeSaga:MassTransitStateM
..
我们正在使用具有自动别名功能的Masstransit和InMemoryRepository来实现传奇持久性.我们大约配置了3个状态机,并且工作正常.我们最近从InMemoryRepository更改为EFCore以实现持久性.这导致只有第一个配置的状态机才能正常运行.休息所有状态机甚至都没有进入Initially事件.需要帮助以了解实施是否正确.以下是代码详细信息: masstransit状
..
在使用nservicebus实现工作流程过程中,我遇到了一个问题,我使用版本2.0.1329.2,而我要实现的工作流程非常简单: 我有一个需要计算的文章列表,工作流程从发布的第一个列表开始.之后,用户可以进行其他发布,从原始列表中添加或删除某些文章.每个列表都有一个代码标识符. 我已经使用列表代码标识的编排服务实现了它.在传奇数据中,还列出了构成列表的所有文章参考. 问题是:当用
..
我对Axon Saga有疑问.我有一个项目,其中有三个微服务,每个微服务都有自己的数据库,但是两个“从"微服务必须将其数据共享给“主"微服务,因此我想使用Axon Saga.我已经问过有关补偿的问题,当出现问题时,我必须自己处理补偿,这是可以的,但并不理想.当前,我正在使用DistributedCommandBus在微服务之间进行通信,这是否有益?我正在使用Choreography Saga模型,
..
我已经写了一个事件源聚合,现在实现了一个事件源Saga ...我注意到两者都是相似的,并创建了一个事件源对象作为派生两者的基类. 我在这里看到了一个演示 http ://blog.jonathanoliver.com/cqrs-sagas-with-event-sourcing-part-ii-of-ii/,但可能会出现问题,因为如果发生进程崩溃,命令可能会丢失因为命令的发送不在写事务之外?
..
我试图理解传奇,同时我对它们有一种特殊的思考方式-但我不确定我是否正确。因此,我想详细说明,并让其他人告诉我它是对还是错。 据我所知,sagas是如何解决问题的一种解决方案。为长期运行的流程建模。长期运行意味着:涉及多个命令,多个事件以及可能的多个聚合。 基本上,一个传奇只不过是一个响应的命令/事件处理程序而已在内部和外部命令/事件上。它不包含自己的逻辑,它只是一个(有限的)状态机,因
..
我有2个微服务S1和S2. S1调用S2来更新数据,然后S1插入另一个数据,但是让我们考虑S1失败,然后我们需要回滚S2更新的数据,否则我们将处于不一致状态. 我也经历了Saga模式,它将满足这种矛盾之处 有人可以为此提出任何更好的解决方案吗? 解决方案 在大多数情况下,分布式事务都存在问题,并且对服务不利 服务边界–服务边界是信任边界.原子 交易需要持有锁并代表他们持有
..
Jimmy Boagard在此处 a>将其与分散收集模式进行比较. 从上述文章中窃取的工作流图像: 初步实施思路: 为所有食品站将获得的所有FoodOrdered事件类型具有一个公共界面,然后每个食品站将能够消费/创建其各自的项目并发布一个公共完成的事件.例如:炸薯条和汉堡站收到有关炸薯条订单的消息,炸薯条站消费该订单,以宣布传奇故事正在侦听的ItemDoneEvent. 初始问
..
我正在尝试连接我的第一个Saga,并且无法让接收端点正确处理启动消息。我得到以下异常: SagaMessageHandler处理 消息失败。 Spring.Objects.Factory.UnsatisfiedDependencyException: 创建名为$ b的对象时出错$ b'NServiceBus.Sagas.Impl.SagaMessageHandler' :不满意的依赖
..
我使用NServiceBus为企业服务总线,在解决方案中我发展我有所有客户端应用程序接收多达10K消息的业务流程服务。我想提高性能架构,从而提升解决方案提供。 我使用的是佐贺数据类,我想与大家分享所有工作线程之间的访问它(到现在我仅有一个线程,但我想设置至少到10),当多个线程试图访问同一传奇istance会发生什么?是否已经NSB提供这样的并发功能?我一定要实现它在我自己的?如果后者的任何
..