Android Observer与Observable

更新时间：2022-01-12

在 Android 上使用 Observer 与 Observable。

import java.util.Observable;

// 继承Observable类
// MyObservable 是一个被观察者
public class MyObservable extends Observable {

    public MyObservable() {}

    private volatile static MyObservable myObservable;

    public static MyObservable getInstance() {
        if (myObservable == null) {
            synchronized (MyObservable.class) {
                if (myObservable == null) {
                    myObservable = new MyObservable();
                }
            }
        }
        return myObservable;
    }

    // 发消息 给所有的观察者
    public void postMessage(String msg) {
        // 标记为已更改
        setChanged();
        // 如果已更改，通知所有的观察者
        notifyObservers(msg);
    }
}

import androidx.appcompat.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import java.util.Observable;
import java.util.Observer;

public class MainActivity extends AppCompatActivity implements Observer {
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        // 把自己设置为观察者
        if (this instanceof Observer) {
            MyObservable.getInstance().addObserver(this);
        }

        // 点击button，触发 被观察者 发消息给 观察者
        findViewById(R.id.post_msg_bt).setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                // 调用 被观察者 的 postMessage 方法，通知所有的观察者
                MyObservable.getInstance().postMessage("ok");
            }
        });
    }

    // 接收回调
    @Override
    public void update(Observable observable, Object obj) {
        Log.d("AAAAAAAAA", "msg: " + obj);
    }
}

随手整理，好记性不如烂笔头！