WCF 服务内部火灾/忘记队列

Question

我目前正在使用 WCF 实现一项服务，该服务控制对 CRM 数据库的操作。我已经实现了 CQRS 的多个方面，将所有操作分为不同的命令和查询。

问题 1：

一些命令操作执行相对简单的操作，但会触发辅助的、通常更昂贵的操作。我已经分离了这些触发器，但它们仍然在原始操作线程中执行。

我正在考虑将它们分离到第二个 WCF 服务中，并进行单向操作。这样原始操作可以立即返回，并且“触发器”服务可以处理所有这些辅助操作。目前可靠性不是主要问题，因此问题记录就足够了 - 但将来可能会扩展。

这是处理这种情况的典型方法吗？或者有没有一种方法可以在不使用辅助服务的情况下完成此操作？

问题2：

在同一台服务器上这样划分WCF服务是否会带来显着的性能提升？

我的想法是，核心 WCF 服务的应用程序池将被更快地释放（尽管新的池将相互竞争），并且可以将附加服务分离到单独的服务器上。

Answer 1

我同意 oleksii 的观点，如果您希望扩展，队列可能是比 WCF 服务更好的选择。它还允许您将命令移动为单向，实际上只是向用户返回一个基本的 ack/nack，表明命令已收到并正在处理（而不是已处理）。

我建议您查看 Greg Young 在他的 CQRS Info 网站上对 CQRS 的介绍文档，特别是在命令侧部分（大约向下一半）。

回答您的问题：

1. 通过转移到单向队列或 WCF 服务，我认为这可以解决您的问题。您的单向服务接收来自客户端的命令，然后将其交给您的域来处理。然后，您的域将根据需要执行的操作触发 0 个、1 个或多个事件 - 这些事件可能是对应用程序中其他 WCF 服务的调用，也可能是丢弃在由事件处理程序拾取的队列中的消息。关键是您让业务规则（域）确定要引发哪些事件。具体如何处理它们是一个实现细节（但我会使用队列或事件存储）。请查看Jonathan Oliver 的活动商店。
2. 我认为释放 IIS 线程（或一般线程）的速度越快是一件好事；因此，如果您将服务分为同步和异步，那可能会很好。我认为，如果您要采用 CQRS 路线，那么在服务上单向返回 ack/nack 消息可能是一件好事，并且从性能角度来看可能会有所帮助，因为您可能会更快地释放线程来处理更多线程请求。

我希望这有帮助。祝你好运！！

Answer 2

没有什么可以阻止您使用同步命令，然后仅异步运行部分执行代码，而无需分离服务。

你提到你已经分离了你的“触发器”。我认为这意味着它们作为单独的方法运行？既然如此，您可以轻松地在后台运行它们并让您的主 WCF 线程返回，而无需分离服务。 （下面的代码不假设事件源。）

public class MyCommandHandler
{
    public string Do(MyCommand1 command)
    {
        var myCrmObject = ... ; // load some object
        string message = myCrmObject.CriticalWork(command); // synchronous
        ThreadPool.QueueUserWorkItem(x => myCrmObject.OtherWork(command)); // async
        // async alternative 1
        //Action<MyCommand1> action = myCrmObject.OtherWork; // make into action delegate
        //action.BeginInvoke(null, command); // start action async, no callback
        // async alternative 1a - custom delegate instead of Action. same BeginInvoke call
        // async alternative 2 - Background Worker
        // async alternative 3 - new System.Threading.Thread(...).Start(command);
        return message; // will be here before OtherWork finishes (or maybe even starts)
    }
}

如果您使用事件流和事件处理程序来执行数据库写入并与其他系统集成，那么这可以构造得更好一些。您可以让您的个人事件处理程序担心它是否应该同步执行。

Answer 3

只是一个建议

1. 你可以尝试一个工作队列，前端的一些服务异步添加项目。后端的其他服务使项目出列并处理工作。工作状态保存到可查询的持久存储中。

2. 队列两侧最好都有多个工作人员，但对于任何改进，您的服务器需要是多核（多处理器）的，这样它将能够真正并行工作。您可能需要实际尝试不同的选项，看看什么是最好的。