标签: nservicebus

我正在尝试为NServiceBus创建新的3.0二进制文件,但它们似乎在包管理器中不可用.

是否有转换强制nuget获取最新版本？

我在MVC4应用程序中运行NSB 3.2.8自托管,这是我的配置:

Configure.With()
.DefiningMessagesAs(t => t.Namespace != null && namespaces.Contains(t.Namespace))
.CastleWindsorBuilder(container)
.XmlSerializer()
.Log4Net()
.MsmqTransport()
    .IsTransactional(true)
    .IsolationLevel(IsolationLevel.ReadUncommitted)
    .PurgeOnStartup(false)                  
.UnicastBus()
.ImpersonateSender(false)
.CreateBus()
.Start();

我可以IBus在我的控制器中添加一个依赖项并将消息发送到队列中,Bus.SendLocal()但是没有从中读取队列,并且没有创建log4net日志文件.

我有一个有趣的用例,其中某些异常类型意味着"此消息不再有效且应该被忽略"但是此代码没有任何意识,Bus以便调用Bus.DoNotContinueDispatchingCurrentMessageToHandlers().

我讨厌像每个消息处理程序中都需要的try/catch块这样的样板代码.所以我开始实现一个UnitOfWork来处理和吞下异常,但我找不到告诉框架的方法"是的,这个代码生成了一个异常,但忘记了这一点,只是完成了事务."

Bus.DoNotContinueDispatchingCurrentMessageToHandlers()不起作用.我尝试过ITransport注入和调用,AbortHandlingCurrentMessage()但这导致整个宇宙爆炸.即使单步执行源代码,我似乎也不知所措.

请注意,很可能这是一个可怕的想法,因为假设实际上存在异常情况时没有异常将导致事务提交,从而导致谁知道有多少不良的未知副作用.因此,最好有一个方法仍然回滚事务但丢弃该消息.但我会对潜在的"是的我知道我在做什么,提交交易而不管异常"选项感兴趣.

我刚刚开始学习NServicebus(和一般的SOA)并且有一些问题和要点我需要澄清解决方案通常是如何构建的和常见的最佳实践:

1. 该文档并未真正解释端点是什么.从我收集的内容来看,它是一个部署单元,您的服务将有一个或多个端点.它是否正确？

2. 您正在开发的每个服务都有一个VS解决方案被认为是最佳做法吗？使用消息项目,然后是每个端点的项目,最后是与包含域层的端点共享的项目？

3. 根据我的阅读,服务通常由单个组件组成.可以(或应该)服务中的任何组件访问同一个数据库,还是应该是每个组件一个数据库？

感谢您提供的任何澄清或见解.

我使用NServiceBus,使用Azure Service Bus作为传输.每次发送邮件时,我都会在日志中看到以下内容:

Checking existence cache for '...'
Checking namespace for existance of the queue '...'
Determined that the queue '...' exists
Queue '...' already exists, skipping creation

尽管日志中有噪音(我可以过滤掉这些消息,但除此之外),我担心每次检查的开销.如何配置NServiceBus以期望这些命名空间和队列存在并停止检查每条消息？

我正在使用ASP.NET MVC应用程序将消息发送到另一台机器上的nServiceBus主机.我正在使用

Bus.CreateSendOnly(busConfiguration);

过度

Bus.Create(busConfiguration);

因为SendOnly配置似乎更接近我期望的功能.

除了稍微提高代码可读性之外,进行此更改是否有任何优势？nServiceBus依赖注入行为是否不同,提高性能等？

我有一个 NServiceBus 主机，它订阅了某个事件并有自己的处理程序（#1）。该主机还引用了一个程序集，该程序集包含同一事件的另一个处理程序 (#2)。我想从 NServiceBus 配置中排除处理程序 #2，但我无法删除引用的程序集。

重要：

1）我尝试使用此设置扫描：http : //docs.particular.net/nservicebus/hosting/assembly-scanning

2) 我使用 NServiceBus 版本 3.x

我有Endpoint一个Handle方法.我想在之前和之后立即采取措施Handle.通过改变,我之前能够完成这个步骤LogCommandEntryBehavior : Behavior<IIncomingLogicalMessageContext>.紧接着需要实施什么Handle？

在一个文档中，他们说 IHandleMessages 处理程序必须以这种方式编写（当我在 Visual Studio 中选择“实现接口”选项时会自动生成签名）：

public class PlaceOrderHandler : IHandleMessages<PlaceOrder>
{
    public Task Handle(PlaceOrder message, IMessageHandlerContext context)
    {
        var orderPlaced = new OrderPlaced { OrderId = message.OrderId };

        return context.Publish(orderPlaced);
    }
}

而另一个文档说它必须这样写：

public class PlaceOrderHandler : IHandleMessages<PlaceOrder>
{
    public async Task Handle(PlaceOrder message, IMessageHandlerContext context)
    {
        var orderPlaced = new OrderPlaced { OrderId = message.OrderId };

        await context.Publish<OrderPlaced>(e => { e.OrderId = message.OrderId; });

    }
}

我想知道这两个陈述有什么区别，有人可以用简单的语言解释一下吗？

哪个选项是正确的？

我当前项目中有一个要求,我需要实现NService总线调度程序.由于我是Nservice总线调度程序实现的新手,请举手,如果有任何人对此有所了解,请分享您对任何有用链接的想法也会有所帮助.

提前致谢

VIMAL