目前,计算工作正常但如果计算花费的时间超过一分钟左右,则消息在完成后不会从队列中删除.在worker角色中,我们通过增加“AutoRenewTimeout”来解决这个问题.

var options = new OnMessageOptions { AutoComplete = true,AutoRenewTimeout = TimeSpan.FromMinutes(3) };
        _queueClient.OnMessage(OnMessage,options);

但是,使用“ServiceFabric.ServiceBus” nuget包,我无法确定你设置它的位置.我使用demo project作为参考来设置实际运行计算的无状态服务.以下是CalculateService.cs的摘录,其中初始化了无状态服务.

internal sealed class CalculateService : StatelessService
{
    public CalculateService(StatelessServiceContext context)
        : base(context)
    { }

    /// <summary>
    /// Optional override to create listeners (e.g.,TCP,HTTP) for this service replica to handle client or user requests.
    /// </summary>
    /// <returns>A collection of listeners.</returns>
    protected override IEnumerable<ServiceInstanceListener> CreateServiceInstanceListeners()
    {
        string serviceBusQueueName = CloudConfigurationManager.GetSetting("QueueName");
        yield return new ServiceInstanceListener(context => new ServiceBusQueueCommunicationListener(new Handler(this),context,serviceBusQueueName),"StatelessService-ServiceBusQueueListener");
    }
}


internal sealed class Handler : AutoCompleteServiceBusMessageReceiver
{
    protected override Task ReceiveMessageImplAsync(BrokeredMessage message,CancellationToken cancellationToken)
    {
        ServiceEventSource.Current.ServiceMessage(_service,$"Handling queue message {message.MessageId}");
        var computeRole = new ExcelCompute();
        var rMessage = new RangeMessage();
        rMessage = message.GetBody<RangeMessage>();
        var result = computeRole.OnMessage(rMessage,message.MessageId); //returns true if the compute was successful (which it currently,always is)
        return Task.FromResult(result);
    }
 }

我确实尝试使用< BrokeredMessage> message.Complete();但这是一个消息锁定错误.