`
lovelease
  • 浏览: 387985 次
社区版块
存档分类
最新评论

Android短信监听功能(解决onChange触发两次的问题)

阅读更多
前言
项目要做短信验证码自动填充的功能,基本上两种方法:ContentObserver监听短信数据库、广播。我个人比较喜欢监听数据库的方式,原因有以下几点:
1.广播方式只能读短信,不能写短信(比如更新短信状态为已读);而监听数据库则可以对短信做增删改查;
2.系统的短信广播是有序广播,如果有其他应用的优先级高于我们的应用,广播会先被其他应用截获,如果其他应用截获短信广播后将其消费掉并且不再继续发送,那我们的应用就收不到广播了;
3.广播方式需要注册receiver,动态注册还好,如果是静态注册,对于sdk类的产品来说,使用者有可能忘记在Manifest中注册;
基于以上原因,我的项目中索性就选择了监听数据库。监听数据库相对于广播稍微复杂点,但是更加灵活,功能更强大,所以还是建议使用监听数据库的方法,不过这里会将两种都说一下。

方法一:监听短信数据库
遇到的问题是大部分手机收到一条短信时会触发两次onChange()方法,很多人提出的解决方法是记录smsId,判断如果是旧的就不做处理,是新的就做该做的事。起初这么做了,后来发现有时候自动填充会先填旧的,立马又填新的,会闪一下,虽然只是偶尔出现,但还是觉得不爽,于是抽空又找别的方法,总算找出来了,也是受到一些网友的启发,下面就分享出来,原理我不多说了,代码注释里都讲得很清楚。
package com.jackie.bindmobile;

import android.app.Activity;
import android.database.ContentObserver;
import android.database.Cursor;
import android.net.Uri;
import android.os.Handler;
import android.text.TextUtils;
import android.util.Log;

import java.util.regex.Matcher;
import java.util.regex.Pattern;

/**
 * Monitor sms database
 * 
 * @author Jackie
 *
 */
public class SmsContent extends ContentObserver {

	private static final String TAG = SmsContent.class.getSimpleName();
	private static final String MARKER = "YOUR_KEYWORD";
	private Cursor cursor = null;
	private Activity mActivity;

	public SmsContent(Handler handler, Activity activity) {
		super(handler);
		this.mActivity = activity;
	}

	/**
	 * This method is called when a content change occurs.
	 * <p>
	 * Subclasses should override this method to handle content changes.
	 * </p>
	 *
	 * @param selfChange True if this is a self-change notification.
	 */
	@Override
	public void onChange(boolean selfChange) {
		super.onChange(selfChange);
		Log.d(TAG, "onChange(boolean selfChange). selfChange=" + selfChange);
		onChange(selfChange, null);
	}

	/**
	 * Notice: onChange will be triggered twice on some devices when a sms received,
	 * eg: samsung s7 edge(API.23) - twice
	 *     samsung note3(API.18) - once
	 * 06-15 11:45:48.706 D/SmsContent: onChange(boolean selfChange, Uri uri). selfChange=false, uri=content://sms/raw
	 * 06-15 11:45:49.466 D/SmsContent: onChange(boolean selfChange, Uri uri). selfChange=false, uri=content://sms/387
	 *
	 * Generally onChange will be triggered twice, first time is triggered by uri "content://sms/raw"(sms received,
	 * but have not written into inbox), second time is triggered by uri "content://sms/387"(number is sms id)
	 *
	 * Android official comments:
	 * This method is called when a content change occurs.
	 * Includes the changed content Uri when available.
	 * <p>
	 * Subclasses should override this method to handle content changes.
	 * To ensure correct operation on older versions of the framework that
	 * did not provide a Uri argument, applications should also implement
	 * the {@link #onChange(boolean)} overload of this method whenever they
	 * implement the {@link #onChange(boolean, Uri)} overload.
	 * </p><p>
	 * Example implementation:
	 * <pre><code>
	 * // Implement the onChange(boolean) method to delegate the change notification to
	 * // the onChange(boolean, Uri) method to ensure correct operation on older versions
	 * // of the framework that did not have the onChange(boolean, Uri) method.
	 * {@literal @Override}
	 * public void onChange(boolean selfChange) {
	 *     onChange(selfChange, null);
	 * }
	 *
	 * // Implement the onChange(boolean, Uri) method to take advantage of the new Uri argument.
	 * {@literal @Override}
	 * public void onChange(boolean selfChange, Uri uri) {
	 *     // Handle change.
	 * }
	 * </code></pre>
	 * </p>
	 *
	 * @param selfChange True if this is a self-change notification.
	 * @param uri The Uri of the changed content, or null if unknown.
	 */
	@Override
	public void onChange(boolean selfChange, Uri uri) {
		Log.d(TAG, "onChange(boolean selfChange, Uri uri). selfChange=" + selfChange + ", uri=" + uri);

		/**
		 * 适配某些较旧的设备,可能只会触发onChange(boolean selfChange)方法,没有传回uri参数,
		 * 此时只能通过"content://sms/inbox"来查询短信
		 */
		if (uri == null) {
			uri = Uri.parse("content://sms/inbox");
		}
		/**
		 * 06-15 11:45:48.706 D/SmsContent: onChange(boolean selfChange, Uri uri). selfChange=false, uri=content://sms/raw
		 * 06-15 11:45:49.466 D/SmsContent: onChange(boolean selfChange, Uri uri). selfChange=false, uri=content://sms/387
		 *
		 * Generally onChange will be triggered twice, first time is triggered by uri "content://sms/raw"(sms received,
		 * but have not written into inbox), second time is triggered by uri "content://sms/387"(number is sms id)
 		 */
		if (uri.toString().equals("content://sms/raw")) {
			return;
		}
		cursor = this.mActivity.getContentResolver().query(uri, null, null, null, null);
		if (cursor != null) {
			if (cursor.moveToFirst()) {
				int id = cursor.getInt(cursor.getColumnIndex("_id"));
				String body = cursor.getString(cursor.getColumnIndex("body"));
				Log.d(TAG, "sms id: " + id + "\nsms body: " + body);
				cursor.close();

				// Already got sms body, do anything you want, for example: filter the verify code
				getVerifyCode(body);
			}
		}
		else {
			Log.e(TAG, "error: cursor == null");
		}
	}
	
	/**
	 * Register a monitor of changing of sms
	 */
	public void register() {
		Log.d(TAG, "Register sms monitor");
		this.mActivity.getContentResolver().registerContentObserver(
				Uri.parse("content://sms/"), true, this);
	}
	
	/**
	 * Unregister the monitor of changing of sms
	 */
	public void unRegister() {
		Log.d(TAG, "Unregister sms monitor");
		this.mActivity.getContentResolver().unregisterContentObserver(this);
	}

	/**
	 * Get verify code from sms body
	 * @param str
	 * @return
     */
	public String getVerifyCode(String str) {
		String verifyCode = null;
		if (smsContentFilter(str)) {
			Log.d(TAG, "sms content matched, auto-fill verify code.");
			verifyCode = getDynamicPassword(str);
		}
		else {
			// Do nothing
			Log.d(TAG, "sms content did not match, do nothing.");
		}
		return verifyCode;
	}

	/**
	 * Check if str is verification-code-formatted
	 *
	 * @param str
	 * @return
     */
	private boolean smsContentFilter(String str) {
		Log.d(TAG, "smsContentFilter. smsBody = " + str);
		boolean isMatched = false;
		if (!TextUtils.isEmpty(str)) {
			// Check if str contains keyword
			if (str.contains(MARKER)) {
				Log.d(TAG, "This sms contains \"" + MARKER + "\"");
				// Check if str contains continuous 6 numbers
				Pattern  continuousNumberPattern = Pattern.compile("[0-9\\.]+");
				Matcher m = continuousNumberPattern.matcher(str);
				while(m.find()){
					if(m.group().length() == 6) {
						Log.d(TAG, "This sms contains continuous 6 numbers : " + m.group());
						isMatched = true;
					}
				}
			}
		}
		return isMatched;
	}

	/**
     * Cut the continuous 6 numbers from str
     * 
     * @param str sms content
     * @return verification code
     */
    private String getDynamicPassword(String str) {
    	Log.d(TAG, "getDynamicPassword. smsBody = " + str);
        Pattern  continuousNumberPattern = Pattern.compile("[0-9\\.]+");
        Matcher m = continuousNumberPattern.matcher(str);
        String dynamicPassword = "";
        while(m.find()){
            if(m.group().length() == 6) {
            	Log.d(TAG, m.group());
                dynamicPassword = m.group();
            }
        }

        Log.d(TAG, "Verification code: " + dynamicPassword);
        return dynamicPassword;
    }
}

用法很简单,注册和注销一下就行:
package com.jackie.bindmobile;

import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;

public class BindMobileActivity extends Activity {

    private static final String TAG = BindMobileActivity.class.getSimpleName();
    private SmsContent smsContent;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        // Register sms monitor
        smsContent = new SmsContent(new Handler(), mActivity);
        smsContent.register();
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        // Unregister sms monitor
        smsContent.unRegister();
    }
}

方法二:广播
public class SMSBroadcastReceiver extends BroadcastReceiver {

    private static final String TAG = "SMSBroadcastReceiver";

    private SMSBroadcastReceiver() {
    }

    public static SMSBroadcastReceiver buildSMSReceiver(Context context) {
        SMSBroadcastReceiver smsReceiver = new SMSBroadcastReceiver();
        IntentFilter iff = new IntentFilter("android.provider.Telephony.SMS_RECEIVED");
        iff.setPriority(IntentFilter.SYSTEM_HIGH_PRIORITY);
        context.registerReceiver(smsReceiver, iff);
        return smsReceiver;
    }

    public static void unregisterSMSReceiver(Context context, SMSBroadcastReceiver receiver) {
        context.unregisterReceiver(receiver);
    }

    @SuppressLint("SimpleDateFormat")
    @Override
    public void onReceive(Context context, Intent intent) {
        Object[] pdus = (Object[]) intent.getExtras().get("pdus");
        for (Object pdu : pdus) {
            SmsMessage smsMessage = SmsMessage.createFromPdu((byte[]) pdu);
            String sender = smsMessage.getDisplayOriginatingAddress();
            String content = smsMessage.getMessageBody();
            long date = smsMessage.getTimestampMillis();
            Date timeDate = new Date(date);
            SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            String time = simpleDateFormat.format(timeDate);
            Log.i(TAG, " ------------- Incoming message details start ------------- ");
            Log.i(TAG, "SMS from: " + sender);
            Log.i(TAG, "SMS body: " + content);
            Log.i(TAG, "SMS timestamp: " + time);
            LogCat.i(TAG, " ------------- Incoming message details end ------------- ");
            // Mark SMS as read
            markAsRead(context, sender);
        }
    }

    private void markAsRead(final Context context, final String sender) {
        // Can not get the latest sms from ContentResolver on Android4.3 device if not run in sub thread
        new Thread(new Runnable() {
            @Override
            public void run() {
                // Wait for mobile system to write sms into database
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    Log.e(TAG, e.getMessage());
                }
                // Query sms from database
                Uri uri = Uri.parse("content://sms/inbox");
                String where = " address = " + sender;
                ContentResolver resolver = context.getContentResolver();
                Cursor cursor = resolver.query(uri, null, where, null, "_id desc");
                if (null == cursor) return;
                if (cursor.moveToNext()) {
                    // Query status
                    String smsId = cursor.getString(cursor.getColumnIndex("_id"));
                    int read = cursor.getInt(cursor.getColumnIndex("read"));
                    String smsBody = cursor.getString(cursor.getColumnIndex("body"));
                    Log.d(TAG, "Before update. smsId=" + smsId + ", read=" + read + ", smsBody=" + smsBody);
                    // Mark as read
                    ContentValues values = new ContentValues();
                    values.put("read", 1);
                    resolver.update(uri, values, "_id=" + smsId, null);
                    Log.d(TAG, "Mark as read DONE");
                    // Confirm status
                    cursor = resolver.query(uri, null, "_id=" + smsId, null, null);
                    cursor.moveToNext();
                    smsId = cursor.getString(cursor.getColumnIndex("_id"));
                    read = cursor.getInt(cursor.getColumnIndex("read"));
                    smsBody = cursor.getString(cursor.getColumnIndex("body"));
                    Log.d(TAG, "After update. smsId=" + smsId + ", read=" + read + ", smsBody=" + smsBody);
                }
                cursor.close();
            }
        }).start();
    }
}

用法也很简单,比如你要在一个Service中使用,只要注册和注销即可:
class SMSService extends Service{
	
	private SMSBroadcastReceiver smsBroadcastReceiver;

	@Override
	private void onCreate() {
		smsBroadcastReceiver = SMSBroadcastReceiver.buildSMSReceiver(this);
	}

	@Override
    public void onDestroy() {
        SMSBroadcastReceiver.unregisterSMSReceiver(this, smsBroadcastReceiver);
        super.onDestroy();
    }
}

上面的例子实现的功能是接收短信广播,收到后将短信设置为已读,实现过程是当触发onReceive后,通过ContentResolver读取短信数据库,并更新相应短信的状态为已读。需要注意里面两个地方:
1.为什么要做3秒的延迟,再去读取短信数据库:
是为了等待手机系统将短信写入短信数据库中,否则你读到的就是旧的数据库信息,不包含刚收到的短信。关于这一点,我的理解是:广播机制它是系统一旦收到短信,就发出一个广播,并将短信内容以pdus的形式放在Intent中,同时系统又去将短信往数据库中写入,发广播和写数据库是并行进行的,他们之间没有什么先后关系,所以当我们收到onReceive时其实很可能短信还没被写入数据库,如果此时去读取数据库,就读不到最新的这条短信。当然我没有去证实这个观点,但应该是八九不离十。
2.更新短信状态的处理为什么要放在子线程:
这个就只是为了适配老设备,起初没有放在子线程中,我在红米(Android4.4.4)上测试时没有问题,只要延时3秒就能读到最新的短消息,但是在一台很老的联想机(Android4.3)上面就总是读到的之前一条短信内容,即便我将延时设置为30秒也没用,我不确定是设备太老还是系统版本太旧,但我偶然发现将这个处理放在子线程后3秒就可以读到最新的短信。如果有大神能解释一下,请多多指教。

其实,方法二这样的功能,最好还是使用第一种方式监听短信,因为只有第一种方式能够写短信内容,而广播只能读短信,如果硬要将两种方式结合起来用,那在读取短信数据库前就不得不做一定的延时处理了。
分享到:
评论

相关推荐

    Android短信验证码监听解决onChange多次调用的方法

    本文将探讨如何有效地监听短信验证码并解决onChange被多次调用的问题。 首先,监听短信通常通过ContentObserver类来实现。ContentObserver允许我们监控ContentResolver中数据的变化。在Android中,短信存储在...

    Android自学笔记-13-ContentObserver内容观察者

    在Android开发中,ContentObserver(内容观察者)是一种非常重要的组件,它允许应用程序监听系统或应用内部数据的变化。本自学笔记将深入探讨ContentObserver的工作原理、使用场景以及如何实现它。 ContentObserver...

    计算机二级公共基础知识模 拟试题及答案详解.pdf

    计算机二级公共基础知识模 拟试题及答案详解.pdf

    电子工程领域的语音发射机电路设计与实现

    内容概要:本文档详细介绍了语音发射机的设计与实现,涵盖了从硬件电路到具体元件的选择和连接方式。文档提供了详细的电路图,包括电源管理、信号处理、音频输入输出接口以及射频模块等关键部分。此外,还展示了各个引脚的功能定义及其与其他组件的连接关系,确保了系统的稳定性和高效性能。通过这份文档,读者可以全面了解语音发射机的工作原理和技术细节。 适合人群:对电子工程感兴趣的初学者、从事嵌入式系统开发的技术人员以及需要深入了解语音发射机制的专业人士。 使用场景及目标:适用于希望构建自己的语音发射设备的研究人员或爱好者,帮助他们掌握相关技术和实际操作技能。同时,也为教学机构提供了一个很好的案例研究材料。 其他说明:文档不仅限于理论讲解,还包括具体的实施步骤,使读者能够动手实践并验证所学知识。

    易语言注册机源码详解:单线程架构下的接码、滑块验证与IP代理实现

    内容概要:本文详细介绍了用易语言编写的单线程全功能注册机源码,涵盖了接码平台对接、滑块验证处理、IP代理管理以及料子导入等多个核心功能。文章首先展示了主框架的初始化配置和事件驱动逻辑,随后深入探讨了接码平台(如打码兔)的API调用及其返回数据的处理方法。对于滑块验证部分,作者分享了如何利用易语言的绘图功能模拟真实用户的操作轨迹,并提高了验证通过率。IP代理模块则实现了智能切换策略,确保代理的有效性和稳定性。此外,料子导入功能支持多种格式的数据解析和去重校验,防止脏数据污染。最后,文章提到了状态机设计用于控制注册流程的状态持久化。 适合人群:有一定编程基础,尤其是熟悉易语言的开发者和技术爱好者。 使用场景及目标:适用于希望深入了解易语言注册机开发的技术细节,掌握接码、滑块验证、IP代理等关键技术的应用场景。目标是帮助读者理解并优化现有注册机的功能,提高其稳定性和效率。 其他说明:文中提到的部分技术和实现方式可能存在一定的风险,请谨慎使用。同时,建议读者在合法合规的前提下进行相关开发和测试。

    计算机绘图实用教程 第三章.pdf

    计算机绘图实用教程 第三章.pdf

    计算机辅助设计—AutoCAD 2018中文版基础教程 各章CAD图纸及相关说明汇总.pdf

    计算机辅助设计—AutoCAD 2018中文版基础教程 各章CAD图纸及相关说明汇总.pdf

    计算机类电子书集合PDF

    C++相关书籍,计算机相关书籍,linux相关及http等计算机学习、面试书籍。

    计算机二级mysql数据库程序设计练习题(一).pdf

    计算机二级mysql数据库程序设计练习题(一).pdf

    计算机发展史.pdf

    计算机发展史.pdf

    计算机二级课件.pdf

    计算机二级课件.pdf

    计算机概论第三讲:计算机组成.pdf

    计算机概论第三讲:计算机组成.pdf

    端侧算力网络白皮书:6G时代终端算力资源高效利用与应用场景解析

    内容概要:本文档由中国移动通信集团终端有限公司、北京邮电大学、中国信息通信研究院和中国通信学会共同发布,旨在探讨端侧算力网络(TCAN)的概念、架构、关键技术及其应用场景。文中详细分析了终端的发展现状、基本特征和发展趋势,阐述了端侧算力网络的定义、体系架构、功能架构及其主要特征。端侧算力网络通过整合海量泛在异构终端的算力资源,实现分布式多级端侧算力资源的高效利用,提升网络整体资源利用率和服务质量。关键技术涵盖层次化端算力感知图模型、资源虚拟化、数据压缩、多粒度多层次算力调度、现场级AI推理和算力定价机制。此外,还探讨了端侧算力网络在智能家居、智能医疗、车联网、智慧教育和智慧农业等领域的潜在应用场景。 适合人群:从事通信网络、物联网、边缘计算等领域研究和开发的专业人士,以及对6G网络和端侧算力网络感兴趣的学者和从业者。 使用场景及目标:适用于希望深入了解端侧算力网络技术原理、架构设计和应用场景的读者。目标是帮助读者掌握端侧算力网络的核心技术,理解其在不同行业的应用潜力,推动端侧算力网络技术的商业化和产业化。 其他说明:本文档不仅提供了端侧算力网络的技术细节,还对其隐私与安全进行了深入探讨

    学习java的心得体会.docx

    学习java的心得体会.docx

    计算机二级考试(南开100题齐全).pdf

    计算机二级考试(南开100题齐全).pdf

    计算机二级C语言考试通关宝典:全面解析核心知识点与解题技巧

    内容概要:本文详细介绍了计算机二级C语言考试的内容和备考方法。首先概述了计算机二级考试的意义及其在计算机技能认证中的重要性,重点讲解了C语言的基础语法,包括程序结构、数据类型、运算符和表达式等。接着深入探讨了进阶知识,如函数、数组、指针、结构体和共用体的应用。最后分享了针对选择题、填空题和编程题的具体解题技巧,强调了复习方法和实战演练的重要性。 适合人群:准备参加计算机二级C语言考试的学生和技术爱好者。 使用场景及目标:①帮助考生系统地掌握C语言的核心知识点;②提供有效的解题策略,提高应试能力;③指导考生制定合理的复习计划,增强实战经验。 其他说明:本文不仅涵盖了理论知识,还提供了大量实例代码和详细的解释,有助于读者更好地理解和应用所学内容。此外,文中提到的解题技巧和复习建议对实际编程也有很大帮助。

    论文格式及要求.doc

    论文格式及要求.doc

    三菱FX3U与台达变频器RS485通信程序设置及应用实例

    内容概要:本文详细介绍了如何使用三菱FX3U PLC及其485BD通信板与四台台达VFD-M系列变频器进行通信的设置与应用。主要内容涵盖硬件连接注意事项、通信参数配置、RS指令的应用、CRC校验算法的实现以及频率给定和状态读取的具体方法。文中提供了多个实用的编程示例,展示了如何通过梯形图和结构化文本编写通信程序,并讨论了常见的调试技巧和优化建议。此外,还提到了系统的扩展性和稳定性措施,如增加温度传感器通信功能和应对电磁干扰的方法。 适合人群:从事工业自动化领域的工程师和技术人员,尤其是那些熟悉三菱PLC和台达变频器的使用者。 使用场景及目标:适用于需要实现多台变频器联动控制的工业应用场景,旨在提高生产效率和系统可靠性。通过学习本文,读者可以掌握如何构建稳定的RS485通信网络,确保变频器之间的高效协同工作。 其他说明:本文不仅提供了详细的理论指导,还包括了许多来自实际项目的经验教训,帮助读者避免常见错误并提升编程技能。

    计算机服务规范.pdf

    计算机服务规范.pdf

Global site tag (gtag.js) - Google Analytics