NServiceBus 处理（接收）一条 Msmq 消息并使用 CastleWindsor 发送到 AzureStorageQueue答案

【问题标题】：NServiceBus handle (receive) a Msmq message and send to a AzureStorageQueue using CastleWindsorNServiceBus 处理（接收）一条 Msmq 消息并使用 CastleWindsor 发送到 AzureStorageQueue
【发布时间】：2014-08-20 15:06:04
【问题描述】：

是否可以有一个端点通过 Msmq 传输处理消息，然后作为处理程序的一部分，然后使用 AzureStorageQueue 传输发送。

我的设置是一个本地端点，它通过 msmq 处理“通知”消息。我的处理程序从数据库中检索一些信息，然后我想将此数据发送到 AzureStorageQueue。

我的 EndpointConfig.cs 看起来像这样：

public class EndpointConfig : IConfigureThisEndpoint, AsA_Server, IWantCustomInitialization
{
    private IWindsorContainer container;

    public void Init()
    {
        this.InitialiseContainer();

        Configure.With()
                 .Log4Net()
                 .CastleWindsorBuilder(this.container)
                 .UseTransport<Msmq>()
                 .PurgeOnStartup(false)
                 .UnicastBus();
    }

    private void InitialiseContainer()
    {
        this.container = new WindsorContainer();
        this.container.Install(FromAssembly.Named("Notifications"));
        this.container.Register(Component.For<IWindsorContainer>()
                                         .Instance(this.container));
    }
}

我的处理程序如下所示：

public class NotificationHandler : IHandleMessages<NotificationV1>
{
    private readonly IWindsorContainer container;

    public NotificationHandler(IWindsorContainer container)
    {
        this.container = container;
    }

    public void Handle(NotificationV1 message)
    {
        if (message != null && message.CorrelationId != Guid.Empty)
        {
            var thingToPublish = new DataAccess.GetThingToPublish(message.Id);

            var publishMessage = new PublishV1
                {
                    CorrelationId = message.CorrelationId,
                    Timestamp = message.Timestamp,
                    Id = message.Id,
                    ThingToPublish = thingToPublish
                };

            // Here I intend to resolve the AzureStorageBus Queue and send the publishMessage to it
            var bus = this.container.Resolve<IBus>(); //Not I know this bit is wrong as it is sending it to the Msmq
            bus.Send("PublishQueue", publishMessage);
        }
    }
}

我的 app.config 中的一些 sn-ps 如下

<configSections>
    <section name="AzureQueueConfig" type="NServiceBus.Config.AzureQueueConfig, NServiceBus.Azure.Transports.WindowsAzureStorageQueues" />
    <section name="MessageForwardingInCaseOfFaultConfig" type="NServiceBus.Config.MessageForwardingInCaseOfFaultConfig, NServiceBus.Core" />
    <section name="TransportConfig" type="NServiceBus.Config.TransportConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
    <section name="AuditConfig" type="NServiceBus.Config.AuditConfig, NServiceBus.Core" />
</configSections>

<UnicastBusConfig>
    <MessageEndpointMappings>
        <add Messages="Messages.NotificationV1, Messages" Endpoint="notification.endpoint" />
    </MessageEndpointMappings>
</UnicastBusConfig>

<AuditConfig QueueName="Notifications.Audit" />

<AzureQueueConfig QueueName="PublishQueue" ConnectionString="UseDevelopmentStorage=true" />

总之： 1. 是否可以处理来自msmq 的消息，然后向AzureStorageQueue 发送消息？ 2. 如果是，我该怎么做？

谢谢丹

【问题讨论】：

标签： castle-windsor msmq nservicebus azure-storage-queues

【解决方案1】：

NServicebus 目前不支持多种传输，因此从 msmq 接收的端点也必须发送到 msmq。但是，如果您稍微尝试一下内部结构，则可以创建从一种传输类型到另一种传输类型的桥梁。不久前，我为使用 msmq 和 azure servicebus 的 poc 执行了此操作，您可以对 azure storage 执行相同操作。见https://github.com/yvesgoeleven/NServiceBus.MsmqAsbBridge

【讨论】：

【解决方案2】：

扩展并回答我是如何解决这个问题的：

使用 NServiceBus 的本地服务处理消息，
丰富了一些数据，然后需要将消息添加到 azure 中的队列中。
为了将消息发送到 azure 托管队列，我创建了一个 API，然后托管在 azure 中
本地服务/消息处理程序将消息发布到 api。
然后 api 使用 NServiceBus 将消息添加到队列中。

这种使用网桥的方法是许多其他人必须采取的措施才能解决此问题。

【讨论】：