开源软件名称：

开源软件地址：

https://gitee.com/zhoufn/r3

开源软件介绍：

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

简介

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

逻辑架构设计

包结构设计

配置样例

接口样例

    public interface SayHelloService {        @Out(SayHelloOutHandler.class)        @In(SayHelloInHandler.class)        List<String> sayHello(List<String> names);    }

分流类

    public class SayHelloOutHandler extends OutHandler {        @Override        public List<Object[]> shard(Object[] parameters, int shardCount) throws Throwable {            List<Object[]> result = new ArrayList<>();            List<String> param = (List<String>) parameters[0];            int perSize = param.size() / shardCount;            for(int i=0;i<shardCount;i++){                result.add(new Object[]{param.subList(i*perSize,(i!=shardCount-1?(i+1)*perSize:param.size()))});            }            return result;        }    }

合流类

    public class SayHelloInHandler extends InHandler {        @Override        public Object join(Object[] results) throws Throwable {            List<String> list = new ArrayList<>();            for(Object object : results){                list.addAll((List<String>)object);            }            return list;        }    }

实现类样例

public class SayHelloServiceImpl implements SayHelloService {    @Override    public List<String> sayHello(List<String> names) {        List<String> newNames = new ArrayList<>();        for (String name : names) {            String newName = "hello " + name;            newNames.add(newName);        }        return newNames;    }}

Worker端

   <r3:application name="worker-1" host="AUTO" port="20080"></r3:application>    <r3:registry address="localhost:2181" namespace="r3"></r3:registry>    <r3:worker id="sayHelloWorker" ref="sayHelloServiceImpl" interface="r3.example.api.SayHelloService"></r3:worker>    <bean id="sayHelloServiceImpl" class="r3.example.worker.SayHelloServiceImpl" scope="prototype"></bean>

Leader端

   <r3:application name="leader-one" ></r3:application>   <r3:registry address="localhost:2181" namespace="r3"></r3:registry>    <r3:leader id="sayHelloServiceImpl" interface="r3.example.api.SayHelloService"></r3:leader>

配置属性

@Out 接口配置

注解类，应用于API接口上，用于参数分流。

Attribute	Description
value	用户自定义参数分流类，需要继承自r3.flow.OutHandler

@In 接口配置

注解类，应用于API接口上，用于参数合流

Attribute	Description
value	用户自定义参数合流类，需要继承自r3.flow.InHandler

r3:application 应用配置

<r3:application name="worker-1" host="localhost" port="20080"></r3:application>

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

r3:registry 注册中心配置

<r3:registry address="localhost:2181" namespace="r3"></r3:registry>

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