Android-自定义Router(路由)

  private static final String TAG = "Xrouter";

    //使用volatile关键字的好处是保证线程可见
    public static volatile Xrouter  mXrouter ;
    //使用HashMap初始化一个队列mXactions，用来存储不同种类的消息通道
    public static HashMap<String,Xaction> mXactions ;


    private  Xrouter() {
        mXactions =new HashMap<>();
    }

//单例模式,支持多线程。参考：https://www.jianshu.com/p/769f2593c94e
    public static Xrouter getInstance(){
        if(mXrouter == null){
           synchronized (Xrouter.class){
               if(mXrouter == null){
                   mXrouter =new Xrouter();
               }
           }
        }
        return mXrouter;
    }


    //往消息队列插入不同消息通道的方法，这里参数包括通道名称和通道本身Xaction.java
    public  void registerAction(String actionKey,Xaction xaction){
        if(mXactions.containsKey(actionKey)){
            Log.e(TAG, "该通道已经注册");
        }else{
            mXactions.put(actionKey,xaction);
        }

    }



    //对应通道发送消息的方法
    public  XrouterResponse senMessage(Context context ,XrouterRequest xrouterRequest){
       XrouterResponse mXrouterResponse=new XrouterResponse();
       Xaction mXaction =getmXAction(xrouterRequest.getActionName());
       //Xaction对象不为空，说明该通道存在，之前已经注册，可以正常发送消息
       if(mXaction != null){
           //将发送的消息内容(xrouterRequest.getData())传递给对应的Xaction的实现类
           Object mObject =mXaction.startAction(context,xrouterRequest.getData());
           mXrouterResponse.setResponseResult(XrouterResponse.RESPONSE_SUCCESS_CODE,XrouterResponse.RESPONSE_SUCCESS,mObject);

       }else{
           mXrouterResponse.setResponseResult(XrouterResponse.RESPONSE_FAIL_CODE,XrouterResponse.RESPONSE_FAIL,"该Xaction没有创建");

       }

     return mXrouterResponse;
    }


    //返回消息通道对应的对象
    public Xaction  getmXAction(String actionName){
        if(mXactions.containsKey(actionName)){
            return mXactions.get(actionName);
        }
        return null;
    }

public class XrouterRequest {

    //消息通道名称
    private String  mActionName;
    //消息通道携带的数据
    private HashMap<String ,Object > mData;


    private XrouterRequest(){
        mData =new HashMap<>();
    }

    public static XrouterRequest create(){
        return new XrouterRequest();
    }


     public XrouterRequest putData(String key, Object value){
         mData.put(key,value);
         return this;
     }

    public XrouterRequest putActionName(String actionName){
        mActionName=actionName;
        return this;
    }


     public String getActionName(){
        return this.mActionName;
     }


     public HashMap<String ,Object> getData(){
        return this.mData;
     }


}

public class XrouterResponse {

    public static final String RESPONSE_SUCCESS="发送消息成功";
    public static final String RESPONSE_FAIL="发送消息失败";
    public static final  int RESPONSE_SUCCESS_CODE=1;
    public static final  int RESPONSE_FAIL_CODE=0;


    //状态码
     private int mcode;
     //描述：消息发送成功或失败
     private String mdes;
     //消息反馈的其他信息
     private Object mbody;



     //获取响应消息
     public JSONObject getResponseResult(){
         JSONObject mJSONObject=null;
         try {
             mJSONObject =new JSONObject();
             mJSONObject.put("code",mcode).put("des",mdes).put("content",mbody);
         } catch (JSONException e) {
             e.printStackTrace();
         }
         return mJSONObject;
     }



     //设置响应消息
     public  void setResponseResult(int code ,String des,Object obj){
         this.mcode=code;
         this.mdes=des;
         this.mbody=obj;
     }
}

public class MainActivity extends AppCompatActivity {
 Button btn_sameProcess;
 Button btn_differentProcess;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);

    btn_sameProcess=findViewById(R.id.sameprocess);
    btn_differentProcess=findViewById(R.id.differnetprocess);

    btn_differentProcess.setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View v) {
            //封装传递的请求数据到XrouterRequest
            XrouterRequest mXrouterRequest =XrouterRequest.create().putData("data","发给不同进程的数据测试").putActionName(DifferentProcessActionMessage.DIFFERENTPROCESSACTIONNAME);
            XrouterResponse mXrouterResponse=Xrouter.getInstance().senMessage(MainActivity.this,mXrouterRequest);
            Toast.makeText(MainActivity.this,mXrouterResponse.getResponseResult()+"",Toast.LENGTH_LONG).show();

        }
    });
    btn_sameProcess.setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View v) {
            //封装传递的请求数据到XrouterRequest
            XrouterRequest mXrouterRequest =XrouterRequest.create().putData("data","发给同进程的数据测试").putActionName(SameProcessActionMessage.SANEPORICESSBANE);
            XrouterResponse mXrouterResponse=Xrouter.getInstance().senMessage(MainActivity.this,mXrouterRequest);
            Toast.makeText(MainActivity.this,mXrouterResponse.getResponseResult()+"",Toast.LENGTH_LONG).show();

        }
    });
}}

public class BaseApplication extends Application {

    @Override
    public void onCreate() {
        super.onCreate();
        //通道的初始化最好放在Application中
        initAction();
    }

        private void initAction() {
            Xrouter.getInstance().registerAction(DifferentProcessActionMessage.DIFFERENTPROCESSACTIONNAME,new com.hxzk.bj.differnertprocess.action.DifferentProcessAction());
           Xrouter.getInstance().registerAction(SameProcessActionMessage.SANEPORICESSBANE,new com.hxzk.bj.sameprocessmodule.action.SameProcessAction());
    }

}