本地NServicebus应用程序从Azure ServiceBus队列接收消息

Question

我目前正努力在nServiceBus托管的应用程序上启动并运行一些东西。我有一个第三方正在向其发布消息的azure ServiceBus队列，我希望我的应用程序（目前在本地托管）接收这些消息。

我在谷歌上搜索了如何配置endpoint的答案，但我在有效的配置中没有运气。有人这样做过吗，因为我可以找到如何连接到Azure存储队列但不是服务总线队列的示例。（由于其他原因，我需要Azure servicebus队列）

我的配置如下所示

public void Init()
    {
        Configure.With()
           .DefaultBuilder()
           .XmlSerializer()
           .UnicastBus()
           .AzureServiceBusMessageQueue()
           .IsTransactional(true)
           .MessageForwardingInCaseOfFault()
           .UseInMemoryTimeoutPersister()
           .InMemorySubscriptionStorage();
    }

.Message=启动endpoint时出现异常，已记录错误。原因：输入队列[mytimeoutmanager@sb://[*].服务总线。窗户。net/]必须与此Source=NServiceBus位于同一台计算机上。主办

.

<configuration>
  <configSections>
    <section name="MessageForwardingInCaseOfFaultConfig" type="NServiceBus.Config.MessageForwardingInCaseOfFaultConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
    <section name="AzureServiceBusQueueConfig" type="NServiceBus.Config.AzureServiceBusQueueConfig, NServiceBus.Azure" />
    <section name="AzureTimeoutPersisterConfig" type="NServiceBus.Timeout.Hosting.Azure.AzureTimeoutPersisterConfig, NServiceBus.Timeout.Hosting.Azure" />
  </configSections>
  <AzureServiceBusQueueConfig IssuerName="owner" QueueName="testqueue" IssuerKey="[KEY]" ServiceNamespace="[NS]" />
  <MessageForwardingInCaseOfFaultConfig ErrorQueue="error" />
  <!-- Use the following line to explicitly set the Timeout manager address -->
  <UnicastBusConfig TimeoutManagerAddress="MyTimeoutManager" />
  <!-- Use the following line to explicity set the Timeout persisters connectionstring -->
  <AzureTimeoutPersisterConfig ConnectionString="UseDevelopmentStorage=true" />
  <startup useLegacyV2RuntimeActivationPolicy="true">
    <supportedruntime version="v4.0" />
    <requiredruntime version="v4.0.20506" />
    <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0" />
  </startup>
</configuration>

Answer 1

我现在也遇到了同样的问题，花了几个小时想办法解决它。基本上，Azure超时持久器仅支持使用NServiceBus的Azure托管endpoint。群众或部队的集合。蔚蓝色的如果您使用NServiceBus。宿主进程要宿主endpoint，它使用NServiceBus。超时。群众或部队的集合。Windows命名空间类。它用MSMQ初始化了一个TransactionalTransport，然后您就得到了这条消息。

我用了两种方法来避免它：

1. 如果必须使用As_服务器endpoint配置，则可以使用。DisableTimeoutManager（）在初始化中，它将完全跳过TimeoutDispatcher初始化

可能有一种方法可以以某种方式注入Azure timeout manager，但我还没有找到它，实际上我需要作为客户端的东西，所以它对我来说很好。

Answer 2

尝试移动UnicastBus（）到呼叫结束，如下所示：

    Configure.With()
       .DefaultBuilder()
       .XmlSerializer()
       .AzureServiceBusMessageQueue()
       .IsTransactional(true)
       .MessageForwardingInCaseOfFault()
       .UseInMemoryTimeoutPersister()
       .InMemorySubscriptionStorage()
       .UnicastBus(); // <- Here

以及那些向队列中发送消息的第三方。请记住，他们需要尊重NServiceBus处理序列化/反序列化的方式。以下是如何在NServiceBus中完成此操作（最重要的部分是使用原始消息初始化BrokeredMessage，这是使用BinaryFormatter进行序列化的结果）：

    private void Send(Byte[] rawMessage, QueueClient sender)
    {
        var numRetries = 0;
        var sent = false;

        while(!sent)
        {
            try
            {
                var brokeredMessage = new BrokeredMessage(rawMessage);

                sender.Send(brokeredMessage);

                sent = true;
            }
                // back off when we're being throttled
            catch (ServerBusyException)
            {
                numRetries++;

                if (numRetries >= MaxDeliveryCount) throw;

                Thread.Sleep(TimeSpan.FromSeconds(numRetries * DefaultBackoffTimeInSeconds));
            }
        }

    }

    private static byte[] SerializeMessage(TransportMessage message)
    {
        if (message.Headers == null)
            message.Headers = new Dictionary<string, string>();

        if (!message.Headers.ContainsKey(Idforcorrelation))
            message.Headers.Add(Idforcorrelation, null);

        if (String.IsNullOrEmpty(message.Headers[Idforcorrelation]))
            message.Headers[Idforcorrelation] = message.IdForCorrelation;

        using (var stream = new MemoryStream())
        {
            var formatter = new BinaryFormatter();
            formatter.Serialize(stream, message);
            return stream.ToArray();
        }
    }

如果您希望NServiceBus正确地反序列化消息，请确保您的用户正确地序列化它。