开源软件名称:chains-spring-boot-component
开源软件地址:https://gitee.com/MiMose/chains-spring-boot-component
开源软件介绍:
CHAINS-SPRING-BOOT-COMPONENT链路组件使用方法:1、创建对应的链路类,继承Chain,首先实现里面的myName()方法,为链路添加一个唯一的标识;若存在满足的链路类,则直接使用 public class ExampleChain extends Chain { @Override public void withInvokers() { // 第3步完成后设置 } @Override public String myName() { // 这个字符串保证唯一,使用该字符串来获取对应的链路 return "example" }} 2、创建对应的请求实体,继承RequestBaseDto; 创建对应的响应实体,继承ResponseBaseDto;若已存在满足的实体,则直接使用 public class ExampleRequestDto extends RequestBaseDto { // 该实体用于传递链路处理的参数 private String param1; private Object param2;}public class ExampleResponseDto extends ResponseBaseDto { // 该实体用于返回处理后的结果,在链路的各个处理器中都能使用 private String result1; @JSONField(format = "yyyy-MM-dd") private Date result2;} 3、创建对应的处理类,继承Invoker;若存在满足的处理类,则直接使用 public class ExampleInvoker_one extends Invoker<ExampleRequestDto, Response> { @Override public Response invoke0(ExampleRequestDto request, Response tResponse) { // 可以通过该方法获取到上个处理器的结果。 当该处理器是第一个处理器时,将获取到一个新的结果,否则获取到上个处理结果 ExampleResponseDto response = super.getLastResponse(tResponse, ExampleResponseDto.builder().build()); // 具体的处理逻辑 // do something // 在处理后,可以根据处理情况,选择是否要中断本次链路 // 若要中断,则返回 return tResponse.end(true, response); // 若要继续进行,则返回 return tResponse.end(false, response); }} 4、实现具体链路类中的withInvokers方法,初始化该链路的所有处理类 public class ExampleChain extends Chain { @Override public void withInvokers() { // 第3步完成后设置 invoker = new ExampleInvoker_one(); //若该链路有2个及2个以上的处理器,通过setNext来进行处理器的增加 invoker.setNext(new ExampleInvoker_two()); invoker.setNext(new ExampleInvoker_three()); // ... } @Override public String myName() { // 这个字符串保证唯一,使用该字符串来获取对应的链路 return "example" }} 5、在业务代码里使用链路: 5.1、同步调用获取结果: // 创建参数、调用链路:ExampleRequestDto requestDto = ExampleRequestDto.builder().param1("参数1").param2("参数2").build();Response<ExampleResponseDto> resp = (Response) Chain.newChain("example").invoke(Request._Request(requestDto)); 获取对应链路 -------> 使用链路中的处理器进行Request处理 // 获取结果ExampleResponseDto respDto = resp.getResponse(); 5.2、异步调动回调结果: 为避免主线程执行过程中,由于暂时不需要该结果,而链路执行会阻塞主线程,导致的主线程执行时间变长,使用Task来进行异步调用获取结果,不阻塞主线程 // 创建参数,先在主线程中获取到链路的task ExampleRequestDto requestDto = ExampleRequestDto.builder().param1("参数1").param2("参数2").build();ResponseAsyn<ExampleResponseDto> resp = (ResponseAsyn) Chain.newChain("example").withSync().invoke(Request._Request(requestDto)); 获取对应链路 -----开启异步任务模式---> 使用链路中的处理器进行Request处理// 主线程继续执行// 主线程业务逻辑....// 到了需要获取链路结果的时候,调用回调方法获取结果(需要传入超时时间[秒],避免链路长时间处理,影响业务) ExampleResponseDto responseDto = resp.getResponse(3); |
请发表评论