Android 开发中利用内容观察者监视短信变动

2024-02-02 12:30:09

在上次的文章中，我们探讨了 Android 中内容观察者的一般用法。它是一种机制，允许应用程序监视数据库中的更改并对这些更改做出反应。然而，我们注意到内容观察者的一个限制：它需要我们主动查询才能知道数据库是否发生了更改。

为了克服这一限制，我们将在本文中介绍如何使用内容观察者在数据库更改的瞬间立即收到通知。我们将以读取短信数据为例，展示内容观察者的实际应用。

理解内容观察者

内容观察者本质上是一个监听器，它注册到特定的内容 URI 上。当内容 URI 所代表的数据发生更改时，内容观察者就会收到通知。我们可以注册多个内容观察者，每个内容观察者都可以监视不同的内容 URI。

注册内容观察者

要注册内容观察者，我们需要以下步骤：

// 定义要观察的内容 URI
Uri contentUri = Uri.parse("content://sms/inbox");

// 创建内容观察者
ContentObserver observer = new ContentObserver(new Handler()) {
    @Override
    public void onChange(boolean selfChange) {
        // 数据库发生更改时调用的方法
    }
};

// 注册内容观察者
getContentResolver().registerContentObserver(contentUri, true, observer);

在上面的示例中，我们注册了一个内容观察者来监视收件箱中的短信（content://sms/inbox）。当收件箱中的短信发生更改时，onChange() 方法将被调用。

读取短信数据

一旦内容观察者被注册，我们就可以在 onChange() 方法中读取短信数据。以下是一个示例：

@Override
public void onChange(boolean selfChange) {
    Cursor cursor = getContentResolver().query(contentUri, null, null, null, null);

    if (cursor != null && cursor.moveToFirst()) {
        // 读取短信数据
    }

    cursor.close();
}

在上面的示例中，我们使用 Cursor 从收件箱中查询短信数据。Cursor 允许我们遍历短信数据并访问每个短信的详细信息。

代码示例

以下是一个完整的代码示例，演示如何使用内容观察者读取短信数据：

public class SMSObserverExample {

    public static void main(String[] args) {
        // 定义要观察的内容 URI
        Uri contentUri = Uri.parse("content://sms/inbox");

        // 创建内容观察者
        ContentObserver observer = new ContentObserver(new Handler()) {
            @Override
            public void onChange(boolean selfChange) {
                // 数据库发生更改时调用的方法

                // 读取短信数据
                Cursor cursor = getContentResolver().query(contentUri, null, null, null, null);

                if (cursor != null && cursor.moveToFirst()) {
                    // 遍历短信数据
                    do {
                        // 获取短信信息
                        String address = cursor.getString(cursor.getColumnIndex("address"));
                        String body = cursor.getString(cursor.getColumnIndex("body"));

                        // 打印短信信息
                        System.out.println("From: " + address);
                        System.out.println("Message: " + body);
                    } while (cursor.moveToNext());
                }

                cursor.close();
            }
        };

        // 注册内容观察者
        getContentResolver().registerContentObserver(contentUri, true, observer);
    }
}