🚀 .NET Core + 飞书机器人：文章编辑成功自动群发通知 🔔

Last updated on 

大家好！👋 今天我们来聊一聊如何利用 .NET Core 的强大功能，结合飞书机器人的便捷性，实现一个优雅的发布订阅模式，在后台编辑文章成功时，自动向飞书群发送通知。✨ 这个功能不仅能提升团队协作效率，还能让消息传递变得更加智能和高效！如果你也对这种自动化流程感兴趣，那就继续往下看吧！😄

🧠 背景：为什么需要这个功能？

在现代团队协作中，信息传递的及时性非常重要。想象一下这样的场景：你的团队正在使用一个基于 .NET Core 开发的后台管理系统，负责编辑和发布文章。每次文章编辑完成后，编辑人员都需要手动在飞书群里通知大家“文章已发布，请查收”。📢 这种手动操作不仅费时费力，还容易出错，尤其是在高频编辑的情况下。😓

于是，我们可以利用飞书机器人和 .NET Core 的事件机制，通过发布订阅模式，实现文章编辑成功后自动向飞书群发送通知的功能。这样，不仅节省了时间，还能让团队成员第一时间获取最新动态。是不是听起来就很棒？🎉

🛠 实现思路：发布订阅模式的核心

在 .NET Core 中，发布订阅模式（Pub/Sub）是一种非常常见的解耦设计模式。它的核心思想是：发布者（Publisher） 负责发布事件，而订阅者（Subscriber） 负责监听和处理事件。两者通过事件总线（Event Bus）解耦，完全不需要直接依赖。🔗

在我们的场景中：

  • 发布者：文章编辑成功的服务逻辑。
  • 订阅者：飞书机器人消息发送服务。
  • 事件：文章编辑成功的事件。

通过这种模式，我们可以轻松扩展功能。比如，未来如果需要将通知发送到钉钉、微信群，甚至是邮件，只需要增加新的订阅者即可，完全不影响现有代码。是不是很优雅？😎

📋 具体实现步骤

下面，我们一步步来实现这个功能。准备好你的键盘，我们要开始敲代码啦！💻

1️⃣ 配置飞书机器人

首先，我们需要在飞书开放平台创建一个机器人，并获取其 Webhook URL，这是我们发送消息的关键。飞书机器人支持丰富的消息格式，比如文本、富文本、卡片消息等。为了让通知更直观，我们选择使用卡片消息（Message Card）。📨

在飞书开放平台：

  • 创建一个自定义机器人。
  • 获取 Webhook URL，例如：https://open.feishu.cn/open-apis/bot/v2/hook/xxxx-xxxx-xxxx-xxxx。
  • 记录下来，后面会用到。

2️⃣ 定义事件模型

在 .NET Core 项目中，我们需要定义一个事件模型，表示“文章编辑成功”这一事件。创建一个 ArticleEditedEvent 类：

public class ArticleEditedEvent
{
    public string ArticleId { get; set; }
    public string Title { get; set; }
    public string Editor { get; set; }
    public DateTime EditedTime { get; set; }
}

这个模型包含了文章的 ID、标题、编辑者和编辑时间，足够我们在飞书消息中展示关键信息。📝

3️⃣ 实现发布者逻辑

接下来，在文章编辑的服务层中，当文章编辑成功后，发布一个 ArticleEditedEvent 事件。这里我们使用 .NET Core 自带的依赖注入和事件机制。

假设我们有一个 IEventBus 接口，用于发布事件：

public interface IEventBus
{
    Task PublishAsync<T>(T @event) where T : class;
}

在文章编辑的服务中，注入 IEventBus，并在编辑成功后发布事件：

public class ArticleService : IArticleService
{
    private readonly IEventBus _eventBus;

    public ArticleService(IEventBus eventBus)
    {
        _eventBus = eventBus;
    }

    public async Task EditArticleAsync(string articleId, string title, string content, string editor)
    {
        // 模拟编辑文章的逻辑
        Console.WriteLine($"文章 {articleId} 编辑成功！标题：{title}");

        // 发布事件
        var articleEditedEvent = new ArticleEditedEvent
        {
            ArticleId = articleId,
            Title = title,
            Editor = editor,
            EditedTime = DateTime.Now
        };

        await _eventBus.PublishAsync(articleEditedEvent);
    }
}

4️⃣ 实现订阅者逻辑：飞书消息发送

现在，我们需要一个订阅者来监听 ArticleEditedEvent 事件，并在事件触发时向飞书群发送消息。这里我们创建一个 FeishuNotificationHandler 类：

public class FeishuNotificationHandler : IEventHandler<ArticleEditedEvent>
{
    private readonly IHttpClientFactory _httpClientFactory;
    private readonly string _webhookUrl = "https://open.feishu.cn/open-apis/bot/v2/hook/xxxx-xxxx-xxxx-xxxx"; // 替换为你的 Webhook URL

