.NET 6开发TodoList应用之实现PUT请求

更新时间:2023-04-04 12:21:47 阅读：评论：0

需求

属蛇的和什么属相最配put请求本身其实可说的并不多，过程也和创建基本类似。在这篇文章中，重点是填上之前文章里留的一个坑，我们曾经给todoitem定义过一个标记完成的领域事件：todoitemcompletedevent，在savechangesasync方法里做了一个dispatchevents的操作。并且在domaineventrvice实现idomaineventrvice的publish方法中暂时以下面的代码代替了：

domaineventrvice.cs

public async task publish(domainevent domainevent){    // 在这里暂时什么都不做，到cqrs那一篇的时候再回来补充这里的逻辑    _logger.loginformation("publishing domain even普通话考试技巧t. event - {event}", domainevent.gettype().name);}

在前几篇应用mediatr实现cqrs的过程中，我们主要是和irequest/irequesthandler打的交道。那么本文将会涉及到另外一对常用的接口：inotification/inotificationhandler，来实现领域事件的处理。

目标

1.实现put请求；

2.实现领域事件的响应处理；

原理与思路

实现put请求的原理和思路与实现post请求类似，就不展开了。关于实现领域事件响应的部分，我们需要实现inotification/inotificationhandler接口，并改写publish的实现，让它能发布领域事件通知。

实现

put请求

我们拿更新todoitem的完成状态来举例，首先来自定义一个领域异常notfoundexception，位于application/common/exceptions里：

notfoundexception.cs

namespace todolist.application.common.exceptions;public class notfoundexception : exception{    public notfoundexception() : ba() { }    public notfoundexception(string message) : ba(message) { }    public notfoundexception(string message, exception innerexception) : ba(message, innerexception) { }    public notfoundexception(string name, object key) : ba($"entity \"{name}\" ({key}) was not found.") { }}

创建对应的command：

updatetodoitemcommand.cs

using mediatr;using todolist.application.common.exceptions;using todolist.application.common.interfaces;using todolist.domain.entities;namespace todolist.application.todoitems.commands.updatetodoitem;public class updatetodoitemcommand : irequest<todoitem>{    public guid id { get; t; }    public string? title { get; t; }    public bool done { get; t; }}public class updatetodoitemcommandhandler : irequesthandler<updatetodoitemcommand, todoitem>{    private readonl张九龄简介y irepository<todoitem> _repository;    public updatetodoitemcommandhandler(irepository<todoitem> repository)    {        _repository = repository;    }    public async task<todoitem> handle(updatetodoitemcommand request, cancellationtoken cancellationtoken)    {        var entity = await _repository.getasync(request.id);        if (entity == null)        {            throw new notfoundexception(nameof(todoitem), request.id);        }        entity.title = request.title ?? entity.title;        entity.done = request.done;        await _repository.updateasync(entity, cancellationtoken);        return entity;    }}

实现controller：

todoitemcontroller.cs

[httpput("{id:guid}")]public async task<apirespon<todoitem>> update(guid id, [frombody] updatetodoitemcommand command){    if (id != command.id)    {        return apirespon<todo体育游戏item>.fail("query id not match witch body");    }    return apirespon<todoitem>.success(await _mediator.nd(command));}

领域事件的发布和响应

首先需要在application/common/models定义一个泛型类，实现inotification接口，用于发布领域事件：

domaineventnotification.cs

using mediatr;using todolist.domain.ba;namespace todolist.application.common.models;public class domaineventnotification<tdomainevent> : inotification where tdomainevent : domainevent{    public domaineventnotification(tdomainevent domainevent)    {        domainevent = domainevent;    }    public tdomainevent domainevent { get; }}

接下来在application/todoitems/eventhandlers中创建对应的handler：

todoitemcompletedeventhandler.cs

using mediatr;using microsoft.extensions.logging;using todolist.application.common.models;using todolist.domain.events;namespace todolist.application.todoitems.eventhandlers;public class todoitemcompletedeventhandler : inotificatio关于祖国的作文nhandler<domaineventnotification<todoitemcompletedevent>>{    private readonly ilogger<todoitemcompletedeventhandler> _logger;    public todoitemcompletedeventhandler(ilogger<todoitemcompletedeventhandler> logger)    {        _logger = logger;    }    public task handle(domaineventnotification<todoitemcompletedevent> notification, cancellationtoken cancellationtoken)    {        var domainevent = notification.domainevent;        // 这里我们还是只做日志输出，实际使用中根据需要进行业务逻辑处理，但是在handler中不建议继续nd其他command或notification        _logger.loginformation("todolist domain event: {domainevent}", domainevent.gettype().name);        return task.completedtask;    }}

最后去修改我们之前创建的domaineventrvice，注入imediator并发布领域事件，这样就可以在handler中进行响应了。

domaineventrvice.cs

using mediatr;using microsoft.extensions.logging;using todolist.application.common.interfaces;using todolist.application.common.models;using todolist.domain.ba;namespace todolist.infrastructure.rvices;public class domaineventrvice : idomaineventrvice{    private readonly imediator _mediator;    private readonly ilogger<domaineventrvice> _logger;    public domaineventrvice(imediator mediator, ilogger<domaineventrvice> logger)    {        _mediator = mediator;        _logger = logger;    }    public async task publish(domainevent domainevent)    {        _logger.loginformation("publishing domain event. event - {event}", domainevent.gettype().name);        await _mediator.publish(getnotificationcorrespondingtodomainevent(domainevent));    }    private inotification getnotificationcorrespondingtodomainevent(domainevent domainevent)    {        return (inotification)activator.createinstance(typeof(domaineventnotification<>).makegenerictype(domainevent.gettype()), domainevent)!;    }}