發(fā)彩信

發(fā)送代碼流程圖

發(fā)送彩信.png

OMA- MMS-CTR-v1_2-20030716-C.pdf


image.png

1.send

packages\apps\Mms\src\com\android\mms\data\WorkingMessage.java

public void send(final String recipientsInUI) {
  new Thread(new Runnable() {
    @Override
    public void run() {
      final SendReq sendReq = makeSendReq(conv, subject);

      // Make sure the text in slide 0 is no longer holding onto a reference to
      // the text in the message text box.
      slideshow.prepareForSend();
      sendMmsWorker(conv, mmsUri, persister, slideshow, sendReq, textOnly);

      updateSendStats(conv);
    }
  }, "WorkingMessage.send MMS").start();
}

2.sendMmsWorker

packages\apps\Mms\src\com\android\mms\data\WorkingMessage.java

private void sendMmsWorker(Conversation conv, Uri mmsUri, PduPersister persister,
            SlideshowModel slideshow, SendReq sendReq, boolean textOnly) {
  //跟短信一樣:重置主題輸入框船惨、內(nèi)容輸入框、附件、mWorkingMessage等
  mStatusListener.onPreMessageSent();
  threadId = conv.ensureThreadId(); //構(gòu)建或者查詢threadId
  newMessage = mmsUri == null;
  if (newMessage) {//如果之前沒有往數(shù)據(jù)庫插入這條記錄
    // Write something in the database so the new message will appear as sending
    ContentValues values = new ContentValues();
    values.put(Mms.MESSAGE_BOX, Mms.MESSAGE_BOX_OUTBOX);
    values.put(Mms.THREAD_ID, threadId);
    values.put(Mms.MESSAGE_TYPE, PduHeaders.MESSAGE_TYPE_SEND_REQ);
    if (textOnly) {
      values.put(Mms.TEXT_ONLY, 1);
    }

    //Mms表插入一條記錄  public static final int MESSAGE_TYPE_OUTBOX = 4
    mmsUri = SqliteWrapper.insert(mActivity, mContentResolver, Mms.Outbox.CONTENT_URI,values);
  }

  try {
    if (newMessage) {
      //更新Mms和part表
      // Create a new MMS message if one hasn't been made yet.
      mmsUri = createDraftMmsMessage(persister, sendReq, slideshow, mmsUri, mActivity, null);
    } else {
      // Otherwise, sync the MMS message in progress to disk.
      updateDraftMmsMessage(mmsUri, persister, slideshow, sendReq, null);
    }

    // Be paranoid and clean any draft SMS up.
    deleteDraftSmsMessage(threadId);
  } finally {
    DraftCache.getInstance().setSavingDraft(false);
  }

  int error = 0;
  try {
    slideshow.finalResize(mmsUri); //壓縮附件,更新到part表
  } catch (ExceedMessageSizeException e1) {
    error = MESSAGE_SIZE_EXCEEDED;
  } catch (MmsException e1) {
    error = UNKNOWN_ERROR;
  }

  MessageSender sender = new MmsMessageSender(mActivity, mmsUri, slideshow.getCurrentMessageSize());
  try {
    if (!sender.sendMessage(threadId)) {
      // The message was sent through SMS protocol, we should
      // delete the copy which was previously saved in MMS drafts.
      SqliteWrapper.delete(mActivity, mContentResolver, mmsUri, null, null);
    }

    // Make sure this thread isn't over the limits in message count
    Recycler.getMmsRecycler().deleteOldMessagesByThreadId(mActivity, threadId);
  } catch (Exception e) {
    Log.e(TAG, "Failed to send message: " + mmsUri + ", threadId=" + threadId, e);
  }
}

3.sendMessage

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

public boolean sendMessage(long token) throws MmsException {
  if (!mMessageUri.toString().startsWith(Mms.Draft.CONTENT_URI.toString())) {
    //之前的類型不是草稿,就在pending_msgs表插入一條記錄
    ContentValues values = new ContentValues(7);
    values.put(PendingMessages.PROTO_TYPE, MmsSms.MMS_PROTO);
    values.put(PendingMessages.MSG_ID, messageId);
    values.put(PendingMessages.MSG_TYPE, pdu.getMessageType());
    values.put(PendingMessages.ERROR_TYPE, 0);
    values.put(PendingMessages.ERROR_CODE, 0);
    values.put(PendingMessages.RETRY_INDEX, 0);
    values.put(PendingMessages.DUE_TIME, 0);

    SqliteWrapper.insert(mContext, mContext.getContentResolver(), PendingMessages.CONTENT_URI, values);
  } else{
    //如果之前是草稿,就更新為public static final int MESSAGE_TYPE_OUTBOX = 4
    p.move(mMessageUri, Mms.Outbox.CONTENT_URI);
  }

  //啟動TransactionService
  mContext.startService(new Intent(mContext, TransactionService.class));
  return true
}

