Lord.Service 6.2.0

.NET 6.0 This package targets .NET 6.0. The package is compatible with this framework or higher.
There is a newer version of this package available.
See the version list below for details. 
dotnet add package Lord.Service --version 6.2.0
                    


                    

                
NuGet\Install-Package Lord.Service -Version 6.2.0
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package. 
<PackageReference Include="Lord.Service" Version="6.2.0" />
For projects that support PackageReference, copy this XML node into the project file to reference the package. 
<PackageVersion Include="Lord.Service" Version="6.2.0" />
                    


                            Directory.Packages.props
                        

                    

                
<PackageReference Include="Lord.Service" />
                    


                            Project file
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package. 
paket add Lord.Service --version 6.2.0
                    


                    

                
#r "nuget: Lord.Service, 6.2.0"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package. 
#:package Lord.Service@6.2.0
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package. 
#addin nuget:?package=Lord.Service&version=6.2.0
                    


                            Install as a Cake Addin
                        

                    

                
#tool nuget:?package=Lord.Service&version=6.2.0
                    


                            Install as a Cake Tool

LordService 使用说明（自用模板）

支持多渠道消息推送、MQ、缓存、加密、日志等的组件化服务。

目录

项目简介

支持微信、钉钉、飞书等多种推送方式的消息推送服务。 支持企业微信应用推送、钉钉 APP 应用推送。 支持多种日志记录方式。 支持多种加密方式。 支持 RabbitMQ 消息队列，支持加密传输。 支持 Redis 缓存。 封装 RestSharp HTTP 请求组件，实现重试等功能。

开发目的

用于解决单位现有“低代码平台”导致的消息推送不稳定问题。由于钉钉或微信群消息有限制，引入 MQ 作为缓冲中间层，实现解耦与限流控制，将事件推送到钉钉或企业微信群。

环境依赖

  1. Visual Studio 2022
  2. .NET Core 3.1 / .NET 5（建议升级到 .NET 6+）
  3. RabbitMQ（如使用 MQ 功能）
  4. Redis（如使用分布式缓存）

使用框架说明

  • RabbitMQ：推送到消费端（解耦消息生产与消费）。
  • HttpPush：推送到钉钉群 / 企业微信群 / 飞书群等。
  • 可选死信队列（DLX）。

部署步骤

  1. 添加引用 / 拷贝项目。
  2. 配置 appsettings.*.json。
  3. 编写 Worker / 控制台 / WebHost，注入并运行服务。

依赖注入示例

services.AddLordService(builder =>
{
    builder
        .UseHttp() // 使用默认 RestSharp 实现，可自定义超时
        .UseLogging(s => s.UseNLog()) // NLog / Log4Net / Serilog 三选一
        .UseCache(s => s.UseCustom(provider =>
        {
            var config = provider.GetRequiredService<IConfiguration>();
            var prefix = config.GetValue<string>("Redis:Prefix");
            var redisString = config.GetValue<string>("Redis:Connection");
            var csRedis = new CSRedisClient($"{redisString},prefix={prefix}");
            RedisHelper.Initialization(csRedis);
            return new RedisCahce(); // 自定义缓存实现
        }))
        // .UseCache(s => s.UseRedis("localhost:6379")) // 内置 Redis 示例
        .UseEncryption(s => s.UseDES(m => m.FromConfiguration("Encryption")))
        .UseMQ(s => s
            // MQ 拦截器：队列参数/死信/加解密/序列化扩展
            .AddFilter<MyMqFilter>()
            // MQ 全局异常拦截器（可多实例）
            .AddExceptionFilter<MyMqExceptionFilter>()
            .UseRabbitMQ(m => m.FromConfiguration("RabbitMQ"))
            .UseDeadLetterExchange(m => m.FromConfiguration("DlxConfig")))
        // 推送用 Add，因为可能需要添加多个类型（钉钉 / 微信 / 飞书 / 应用等）
        .UsePush(s => s.AddDingTalk(config => config.FromConfiguration("CommonPushApi")));
});

MQ 拦截器示例（队列参数/死信/加解密/序列化）

public class MyMqFilter : IMQQueueArgsFilter, IMQDeadLetterFilter, IMQJsonFilter, IMQCryptoFilter
{
    public void OnQueueArgsConfiguring(IMQSettings settings, IDictionary<string, object?> args)
    {
        args["x-message-ttl"] = 30_000; // 30 秒过期
    }

