Android系统服务TelecomService启动过程原理分析

 

   
   ....
   // 包含TelecomService
   
    
     
    
   
  ....
  
 

 private void startOtherServices() {
  ....
  //启动TelecomLoaderService系统服务，用于加载Telecom
  mSystemServiceManager.startService(TelecomLoaderService.class);
  // 启动telephony注册服务，用于注册监听telephony状态的接口
  telephOnyRegistry= new TelephonyRegistry(context);
  ServiceManager.addService("telephony.registry", telephonyRegistry);
 }

 public class SystemServiceManager {

  @SuppressWarnings("unchecked")
  public SystemService startService(String className) {
   final Class serviceClass;
   try {
    serviceClass = (Class)Class.forName(className);
   } catch (ClassNotFoundException ex) {
    ....
   }
   return startService(serviceClass);
  }

  // 服务的class文件来创建新的服务对象(服务必须继承SystemService)
  @SuppressWarnings("unchecked")
  public  T startService(Class serviceClass) {
   try {
    final String name = serviceClass.getName();
    Slog.i(TAG, "Starting " + name);
    Trace.traceBegin(Trace.TRACE_TAG_SYSTEM_SERVER, "StartService " + name);

    // Create the service.
    if (!SystemService.class.isAssignableFrom(serviceClass)) {
     throw new RuntimeException("Failed to create " + name
       + ": service must extend " + SystemService.class.getName());
    }
    final T service;
    try {
     Constructor cOnstructor= serviceClass.getConstructor(Context.class);
     service = constructor.newInstance(mContext);
    } catch (InstantiationException ex) {
     throw new RuntimeException("Failed to create service " + name
       + ": service could not be instantiated", ex);
    } 
    ....
    // Register it.
    mServices.add(service);

    // Start it.
    try {
     service.onStart();
    } catch (RuntimeException ex) {
     throw new RuntimeException("Failed to start service " + name
       + ": onStart threw an exception", ex);
    }
    return service;
   } finally {
    Trace.traceEnd(Trace.TRACE_TAG_SYSTEM_SERVER);
   }
  }
 }

 public class TelecomLoaderService extends SystemService {
  ...
  public TelecomLoaderService(Context context) {
   super(context);
   mCOntext= context;
   registerDefaultAppProviders();
  }

  @Override
  public void onStart() {
  }

  private void registerDefaultAppProviders() {
   final PackageManagerInternal packageManagerInternal = LocalServices.getService(
     PackageManagerInternal.class);

   // Set a callback for the package manager to query the default sms app.
   packageManagerInternal.setSmsAppPackagesProvider(
     new PackageManagerInternal.PackagesProvider() {
    @Override
    public String[] getPackages(int userId) {
     synchronized (mLock) {
     ....
     ComponentName smsCompOnent= SmsApplication.getDefaultSmsApplication(
       mContext, true);
     if (smsComponent != null) {
      return new String[]{smsComponent.getPackageName()};
     }
     return null;
    }
   });

   // Set a callback for the package manager to query the default dialer app.
   packageManagerInternal.setDialerAppPackagesProvider(
     new PackageManagerInternal.PackagesProvider() {
    @Override
    public String[] getPackages(int userId) {
     synchronized (mLock) {
     ....
     String packageName = DefaultDialerManager.getDefaultDialerApplication(mContext);
     if (packageName != null) {
      return new String[]{packageName};
     }
     return null;
    }
   });

   // Set a callback for the package manager to query the default sim call manager.
   packageManagerInternal.setSimCallManagerPackagesProvider(
     new PackageManagerInternal.PackagesProvider() {
    @Override
    public String[] getPackages(int userId) {
     synchronized (mLock) {
     ....
     TelecomManager telecomManager =
      (TelecomManager) mContext.getSystemService(Context.TELECOM_SERVICE);
     PhoneAccountHandle phOneAccount= telecomManager.getSimCallManager(userId);
     if (phoneAccount != null) {
      return new String[]{phoneAccount.getComponentName().getPackageName()};
     }
     return null;
    }
   });
  }
 }

 public class TelecomLoaderService extends SystemService {

  private static final ComponentName SERVICE_COMPOnENT= new ComponentName(
    "com.android.server.telecom",
    "com.android.server.telecom.components.TelecomService");

  private static final String SERVICE_ACTION = "com.android.ITelecomService";

  // 当前系统启动的阶段
  @Override
  public void onBootPhase(int phase) {
   if (phase == PHASE_ACTIVITY_MANAGER_READY) {
    registerDefaultAppNotifier();
    registerCarrierConfigChangedReceiver();
    connectToTelecom();
   }
  }

  //绑定Telecom服务
  private void connectToTelecom() {
   synchronized (mLock) {
    if (mServiceConnection != null) {
     // TODO: Is unbinding worth doing or wait for system to rebind&＃63;
     mContext.unbindService(mServiceConnection);
     mServiceCOnnection= null;
    }

    TelecomServiceConnection serviceCOnnection= new TelecomServiceConnection();
    Intent intent = new Intent(SERVICE_ACTION);
    intent.setComponent(SERVICE_COMPONENT);
    int flags = Context.BIND_IMPORTANT | Context.BIND_FOREGROUND_SERVICE
      | Context.BIND_AUTO_CREATE;

    // Bind to Telecom and register the service
    if (mContext.bindServiceAsUser(intent, serviceConnection, flags, UserHandle.SYSTEM)) {
     mServiceCOnnection= serviceConnection;
    }
   }
  }
 }

 public class TelecomLoaderService extends SystemService {

  private class TelecomServiceConnection implements ServiceConnection {
    @Override
    public void onServiceConnected(ComponentName name, IBinder service) {
     // Normally, we would listen for death here, but since telecom runs in the same process
     // as this loader (process="system") thats redundant here.
     try {
      service.linkToDeath(new IBinder.DeathRecipient() {
       @Override
       public void binderDied() {
        connectToTelecom();
       }
      }, 0);
      SmsApplication.getDefaultMmsApplication(mContext, false);
      //添加Telecom服务
      ServiceManager.addService(Context.TELECOM_SERVICE, service);
      ....
    }

    @Override
    public void onServiceDisconnected(ComponentName name) {
     connectToTelecom();
    }
   }
 }

 /**
  * Implementation of the ITelecom interface.
  */
 public class TelecomService extends Service implements TelecomSystem.Component {

  @Override
  public IBinder onBind(Intent intent) {
   // 初始化整个Telecom系统
   initializeTelecomSystem(this);
   //返回IBinder接口
   synchronized (getTelecomSystem().getLock()) {
    return getTelecomSystem().getTelecomServiceImpl().getBinder();
   }
  }

 }

 static void initializeTelecomSystem(Context context) {
   if (TelecomSystem.getInstance() == null) {

    final NotificationManager notificatiOnManager=
      (NotificationManager) context.getSystemService(Context.NOTIFICATION_SERVICE);
    // 用于获取联系人
    cOntactInfoHelper= new ContactInfoHelper(context);
    // 新建一个单例模式的对象
    TelecomSystem.setInstance(new TelecomSystem(....));
   }
   ....
  }
 }

 public TelecomSystem(
    Context context,
    /* 用户未接来电通知类（不包括已接或者拒绝的电话） */
    MissedCallNotifierImplFactory missedCallNotifierImplFactory,
    /* 查询来电信息 */
    CallerInfoAsyncQueryFactory callerInfoAsyncQueryFactory,
    /* 耳机接入状态监听 */
    HeadsetMediaButtonFactory headsetMediaButtonFactory,
    /* 距离传感器管理 */
    ProximitySensorManagerFactory proximitySensorManagerFactory,
    /* 通话时电话管理 */
    InCallWakeLockControllerFactory inCallWakeLockControllerFactory,
    /* 音频服务管理 */
    AudioServiceFactory audioServiceFactory,
    /* 蓝牙设备管理 */
    BluetoothPhoneServiceImplFactory bluetoothPhoneServiceImplFactory,
    BluetoothVoIPServiceImplFactory bluetoothVoIPServiceImplFactory,
    /* 查询所有超时信息 */
    Timeouts.Adapter timeoutsAdapter,
    /* 响铃播放 */
    AsyncRingtonePlayer asyncRingtonePlayer,
    /* 电话号码帮助类 */
    PhoneNumberUtilsAdapter phoneNumberUtilsAdapter,
    /* 通话时阻断通知 */
    InterruptionFilterProxy interruptionFilterProxy) {
   mCOntext= context.getApplicationContext();
   // 初始化telecom相关的feature
   TelecomFeature.makeFeature(mContext);
   // 初始化telecom的数据库
   TelecomSystemDB.initialize(mContext);
   // 创建一个PhoneAccount注册管理类
   mPhOneAccountRegistrar= new PhoneAccountRegistrar(mContext);
   ....
   // 初始化通话管家，正是它负责与上层UI的交互
   mCallsManager = new CallsManager(
     mContext, mLock, mContactsAsyncHelper,
     callerInfoAsyncQueryFactory, mMissedCallNotifier,
     mPhoneAccountRegistrar, headsetMediaButtonFactory,
     proximitySensorManagerFactory, inCallWakeLockControllerFactory,
     audioServiceFactory, bluetoothManager,
     wiredHeadsetManager, systemStateProvider,
     defaultDialerAdapter, timeoutsAdapter,AsyncRingtonePlayer,
     phoneNumberUtilsAdapter, interruptionFilterProxy);

   CallsManager.initialize(mCallsManager);
   // 注册需要接收的广播 
   mContext.registerReceiver(mUserSwitchedReceiver, USER_SWITCHED_FILTER);
   mContext.registerReceiver(mUserStartingReceiver, USER_STARTING_FILTER);
   mContext.registerReceiver(mFeatureChangedReceiver, FEATURE_CHANGED_FILTER);
   mContext.registerReceiver(mEmergencyReceiver, EMERGENCY_STATE_CHANGED);
   .... 
   // 所有来电与去电的处理中转站
   mCallIntentProcessor = new CallIntentProcessor(mContext, mCallsManager);
   // 创建一个TelecomServiceImpl用于调用TelecomService的接口
   mTelecomServiceImpl = new TelecomServiceImpl(
     mContext, mCallsManager, mPhoneAccountRegistrar,
     new CallIntentProcessor.AdapterImpl(),
     new UserCallIntentProcessorFactory() {
      @Override
      public UserCallIntentProcessor create(Context context, UserHandle userHandle) {
       return new UserCallIntentProcessor(context, userHandle);
      }
     },
     defaultDialerAdapter,
     new TelecomServiceImpl.SubscriptionManagerAdapterImpl(),
     mLock);
   // 执行特定的初始化操作
   initialize(mContext);
  }
 }