码云推荐 |基于 Spring 的分布式实时处理框架 R3

R3 FRAMEWORK – 分布式实时处理框架

简介

基于Spring的分布式实时处理框架。

逻辑架构设计

包结构设计

配置样例

Worker端

 
    
    
   

Leader端

    
   

配置属性

r3:application 应用配置

AttributeDescription
name应用名称,必须项,同名的application为同组,组内软负载取其一。
host监听地址,默认为“AUTO”,如果为“AUTO”的话,会自动采用本机IP地址。多网卡的情况下可以手动设置IP。
port监听端口,默认为20080。

r3:registry 注册中心配置

AttributeDescription
address注册中心zookeeper的地址,默认为“localhost:2181”。
namespace应用注册的命名空间,zookeeper的根节点,默认为:r3。
sessionTimeout回话超时时间设置,单位为毫秒,默认为3000。
connectionTimeout连接的超时时间,单位为毫秒,默认为3000。
interval多次尝试注册服务的时间间隔,单位为毫秒,默认为30000。

r3:worker 工作者配置

AttributeDescription
idspring bean id。
ref引用的spring的bean。
interface实现的接口类。

r3:leader 代理者配置

AttributeDescription
idspring bean id。
interface代理的接口类。
loadbalance负载策略,默认为“random”,尚不支持其他策略。

版本说明

采用行星名称命名。

后续开发计划

  1. 引入Filter概念,提供r3-filter模块。
  2. 引入leader的超时和重试机制。
  3. 提供其他的LoadBalance策略。
开源中国责编内容来自:开源中国 (源链) | 更多关于

阅读提示:酷辣虫无法对本内容的真实性提供任何保证,请自行验证并承担相关的风险与后果!
本站遵循[CC BY-NC-SA 4.0]。如您有版权、意见投诉等问题,请通过eMail联系我们处理。
酷辣虫 » 综合编程 » 码云推荐 |基于 Spring 的分布式实时处理框架 R3

喜欢 (0)or分享给?

专业 x 专注 x 聚合 x 分享 CC BY-NC-SA 4.0

使用声明 | 英豪名录