Kaa学习指南（Java版）

Kaa项目学习有一个月时间， 由于是代码量非常庞大的开源项目， 上手起来还是比较困难的， 本文章主要是要和大家分享我的学习过程，遇到的困难，以及我们应该从哪里入手阅读代码比较好。

环境搭建

阅读文档

阅读Kaa的 设计文档 ，了解各个业务类型的。

阅读代码

从Notification Demo入手（下载源码）， 从官方给的源码，我们可以分析出客户端程序运行的入口。其实很简单， 只需要如下两行代码， 就可以将KaaClient启动起来。

/** new KaaClient 实例。 new DesktopKaaPlatformContext初始化Kaa上下文信息，主要是将sdk中client.properties信息同步到对象中；    * 还有初始化4个Executor（KaaClient start时候， 执行init()才将线程实例化）。他们分别是：    * lifeCycleExecutor（Kaa启动依赖本线程，如果该线程执行stop其他所有任务将停止，所以说他是kaaClient的生命周期），    * apiExecutor（），    * callbackExecutor（），              * scheduledExecutor(延时任务，典型例子DefaultChannelManager.onServerFailed())   **/  kaaClient = Kaa.newClient(new DesktopKaaPlatformContext());  kaaClient.start(); // 将其启动起来

Kaa.newClient主要执行的代码逻辑在其父类 AbstractKaaClient

AbstractKaaClient(KaaClientPlatformContext context, KaaClientStateListener listener) throws IOException, GeneralSecurityException {          /*          * KaaClientPlatformContext 中包含:          * 3个线程 + 1个定时任务线程 (Java Executor), 但未启动 SimpleExecutorContext          * */          this.context = context;          this.stateListener = listener;          if (context.getProperties() != null) {              this.properties = context.getProperties();          } else { // 客户端SDK示例代码 仅仅new了一个 DesktopKaaPlatformContext, 需要初始化client properties              /*              *  是对client.properties 文件进行解析              *  1.获取client.properties              *  2.解析bootstrap server 列表              *  3.等其他sdk中包含的信息              */              this.properties = new KaaClientProperties();          }            // 传递 Base64 编解码能力, BootstrapServers信息是Base64编码记录的          this.properties.setBase64(context.getBase64());            // 获取bootstrapServers信息          Map<TransportProtocolId, List<TransportConnectionInfo>> bootstrapServers = this.properties.getBootstrapServers();          if (bootstrapServers == null || bootstrapServers.isEmpty()) {              throw new RuntimeException("Unable to obtain list of bootstrap servers."); // NOSONAR          }            // 对bootstrapServer列表进行打乱操作          for (Map.Entry<TransportProtocolId, List<TransportConnectionInfo>> cursor : bootstrapServers.entrySet()) {              Collections.shuffle(cursor.getValue());          }            /*          * kaaClientState 数据初始化. kaaClient第一次启动是没有status.properties文件的, 当应用关闭时, Kaa status信息会持久化到status.properties文件中          * */          kaaClientState = new KaaClientPropertiesState(context.createPersistentStorage(), context.getBase64(), this.properties);            /*          * transportContext 实例化, 每个transport都有的功能是生成sync请求信息, 和接收sync请求服务器端的返回信息后,交给对应的manger处理具体业务.          * notes: sync操作就是客户端向服务器发起请求的操作. 当请求内容要有定制的是, 这里是修改点.          * */          TransportContext transportContext = buildTransportContext(properties, kaaClientState);            /*          * bootstrapManager主要功能是, 向bootstrapServer获取 operationServer的服务器列表, 和对operationServer列表的管理          * */          bootstrapManager = buildBootstrapManager(properties, kaaClientState, transportContext);            /*          * channelManager是对channel的管理, 目前有两个channel, bootStrapChannel(HTTP协议, 客户端和bootstrap交互的消息通道), operationChannel(MQTT协议, 客户端和operationServer交互的消息通道)          * notes: mqtt协议是包装在TCP协议上次的协议, 实际编程就是sock编程, 只是多了一次用mqtt协议编解码的过程.          * */          channelManager = buildChannelManager(bootstrapManager, bootstrapServers);            /*          * failoverManager是对channel发生故障后进行的业务操作          * */          failoverManager = buildFailoverManager(channelManager);            /*          * channelManager 和 failoverManager是相互依赖的          * */          channelManager.setFailoverManager(failoverManager);            /*          *  初始化 bootstrapChannel,operationsChannel. 将这两个channel添加到channelManger中管理.          *  添加channel到channelManager的channel list中之后, 每添加一个channel会启动一个使用该channel的线程, 线程会去处理一个阻塞队列. 也就是说会有会有地方去往这个队列中放消息的.          *  其实这两个阻塞队列就是sync操作的中转站. 当需要向服务端获取信息的时候, 向队列中放不同类型TransportType的SyncTask就会自动去执行sync操作了.          * */          initializeChannels(channelManager, transportContext);            bootstrapManager.setChannelManager(channelManager);          bootstrapManager.setFailoverManager(failoverManager);            /*          * 如下manger是处理来着各自transport的操作. transport是来着          * */          profileManager = buildProfileManager(properties, kaaClientState, transportContext);          notificationManager = buildNotificationManager(properties, kaaClientState, transportContext);          eventManager = buildEventManager(properties, kaaClientState, transportContext);          endpointRegistrationManager = buildRegistrationManager(properties, kaaClientState, transportContext);          logCollector = buildLogCollector(properties, kaaClientState, transportContext);          configurationManager = buildConfigurationManager(properties, kaaClientState, transportContext, context.getExecutorContext());            /*          * 将manager注入到transport中, 为了将manger的业务处理能力透传给transport          * */          transportContext.getRedirectionTransport().setBootstrapManager(bootstrapManager);          transportContext.getBootstrapTransport().setBootstrapManager(bootstrapManager);          transportContext.getProfileTransport().setProfileManager(profileManager);          transportContext.getEventTransport().setEventManager(eventManager);          transportContext.getNotificationTransport().setNotificationProcessor(notificationManager);          transportContext.getConfigurationTransport().setConfigurationHashContainer(configurationManager.getConfigurationHashContainer());          transportContext.getConfigurationTransport().setConfigurationProcessor(configurationManager.getConfigurationProcessor());          transportContext.getUserTransport().setEndpointRegistrationProcessor(endpointRegistrationManager);          transportContext.getLogTransport().setLogProcessor(logCollector);          transportContext.initTransports(this.channelManager, this.kaaClientState);            /*          * 构建EventFamily, 给客户端编程暴露接口          * */          eventFamilyFactory = new EventFamilyFactory(eventManager, context.getExecutorContext());  }