Antenna——一款简单的点对点服务治理框架,同时它也可以作为一款灵活小巧的MVC开发框架。
该框架总体逻辑架构如下:
自底向上分别为:数据层、服务层、配置层、接入层。
- 数据层:用于持久化配置、日志、分析数据、缓存等
- 服务层:提供业务逻辑等服务的实现,分为三大类:基础服务类、工具服务类、业务服务类。
- 配置层:本框架提供配置 对外暴露的接口、可调用的接口以及一些规则的配置,比如接口暴露策略、通讯协议、白名单、重试策略、加密策略、认证策略、日志框架、异常处理策略、接口路由配置。
- 接入层:本框架的暴露给外部的接口以及实现,包含接入和输出管理,同时也提供了容器的管理和支持,出口即接口调用,入口即接口受理。
- 统一的服务受理、服务调用抽象。
- 提供统一的传输认证和加密。
- 提供访问者并发控制。
- 统一的异步日志记录。
- 统一并封装了请求输入和输出。
- 对正在进行的访问可控。
- 针对调用者,提供重试机制。
- 提供统一的异常处理机制。
- 提供统一的请求过滤功能。
- 通过配置,提供灵活的功能扩展。
- 提供简单的监控功能,包括访问者进程、调用统计、日志跟踪等。
- 线上存在多应用服务,同时多应用之间需要通过接口相互通讯,若引入dubbo、springcloud可能技术成本又太高,若想简单的进行服务治理,那么antenna可能是一个不错的选择。
- 线上存在多应用服务,同时多应用之间需要通过接口相互通讯,但通讯接口分布在不同的应用中,写法千差万别,处理方式层出不穷,质量得不到统一保障,也无法统一监控分析各个接口的运作成绩。
<dependency>
<groupId>com.waspring.framework</groupId>
<artifactId>antenna-access</artifactId>
<version>1.0.0</version>
</dependency>
<listener>
<listener-class>com.waspring.framework.antenna.access.servlet.AntennaListener</listener-class>
</listener>
<context-param>
<param-name>atennaConfigLocation</param-name>
<param-value>
classpath://config.xml
</param-value>
</context-param>
<context-param>
<param-name>atennaPropertyLocation</param-name>
<param-value>
classpath://root.properties
</param-value>
</context-param>
- 参数atennaConfigLocation为为入口的配置文件,支持协议:classpath://,file://,http://
- 参数atennaPropertyLocation 为属性配置,主要是指定key,sercret,debug,logdir等参数。
- 若debug为true,那么传输认证和加密都不生效,即key,sercret配置无效。
<servlet>
<servlet-name>antennaServlet</servlet-name>
<servlet-class>com.waspring.framework.antenna.access.servlet.AntennaServlet</servlet-class>
<init-param>
<param-name>containerId</param-name>
<param-value>antennaContainer</param-value>
</init-param>
</servlet>
<servlet-mapping>
<servlet-name>antennaServlet</servlet-name>
<url-pattern>/antenna</url-pattern>
</servlet-mapping>
- containerId配置和配置文件中对应的容器ID
- 这里大家可能会问多个容器怎么办? 嗯,配置多个servlet对应!
- 接口访问地址:http://ip:port/servletname?action=providerID
PropertiesUtil.loadConfig("classpath://root.properties");
IApplication application = ApplicationUtil.getApplication().setConfigFilePath("classpath://config.xml");
LifecycleUtils.init(application);
LifecycleUtils.destory(application);
//注意:这里用到的容器名称即主配置文件配置的对应容器ID
IVisitorContainer container = ApplicationUtil.getApplication().applyContainer("antennaContainer");
IRequest request = ApplicationUtil.instanceServerRequest(container.getId(), request);//这里request也可以自己申请,设置参数isServer=true即可
IVisitor visitor = null;
visitor = container.establishVisitor(request);
//获取结果
System.out.println(visitor.getResponse());
IVisitorContainer container = ApplicationUtil.getApplication().applyContainer("antennaContainer");
///通过bean创建request对象,同样action属性会去路由invoker。
//同时bean有要求,字段只有添加了RequestField注解,才会被映射到request。
IRequest request = ApplicationUtil.instanceClientRequest(container.getId(), new TestBean());
IVisitor visitor = null;
visitor = container.establishVisitor(request);
//获取结果
System.out.println(visitor.getResponse());
那么需要在系统启动的时候执行:
PropertiesUtil.loadConfig("classpath://root.properties");
IApplication application = ApplicationUtil.getApplication().setConfigFilePath("classpath://config.xml");
LifecycleUtils.init(application);
系统关闭的时候调用:
LifecycleUtils.destory(application);
请参考 配置详解
#通讯认证用到key
key=123501
#通讯认证用到的sercret
secret=RTUDUDO0232KDJDU1Ie33IIU3139I
#调试模式,设置为true通讯认证不会开启
debug=true
#默认通讯日志存储目录
logdir=logs
请移步 antenn-client 或者 antenn-monitor
- 服务发现
目前本框架在真正的服务治理上还比较弱,仅仅支持点对点的发现,且依赖于本地的服务配置。
- 性能与内存消耗
为了提高程序的并发处理能力,当前每次visitor访问都需要反射创建provider或者invoker来处理业务逻辑,执行效率和内存上都会打折扣。
我们可以参考servlet的架构思路优化,即处理程序只创建一次,访问方法保证线程安全。
- 异常处理机制
目前异常方面会被吃掉很多,没有逐级上浮,虽然可以通过log跟踪,我们希望还是能从用户端直接判断大部分异常场景!
- 配置管理
目前通过xml配置受理者和调用者,同时要在应用启动的时候指定容器,配置起来其实挺繁琐,我们希望通过注解等方式来简化配置!
另外当前也不支持动态配置,可以使用第三方全局一致性服务来实现。
- 传输认证与加密
本框架虽然支持认证与加密,但有以下两个缺陷,一方面在传输数据量较大场景效率很低下,另一方面认证机制依赖双方的本地化配置,安全性和可维护下大大折扣。
当前可以通过扩展request对象解决,比如采用第三方认证中心。
- 通讯日志
本框架通讯日志默认采用异步队列本地文件存储,在真正的正式环境中,我们一般不会这么做,基本上会采用第三方的存储服务,可以通过扩展:IQueueTaskHander来实现。
- 重试机制
目标重试机制实现主要是通过第三方框架guava-retrying实现,进行了简单封装,使用变得简单,同时扩展能力缺被削弱了。
- 补偿机制
这里的补偿主要是指当一次调用失败后,然后刚好服务重启,是否要进行重试的机制,目前框架并未支持。可以考虑请求前持久化等方案!
详细开发引导请见:开发手册