okhttp异步操作+EventBus直接响应在UI线程上

Posted 2021-12-21 努力的柳某人

一、首先从代码上介绍一下我使用的EventBus

1. 注册事件,通常当在某个Activity或Fragment界面需要使用时,在onStrat()方向下写入代码,简单的说就是:注册给定订阅服务器以接收事件 EventBus.getDefault().register(this);

2. 提交事件,在某个地方(如okHttp异步响应结果时,下方会有介绍)需要调用到UI或其他线程时,此时提交你所需要传输的数据或操作: EventBus.getDefault().post(new MessageEvent());

3. 接收事件,ThreadMode有4种响应线程中调用的方法,因为该文章要做Okhttp请求,则我需要返回到UI线程(ThreadMode.MAIN),且该方法需要放在有注册事件的Activity或Fragment里哦,不然你会发现没有效果:

@Subscribe(threadMode = ThreadMode.MAIN)
public void toDoSomething(MessageEvent event) 
       if (event.isSuccess)
           Log.i(event.str, "toDoSomething: "+event.code);
       

4. 注销事件,在onStop()方法下写入代码,简单的说是不再接收事件 EventBus.getDefault().unregister(this);

附上MessageEvent.class

public class MessageEvent 
        String str;
        boolean isSuccess;
        int code;
        /*get set constructor  */
    

二、EventBus的优点缺点各半

1. 优点就是调度灵活,不用去像广播一样注册也不需要Context,而且使用的代码量不大,解耦是有的。简单地说就是:快,代码少
2. 缺点就是如果有过多的事件和相同的类和参数提交,需要溯源哪个地方提交的方法时,会让维护人员原地爆炸。如果代码阅读能力很强,那就当我没说。

三、接下来是Okhttp与EventBus的用法

	// 首先初始化mClient
    private OkHttpClient mClient;

    private void initHttp() 
        mClient = new OkHttpClient.Builder()
                .connectTimeout(15, TimeUnit.SECONDS)
                .writeTimeout(15, TimeUnit.SECONDS)
                .readTimeout(15, TimeUnit.SECONDS).build();
    

// okhttp+EventBus的操作示例
 try 
   RequestBody body = new FormBody.Builder()
                .add("Parameter1", "1")
                .add("Parameter2", "2")
                .add("Parameter3", "2")
                .build();
                Request request = new Request.Builder().url("http://" + IP + ":8080/Example")
                        .build();
                     
                Call call = mClient.newCall(request);
                	//这是同步请求我就不多做介绍了
               		// Response response = call.execute(); 
               		
                   //异步请求
                call.enqueue(new Callback() 
                    @Override
                    public void onResponse(@NonNull Call call, @NonNull Response response) throws IOException 
              // 将数据放入自定义的MessageEvent中并直接提交方法
                             EventBus.getDefault().post(new MessageEvent(true, response.body().string(),response.code()));
                             // 可以简化如下操作交由EventBus去操作
//                        getActivity().runOnUiThread(() -> 
//                            Toast.makeText(getActivity(), "请求成功", Toast.LENGTH_SHORT).show();
//                        );
                    

                    @Override
                    public void onFailure(@NonNull Call call, @NonNull IOException e) 
                   
                    
                );
             catch (Exception e) 
                e.printStackTrace();
                EventBus.getDefault().post(new MessageEvent());
            

四、总结

用是都能用,看好EventBus的优缺点再决定要不要用。
引用的依赖:

    // okhttp
    implementation 'com.squareup.okhttp3:okhttp:4.9.0'
    // EventBus
    implementation 'org.greenrobot:eventbus:3.1.1'

想了解Retorfit2的话请参考:我写的Retorfit2对接GoogleDriveAPi的文章