收到彩信二

接收彩信2.png

收到通知，返回通知确认

收到彩信通知

下载彩信

下载彩信

1.onReceive

packages\apps\Mms\src\com\android\mms\transaction\PushReceiver.java

public void onReceive(Context context, Intent intent) {
  if (intent.getAction().equals(WAP_PUSH_DELIVER_ACTION) && ContentType.MMS_MESSAGE.equals(intent.getType())) {
    // Hold a wake lock for 5 seconds, enough to give any
    // services we start time to take their own wake locks.
    PowerManager pm = (PowerManager)context.getSystemService(Context.POWER_SERVICE);
    //PARTIAL_WAKE_LOCK：Wake lock level: Ensures that the CPU is running; the screen and keyboard backlight will be allowed 
    //to go off.
    PowerManager.WakeLock wl = pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK,
                                            "MMS PushReceiver");
    wl.acquire(5000);
    new ReceivePushTask(context).execute(intent);
  }
}

2.doInBackground

packages\apps\Mms\src\com\android\mms\transaction\PushReceiver.java

private class ReceivePushTask extends AsyncTask<Intent,Void,Void> {
  protected Void doInBackground(Intent... intents) {
    Intent intent = intents[0];
    // Get raw PDU push-data from the message and parse it
    byte[] pushData = intent.getByteArrayExtra("data"); //获得数据
    PduParser parser = new PduParser(pushData, PduParserUtil.shouldParseContentDisposition());
    GenericPdu pdu = parser.parse(); //解析成pdu

    PduPersister p = PduPersister.getPduPersister(mContext);
    ContentResolver cr = mContext.getContentResolver();
    int type = pdu.getMessageType();
    long threadId = -1;

    switch (type) {
      case MESSAGE_TYPE_NOTIFICATION_IND: {
        NotificationInd nInd = (NotificationInd) pdu;
        if (!isDuplicateNotification(mContext, nInd)) { //不存在相同的通知
          // Save the pdu. If we can start downloading the real pdu immediately,
          // don't allow persist() to create a thread for the notificationInd
          // because it causes UI jank.
          //如果是自动下载彩信的，这里存入数据库的时候不创建threadId
          Uri uri = p.persist(pdu, Inbox.CONTENT_URI, !NotificationTransaction.allowAutoDownload(),
                                    MessagingPreferenceActivity.getIsGroupMmsEnabled(mContext), null);

          // Start service to finish the notification transaction.
          Intent svc = new Intent(mContext, TransactionService.class);
          svc.putExtra(TransactionBundle.URI, uri.toString());
          svc.putExtra(TransactionBundle.TRANSACTION_TYPE, Transaction.NOTIFICATION_TRANSACTION);
          mContext.startService(svc);
        }
      }
    }
  }
}

3.onStartCommand

packages\apps\Mms\src\com\android\mms\transaction\TransactionService.java

public int onStartCommand(Intent intent, int flags, int startId) {
  if (intent != null) {
    Message msg = mServiceHandler.obtainMessage(EVENT_NEW_INTENT);
    msg.arg1 = startId;
    msg.obj = intent;
    mServiceHandler.sendMessage(msg);
  }
  return Service.START_NOT_STICKY;
}

4.handleMessage

packages\apps\Mms\src\com\android\mms\transaction\TransactionService.java

private final class ServiceHandler extends Handler {
  public void handleMessage(Message msg) {
    Transaction transaction = null;
    switch (msg.what) {
      case EVENT_NEW_INTENT:
        onNewIntent((Intent)msg.obj, msg.arg1);
        break;
    }
  }
}

5.onNewIntent

packages\apps\Mms\src\com\android\mms\transaction\TransactionService.java

public void onNewIntent(Intent intent, int serviceId) {
  String action = intent.getAction();
  if (ACTION_ONALARM.equals(action) || ACTION_ENABLE_AUTO_RETRIEVE.equals(action) ||
                (intent.getExtras() == null)) {

  } else{//彩信通知走这里
    // For launching NotificationTransaction and test purpose.
    TransactionBundle args = new TransactionBundle(intent.getExtras());
    launchTransaction(serviceId, args, noNetwork);
  }
}

6.launchTransaction

packages\apps\Mms\src\com\android\mms\transaction\TransactionService.java

private void launchTransaction(int serviceId, TransactionBundle txnBundle, boolean noNetwork) {
  if (noNetwork) {
    Log.w(TAG, "launchTransaction: no network error!");
    onNetworkUnavailable(serviceId, txnBundle.getTransactionType());
    return;
  }
  Message msg = mServiceHandler.obtainMessage(EVENT_TRANSACTION_REQUEST);
  msg.arg1 = serviceId;
  msg.obj = txnBundle;

  if (Log.isLoggable(LogTag.TRANSACTION, Log.VERBOSE)) {
    Log.v(TAG, "launchTransaction: sending message " + msg);
  }
  mServiceHandler.sendMessage(msg);
}

