您当前的位置： 首页 > 学无止境 > 心得笔记 网站首页心得笔记
34_内容观察者&通过内容观察者获取用户发送短信的内容
发布时间：2021-02-21 15:16:29编辑：雪饮阅读（）
通知服务搭建
在昨天的内容提供者中，其实还可以在每个操作之后进行通知，通知观察者（即昨天的那个其它apk包，只是昨天那个apk包还没有实现观察者服务）
那么在昨天的PersonProvider.java中实现通知服务如：
package com.example.myapplication.provider;
import com.example.myapplication.MyDBOpenHelper;
import com.example.myapplication.PersonDao;
import android.content.ContentProvider;
import android.content.ContentUris;
import android.content.ContentValues;
import android.content.UriMatcher;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.net.Uri;
import android.util.Log;
public class PersonProvider extends ContentProvider {
//创建一个路径的识别器 uriMatcher 默认的返回值，如果没有找到匹配的类型 返回-1（NO_MATCH）
public static final UriMatcher matcher = new UriMatcher(UriMatcher.NO_MATCH);
public static final int ALL_PERSONS = 1;
public static final int PERSON = 2;
public static final int HAHA =3;
public static final int INSERT =4;
public static final int DELETE =5;
public static final int UPDATE =6;
private static final String TAG = "PersonProvider";
MyDBOpenHelper openHelper;
Uri baseuri = Uri.parse("com.example.myapplication.provider.PersonProvider");
static {
//第一个参数authority的值与外面清单文件AndroidManifest.xml中定义的provider标签的authorities属性值保持一致
matcher.addURI("com.example.myapplication.provider.PersonProvider", "persons", ALL_PERSONS);
// 指定一个路径的匹配规则
//如果路径 满足 content://com.example.myapplication.provider.PersonProvider/persons 返回值就是( ALL_PERSONS) 1
matcher.addURI("com.example.myapplication.provider.PersonProvider", "person/#",PERSON );
//如果路径满足 content://com.example.myapplication.provider.PersonProvider/person/10 返回值就是( PERSON) 2
matcher.addURI("com.example.myapplication.provider.PersonProvider", "haha", HAHA);
matcher.addURI("com.example.myapplication.provider.PersonProvider", "insert", INSERT);
matcher.addURI("com.example.myapplication.provider.PersonProvider", "delete", DELETE);
matcher.addURI("com.example.myapplication.provider.PersonProvider", "update", UPDATE);
}
/**
* PeronProvder 内容提供者第一次被创建的时候 调用的方法
*/
@Override
public boolean onCreate() {
openHelper = new MyDBOpenHelper(getContext());
//根据自己业务需求返回布尔值
return false;
}
@Override
public Cursor query(Uri uri, String[] projection, String selection,
String[] selectionArgs, String sortOrder) {
int result = matcher.match(uri);
switch (result) {
// 符合content://com.example.myapplication.provider.PersonProvider/persons 代表的返回所有的数据
case ALL_PERSONS:
PersonDao dao = new PersonDao(getContext());
return dao.findAllbyCursor();
//符合 content://com.example.myapplication.provider.PersonProvider/person/10 代表的返回指定id的数据
case PERSON:
//从uri中获取id参数
long id = ContentUris.parseId(uri);
SQLiteDatabase db = openHelper.getReadableDatabase();
if(db.isOpen()){
Cursor cursor = db.query("person", null, "personid=?", new String[]{id+""}, null, null, null);
return cursor;
}
case HAHA:
Log.i(TAG,"我是haha对应的路径，我不返回内容哦");
break;
default:
throw new IllegalArgumentException("uri不能被识别 请注意哦");
}
return null;
}
@Override
public String getType(Uri uri) {
int result = matcher.match(uri);
switch (result) {
// 符合content://com.example.myapplication.provider.PersonProvider/persons 代表的返回所有的数据
case ALL_PERSONS:
//vnd.android.cursor.dir,前面这部分表示返回的是集合，这是一个规范，但也可以不遵循规范。。。
//后面你随意
return "vnd.android.cursor.dir/people";
//符合 content://com.example.myapplication.provider.PersonProvider/person/10 代表的返回指定id的数据
case PERSON:
//vnd.android.cursor.item 前面这部分表示返回的是一个单独的项目，这是一个规范，但也可以不遵循规范。。。
//后面你随意
return "vnd.android.cursor.item/people";
default :
return null;
}
}
public Uri getAuthUri(Uri uri){
Uri.Builder builder=new Uri.Builder();
//通过authority、uri、scheme（即如content://com.example.myapplication.provider.PersonProvider/persons 中的content协议部分）构造一个编码后的Uri
//据说在安卓8以前是不需要构造的，可以直接给notifyChange使用
return builder.authority("com.example.myapplication.provider.PersonProvider").path(String.valueOf(uri)).scheme("content").build();
}
@Override
public Uri insert(Uri uri, ContentValues values) {
// content://com.example.myapplication.provider.PersonProvider/insert
int result = matcher.match(uri);
switch (result) {
case INSERT:
SQLiteDatabase db = openHelper.getWritableDatabase();
db.insert("person", "personid", values);
// 当数据发生改变的时候,notifyChange通知改变的时候调用者uri需要经过authority（即清单文件中的authorities）进行一次构造才可以
getContext().getContentResolver().notifyChange(getAuthUri(baseuri), null);
return uri;
default:
throw new IllegalArgumentException("插入时发现uri不能被识别");
}
}
@Override
public int delete(Uri uri, String selection, String[] selectionArgs) {
int result = matcher.match(uri);
switch (result) {
case DELETE:
SQLiteDatabase db = openHelper.getWritableDatabase();
getContext().getContentResolver().notifyChange(getAuthUri(baseuri), null);
return db.delete("person", selection, selectionArgs);
default:
throw new IllegalArgumentException("删除时发现uri不能被识别");
}
}
@Override
public int update(Uri uri, ContentValues values, String selection,
String[] selectionArgs) {
int result = matcher.match(uri);
switch (result) {
case UPDATE:
SQLiteDatabase db = openHelper.getWritableDatabase();
getContext().getContentResolver().notifyChange(getAuthUri(baseuri), null);
return db.update("person", values, selection, selectionArgs);
default:
throw new IllegalArgumentException("更新时发现uri不能被实现 ");
}
}
}
观察者实现
通知服务搭建完成后，我们就在昨天这个其它包中实现观察者并测试下插入通知则其它包的MainActivity.java则如：
package com.example.other;
import androidx.appcompat.app.AppCompatActivity;
import android.content.ContentResolver;
import android.content.ContentValues;
import android.database.ContentObserver;
import android.net.Uri;
import android.os.Bundle;
import android.os.Handler;
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
//注册内容观察者
Uri uri = Uri.parse("content://com.example.myapplication.provider.PersonProvider/");
getContentResolver().registerContentObserver(uri, true , new MyObserver(new Handler()));
//测试下新增
testAdd();
}
public void testAdd(){
ContentResolver resolver = getContentResolver();
Uri uri = Uri.parse("content://com.example.myapplication.provider.PersonProvider/insert");
ContentValues values = new ContentValues();
values.put("name", "laofang");
values.put("age", 18);
resolver.insert(uri, values);
}
public class MyObserver extends ContentObserver {
public MyObserver(Handler handler) {
super(handler);
}
/**
* 当内容观察者发现了数据发生改变的时候 调用的方法
*/
@Override
public void onChange(boolean selfChange) {
System.out.println("数据发生改变了 ");
super.onChange(selfChange);
}
}
}
然后经过插入测试可以发现数据是改变了，那么插入的通知服务与观察者之间就打通了
那么接下来我们就在观察者中再实现下删除数据进行测试通知与观察的结果，那么其它包中MainActivity.java则如：
package com.example.other;
import androidx.appcompat.app.AppCompatActivity;
import android.content.ContentResolver;
import android.content.ContentValues;
import android.database.ContentObserver;
import android.net.Uri;
import android.os.Bundle;
import android.os.Handler;
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
//注册内容观察者
Uri uri = Uri.parse("content://com.example.myapplication.provider.PersonProvider/");
getContentResolver().registerContentObserver(uri, true , new MyObserver(new Handler()));
//测试下删除
testDel();
}
public void testAdd(){
ContentResolver resolver = getContentResolver();
Uri uri = Uri.parse("content://com.example.myapplication.provider.PersonProvider/insert");
ContentValues values = new ContentValues();
values.put("name", "laofang");
values.put("age", 18);
resolver.insert(uri, values);
}
public void testDel(){
ContentResolver resolver = getContentResolver();
Uri uri = Uri.parse("content://com.example.myapplication.provider.PersonProvider/delete");
int raw = resolver.delete(uri, "name=?", new String[]{"lisi99"});
System.out.println("删除了 "+raw+"行" );
}
public class MyObserver extends ContentObserver {
public MyObserver(Handler handler) {
super(handler);
}
@Override
public void onChange(boolean selfChange) {
System.out.println("数据发生改变了 ");
super.onChange(selfChange);
}
}
}
则结果如：
那么同样的我们测试下修改，则其它包中的MainActivity.java则如：
package com.example.other;
import androidx.appcompat.app.AppCompatActivity;
import android.content.ContentResolver;
import android.content.ContentValues;
import android.database.ContentObserver;
import android.net.Uri;
import android.os.Bundle;
import android.os.Handler;
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
//注册内容观察者
Uri uri = Uri.parse("content://com.example.myapplication.provider.PersonProvider/");
getContentResolver().registerContentObserver(uri, true , new MyObserver(new Handler()));
//测试下修改
testUpdate();
}
public void testAdd(){
ContentResolver resolver = getContentResolver();
Uri uri = Uri.parse("content://com.example.myapplication.provider.PersonProvider/insert");
ContentValues values = new ContentValues();
values.put("name", "laofang");
values.put("age", 18);
resolver.insert(uri, values);
}
public void testDel(){
ContentResolver resolver = getContentResolver();
Uri uri = Uri.parse("content://com.example.myapplication.provider.PersonProvider/delete");
int raw = resolver.delete(uri, "name=?", new String[]{"lisi99"});
System.out.println("删除了 "+raw+"行" );
}
public void testUpdate(){
ContentResolver resolver = getContentResolver();
Uri uri = Uri.parse("content://com.example.myapplication.provider.PersonProvider/update");
ContentValues values = new ContentValues();
values.put("name", "duminjie");
values.put("age", 220807);
int raw = resolver.update(uri, values, "personid=?", new String[]{"600"});
System.out.println("更新了 "+raw+"行" );
}
public class MyObserver extends ContentObserver {
public MyObserver(Handler handler) {
super(handler);
}
@Override
public void onChange(boolean selfChange) {
System.out.println("数据发生改变了 ");
super.onChange(selfChange);
}
}
}
然后结果也ok啦
短信观察者
安卓中的默认短信应用也有短信内容提供者，则我们可以搭建一个apk做一个观察者，就可以实现监听读取设备所收到的短信。那么我们建立sms项目中MainActivity.java如：
package com.example.sms;
import androidx.appcompat.app.AppCompatActivity;
import android.database.ContentObserver;
import android.database.Cursor;
import android.net.Uri;
import android.os.Bundle;
import android.os.Handler;
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
Uri uri = Uri.parse("content://sms/");
getContentResolver().registerContentObserver(uri, true, new SmsObserver(new Handler()));
}
public class SmsObserver extends ContentObserver {
public SmsObserver(Handler handler) {
super(handler);
}
@Override
public void onChange(boolean selfChange) {
System.out.println("有新的短信产生 ");
//---------收件箱-----------
Cursor cursor = getContentResolver().query(Uri.parse("content://sms/inbox"),null, null, null, null);
while(cursor.moveToNext()){
StringBuilder sb = new StringBuilder();
sb.append("_id=").append(cursor.getInt(cursor.getColumnIndex("_id")));
sb.append(",address=").append(cursor.getString(cursor.getColumnIndex("address")));
sb.append(";body=").append(cursor.getString(cursor.getColumnIndex("body")));
sb.append(";time=").append(cursor.getLong(cursor.getColumnIndex("date")));
System.out.println("收件箱-短信内容:"+sb.toString());
}
super.onChange(selfChange);
}
}
}
同时由于要读取短信，所以我们需要在这个新建的sms项目的清单文件中加入短信读取权限，则其的AndroidManifest.xml如：
<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
package="com.example.sms">
<uses-permission android:name="android.permission.READ_SMS"/>
<application
android:allowBackup="true"
android:icon="@mipmap/ic_launcher"
android:label="@string/app_name"
android:roundIcon="@mipmap/ic_launcher_round"
android:supportsRtl="true"
android:theme="@style/Theme.Sms">
<activity android:name=".MainActivity">
<intent-filter>
<action android:name="android.intent.action.MAIN" />
<category android:name="android.intent.category.LAUNCHER" />
</intent-filter>
</activity>
</application>
</manifest>
最后部署该项目到设备，并勾选上面清单这个短信读取权限，然后记住该设备的手机号，如我这里是5444，那么接下来我们另外开一个设备给5444发送短信，就可以看到日志猫中就能读取到短信了
关键字词：观察者,android