4.TransactionService

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;
}

5.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;
    }
  }
}

6.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)) {
    //查詢pending_msgs的所有在當前時間之前的所有彩信
    Cursor cursor = PduPersister.getPduPersister(this).getPendingMessages(System.currentTimeMillis());
    while (cursor.moveToNext()) {
      int transactionType = getTransactionType(msgType); //如果是發(fā)送的彩信,SEND_TRANSACTION         = 2
      
      switch (transactionType) {
        default:
          Uri uri = ContentUris.withAppendedId(Mms.CONTENT_URI,cursor.getLong(columnIndexOfMsgId));
          TransactionBundle args = new TransactionBundle(transactionType, uri.toString());
           // FIXME: We use the same startId for all MMs.
           launchTransaction(serviceId, args, false);
           break;
      }
     }
  }
}

7.launchTransaction

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

private void launchTransaction(int serviceId, TransactionBundle txnBundle, boolean noNetwork) {
  Message msg = mServiceHandler.obtainMessage(EVENT_TRANSACTION_REQUEST);
  msg.arg1 = serviceId;
  msg.obj = txnBundle;

  mServiceHandler.sendMessage(msg);
}

8.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.SEND_TRANSACTION:
            transaction = new SendTransaction(TransactionService.this, serviceId,transactionSettings, args.getUri());
            break;
        }
        if (!processTransaction(transaction)) {
          transaction = null;
          return;
        }
    }
  }
}

9.processTransaction

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

private boolean processTransaction(Transaction transaction) throws IOException {
  synchronized (mProcessing) {
    for (Transaction t : mPending) {
      if (t.isEquivalent(transaction)) {  //如果已經(jīng)存在于mPending List顺献,返回
        return true;
      }
    }

    for (Transaction t : mProcessing) { //如果已經(jīng)存在于mProcessing List,返回
      if (t.isEquivalent(transaction)) {
        return true;
      }
    }

    int connectivityResult = beginMmsConnectivity();
    if (connectivityResult == PhoneConstants.APN_REQUEST_STARTED) {
      mPending.add(transaction);
      return true;
    }

    if (mProcessing.size() > 0) { //如果mProcessing List已經(jīng)有 transaction
      mPending.add(transaction); 
      return true;
    } else{
      mProcessing.add(transaction); //加入mProcessing List
    }
  }

  sendMessageDelayed(obtainMessage(EVENT_CONTINUE_MMS_CONNECTIVITY), APN_EXTENSION_WAIT);

  //將Transaction.this添加到自己的成員變量mObservers里
  transaction.attach(TransactionService.this);  //mObservers.add(observer);
  transaction.process();
  return true;
}

10.process

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

public void process() {
  mThread = new Thread(this, "SendTransaction");
  mThread.start();
}

11.run

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

public void run() {
  try{
    // Load M-Send.req from outbox
    PduPersister persister = PduPersister.getPduPersister(mContext);
    SendReq sendReq = (SendReq) persister.load(mSendReqURI);

    //發(fā)送出去M-Send.req
    byte[] response = sendPdu(SendingProgressTokenManager.get(tokenKey), new PduComposer(mContext, sendReq).make());

    //收到M-Send.conf
    SendConf conf = (SendConf) new PduParser(
                    response, PduParserUtil.shouldParseContentDisposition()).parse();
    int respStatus = conf.getResponseStatus(); //發(fā)送結(jié)果
    if (respStatus != PduHeaders.RESPONSE_STATUS_OK) { //0x80:128
      SqliteWrapper.update(mContext, mContext.getContentResolver(), mSendReqURI, values, null, null);
      return;
    }
    SqliteWrapper.update(mContext, mContext.getContentResolver(), mSendReqURI, values, null, null);

    //更新彩信為public static final int MESSAGE_TYPE_SENT   = 2  
    // Move M-Send.req from Outbox into Sent.
    Uri uri = persister.move(mSendReqURI, Sent.CONTENT_URI);
  } finally {
    //調(diào)用TransactionService的update方法:處理mProcessing枯怖、mPending注整、網(wǎng)絡(luò)連接等
    notifyObservers();
  }
}

