.NET 6网络应用程序接口和Blazor服务器应用程序之间的回调监听器

public class ResourceCreatedEventArgs : EventArgs
{
    public string ResourceId { get; set; }
}

public class ResourceController : ControllerBase
{
    private readonly IEventPublisher _eventPublisher;

    public ResourceController(IEventPublisher eventPublisher)
    {
        _eventPublisher = eventPublisher;
    }

    [HttpPost]
    public IActionResult CreateResource(Resource resource)
    {
        // 创建资源逻辑...

        // 发布事件
        _eventPublisher.Publish(new ResourceCreatedEventArgs { ResourceId = resource.Id });

        return CreatedAtAction(nameof(GetResource), new { id = resource.Id }, resource);
    }
}

public interface IEventPublisher
{
    void Publish<T>(T eventData) where T : EventArgs;
}

public class EventPublisher : IEventPublisher
{
    private readonly List<IEventHandler> _handlers;

    public EventHandler()
    {
        _handlers = new List<IEventHandler>();
    }

    public void Subscribe(IEventHandler handler)
    {
        _handlers.Add(handler);
    }

    public void Publish<T>(T eventData) where T : EventArgs
    {
        foreach (var handler in _handlers)
        {
            if (handler.CanHandle(eventData))
            {
                handler.Handle(eventData);
            }
        }
    }
}

public interface IEventHandler
{
    bool CanHandle(EventArgs eventData);
    void Handle(EventArgs eventData);
}

@page "/fetchdata"
@inject HttpClient Http
@inject NavigationManager NavigationManager
@implements IDisposable

<h3>Fetch data</h3>

<p>@message</p>

@code {
    private HubConnection hubConnection;
    private string message = "Initial message";

    protected override async Task OnInitializedAsync()
    {
        hubConnection = new HubConnectionBuilder()
            .WithUrl(NavigationManager.ToAbsoluteUri("/chathub"))
            .Build();

        hubConnection.On<string>("ReceiveMessage", (msg) =>
        {
            message = msg;
            StateHasChanged();
        });

        await hubConnection.StartAsync();
    }

    public async ValueTask DisposeAsync()
    {
        if (hubConnection != null)
        {
            await hubConnection.DisposeAsync();
        }
    }
}