SqlConnection 并避免升级到 MSDTC
当我们需要在我们的应用程序中进行数据库访问时，我们使用以下模式: 为了查询，我们有一个带有方法 CreateOpenConnection 的静态工厂类，它只执行 new SqlConnection(myConnectionString) 并调用 Open()代码>就可以了.在我们执行查询之前调用此方法，并在查询返回后处理连接. 对于插入/更新/删除，我们使用工作单元模式，其中更改被批处理并
..
rebus相关内容
Rebus，从异步处理程序创建 AppDomain/实例时出现异常
我们对旧版本不存在的新(异步)版本的 Rebus 存在问题. 在处理 rebus 消息并尝试创建 AppDomain 和 Instance 以动态运行插件代码时，它总是给我一个异常.为了让例子尽可能简单，我做了一个测试方法: public static void Test(){AppDomain ad = AppDomain.CreateDomain("Test");Loader load
..
暂停工作人员从队列中获取消息
我一直在尝试找出是否有任何方法可以使工人暂停从Rebus队列中获取更多工作/消息？我希望能够通过GUI“禁用”一个工作人员，以便它完成当前正在处理的工作（如果有），然后停止执行更多工作。 然后，如果我希望它再次开始接受工作，则通过gui发出信号。 我为Rebus工作的设置如下： 私人无效SetupRebus（int numberOfWorkers，字符串messageName） {
..
重用：2个进程中的2个处理程序。前后交替打
我有两个使用Rebus的控制台应用程序。它们都引用定义消息（命令和事件）的程序集。 控制台应用程序“ A”发送命令并监听事件以进行记录（例如：发送CreateTCommand并监听TCreatedEvent）。控制台应用程序“ B”（实际上是ASP.NET Core应用程序）侦听命令并进行处理（例如：由CreateTCommand发起传奇，创建聚合并引发TCreatedEvent）。在应用程序“
..
Rebus，从异步处理程序创建AppDomain/实例时发生异常
我们遇到了Rebus的新(异步)版本的问题，而旧版本则不存在. 当处理重传消息并尝试创建AppDomain和Instance来动态运行插件代码时，它总是给我一个例外. 为了使示例尽可能简单，我制作了一个Test方法: public static void Test() { AppDomain ad = AppDomain.CreateDomain("Test"); Lo
..
重用和远程队列
我正在使用Rebus( https://github.com/rebus-org (v. 0.83))，直到现在，它都只在一台机器上本地运行.现在，我需要使用从我的网站到应用程序服务器的远程队列.我还不太清楚如何使用Rebus进行设置.几个问题 我猜我需要两台计算机(Web和应用程序)上的MSMQ正确吗?我已经将该网站配置为UseMsmqInOneWayClientMode； 还是有一种方
..
如何将Rebus配置为具有基于处理程序类型的主题
我正在使用Rebus，我想介绍 CQRS旅程中所述的内容在"避免多次处理事件"中，但我无法弄清楚. 我将Rebus配置为将SQL Server用于 Transport ，将MongoDB用于 Subscriptions 和 Sagas . 路由配置为 TypeBased ，并将所有命令处理程序的类型映射到 Transport 中配置的队列. var bus = Configure.W
..
我应该如何为一个生产商和许多消费者设置重新营销
我正在浏览示例并阅读文档，但是我仍然不确定如何为我的场景配置rebus(或者使用总线很合适). 我有一个Tasks的生产者可以做，比如说ImportOrder和CalculateOrderPrice 我想转储来自生产者的消息并将这些消息排入队列. 我想要两个侦听ImportOrder的客户端，以及10个侦听CalculatePriceOfOrder的客户端.我不希望同一订单同时进入多个
..
重订订户-发布者系统.仅由单个订户处理消息
我有一个拥有一个发布者和几个订阅者的系统.但是某些消息应仅由单个订户处理.在我的情况下，发布者发送有关更改数据库中数据的消息，所有订阅者都可以访问相同的数据库，但是我不需要他们都更改相同的数据. 如何使用rebus来实现? PS.忘了提.我不能只订阅一个订阅者，因为订阅者可以一直在线/离线. 解决方案 但是某些消息应仅由单个订户处理 然后，您不应该将bus.Publish用
..
消息总线中的总线发现
我正在设法绕过消息总线和ioc，而我的头却在发问. 这是我想到的情况 三台计算机通过局域网连接，无法访问互联网.这三台计算机各自具有运行的服务，并自动发现其他计算机，换句话说，它们分别在公共总线上发送消息?可以证明自己的身份. 从那时起，他们可以交换任何类型的消息. 首先使用消息总线体系结构是否有可能? 如果是，自我发现位将如何工作?我所看到的所有示例似乎都是特定于机
..
SqlConnection和避免推广MSDTC
当我们需要做的数据库访问的应用程序，我们使用以下方式： 有关查询，我们有一个静态工厂类的方法 CreateOpenConnection 它什么也不做超过新的SqlConnection（myConnectionString）并要求打开（）就可以了。调用此方法之前，我们做了查询和连接设置在查询返回后。 对于插入/更新/删除，我们使用的是更改是成批起来，并调用提交到数据库中，以 work.Commit
..
在Rebus的某消息类型的串行处理
我们有一个会谈到第三方Web服务一个Rebus的消息处理程序。由于我们无法直接控制的原因，这WCF服务频频抛出一个异常，因为它遇到了自己的数据库数据库死锁。画谜将尝试处理此消息五次，在大多数情况下是指那些五次之一将是幸运的，并没有得到一个僵局。但它经常发生，一个消息并僵局后得到的僵局，并在我们的错误队列中结束了。 除了固定的死锁的来源，这将是一个长期的目标，我能想到的两个选项： 请只用这种
..