- 在 android 中经常会出现改变数据库内容后再去使用数据库更新的内容，很多人会重新去 query 一遍，但是这样的问题就是程序会特别占内存，而且有可能会忘关 cursor 而导致程序内存未释放等等。
- android 内部提供了一种 ContentObserver 来监听数据库内容的变化。作用是观察（捕捉）特定 Uri 引起的数据库的变化，继而做一些相应的处理。
1. 创建一个 ContentObserver 的子类，实现 onChange() 方法。
- 监听的 Uri 中的数据发生变化的时候，会调用 onchange() 方法。
- 构造方法：
public void ContentObserver(Handler handler)
参数需要一个 Hanlder，因为 ContentObserver 内部使用了一个实现 Runnable 接口的内部类 NotificationRunnable，需要通过 Handler 去做比如 UI 变化。
（可以从主线程传入一个 handler。） - 简单示例：
public class MyContentObserver extends ContentObserver{
private Handler handler;
public MyContentObserver(Handler handler) {
super(handler);
this.handler=handler;
}
@Override
public void onChange(boolean selfChange) {
super.onChange(selfChange);
// Do something
}
}
2. 注册 ContentObserver
- registerContentObserver() 方法：
public final void registerContentObserver(Uri uri, boolean notifyForDescendants, ContentObserver observer)
- 第一个参数：需要监听的 uri。
- 第二个参数：为 false 表示精确匹配，即只匹配该 Uri。为 true 表示可以同时匹配其派生的 Uri，如：
content://com.qin.cb/student（精确匹配）
content://com.qin.cb/student/# （派生，false 才能匹配到）
content://com.qin.cb/student/schoolchild（派生，false 才能匹配到） - 第三个参数：ContentObserver 的实例。
- 注册举例：
getContentResolver().registerContentObserver(uri, false, myContentObserver);
3. 用完后记得取消注册 ContentObserver
getContentResolver().unregisterContentObserver(myContentObserver)
4. 示例
Demo 中共有两个不同的 ContentObserver 派生类：
- 用来观察系统是否改变了飞行模式状态，
- 观察系统的短信息数据发生了变化。当监听到短信数据发生变化时，查询所有已发送的短信并且显示出来。
AirplaneContentObserver：
//用来观察system表里飞行模式所在行是否发生变化 ， “行”内容观察者
public class AirplaneContentObserver extends ContentObserver {
private static String TAG = "AirplaneContentObserver";
private static int MSG_AIRPLANE = 1;
private Context mContext;
private Handler mHandler; //此Handler用来更新UI线程
public AirplaneContentObserver(Context context, Handler handler) {
super(handler);
mContext = context;
mHandler = handler;
}
/**
* 当所监听的Uri发生改变时，就会回调此方法
*
* @param selfChange 此值意义不大 一般情况下该回调值false
*/
@Override
public void onChange(boolean selfChange) {
Log.i(TAG, "-------------the airplane mode has changed-------------");
// 系统是否处于飞行模式下
try {
int isAirplaneOpen = Settings.System.getInt(mContext.getContentResolver(), Settings.System.AIRPLANE_MODE_ON);
Log.i(TAG, " isAirplaneOpen -----> " + isAirplaneOpen);
mHandler.obtainMessage(MSG_AIRPLANE, isAirplaneOpen).sendToTarget();
} catch (SettingNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
SMSContentObserver：
//用来观察系统里短消息的数据库变化 ”表“内容观察者,只要信息数据库发生变化，都会触发该ContentObserver 派生类
public class SMSContentObserver extends ContentObserver {
private static String TAG = "SMSContentObserver";
private int MSG_OUTBOXCONTENT = 2;
private Context mContext;
private Handler mHandler; //更新UI线程
public SMSContentObserver(Context context, Handler handler) {
super(handler);
mContext = context;
mHandler = handler;
}
/**
* 当所监听的Uri发生改变时，就会回调此方法
*
* @param selfChange 此值意义不大 一般情况下该回调值false
*/
@Override
public void onChange(boolean selfChange) {
Log.i(TAG, "the sms table has changed");
//查询发件箱里的内容
Uri outSMSUri = Uri.parse("content://sms/sent");
Cursor c = mContext.getContentResolver().query(outSMSUri, null, null, null, "date desc");
if (c != null) {
Log.i(TAG, "the number of send is" + c.getCount());
StringBuilder sb = new StringBuilder();
//循环遍历
while (c.moveToNext()) {
// sb.append("发件人手机号码: "+c.getInt(c.getColumnIndex("address")))
// .append("信息内容: "+c.getInt(c.getColumnIndex("body")))
// .append("是否查看: "+c.getInt(c.getColumnIndex("read")))
// .append("发送时间： "+c.getInt(c.getColumnIndex("date")))
// .append("\n");
sb.append("发件人手机号码: " + c.getInt(c.getColumnIndex("address")))
.append("信息内容: " + c.getString(c.getColumnIndex("body")))
.append("\n");
}
c.close();
mHandler.obtainMessage(MSG_OUTBOXCONTENT, sb.toString()).sendToTarget();
}
}
}
MainActivity：
public class MainActivity extends Activity {
private TextView tvAirplane;
private EditText etSmsoutbox;
// Message 类型值
private static final int MSG_AIRPLANE = 1;
private static final int MSG_OUTBOXCONTENT = 2;
private AirplaneContentObserver airplaneCO;
private SMSContentObserver smsContentObserver;
/**
* Called when the activity is first created.
*/
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
tvAirplane = (TextView) findViewById(R.id.tvAirplane);
etSmsoutbox = (EditText) findViewById(R.id.smsoutboxContent);
// 创建两个对象
airplaneCO = new AirplaneContentObserver(this, mHandler);
smsContentObserver = new SMSContentObserver(this, mHandler);
//注册内容观察者
registerContentObservers();
}
private void registerContentObservers() {
// 通过调用getUriFor 方法获得 system表里的"飞行模式"所在行的Uri
Uri airplaneUri = Settings.System.getUriFor(Settings.System.AIRPLANE_MODE_ON);
// 注册内容观察者
getContentResolver().registerContentObserver(airplaneUri, false, airplaneCO);
// ”表“内容观察者 ，通过测试我发现只能监听此Uri -----> content://sms
// 监听不到其他的Uri 比如说 content://sms/outbox
Uri smsUri = Uri.parse("content://sms");
getContentResolver().registerContentObserver(smsUri, true, smsContentObserver);
}
private Handler mHandler = new Handler() {
public void handleMessage(Message msg) {
System.out.println("---mHanlder----");
switch (msg.what) {
case MSG_AIRPLANE:
int isAirplaneOpen = (Integer) msg.obj;
if (isAirplaneOpen != 0)
tvAirplane.setText("飞行模式已打开");
else if (isAirplaneOpen == 0)
tvAirplane.setText("飞行模式已关闭");
break;
case MSG_OUTBOXCONTENT:
String outbox = (String) msg.obj;
etSmsoutbox.setText(outbox);
break;
default:
break;
}
}
};
}
5. ?
为什么数据改变后会回调至ContentObserver？ 为什么我们自定义的 ContentProvider 数据源发生改变后，却没有监听到任何反应？
这与系统的回调系统逻辑有关。
每个ContentProvider数据源发生改变后，如果想通知其监听对象， 例如ContentObserver时，必须在其对应方法 update / insert / delete 时，显式地调用 this.getContentReslover().notifychange(uri,null) 方法，回调监听处理逻辑。否则，我们的 ContentObserver 是不会监听到数据发生改变的。
