我对领域驱动的设计概念相当陌生,我遇到了一个问题,即在使用命令总线和域逻辑的命令和命令处理程序时,在API中返回正确的响应.

假设我们正在使用域驱动设计方法构建应用程序.我们有一个后端和前端部分.后端的所有域逻辑都带有公开的API.前端使用API​​向应用程序发出请求.

我们使用映射到命令总线的命令和命令处理程序构建域逻辑.在我们的域目录下,我们有一个命令用于创建名为CreatePostCommand的帖子资源.它通过命令总线映射到其处理程序CreatePostCommandHandler.

final class CreatePostCommand
{
    private $title;
    private $content;

    public function __construct(string $title,string $content)
    {
        $this->title = $title;
        $this->content= $content;

    }

    public function getTitle() : string
    {
        return $this->title;
    }

    public function getContent() : string
    {
        return $this->content;
    }
}

final class CreatePostCommandHandler
{
    private $postRepository;

    public function __construct(PostRepository $postRepository)
    {
        $this->postRepository = $postRepository;
    }

    public function handle(Command $command)
    {
        $post = new Post($command->getTitle(),$command->getContent());
        $this->postRepository->save($post);
    }
}

在我们的API中,我们有一个用于创建帖子的端点.这将在我们的Application目录下的PostController中路由createPost方法.

final class PostController
{
    private $commandBus;

    public function __construct(CommandBus $commandBus)
    {
        $this->commandBus = $commandBus;
    }

    public function createPost($req,$resp)
    {
        $command = new CreatePostCommand($command->getTitle(),$command->getContent());
        $this->commandBus->handle($command);

        // How do we get the data of our newly created post to the response here?

        return $resp;
    }
}

现在在我们的createPost方法中,我们希望在响应对象中返回新创建的帖子的数据,以便我们的前端应用程序可以了解新创建的资源.这很麻烦,因为我们知道根据定义,命令总线不应该返回任何数据.所以现在我们陷入一个混乱的位置,我们不知道如何将新帖子添加到响应对象.

我不知道如何从这里开始解决这个问题,我想到了几个问题:

>在回复中是否有一种优雅的方式来返回帖子的数据?
>我是否错误地实现了Command / CommandHandler / CommandBus模式?
>这只是Command / CommandHandler / CommandBus模式的错误用例吗?

首先,请注意,如果我们将控制器直接连接到命令处理程序,我们将遇到类似的问题:
public function createPost($req,$command->getContent());
        $this->createPostCommandHandler->handle($command);

        // How do we get the data of our newly created post to the response here?
        return $resp;
    }

总线引入了一个间接层,允许您将控制器与事件处理程序分离,但是您遇到的问题更为根本.

I’m not sure how to proceed with this problem from here

TL; DR – 告诉域使用什么标识符,而不是询问域使用了什么标识符.

public function createPost($req,$resp)
    {
        // TADA
        $command = new CreatePostCommand($req->getPostId(),$command->getTitle(),$command->getContent());

        $this->createPostCommandHandler->handle($command);

        // happy path: redirect the client to the correct url
        $this->redirectTo($resp,$postId)
    }

简而言之,客户端而不是域模型或持久层,负责生成新实体的id.应用程序组件可以读取命令本身中的标识符,并使用它来协调下一个状态转换.

在该实现中,应用程序简单地将消息从DTO表示转换为域表示.

替代实现使用命令标识符,并从该命令派生将使用的标识

$command = new CreatePostCommand(
                 $this->createPostId($req->getMessageId()),$command->getContent());

Named UUIDs是后一种情况的常见选择;它们是确定性的,并且具有小的碰撞概率.

现在,这个答案是一种欺骗 – 我们实际上只是证明了在这种情况下我们不需要命令处理程序的结果.

一般来说,我们宁愿拥有一个; Post / Redirect / Get是用于更新域模型的好习惯,但是当客户端获取资源时,我们希望确保他们获得的版本包含他们刚刚编辑的版本.

如果您的读取和写入使用相同的记录簿,则这不是问题 – 无论您阅读的内容始终是最新版本.

