目前我使用WCF作为服务总线。但我想换一种功能更强大的服务总线。我选择了雷布斯。我对雷布斯有点陌生。我有一些问题:
1)我的数据被保存在一个DB表中。我希望发布者每n秒读取所有持久化数据并将其发布给订阅者，然后在DB中设置发送标志。是否有出版的时间?读取、发布和更改(设置标志)数据必须在事务范围内完成。在Rebus中有定义的解决方案吗?
2)在Consumer中，我想将发布的数据保存在某个表中。从消息队列中读取消息并保存在DB中(在我的处理程序中)必须在事务范围内完成。雷布斯是怎么做到的?
3)发布消息的消息标签设置为随机唯一字符串。我想为创建的MSMQ消息设置自定义标签。有解决办法吗?
1)当涉及到定期查询数据库表时，您可以自己操作-在Rebus中没有内置机制可以做到这一点。
我可以建议你看看System.Timers.Timer或类似的东西。
2)您可以使用Rebus.TransactionScopes包在Rebus处理程序中启用自动事务作用域。
3)开箱即用，不可能指定在MSMQ消息上使用的标签。它将由Rebus设置为由此扩展方法所指示的消息类型和ID组成的字符串。