    public void OnDeadLetterConfiguring(IMQSettings settings, MQDeadLetterContext context)
    {
        context.Option = new DlxOption
        {
            DlxChangeName = $"dlx.{settings.ExchangeName}",
            DlxRoutingKey = $"dlx.{settings.RouteKey}",
            DlxQueueName = $"dlx.{settings.QueueName}"
        };
        // 如需关闭 DLX，可将 Option 置空或 context.Enabled = false
    }

    public string OnSerializing<T>(T value, IMQSettings settings, IJsonFormat defaultFormat)
    {
        // 可替换默认序列化
        return defaultFormat.Serialize(value);
    }

    public T? OnDeserialized<T>(string payload, IMQSettings settings, IJsonFormat defaultFormat)
    {
        // 可替换默认反序列化
        return defaultFormat.Deserialize<T>(payload);
    }

    // 自定义加解密（可不实现 IEncryptProvider）
    public ReadOnlyMemory<byte> OnEncrypt(ReadOnlyMemory<byte> payload, Type? type, IMQSettings settings, IEncryptProvider? defaultProvider)
    {
        // 直接复用默认 Provider
        if (defaultProvider != null)
        {
            return defaultProvider.Encryption(payload.ToArray());
        }
        return payload;
    }

    public ReadOnlyMemory<byte> OnDecrypt(ReadOnlyMemory<byte> payload, Type? type, IMQSettings settings, IEncryptProvider? defaultProvider)
    {
        if (defaultProvider != null)
        {
            return defaultProvider.Decryption(payload.Span);
        }
        return payload;
    }
}

MQ 全局异常拦截器示例

public class MyMqExceptionFilter : IMQExceptionFilter
{
    private readonly ILogger<MyMqExceptionFilter> logger;
    public MyMqExceptionFilter(ILogger<MyMqExceptionFilter> logger) => this.logger = logger;

    public void OnException(Exception exception, string message)
    {
        // 可按队列名等信息自定义处理（解析 message 内容或自定义格式）
        logger.LogError(exception, "MQ 异常: {Message}", message);
    }
}

说明：

  • 拦截器通过 UseMQ(...).AddFilter<T>() 和 UseMQ(...).AddExceptionFilter<T>() 注册，支持多实例，按需在实现里区分队列名/路由键等做差异化处理。
  • IMQPush / IMQReceive 构造时会自动订阅拦截器，无需在业务代码里手动挂事件，保持开箱即用又可扩展。
Product Compatible and additional computed target framework versions.
.NET net6.0 is compatible.  net6.0-android was computed.  net6.0-ios was computed.  net6.0-maccatalyst was computed.  net6.0-macos was computed.  net6.0-tvos was computed.  net6.0-windows was computed.  net7.0 was computed.  net7.0-android was computed.  net7.0-ios was computed.  net7.0-maccatalyst was computed.  net7.0-macos was computed.  net7.0-tvos was computed.  net7.0-windows was computed.  net8.0 is compatible.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed.  net9.0 is compatible.  net9.0-android was computed.  net9.0-browser was computed.  net9.0-ios was computed.  net9.0-maccatalyst was computed.  net9.0-macos was computed.  net9.0-tvos was computed.  net9.0-windows was computed.  net10.0 was computed.  net10.0-android was computed.  net10.0-browser was computed.  net10.0-ios was computed.  net10.0-maccatalyst was computed.  net10.0-macos was computed.  net10.0-tvos was computed.  net10.0-windows was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last Updated
7.10.8 41 8/11/2026
7.10.7 94 8/6/2026
7.10.6 95 8/5/2026
7.10.5 93 8/4/2026
7.10.1 103 8/1/2026
7.10.0 100 7/30/2026
7.0.8 114 7/29/2026
7.0.7 104 7/29/2026
7.0.6 104 7/16/2026
7.0.5 119 4/24/2026
7.0.3 145 2/10/2026
7.0.2 137 2/6/2026
7.0.1 139 2/4/2026
7.0.0 150 1/26/2026
6.2.0 146 1/23/2026
6.0.9 142 1/12/2026
6.0.8 314 11/30/2025
Loading failed

升级为NET6/NET8/NET9多目标支持，加入Serilog/NLog/Log4Net官方扩展