7.handleMessage

packages\apps\Mms\src\com\android\mms\transaction\TransactionService.java

private final class ServiceHandler extends Handler {
  public void handleMessage(Message msg) {
    Transaction transaction = null;
    switch (msg.what) {
      case EVENT_TRANSACTION_REQUEST:
        int transactionType = args.getTransactionType();
        switch (transactionType) {
          case Transaction.NOTIFICATION_TRANSACTION:
            String uri = args.getUri();
            if (uri != null) {
              transaction = new NotificationTransaction(TransactionService.this, serviceId, transactionSettings, uri);
            }
        }
  
        if (!processTransaction(transaction)) {
          transaction = null;
          return;
        }
    }
  }
}

8.processTransaction

packages\apps\Mms\src\com\android\mms\transaction\TransactionService.java

private boolean processTransaction(Transaction transaction) throws IOException {
  transaction.attach(TransactionService.this);
  transaction.process();
  return true;
}

9.process

packages\apps\Mms\src\com\android\mms\transaction\NotificationTransaction.java

public void process() {
  new Thread(this, "NotificationTransaction").start();
}

10.run

packages\apps\Mms\src\com\android\mms\transaction\NotificationTransaction.java

public void run() {
  DownloadManager downloadManager = DownloadManager.getInstance();
  boolean autoDownload = allowAutoDownload(); //是否自动下载
  try {
    // By default, we set status to STATUS_DEFERRED because we
    // should response MMSC with STATUS_DEFERRED when we cannot
    // download a MM immediately.
    int status = STATUS_DEFERRED;
    // Don't try to download when data is suspended, as it will fail, so defer download
    if (!autoDownload) { //如果不是自动下载
      downloadManager.markState(mUri, DownloadManager.STATE_UNSTARTED);
      sendNotifyRespInd(status); //发送  M-NotifyResp.ind
      return;
    }
    downloadManager.markState(mUri, DownloadManager.STATE_DOWNLOADING);
    byte[] retrieveConfData = null;
    // We should catch exceptions here to response MMSC
    // with STATUS_DEFERRED.
    try {
      retrieveConfData = getPdu(mContentLocation); //下载彩信
    } catch (IOException e) {
      mTransactionState.setState(FAILED);
    }

    if (retrieveConfData != null) {
      //解析
      GenericPdu pdu = new PduParser(retrieveConfData, PduParserUtil.shouldParseContentDisposition()).parse();
      if ((pdu == null) || (pdu.getMessageType() != MESSAGE_TYPE_RETRIEVE_CONF)) {//如果下载的类型不对
        mTransactionState.setState(FAILED);
        status = STATUS_UNRECOGNIZED;
      } else{ //下载到正确的M-Retrieve.conf pdu
        // Save the received PDU (must be a M-RETRIEVE.CONF).
        PduPersister p = PduPersister.getPduPersister(mContext);
        //存储彩信
        Uri uri = p.persist(pdu, Inbox.CONTENT_URI, true, MessagingPreferenceActivity.getIsGroupMmsEnabled(mContext), null);
        // We have successfully downloaded the new MM. Delete the
        // M-NotifyResp.ind from Inbox.
        //删除通知   M-Notification.ind
       SqliteWrapper.delete(mContext, mContext.getContentResolver(), mUri, null, null);

        mUri = uri;
        status = STATUS_RETRIEVED;
      }
    }
    sendNotifyRespInd(status); //发送  M-NotifyResp.ind
  } finally {
    mTransactionState.setContentUri(mUri);
    if (!autoDownload) {
      // Always mark the transaction successful for deferred
      // download since any error here doesn't make sense.
      mTransactionState.setState(SUCCESS);
    }
    if (mTransactionState.getState() != SUCCESS) {
      mTransactionState.setState(FAILED);
      Log.e(TAG, "NotificationTransaction failed.");
    }
    notifyObservers(); //执行TransactionService的update
  }
}
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 203,937评论 6赞 478
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 85,503评论 2赞 381
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 150,712评论 0赞 337
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,668评论 1赞 276
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,677评论 5赞 366
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,601评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 37,975评论 3赞 396
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,637评论 0赞 258
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,881评论 1赞 298
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,621评论 2赞 321
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,710评论 1赞 329
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,387评论 4赞 319
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,971评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,947评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,189评论 1赞 260
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 44,805评论 2赞 349
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,449评论 2赞 342