文档章节

消息智能路由组件SmartRoute

泥水佬
 泥水佬
发布于 2015/08/17 15:57
字数 1419
阅读 209
收藏 2

         消息传递在软件开发过程中是一件很常见的事情,而在不同的场景所使用消息传递方式也有所不同,在对象之间制定相关接口方法和对象结构,对于进程之间可能使用内存共享或一些通讯产品,在不同服务器之的消息通讯则使用一些通讯产品(MQ)或构建满足自己的RPC通讯机制.不同场景技术人员都要掌握不同的技术方法来实现,由于应用技术和差异性容易导致开发成本和维护成本的上涨,为了解决这一系列的问题在这段时候思考后实现一种统一的消息传递方式,而这种应用方式不管是对象间,进程或服务器在应用上都不会任何差,在这里称这技术为消息智能路由(为了快速验证想法,大概花了一周的业余时间制定了一个可用的原型).

SmartRoute可实现场景

如何智能?

         SmartRoute是依据订阅者的ID来进行消息发送传递,类似于邮件地址一样;只要在订阅的时候制定相应的接收实现即可接收投递到这一ID的消息.然而这方式非常普通并没有什么所谓智能高大上在这里.其实SmartRoute的智能优点在于技术人员完全不用去关心订阅者所在的位置,不管是当前程序,其他应用程序还是其他服务器,SmartRoute都可以自动地帮你投递过去.最重要的是技术人员完全不用配置任何环境和安装任何中间服务,只需要在程序中加载SmartRoute这系列的工作都可以自动完成(没错,即使你是跨服务器投递消息也不需要做额外的配置和安装中间服务器);每个SmartRoute实例除承担着接收和投递工作的同时也承担了消息路由的角色;不同进程和不同服务器运行的SmartRoute实例会自动组建集群(而这个自动构建也不需要配置或安装服务)

Hello应用

         一个组件的易用性才能体现它的价值,所以在设计SmartRoute的时候就遵循一个原则,在应用中尽量做到不需要配置即可用.以下通过通过简单的Hello程序来描述一下组件设计的易用性.

HelloRequest

class Request : ISubscribeHandler
    {
        public Request()
        {
            Route.Subscribe("Ken", this);
        }

        public DateTime CreateTime
        {
            get;
            set;
        }

        public void Say(string name)
        {
            Hello hello = new Hello { Name ="hello "+ name };
            hello.SendTo(s => s.From("Ken"), "henry");
        }

        public ILogHandler Log
        {
            get;
            set;
        }

        public void Process(INode node, IMessage message)
        {
            Hello hello = message.GetBody<Hello>();
            Console.WriteLine("{0} Request  receive:{1}",DateTime.Now, hello.Name);
        }
    }

HelloReqponse

class Response : ISubscribeHandler
    {
        public Response()
        {
            Route.Subscribe("henry", this);
        }
        public DateTime CreateTime
        {
            get;
            set;
        }

        public ILogHandler Log
        {
            get;
            set;
        }

        public void Process(INode node, IMessage message)
        {
            Hello hello = message.GetBody<Hello>();
            Console.WriteLine("{0} response receive:{1}",DateTime.Now, hello.Name);
            hello.Name = "hello " + message.Sender;
            hello.SendTo(message.Sender);
        }
    }

RequestResponse各自订阅了信息,通过实现ISubscribeHandler来接收投递过来的消息.可以通过运行以下代码来测试订阅的有效性.

class Program
    {
        static Request request;
        static Response response;
        static void Main(string[] args)
        {
            request = new Request();
            response = new Response();
            while (true)
            {
                request.Say("henry");
                System.Threading.Thread.Sleep(3000);
            }
        }
    }

l  运行结果

扩展进程间通讯

         对于SmartRoute对现有的订阅进行跨进程访问则是一件非常简单的事件,并不需要修改或配置任何代码即可完成.下面分别建两个程序分别引用HelloRequestHelloResponse

HelloRequestApp

class Program
    {
        static Request request;
        static void Main(string[] args)
        {
          
            request = new Request();
            while (true)
            {
                request.Say("henry");
                System.Threading.Thread.Sleep(3000);
            }
        }
    }

HelloResponseApp

class Program
    {
      
        static Response response;
        static void Main(string[] args)
        {
           
            response = new Response();
            System.Threading.Thread.Sleep(-1);
        }
    }

l  运行结果


服务器间通讯

         SmartRoute在同一个局域网内会自动发现和组建路由,所以在不调整任何设计和代码的情况下,只需要把两个应用部署在不同服务器就可以进行信息订阅和发送.

技术要点

l  通信功能

除了本进程内订阅和转发不需要涉及到通讯外,进程和服务器间都需要通讯服务.所以做这样一个功能需要点通讯技术经验,不过现在成熟的开发的通讯库也有不少可以直接拿来用.

