目錄

• 需求
• 目標
• 原理與思路
• 實現
• PUT請求
• 領域事件的釋出和響應
• 驗證
• 總結

需求

PUT請求本身其實可說的並不多，過程也和建立基本類似。在這篇文章中，重點是填上之前文章裡留的一個坑，我們曾經給TodoItem定義過一個標記完成的領域事件：TodoItemCompletedEvent，在SaveChangesAsync方法裡做了一個DispatchEvents的操作。並且在DomainEventService實現IDomainEventService的Publish方法中暫時以下面的程式碼代替了：

DomainEventService.cs

public async Task Publish(DomainEvent domainEvent)
{
    // 在這裡暫時什麼都不做，到CQRS那一篇的時候再回來補充這裡的邏輯
    _logger.LogInformation("Publishing domain event. 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() : base() { }
    public NotFoundException(string message) : base(message) { }
    public NotFoundException(string message,Exception innerException) : base(message,innerException) { }
    public NotFoundException(string name,object key) : base($"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; set; }
    public string? Title { get; set; }
    public bool Done { get; set; }
}

public class UpdateTodoItemCommandHandler : IRequestHandler<UpdateTodoItemCommand,TodoItem>
{
    private readonly 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);
 OigktWx       }

        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<ApiResponse<TodoItem>> Update(Guid id,[FromBody] UpdateTodoItemCommand command)
{
    if (id != command.Id)
    {
        return ApiResponse<TodoItem>.Fail("Query id not match witch body");
    }

    return ApiResponse<TodoItem>.Success(await _mediator.Send(command));
}

領域事件的釋出和響應

首先需要在Application/Common/Models定義一個泛型類，實現INotification介面，用於釋出領域事件：

DomainEventNotification.cs

using MediatR;
using TodoList.Domain.Base;

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 : INotificatOigktWxionHandler<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中不建議繼續Send其他Command或Notification
        _logger.LogInformation("TodoList Domain Event: {DomainEvent}",domainEvent.GetType().Name);

        return Task.CompletedTask;
    }
}

最後去修改我們之前建立的DomainEventService，注入IMediator併發布領域事件，這樣就可以在Handler中進行響應了。

DomainEventService.cs

using MediatR;
using Microsoft.Extensions.Logging;
using TodoList.Applicatiohttp://www.cppcns.comn.Common.Interfaces;
using TodoList.Application.Common.Models;
using TodoList.Domain.Base;

namespace TodoList.Infrastructure.Services;

public class DomainEventService : IDomainEventService
{
    private readonly IMediator _mediator;
    private readonly ILogger<DomainEventService> _logger;

    public DomainEventService(IMediator mediator,ILogger<DomainEventService> 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)!;
    }
}

驗證

啟動Api項客棧目，更新TodoItem的完成狀態。

請求

響應

領域事件釋出

總結

這篇文章主要在實現PUT請求的過程中介紹瞭如何通過MediatR去響應領域事件，我們用的示例程式碼中類似“建立TodoList”，包括後面會講到的“刪除TodoItem”之類的領域事件，都是相同的處理方式，我就不一一演示了。

可以看出來，在我們這個示例應用程式的框架基本搭建完畢以後，進行領域業務的開發的思路是比較清晰的，模組之間的耦合也處在一個理想的情況。

在我們來完成CRUD的最後一個請求之前，下一篇會簡單地介紹一下PATCH請求的相關內容，這個請求實際應用比較少，但是為了保持知識樹的完整性，還是會過一下。

到此這篇關於.NET 6開發TodoList應用之實現PUT請求的文章就介紹到這了,更多相關.NET 6 實現PUT請求內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們！