文档章节

消息智能路由组件SmartRoute

泥水佬
 泥水佬
发布于 2015/08/17 15:57
字数 1419
阅读 211
收藏 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

© 著作权归作者所有

共有 人打赏支持
泥水佬

泥水佬

粉丝 69
博文 82
码字总数 51372
作品 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

没有更多内容

加载失败,请刷新页面

加载更多

URL访问网站的网络传输全过程

打开浏览器,在地址栏输入URL,回车,出现网站内容。这是我们几乎每天都在做的事,那这个过程中到底是什么原理呢?HTTP、TCP、DNS、IP这些耳熟能详的名词都在什么时候起着什么作用呢?在这里...

MrBoyce
15分钟前
1
0
都9102年了,还不会Docker?10分钟带你从入门操作到实战上手

Docker简述 Docker是一种OS虚拟化技术,是一个开源的应用容器引擎。它可以让开发者将应用打包到一个可移植的容器中,并且该容器可以运行在几乎所有linux系统中(Windows10目前也原生支持,W...

公众号_Zack说码
16分钟前
2
0
day175-2018-12-12-英语流利阅读-待学习

日本报纸修改二战“慰安妇”描述,引发众怒 雪梨 2018-12-12 1.今日导读 第二次世界大战期间,日本肆意侵略其他国家,所到之处,无数妇女沦为日本士兵肆意践踏的对象。半个多世纪过去了,面对...

飞鱼说编程
18分钟前
2
0
TiDB 源码阅读系列文章(二十一)基于规则的优化 II

在 TiDB 源码阅读系列文章(七)基于规则的优化 一文中,我们介绍了几种 TiDB 中的逻辑优化规则,包括列剪裁,最大最小消除,投影消除,谓词下推和构建节点属性,本篇将继续介绍更多的优化规...

TiDB
24分钟前
1
0
mysql 时间格式化

DATE_FORMAT

1713716445
30分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部