l  节点发现和握手

组件的灵活之处就是不需要任何配置就能实现交互,所以每个节点都具备发其他节点的能力;为了满足这一需求需要使用UDP广播技术,每个节点都会把自己的服务信息广播出去,当其他节点接收到这些信息后就创建握手连接.

l  同步订阅信息

由于在设计的过程中强调没有数据中心点,就是整个集群里的所有节点都是相互直连的.所以每个节点的订阅信息都会同步到不同节点上,这样才能保证消息投递的有效性.为了保证订阅的有效性同样订阅取的时候需要告诉其他节点变更情况.

l  制定订阅规则

订阅在接收消息处理的情况是多样性的,有可能是操作数据库,HTTP或者网络转发;所以需要给订阅制定规划,让使用者可以实现不同的订阅处理.

以下是一个简单网络转发订阅

public class TCPSubscribeHandler : ISubscribeHandler
    {
        public ILogHandler Log { get; set; }

        public IChannel Channel
        {
            get;
            set;
        }

        public void Process(INode node, IMessage message)
        {
            Channel.Server.Send(message,Channel);
        }

        public DateTime CreateTime
        {
            get;
            set;
        }
    }

下载DEMO

© 著作权归作者所有

共有 人打赏支持
泥水佬

泥水佬

粉丝 65
博文 75
码字总数 42355
作品 7
广州
架构师
加载中

评论(1)

红薯
红薯
建议把代码放到 git.oschina.net 上
SmartRoute应用-helloWorld示例

本章主要是通过helloWorld来介绍SmartRoute组件的使用,SmartRoute和一般的通讯组件使用方式用点差别,使用方式主要强调就用零配置和零安装即可用.在传统通讯应用中需要开启服务端然后由另一方...

泥水佬
2015/08/24
0
0
smartroute集成聊天通讯集群

在制定一个规模比较多大的聊天应用时,往往需要制定部署多个应用服务,其一可以保障服务的可靠性,其二可以增加用户负载量.但制定这样一种应用体系是一件复杂的事情,毕竟同一群体的用户实际上会...

泥水佬
2015/08/26
0
0
基于 Dotnet Core 的服务通讯组件--SmartRoute

SmartRoute 是基于Dotnet Core设计的可运行在linux和windows下的服务通讯组件,其设计理念是去中心化和零配置即可实现服务通讯集群。SmartRoute是通过消息订阅的机制实现服务与服务之间的通讯...

泥水佬
2016/11/08
1K
2
.Net Core开源通讯组件 SmartRoute(服务即集群)

SmartRoute是基于Dotnet Core设计的可运行在linux和windows下的服务通讯组件,其设计理念是去中心化和零配置即可实现服务通讯集群。SmartRoute是通过消息订阅的机制实现服务与服务之间的通讯...

泥水佬
2016/11/08
99
0
SmartRoute零配置零安装实现分布式负载应用

随着应用规模的增长服务则需要扩展集群休部署,在集群化部署过程首先要考虑服务负载处理的问题,在实现应用场中有很多集群化的负载方式,如网络通讯层面的LVS,HTTP应用协议层面的nginx.然而这...

泥水佬
2016/01/14
174
0

没有更多内容

加载失败,请刷新页面

加载更多

Mac OS X下Maven的安装与配置

Mac OS X 安装Maven: 下载 Maven, 并解压到某个目录。例如/Users/robbie/apache-maven-3.3.3 打开Terminal,输入以下命令,设置Maven classpath $ vi ~/.bash_profile 添加下列两行代码,之后...

TonyStarkSir
今天
3
0
关于编程,你的练习是不是有效的?

最近由于工作及Solution项目的影响,我在重新学习DDD和领域建模的一些知识。然后,我突然就想到了这个问题,以及我是怎么做的? 对于我来说,提升技能的项目会有四种: 纯兴趣驱动的项目。即...

问题终结者
今天
4
0
打开eclipse出现an error has occurred see the log file

解决方法: 1,打开eclipse安装目录下的eclipse.ini文件; 2,打开的文本文件最后添加一行 --add-modules=ALL-SYSTEM 3,保存重新打开Eclipse。...

任梁荣
昨天
4
0
搞定Northwind示例数据库,无论哪个版本的SQLServer都受用

Northwind数据库 从这里可以找到突破口: http://social.msdn.microsoft.com/Forums/zh-CN/Vsexpressvb/thread/8490a1c6-9018-40c9-aafb-df9f79d29cde 下面是MSDN: http://msdn2.microsoft......

QQZZFT
昨天
1
0
mysql主从同步,安装配置操作

准备 两台mysql服务,我这里准备了如下: 主库:192.168.176.128 从库:192.168.176.131 如何在Linux上安装mysql服务,请看https://blog.csdn.net/qq_18860653/article/details/80250499 操作...

小致dad
昨天
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部