登录

去注册 忘记密码?

登录

注册

去登录

  • 扫码关注公众号
  • 发送“我爱安卓
  • 即可获取验证码

注册

解锁回答区域

  • 扫码关注公众号
  • 发送“我爱安卓

若你登陆,将永久解锁;
若未登录,仅本机解锁。

解锁回答区域

获取注册验证码

  • 扫码关注公众号
  • 发送“我爱安卓
  • 即可获取验证码

WorkFlow-轻松低成本解决串行调用链之间的耦合

soulqw   2020-04-26 22:45   收藏

WorkFlow

简化顺序调用方法之间的嵌套和耦合:

  • 轻松替换方法调用之间的顺序关系

  • 提高代码简洁性和可读性、降低维护成本

  • 增删改方便,提高效率

Installation:

dependencies {
     implementation 'com.qw:workflow:0.0.2'
}

Usage:

场景示例1

依次顺序的展示Toast,Dialog,SnackBar:

    private static final int STEP_TOAST = 1;

    private static final int STEP_DIALOG = 2;

    private static final int STEP_SNACK_BAR = 3;

    private void startWorkFlow() {
        new WorkFlow.Builder()
                .withNode(WorkNode.build(STEP_TOAST, new Worker() {
                    @Override
                    public void doWork(final Node current) {
                        //do any work you want
                        Toast.makeText(MainActivity.this, "step for toast", Toast.LENGTH_SHORT).show();
                        new Handler().postDelayed(new Runnable() {
                            @Override
                            public void run() {
                                //call it when finish work
                                current.onCompleted();
                            }
                        }, 2000);

                    }
                }))
                .withNode(WorkNode.build(STEP_SNACK_BAR, new Worker() {
                    @Override
                    public void doWork(final Node current) {
                        Snackbar.make(findViewById(R.id.btn_after), "step for snack_bar", Snackbar.LENGTH_SHORT).show();
                        new Handler().postDelayed(new Runnable() {
                            @Override
                            public void run() {
                                current.onCompleted();
                            }
                        }, 2000);
                    }
                }))
                .withNode(WorkNode.build(STEP_DIALOG, new Worker() {
                    @Override
                    public void doWork(final Node current) {
                        new AlertDialog.Builder(MainActivity.this)
                                .setTitle("step for show dialog")
                                .setPositiveButton("complete", null)
                                .setOnDismissListener(new DialogInterface.OnDismissListener() {
                                    @Override
                                    public void onDismiss(DialogInterface dialogInterface) {
                                        current.onCompleted();
                                    }
                                }).create().show();
                    }
                })).create()
                .start();
    }

效果如图:

image

假如现在需要让Dialog和SnackBar,替换位置,只需要让Dialog定义值比SnackBar大即可:

    private static final int STEP_TOAST = 1;

    private static final int STEP_DIALOG = 20;

    private static final int STEP_SNACK_BAR = 3;

效果如下:

image

场景示例2

进入APP首页按顺序请求3个接口,第一个接口和第三个接口成功后启动对话框,第二个接口跳转到Web页面

public class AfterActivity extends AppCompatActivity {

    private static final int REQUEST_CODE_H5 = 1;

    /**
     * 初次广告弹框
     */
    private static final int NODE_FIRST_AD = 10;

    /**
     * 初次进入h5页
     */
    private static final int NODE_CHECK_H5 = 20;

    /**
     * 初次进入的注册协议
     */
    private static final int NODE_REGISTER_AGREEMENT = 30;

