问题标签 [lokad-cqrs]

我们有一个与多个第 3 方系统集成的 Windows Azure 应用程序（Lokad.CQRS 架构）。其中一种集成发生在 mySQL 上。一切都很顺利，但最近我们有一个 Windows Azure 应用程序无法连接的 mySQL 数据库，导致超时。

这是相关的堆栈跟踪：

重要亮点：

• 目标数据库可从 Windows Azure 访问（通过 MySQL Workbench 连接时使用端口转发进行验证）；
• 与目标数据库的集成在本地 Azure Dev Fabric 中正常工作；
• Windows Azure 上的问题发生在展位池连接和非池连接。
• TCP/IP，普通端口，无 SSL；
• 此操作的连接超时足够大 - 5 秒，并且它连续失败（但总是在距离 NE DC 不远的非 Azure 机器上成功）

我们有 Oracle、MS SQL、mySQL 和 PostgreSQL 连接，通过 Lokad.CQRS 在 Windows Azure 上以各种设置和配置（Linux/Windows 托管的数据库服务器）工作。但是这个特定的 mySQL 案例完全让我感到困惑。

关于可能导致问题的任何猜测？

我如何通过自己的服务总线构建？我知道有很多可用的开源服务总线，如 NService Bus、Rhino Bus 等......但我想通过这样做来学习......

1）你将如何建造巴士？它有什么特点

2）我怎样才能使它独立于队列技术..即它应该与 MSMQ 作为天蓝色队列一起使用（从未与天蓝色队列一起使用）

3）我如何实现监听器？我有一个链接.. Nservice Bus 是怎么做的 （MSMQListner）

4）我如何激活队列..我可以在 IIS 中托管我的服务，这样处理负载就不会成为问题（我希望如此）

5) MSMQ 的主机选项将如何？

请我不想使用 WCF。只是因为它使消息传递架构成为 RPC 调用

我最近开始研究 MSMQ，所以我有基本的疑问。如果两个应用程序需要通信，比如说服务器和客户端，我认为两者都将共享相同的 MQ 地址，当客户端更新时，服务器将拥有 MSMQ 观察程序，它会监听消息并使用它。所以根据我的说法，我们需要三个组件

客户端 - 知道队列位置

队列观察者 - 观察队列

服务——队列观察者将消息发送到哪个

我目前正在研究用于将在Azure中托管的项目的CQRS框架。

我已阅读有关Ncqrs和 Lokad.CQRS 的信息，目前有点困惑。

它们是否都与 Azure 一起工作，都能够使用 NServiceBus 还是 Lokad 使用自己的消息传递？

我将使用的客户端是 Web 和移动客户端。我想制作一个 WCF 服务来获取命令，但不确定它是否会是 WCF。

有什么建议吗？

当然，我们可以使用quartz.net，它具有并发控制和负载平衡等不错的功能。然而，它对我来说似乎有点臃肿。

1）我错了吗？2）如果不是，您将如何实现符合云的调度程序（即：部署在本地或天蓝色内）？Lokad 调度是最佳方法吗？

我们正在从 Lokad 切换到 CloudFx 来处理将数据放入/取出表存储的问题。

使用 Lokad，我们有 3 个实体：

据我所知，CloudFx 将该信息输入到表存储中的唯一方法是用一个具有前三个对象的所有属性的大型对象将整个事物展平。使用 Lokad，我们可以只使用Skinny=true。

想法？

我正在使用 Azure 队列存储。我刚刚从使用 Microsoft.WindowsAzure.StorageClient 升级到 Microsoft.WindowsAzure.Storage。我最近也从使用 Lokad 改为使用 CloudFx。在此过程中的某个时刻，我开始在队列存储中获取更多列，包括重复的出队计数。

我无法弄清楚这些列是如何创建的。为什么有两个 Dequeue Count 列？

lokad -iddd-sample代码实现了 Vaughn Vernon 书中讨论的 cqrs+es 写入端。不幸的是，读取模型方面是不完整的。有没有人知道实现读取模型端的工作版本的类似代码（理想情况下基于 Vaughn Vernon 的书）？

Aggregate可以使用View这个事实是在Vaughn Vernon's book 中描述的：

此类读取模型投影经常用于向各种客户端（例如桌面和 Web 用户界面）公开信息，但它们对于在有界上下文及其聚合之间共享信息也非常有用。考虑发票聚合需要一些客户信息（例如，姓名、账单地址和税号）以计算和准备正确发票的场景。我们可以通过 CustomerBillingProjection 以易于使用的形式捕获此信息，这将创建和维护 CustomerBilling-View 的专有实例。此读取模型可通过名为 IProvideCustomerBillingInformation 的域服务用于发票聚合。在幕后，这个域服务只是在文档存储中查询适当的 CustomerBillingView 实例

让我们想象一下，我们的应用程序应该允许创建许多用户，但具有唯一的名称。命令/事件流：

• CreateUser{Alice}发送的命令
• UserAggregate检查UsersListView，因为没有名为 Alice 的用户，聚合决定创建用户并发布事件。
• UserCreated{Alice}事件发布 // 由 UserAggregate
• UsersListProjection已处理UserCreated{Alice}// 为简单起见，让我们认为 UsersListProjection 只是在收到时累积用户名UserCreated event。
• CreateUser{Bob}发送的命令
• UserAggregate检查UsersListView，因为没有名为 Bob 的用户，聚合决定创建用户并发布事件。
• UserCreated{Bob}事件发布 // 由 UserAggregate
• CreateUser{Bob}发送的命令
• UserAggregate检查UsersListView，因为没有名为 Bob 的用户，聚合决定创建用户并发布事件。
• UsersListProjection处理过UserCreated{Bob}。
• UsersListProjection处理过UserCreated{Bob}。

问题是 -UsersListProjection没有时间处理事件并且包含不相关的数据，聚合使用了这些不相关的数据。结果 - 创建了 2 个同名用户。

如何避免这种情况？如何使聚合和预测一致？