Galosys.Foundation.RulesEngine.Redis 26.5.20.1

Galosys.Foundation.RulesEngine.Redis

规则引擎 Redis Pub/Sub 热更新广播模块，支持多实例部署时规则变更的跨实例同步通知。

依赖: Galosys.Foundation.RulesEngine（必选）+ Galosys.Foundation.Redis（必选）

快速开始

1. 注册服务

// Program.cs
services.AddRuleEngine(configuration);
services.AddRedisRuleChangeNotifier(configuration);

需先注册 Redis 实现（FreeRedis 或 StackExchange.Redis）：

services.AddFreeRedis(configuration); // 或 services.AddStackExchangeRedis(configuration);
services.AddRuleEngine(configuration);
services.AddRedisRuleChangeNotifier(configuration);

2. 配置

{
 "Rules": {
 "Redis": {
 "Channel": "rules:change"
 }
 }
}

3. 发布变更通知

管理后台修改规则后，通知所有实例刷新缓存：

public class RuleAdminController : ControllerBase
{
 private readonly RuleChangePublisher _publisher;

 public RuleAdminController(RuleChangePublisher publisher)
 {
 _publisher = publisher;
 }

 /// <summary>
 /// 通知所有实例刷新指定规则集
 /// </summary>
 [HttpPost("rules/{ruleSet}/refresh")]
 public async Task<IActionResult> RefreshRules(string ruleSet)
 {
 await _publisher.PublishAsync(ruleSet);
 return Ok();
 }
}

工作原理

实例 A (修改规则) ──publish──▶ Redis (rules:change channel)
 │
 ┌───────────┼───────────┐
 ▼ ▼ ▼
 实例 A 实例 B 实例 C
 (清缓存) (清缓存) (清缓存)

• RedisRuleChangeListener 监听 Redis Pub/Sub 消息
• 收到消息后调用 RuleSetCache.Remove（精准刷新）或 Clear()（全量刷新）
• RuleChangePublisher 发布变更通知，供管理后台调用

消息格式

{
 "RuleSet": "discount",
 "Type": "Updated"
}