分布式消息总线,基于.NET Socket Tcp的发布-订阅框架之离线支持,附代码下载
一、分布式消息总线以及基于Socket的实现 在前面的分享一个分布式消息总线,基于.NET Socket Tcp的发布-订阅框架,附代码下载一文之中给大家分享和介绍了一个极其简单也非常容易上的基于.NET Socket Tcp 技术实现的分布消息总线,也是一个简单的发布订阅框架: 并且以案例的形式为大家演示了如何使用这个分布式消息总线架构发布订阅架构模式的应用程序,在得到各位同仁的反馈的同时,大家也非常想了解订阅者离线的情况,即支持离线构发布订阅框架。 二、离线架构 不同于订阅者、发布者都同时在线的情况,支持订阅者离线,架构将有所变化,如下图所示: 也会比原先的结构将更加复杂,其中需要处理以下两个关键点: 1)订阅者的持久化存储。 2)订阅者离线之后其所订阅消息的持久存储。 三、解决方案 为解决消息总线的离线支持机制,我们在Socket 框架之中增加了一个接口ISubscribeStorager: 1: using System; 2: using System.Collections.Generic; 3: using System.Linq; 4: using Sys...