    public FeishuNotificationHandler(IHttpClientFactory httpClientFactory)
    {
        _httpClientFactory = httpClientFactory;
    }

    public async Task HandleAsync(ArticleEditedEvent @event)
    {
        var client = _httpClientFactory.CreateClient();
        var message = new
        {
            msg_type = "interactive",
            card = new
            {
                config = new { wide_screen_mode = true },
                header = new
                {
                    title = new { tag = "plain_text", content = "🎉 文章编辑成功通知" },
                    template = "green"
                },
                elements = new[]
                {
                    new { tag = "div", text = new { tag = "lark_md", content = $"**标题**：{@event.Title}" } },
                    new { tag = "div", text = new { tag = "lark_md", content = $"**编辑者**：{@event.Editor}" } },
                    new { tag = "div", text = new { tag = "lark_md", content = $"**编辑时间**：{@event.EditedTime:yyyy-MM-dd HH:mm:ss}" } },
                    new { tag = "action", actions = new[] { new { tag = "button", text = new { tag = "plain_text", content = "查看详情" }, type = "default", url = $"https://yourdomain.com/article/{@event.ArticleId}" } } }
                }
            }
        };

        var jsonContent = JsonSerializer.Serialize(message);
        var content = new StringContent(jsonContent, Encoding.UTF8, "application/json");

        var response = await client.PostAsync(_webhookUrl, content);
        if (response.IsSuccessStatusCode)
        {
            Console.WriteLine("飞书消息发送成功！🚀");
        }
        else
        {
            Console.WriteLine($"飞书消息发送失败：{response.StatusCode}");
        }
    }
}

这段代码中，我们使用了飞书的卡片消息格式，生成了一个包含文章标题、编辑者、编辑时间和查看详情按钮的消息。点击“查看详情”按钮，可以跳转到文章详情页（需要替换为你实际的域名）。🔍

5️⃣ 实现事件总线

为了让发布者和订阅者解耦，我们需要一个事件总线来管理事件的发布和订阅。这里我们简单实现一个 InMemoryEventBus：

public interface IEventHandler<T>
{
    Task HandleAsync(T @event);
}

public class InMemoryEventBus : IEventBus
{
    private readonly IServiceProvider _serviceProvider;

    public InMemoryEventBus(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }

    public async Task PublishAsync<T>(T @event) where T : class
    {
        var handlers = _serviceProvider.GetServices<IEventHandler<T>>();
        foreach (var handler in handlers)
        {
            await handler.HandleAsync(@event);
        }
    }
}

6️⃣ 注册服务

最后，在 Startup.cs 或 Program.cs 中注册相关服务：

public void ConfigureServices(IServiceCollection services)
{
    services.AddSingleton<IEventBus, InMemoryEventBus>();
    services.AddTransient<IEventHandler<ArticleEditedEvent>, FeishuNotificationHandler>();
    services.AddTransient<IArticleService, ArticleService>();
    services.AddHttpClient();
}

7️⃣ 测试功能

现在，启动项目，调用 ArticleService.EditArticleAsync 方法，模拟编辑一篇文章。你会看到飞书群里自动收到一条卡片消息，内容类似于：

🎉 文章编辑成功通知
标题：如何使用 .NET Core 实现自动化通知
编辑者：小明
编辑时间：2023-10-01 14:30:00
[查看详情]（按钮）

是不是超级方便？😄

🌟 扩展与优化

到这里，我们已经实现了一个基本的发布订阅模式，并成功将通知发送到飞书群。但这只是起点！以下是一些可以进一步优化的方向：

  1. 支持多种通知渠道：通过添加新的 IEventHandler<ArticleEditedEvent> 实现类，可以轻松扩展到钉钉、微信、邮件等渠道。📧
  2. 使用第三方事件总线：我们的 InMemoryEventBus 是简单的内存实现，适合小型项目。如果需要分布式系统支持，可以使用第三方库，比如 MediatR、CAP 或 RabbitMQ。🚀
  3. 消息队列：如果消息发送失败，可以引入消息队列（如 RabbitMQ 或 Redis），实现重试机制，确保消息可靠送达。🔄
  4. 权限控制：可以在事件中加入团队或群组信息，确保消息只发送到指定的飞书群。🔒

🎉 总结

通过这篇文章，我们学习了如何在 .NET Core 中使用发布订阅模式，结合飞书机器人，实现文章编辑成功的自动通知功能。整个实现过程不仅体现了设计模式的优雅，还展示了 .NET Core 的强大扩展能力。希望这篇文章能给你带来启发，让你的项目也能用上类似的自动化功能！💡

如果你有任何问题或更好的建议，欢迎在评论区留言！👇 记得点赞和分享哦！😊

🚀 让我们一起用代码改变世界吧！ 🚀