Orleans Streams 是 Orleans 的消息传递抽象层，用于 grain 间可靠、有序、可重放地传递事件，适用于订单广播、实时指标推送、传感器数据聚合等场景；需显式配置 stream provider（如 AzureQueueStreamProvider），消费端须在 OnActivateAsync 中订阅并持久化 handle，注意命名空间、序列化器一致性及 grain 激活状态。
Orleans Streams 是什么，适合哪些场景
Orleans Streams 不是传统意义上的“流式计算框架”，它本质是 Orleans 的一种消息传递抽象层，用于在 grain 之间可靠、有序、可重放地传递事件。它不处理窗口、聚合、时间语义等 Flink/Spark Streaming 的能力，而是解决“如何让多个 grain 协同响应同一类事件”这个分布式协调问题。
常见适用场景包括：
- 订单状态变更广播给相关用户 grain 和通知 grain
- 实时指标更新推送给仪表盘 grain
- 多个 sensor grain 向一个聚合 grain 上报数据（需配合 stream provider 配置）
关键点：stream 本身无状态，状态必须落在 grain 上；事件顺序由 stream provider 保证（如 Azure Queue、RabbitMQ、MemoryStreamProvider），但跨 stream 不保证全局序。
如何配置和使用 IStreamProvider
Orleans 3.0+ 默认不启用任何 stream provider，必须显式注册。最常用的是 MemoryStreamProvider（仅本地开发）和 AzureQueueStreamProvider（生产推荐）。
配置示例（Program.cs）：
builder.AddAzureQueueStreams("azurequeue", configureOptions => { configureOptions.ConnectionString = "DefaultEndpointsProtocol=https;AccountName=xxx;AccountKey=xxx;"; configureOptions.QueueName = "orleans-streams"; });
使用时通过 grain 内部注入 IStreamProvider 获取 stream：
var streamProvider = GetStreamProvider("azurequeue");
var stream = streamProvider.GetStream(
streamId: StreamId.Create("order-updates", "shard-123"),
streamNamespace: "OrderEvents"); 注意：StreamId.Create 第二个参数是 namespace，不是 provider name；同一个 namespace 下不同 streamId 互不干扰。
如何让 grain 消费 stream 事件
消费端 grain 必须实现 IAsyncObserver 或继承 AsyncStreamConsumer（Orleans 7+ 推荐后者）。不能直接在普通 grain 方法里调用 stream.SubscribeAsync——订阅必须在 grain 激活生命周期内完成，且需持久化订阅关系（否则重启后丢失）。
正确做法：
- 在 grain 的
OnActivateAsync中执行订阅 - 使用
GetStreamProvider(...).GetStream(...).SubscribeAsync(this) - grain 类需标记
[ImplicitStreamSubscription("OrderEvents")]（自动订阅命名空间下所有 stream）或手动管理 subscription token
常见错误：
- 在构造函数里订阅 → grain 尚未激活，
IStreamProvider不可用 - 忘记保存
StreamSubscriptionHandle→ 无法取消订阅，内存泄漏 - 同一 grain 实例重复订阅同一 stream → 触发重复处理（Orleans 不去重）
为什么事件没收到？排查 stream 通信失败的典型原因
Orleans Streams 故障往往静默，不抛异常，只表现为“没触发”。
检查清单：
-
IStreamProvider名称在发布端和消费端是否完全一致（大小写敏感） - stream namespace 和 streamId 是否匹配（特别是
StreamId.Create的两个参数顺序） - 消费 grain 是否真的激活了？用
GrainFactory.GetGrain触发一次激活(id).DoSomething() - 日志中是否有
Streaming: Failed to deliver event或Unable to resolve stream provider（开启Microsoft.Orleans.Streaming日志级别为 Debug） - Azure Queue 场景下，确认 queue 存在、权限正确、SAS token 未过期；MemoryStreamProvider 下确认未跨 silo（它不跨节点）
真正容易被忽略的是：stream provider 的序列化器必须两端一致。比如发布端用 SystemTextJsonSerializer，消费端却用 NewtonsoftJsonSerializer，事件会静默丢弃——连日志都不报。