12.sendPdu

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

protected byte[] sendPdu(long token, byte[] pdu) throws IOException, MmsException {
  return sendPdu(token, pdu, mTransactionSettings.getMmscUrl());
}

13.sendPdu

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

protected byte[] sendPdu(long token, byte[] pdu, String mmscUrl) throws IOException, MmsException {
  if (pdu == null) {
    throw new MmsException();
  }

  ensureRouteToHost(mmscUrl, mTransactionSettings);
  return HttpUtils.httpConnection(
                mContext, token,
                mmscUrl,
                pdu, HttpUtils.HTTP_POST_METHOD,
                mTransactionSettings.isProxySet(),
                mTransactionSettings.getProxyAddress(),
                mTransactionSettings.getProxyPort());
}

14.httpConnection

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

protected static byte[] httpConnection(Context context, long token,
            String url, byte[] pdu, int method, boolean isProxySet,
            String proxyHost, int proxyPort) throws IOException {
  HttpResponse response = client.execute(target, req);
}
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市度硝,隨后出現(xiàn)的幾起案子肿轨,更是在濱河造成了極大的恐慌,老刑警劉巖蕊程,帶你破解...
    沈念sama閱讀 219,188評論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件椒袍,死亡現(xiàn)場離奇詭異,居然都是意外死亡藻茂,警方通過查閱死者的電腦和手機驹暑,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,464評論 3 395
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來辨赐,“玉大人优俘,你說我怎么就攤上這事∠菩颍” “怎么了帆焕?”我有些...
    開封第一講書人閱讀 165,562評論 0 356
  • 文/不壞的土叔 我叫張陵,是天一觀的道長森枪。 經(jīng)常有香客問我视搏,道長,這世上最難降的妖魔是什么县袱? 我笑而不...
    開封第一講書人閱讀 58,893評論 1 295
  • 正文 為了忘掉前任浑娜,我火速辦了婚禮,結(jié)果婚禮上式散,老公的妹妹穿的比我還像新娘筋遭。我一直安慰自己,他們只是感情好暴拄,可當我...
    茶點故事閱讀 67,917評論 6 392
  • 文/花漫 我一把揭開白布漓滔。 她就那樣靜靜地躺著,像睡著了一般乖篷。 火紅的嫁衣襯著肌膚如雪响驴。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,708評論 1 305
  • 那天撕蔼,我揣著相機與錄音豁鲤,去河邊找鬼。 笑死鲸沮,一個胖子當著我的面吹牛琳骡,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播讼溺,決...
    沈念sama閱讀 40,430評論 3 420
  • 文/蒼蘭香墨 我猛地睜開眼楣号,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了怒坯?” 一聲冷哼從身側(cè)響起炫狱,我...
    開封第一講書人閱讀 39,342評論 0 276
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎剔猿,沒想到半個月后毕荐,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,801評論 1 317
  • 正文 獨居荒郊野嶺守林人離奇死亡艳馒,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,976評論 3 337
  • 正文 我和宋清朗相戀三年憎亚,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片弄慰。...
    茶點故事閱讀 40,115評論 1 351
  • 序言:一個原本活蹦亂跳的男人離奇死亡第美,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出陆爽,到底是詐尸還是另有隱情什往,我是刑警寧澤,帶...
    沈念sama閱讀 35,804評論 5 346
  • 正文 年R本政府宣布慌闭,位于F島的核電站别威,受9級特大地震影響躯舔,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜省古,卻給世界環(huán)境...
    茶點故事閱讀 41,458評論 3 331
  • 文/蒙蒙 一粥庄、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧豺妓,春花似錦惜互、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,008評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至白嘁,卻和暖如春坑鱼,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背絮缅。 一陣腳步聲響...
    開封第一講書人閱讀 33,135評論 1 272
  • 我被黑心中介騙來泰國打工姑躲, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人盟蚣。 一個月前我還...
    沈念sama閱讀 48,365評論 3 373
  • 正文 我出身青樓黍析,卻偏偏與公主長得像,于是被迫代替她去往敵國和親屎开。 傳聞我的和親對象是個殘疾皇子阐枣,可洞房花燭夜當晚...
    茶點故事閱讀 45,055評論 2 355

推薦閱讀更多精彩內(nèi)容