但是,cqrs是域驱动设计中的常见架构模式,在这种情况下,写模型(处理帖子)将重定向到读取模型 – 通常是发布陈旧数据.因此,您可能希望在get请求中包含最小版本,以便处理程序知道刷新其过时的缓存.

Is there an elegant way to return the post’s data in the response?

您在问题中提供的代码示例中有一个示例:

public function createPost($req,$resp)

想一想:$req是http请求消息的表示,它大致类似于你的命令,$resp本质上是一个数据结构的句柄,你可以将结果写入.

换句话说,使用您的命令传递回调或结果句柄,并让命令处理程序填写详细信息.

当然,这取决于你的公共汽车支持回调;不保证.

另一种不需要更改命令处理程序签名的可能性是安排控制器订阅命令处理程序发布的事件.您在命令和事件之间协调correlation id,并使用它来提取您需要的结果事件.

具体细节并不重要 – 处理命令时生成的事件可以写入消息总线,或者复制到邮箱中,或者….

php – 如何从命令总线获取数据?的更多相关文章

  1. 从iOS应用程序发送帖子到PHP脚本不工作…简单的解决方案就像

    我之前已经做了好几次了但是由于某些原因我无法通过这个帖子…我尝试了设置为_POST且没有的变量的PHP脚本……当它们未设置为发布时它工作精细.这是我的iOS代码:这里是PHP的一大块,POST变量不在正确的位置?我想这对于更有经验的开发人员来说是一个相当简单的答案,感谢您的帮助!解决方法$_POST是一个数组,而不是一个函数.您需要使用方括号来访问数组索引:

  2. swift学习2 元组 tuples

    swift中出现了一种新的数据结构,非常牛掰的元组tuples如果懂PHP的猿,会发现这个元组和PHP的数组非常类似,同样是可以默认不指定key,也可以指定key目前的学习疑问是,如何进行元组的遍历?

  3. Swift设计模式之命令模式

    转自Swift设计模式原文Design-Patterns-In-Swift

  4. Ceph部署二RGW搭建

    背景CephRGW简介CephRGW基于librados,是为应用提供RESTful类型的对象存储接口。环境规划如上篇文章《Ceph部署(一)集群搭建》所述:4台服务器:1台作为Monitor,1台作为OSDRGW,还有两台作为OSD。部署CephRGW进入上文所述的my-cluster目录。该脚本会连接RGW,创建一个bucket并列出所有的bucket。正常的输出应该为:小结通过ceph-deploy命令,已经大大地简化了对Ceph集群和RGW的安装和配置。但如果想挑战下自己,或者想让自己了解更多,试

  5. EFColorPicker - 一个纯 Swift 的轻量级 iOS 颜色选择器

    EFColorPicker是一个纯Swift的轻量级iOS颜色选择器,受MSColorPicker启发。或执行以下命令:环境iOS8.0+Xcode9.0+Swift4.0+安装EFColorPicker可以通过CocoaPods进行获取。只需要在你的Podfile中添加如下代码就能实现引入:备注EFColorPicker的第一个版本从MSColorPicker转换而来,在此对MSColorPicker的作者sgl0v表示感谢!作者EyreFree,eyrefree@eyrefree.org协议EFQRC

  6. 使用LLDB调试Swift

    LLDB是个很好的选择。接下来我会探讨一些工作中常用到的一些LLDB调试技巧。LLDB拥有大量有用的调试工具。LLDB的bugreport命令可以生成一份详细的app当前状态的报告。这些命令有针对C++,Objective-C,Swift和RenderScript的。使用LLDB的这些命令可以让调试变得更自动化。process用于控制要调试的进程,可把LLDB依附到特定target或从target上解绑。processstatus用于打印当前进程及断点处的相关信息:使用如下命令可继续执行:这等同于Xcod

  7. 尝试使用swift mailer,gmail smtp,php发送邮件

    这里是我的代码:在运行时出现此错误…

  8. android – 来自adb的’grep’命令的问题

    当我用adb写的时候:我得到错误输出:但如果我将它拆分为两个操作符:它工作正常.如果唯一的方法是将它拆分为两个–首先进入adbshell,然后运行Inquire,有一种方法可以从c#中执行此操作吗?

  9. android – 交互式设置屏幕设置

    我想在KitKat中将屏幕锁定模式设置为None,这样我就可以运行CTS了.我正在使用DragonBoardAPQ8074进行Intrinsyc的开发,他们刚刚发布了针对AndroidKitKat4.4.2的BSP.麻烦的是,它不稳定,设置中的安全菜单崩溃了.所以我不能使用adbshell来输入keyevents19,20,21,22,23进行导航.adbshellsettings命令似乎应该适用

  10. android – 在“重新启动系统命令”之后,引导程序如何接收命令?

    此外,它似乎不是Android特有的,而是Linux执行“使用命令重新启动”的方式.有关在Linux中如何“正常”处理/使用的任何信息?