    private WorkFlow workFlow;

    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_compare);
        ((TextView) findViewById(R.id.tv_desc)).setText("使用后");
        startWorkFlow();
    }

    private void startWorkFlow() {
        workFlow = new WorkFlow.Builder()
                .withNode(getFirstAdNode())
                .withNode(getShowRegisterAgreementNode())
                .withNode(getShowH5Node())
                .create();
        workFlow.start();
    }

    private WorkNode getFirstAdNode() {
        return WorkNode.build(NODE_FIRST_AD, new Worker() {
            @Override
            public void doWork(final Node current) {
                Utils.fakeRequest("http://www.api1.com", new HttpCallBack() {
                    @Override
                    public void onOk() {
                        new AlertDialog.Builder(AfterActivity.this)
                                .setTitle("这是一条有态度的广告")
                                .setPositiveButton("我看完了", null)
                                .setOnDismissListener(new DialogInterface.OnDismissListener() {
                                    @Override
                                    public void onDismiss(DialogInterface dialogInterface) {
                                        //仅仅只需关心自己是否完成,下一个节点会自动执行
                                        current.onCompleted();
                                    }
                                }).create().show();
                    }

                    @Override
                    public void onFailure() {
                        //仅仅只需关心自己是否完成,下一个节点会自动执行
                        current.onCompleted();
                    }
                });
            }
        });
    }

    private WorkNode getShowRegisterAgreementNode() {
        return WorkNode.build(NODE_REGISTER_AGREEMENT, new Worker() {
            @Override
            public void doWork(final Node current) {
                Utils.fakeRequest("http://www.api2.com", new HttpCallBack() {
                    @Override
                    public void onOk() {
                        new AlertDialog.Builder(AfterActivity.this)
                                .setTitle("这是注册协议")
                                .setPositiveButton("我看完了", null)
                                .setOnDismissListener(new DialogInterface.OnDismissListener() {
                                    @Override
                                    public void onDismiss(DialogInterface dialogInterface) {
                                        current.onCompleted();
                                    }
                                }).create().show();
                    }

                    @Override
                    public void onFailure() {
                        current.onCompleted();
                    }
                });
            }
        });
    }

    private WorkNode getShowH5Node() {
        return (WorkNode.build(NODE_CHECK_H5, new Worker() {
            @Override
            public void doWork(final Node current) {
                Utils.fakeRequest("http://www.api3.com", new HttpCallBack() {
                    @Override
                    public void onOk() {
                        startActivityForResult(new Intent(AfterActivity.this, TestH5Activity.class), REQUEST_CODE_H5);
                    }

                    @Override
                    public void onFailure() {
                        current.onCompleted();
                    }
                });
            }
        }));
    }

    @Override
    protected void onActivityResult(int requestCode, int resultCode, @Nullable Intent data) {
        super.onActivityResult(requestCode, resultCode, data);
        switch (requestCode) {
            case REQUEST_CODE_H5:
                workFlow.continueWork();
                break;
            default:
                break;
        }
    }
}

效果:

image

流程:

image

功能介绍:

  • 每个节点只关注自己是否完成:

    private WorkNode getFirstAdNode() {
          return WorkNode.build(NODE_FIRST_AD, new Worker() {
              @Override
              public void doWork(final Node current) {
                  //仅仅只需关心自己是否完成,下一个节点会自动执行
                  current.onCompleted();
              }
          });
      }
    
  • 可以操作WorkFlow对象来控制全局节点

    public class WorkFlow {
    
      /**
       * 标记为处理完成,调用后不再能执行任何开启的操作
       */
      public void dispose()
    
      /**
       * 给workflow添加一个工作节点
       *
       * @param workNode 节点
       */
      public void addNode(WorkNode workNode)
    
      /**
       * 开始工作,默认从第一个节点
       */
      public void start()
    
      /**
       * 基于某个节点Id 开始工作
       *
       * @param startNodeId 节点id
       */
      public void startWithNode(int startNodeId)
    
      /**
       * 让当前工作流继续工作
       * 效果等同于当前节点调用 Node.onCompleted
       */
      public void continueWork()
    
      /**
       * 回退
       * 基于最近节点回退至上一节点
       */
      public void revert()
    
    }
    

更多代码可参考demo

工作原理和最佳示例

GitHub地址

项目地址:https://github.com/soulqw/WorkFlow