小编ale*_*dev的帖子

NServiceBus传奇设计问题

我在使用NServiceBus saga时遇到"乐观并发冲突"异常.

我的传奇涵盖了一个相对简单的流程:当任何消息到达时,它几乎没有外部请求,并在一段时间后收集回复.

下面你可以找到我的传奇的一个例子.

NServiceBus为此类流产生"乐观并发冲突"异常是否正常?

我应该考虑以某种方式重新设计传奇吗?

class MySaga: SqlSaga<SagaData>, ...
{
    CorrelationPropertyName => nameof(SagaData.UserId);

    public Task Handle(StartSagaMessage message, IMessageHandlerContext context)
    {
        // save a new item id
        Data.Items.Add(message.ItemId);

        // make an external request for the item title
        context.Send<GetItemTitle>(message.ItemId);
        // make an external request for the item description
        context.Send<GetItemDescription>(message.ItemId);

        // gather results after one hour
        RequestTimeout<RequestTimeout>(TimeSpan.FromHours(1));
    }

    // this method sometimes raises "optimistic concurrency violation" exception
    public Task Handle(GetItemTitleResponse message, IMessageHandlerContext context)
    {
        Data.ItemTitles[message.ItemId] = message.ItemTitle;
    }

    // this method sometimes …
Run Code Online (Sandbox Code Playgroud)

c# persistence nservicebus saga nservicebus-sagas

3
推荐指数
1
解决办法
332
查看次数

标签 统计

c# ×1

nservicebus ×1

nservicebus-sagas ×1

persistence ×1

saga ×1