随机推荐

  1. PHP个人网站架设连环讲(一)

    先下一个OmnihttpdProffesinalV2.06,装上就有PHP4beta3可以用了。PHP4给我们带来一个简单的方法,就是使用SESSION(会话)级变量。但是如果不是PHP4又该怎么办?我们可以假设某人在15分钟以内对你的网页的请求都不属于一个新的人次,这样你可以做个计数的过程存在INC里,在每一个页面引用,访客第一次进入时将访问时间送到cookie里。以后每个页面被访问时都检查cookie上次访问时间值。

  2. PHP函数学习之PHP函数点评

    PHP函数使用说明,应用举例,精简点评,希望对您学习php有所帮助

  3. ecshop2.7.3 在php5.4下的各种错误问题处理

    将方法内的函数,分拆为2个部分。这个和gd库没有一点关系,是ecshop程序的问题。会出现这种问题,不外乎就是当前会员的session或者程序对cookie的处理存在漏洞。进过本地测试,includes\modules\integrates\ecshop.php这个整合自身会员的类中没有重写integrate.php中的check_cookie()方法导致,验证cookie时返回的username为空,丢失了登录状态,在ecshop.php中重写了此方法就可以了。把他加到ecshop.php的最后面去就可

  4. NT IIS下用ODBC连接数据库

    $connection=intodbc_connect建立数据库连接,$query_string="查询记录的条件"如:$query_string="select*fromtable"用$cur=intodbc_exec检索数据库,将记录集放入$cur变量中。再用while{$var1=odbc_result;$var2=odbc_result;...}读取odbc_exec()返回的数据集$cur。最后是odbc_close关闭数据库的连接。odbc_result()函数是取当前记录的指定字段值。

  5. PHP使用JpGraph绘制折线图操作示例【附源码下载】

    这篇文章主要介绍了PHP使用JpGraph绘制折线图操作,结合实例形式分析了php使用JpGraph的相关操作技巧与注意事项,并附带源码供读者下载参考,需要的朋友可以参考下

  6. zen_cart实现支付前生成订单的方法

    这篇文章主要介绍了zen_cart实现支付前生成订单的方法,结合实例形式详细分析了zen_cart支付前生成订单的具体步骤与相关实现技巧,需要的朋友可以参考下

  7. Thinkphp5框架实现获取数据库数据到视图的方法

    这篇文章主要介绍了Thinkphp5框架实现获取数据库数据到视图的方法,涉及thinkPHP5数据库配置、读取、模型操作及视图调用相关操作技巧,需要的朋友可以参考下

  8. PHP+jquery+CSS制作头像登录窗(仿QQ登陆)

    本篇文章介绍了PHP结合jQ和CSS制作头像登录窗(仿QQ登陆),实现了类似QQ的登陆界面,很有参考价值,有需要的朋友可以了解一下。

  9. 基于win2003虚拟机中apache服务器的访问

    下面小编就为大家带来一篇基于win2003虚拟机中apache服务器的访问。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧

  10. Yii2中组件的注册与创建方法

    这篇文章主要介绍了Yii2之组件的注册与创建的实现方法,非常不错,具有参考借鉴价值,需要的朋友可以参考下

返回
顶部