android RxJava 异步分发案列 android异步消息处理机制

如果我们在Android的子线程中去更新UI，我们就会发现程序崩了，
这是因为Android不允许在子线程中进行UI操作，但是有时候我们
由必须在子线程中执行一些耗时操作，然后将执行的结果显示到
UI界面上又咋办呢，这里在Android中的异步消息机制很好的解决
了这个问题

异步消息处理机制

在Android中的异步消息处理机制主要涉及

• Message：携带少量的信息，在线程间传递消息内容，其中除了有what字段，arg1，arg2还可以储存一些整型字段，还有obj可以携带object对象
• Handler：就是字面上的意思，消息处理者，它用来发送和处理接收到的消息，我们使用Handler中的sendMessage（）发送的消息都会传递到Handler的handlerMessage（）方法中，在handlerMessage（）我们就可以写接收到此类消息的逻辑
• MessageQueue:也是字面上的意思，就是消息队列，用来储存发出来的消息，这个讲究先进先出的原则
• Looper:循环器，用来管理MessageQueue中的消息，这个会一会循环，当发现MessageQueue中有消息就取出来，传递到handlerMessage中去处理
• 具体如下图所示



• 下面我们可以来具体看看是怎么使用的
  我们就在子线程中来更新UI
  创建活动MainActivity
  activity_main.xml代码如下

<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:app="http://schemas.android.com/apk/res-auto"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    tools:context="com.example.administrator.androidthreadtest.MainActivity">
<Button
    android:layout_width="match_parent"
    android:layout_height="wrap_content"
    android:id="@+id/change_text"
    android:text="Change Text"/>
    <TextView
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:id="@+id/text_view"
        android:layout_centerInParent="true"
        android:text="Hello World"
        android:textSize="20dp"/>

</RelativeLayout>

这里我们就定义了两个简单的控件，我们通过点击按钮来更新UI显示的内容
MainActivity.java的代码如下：

public class MainActivity extends AppCompatActivity implements View.OnClickListener {
    private TextView textView;
    public static final int UPDATE_TEXT = 1;
   private Handler handler = new Handler(){
       @Override
       public void handleMessage(Message msg) {
           switch (msg.what){
               case UPDATE_TEXT:
                   textView.setText("Update UI");
                   break;
               default:
                   break;
           }
       }
   };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        textView = (TextView) findViewById(R.id.text);
        Button changeText = (Button) findViewById(R.id.change_text);
        changeText.setOnClickListener(this);
    }

    @Override
    public void onClick(View view) {
        switch (view.getId()){
            case R.id.change_text:
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        Message message = new Message();
                        message.what = UPDATE_TEXT;
                        handler.sendMessage(message);
                    }
                }).start();

                break;
            default:
                break;
        }

    }
}

在这里我首先new了一个Handler对象，并重写了handlerMessage（）方法，在定义了一个整形UPDATE_TEXT来表示TextView 的更新，然后在按钮的点击事件中开启一个子线程，我们不能在这个线程中直接更新UI，而是创建一个Message对象，将他的what字段定义为UPDATE_TEXT，最后通过sendMessage（）将这条消息发出去，进去MessageQueue中，Handler接收到消息后就执行在handlerMessage（）重写的方法，而handlerMessage（）是在主线程中执行的，这样就能完成UI更新了，就将hello world更新为Update UI。