QueueClient.OnMessage在员工角色启动期间抛出StackOverflowException

Question

我正在尝试部署我的第一个Azure工作者角色，当在服务启动期间调用Run()方法时，我遇到了这个错误。

“System.StackOverflowException”类型的未处理异常发生在未知模块中。

我尝试远程调试我的代码，并在这一行抛出错误。MyPublisher类似于MyQueue，但它封装了主题而不是队列。知道为什么QueueClient.OnMessage会导致StackOverflow吗？

Client.OnMessage(messageHandler，options)；

这是部分代码。如果没有正确格式化(将尝试格式化)或代码中缺少任何内容，我的道歉。

public class MyQueue
{
    String QueueName;
    public QueueClient Client { get; protected set; }

    public MyQueue(String queueName)
    {
        Trace.WriteLine($"Creating service Queue with name : {queueName} ");
        QueueName = queueName;
    }

    public void EstableshConnection(string connectionString = null)
    {
        Trace.WriteLine($"Establishing connection with service Queue : {QueueName} ");
        // Set the maximum number of concurrent connections 
        ServicePointManager.DefaultConnectionLimit = 12;

        connectionString = connectionString ?? CloudConfigurationManager.GetSetting("Microsoft.ServiceBus.ConnectionString");
        NamespaceManager namespaceManager = NamespaceManager.CreateFromConnectionString(connectionString);
        if (!namespaceManager.QueueExists(QueueName))
            namespaceManager.CreateQueue(QueueName);

        Client = QueueClient.CreateFromConnectionString(connectionString, QueueName);
    }

    public void Send(BrokeredMessage message)
    {
        Trace.WriteLine($"Sending brokered message to queue : {QueueName} ");
        if (Client != null && !Client.IsClosed)
            Client.Send(message);
    }

    public void OnMessage(Action<BrokeredMessage> messageHandler)
    {
        Trace.WriteLine($"OnMessage handler: Queue Name : {QueueName} ");
        OnMessageOptions options = new OnMessageOptions();
        options.AutoComplete = true; // Indicates if the message-pump should call complete on messages after the callback has completed processing.
        options.MaxConcurrentCalls = 1; // Indicates the maximum number of concurrent calls to the callback the pump should initiate 
        options.ExceptionReceived += LogErrors; // Allows users to get notified of any errors encountered by the message pump

//=====================StackOverFlowException on Client.OnMessage======
        if (Client != null && !Client.IsClosed)
            Client.OnMessage(messageHandler, options);  //This is where I get StackOverflowException Error. 
    }

    private void LogErrors(object sender, ExceptionReceivedEventArgs e)
    {
        if (e.Exception != null)
            Trace.WriteLine("Queue client processing error: " + e.Exception.Message);
    }

    public void Disconnect()
    {
        Trace.WriteLine($"closing queue {QueueName}");
        Client.Close();
    }
}

这是我的工作角色实现。

public class MyWorkerRole : RoleEntryPoint
{
    #region Variables
    ManualResetEvent CompletedEvent = new ManualResetEvent(false);

    MyQueue RequestQueue;           //for Request
    MyPublisher ResponseTopicClient;    //ReponseTopic to notify Subscriber when processing is completed

    Public MyWorkerRole()
    {
        RequestQueue = new MyQueue("JobRequestQueue");
        ResponseTopicClient = new MyPublisher("JobCompletedTopic");
    }


    public override bool OnStart()
    {
        try
        {
            RequestQueue.EstableshConnection();
            ResponseTopicClient.EstableshConnection();
        }
        catch (Exception ex)
        {
            Trace.TraceWarning($"Trace: starting service failed. Error {ex.Message} ");
        }
        return base.OnStart();
    }

    public override void OnStop()
    {
        try
        {
            RequestQueue.Disconnect();
            ResponseTopicClient.Disconnect();
            CompletedEvent.Set();
        }
        catch (Exception ex)
        {
            Trace.TraceWarning($"Trace: stopping service failed with error. {ex.Message} ");
        }
        base.OnStop();
    }

    public override void Run()
    {
        try
        {
            Trace.WriteLine("Trace: Starting Message Processing");

            //var receivedMessage2 = RequestQueue.Client.Receive(new TimeSpan(hours: 0, minutes: 2, seconds: 0));
            RequestQueue.OnMessage((receivedMessage) =>
            {
                try
                {
                    Guid resultGuid = (Guid)receivedMessage.Properties["CorrelationGuid"];
                    Trace.TraceWarning($"Trace: processing message with GUID {resultGuid}");

                    var messageToSend = JobProcessor.ProcessRequest(receivedMessage);
                    if (messageToSend == null)
                    {
                        Trace.TraceError("Trace: > Broken message!");
                        receivedMessage.Abandon();
                        return;
                    }
                    ResponseTopicClient.Send(messageToSend);
                    receivedMessage.Complete();
                }
                catch (Exception ex)
                {
                    Trace.TraceError("Trace: Processing exception: " + ex.Message + "\nStack Trace" + ex.StackTrace);
                    Logger.Error("Processing exception: " + ex.Message + "\nStack Trace" + ex.StackTrace);
                }
            });
            CompletedEvent.WaitOne();
        }
        catch (Exception ex)
        {
            Trace.TraceError("Trace: Run exception: " + ex.Message + "\nStack Trace" + ex.StackTrace);
        }
        finally
        {
            CompletedEvent.Set();
        }
    }
}

Answer 1

弄明白了。所以，问题不在于代码。在我的存储帐户下的WADWindowsEventLogsTable中报告了以下错误。

故障应用程序名称: WaWorkerHost.exe，版本: 2.7.1198.768，时间戳: 0x57159090故障模块名称: Microsoft.IntelliTrace.Profiler.SC.dll，版本: 15.0.27128.1，时间戳: 0x5a1e2eb9异常代码: 0xc00000fd故障偏移量:0x000000000000008ae7b故障处理进程id: 0xcf4故障应用程序启动时间:0x01dd3b75ed89dc2f9故障应用程序路径: F:\base\x64\WaWorkerHost.exe故障处理模块路径:F：\base\x64\WaWorkerHost.exe故障处理模块路径

这给了我一个关于禁用IntelliTrace的提示，它运行得很好。下面是在发布软件包时禁用VS 2017的方法。

1.)右键单击“员工角色”项目并选择“从菜单中发布”。 2.)在“设置”页->“高级设置”中，取消选中“启用IntelliTrace”选项。

Answer 2

当您的工作人员启动时，它将调用Run方法，并且在您的代码中有：

 //var receivedMessage2 = RequestQueue.Client.Receive(new TimeSpan(hours: 0, minutes: 2, seconds: 0));

RequestQueue.OnMessage((receivedMessage) => )

因此，代码不会等待一条新消息，因为第一行是注释的，它调用OnMessage方法，该方法一次又一次递归地调用自己，直到触发StackOverflowException

在所有情况下，您都需要更改实现，因为当接收到新消息时，无论如何都会发生StackOverflowException。