老李推荐：第6章2节《MonkeyRunner源码剖析》Monkey原理分析-事件源-事件源概览-获取命令字串

从上一节的描述可以知道，MonkeyRunner发送给Monkey的命令是以字符串的形式交互的，那么事件处理的第一步当然是先去获得MonkeyRunner发送过来的字串命令了。

在事件源MonkeySourceNetwork初始化的时候构造函数会创建一个ServerSocket来监听来自客户端的链接和数据，但这个时候客户端并不能真正实现和服务端通信，因为该ServerSocket尚处于阻塞状态。既然ServerSocket是MonkeySourceNetwork的构造函数创建的，那么建立通信的又是哪个方法呢？真正的通信又是什么时候开始建立呢？

这里我们先回答第一个问题，建立通信是由MonkeySourceNetwork的私有成员方法startServer来处理的:

private void startServer()

throws IOException

{

this.clientSocket = this.serverSocket.accept();

...

MonkeySourceNetworkViews.setup();

wake();

this.input = new BufferedReader(new InputStreamReader(this.clientSocket.getInputStream()));

this.output = new PrintWriter(this.clientSocket.getOutputStream(), true);

}

代码6-2-1 MonkeySourceNetwork - startServer

• 572行: 通过调用serverSocket的accept方法来建立一个与客户端连接的Socket通信通道，并把该Socket实例赋予给clientSocket,往下会通过操作这个Socket实例来和客户端交互

• 581行: 初始化从clientSocket读取数据的BufferedReader实例并赋予给input成员变量，往后的代码只需要调用input的readline方法就能获得一行命令字串数据

• 583行: 初始化往clientSocket打印输出的PrintWriter实例并赋予给output成员变量，往后的代码只需要调用output的print或者println之类的方法就能往客户端传送数据

回答完第一个问题后，我们跟着看第二个问题，什么时候开始建立通信的？其实这个问题到了现在可以替换成:startServer是谁触发调用的。是从Monkey类的循环执行事件方法runMonkeyCyles调用mEventSource.getNextEvent开始触发的。上一章已经分析过这里的mEventSource是被初始化成MonkeySourceNetwork,因为Monkey是通过MonkeyRunner发送的命令”monkey --port 12345”来启动的。那么我们进入MonkeySourceNetwork的getNextEvent方法:

682   public MonkeyEvent getNextEvent()

683   {

684     if (!this.started) {

685       try {

686         startServer();

687       } catch (IOException e) {

688         Log.e("MonkeyStub", "Got IOException from server", e);

689         return null;

690       }

691       this.started = true;

692     }

...

696     try

697     {

698       for (;;)

699       {

700         MonkeyEvent queuedEvent = this.commandQueue.getNextQueuedEvent();

701         if (queuedEvent != null)

702         {

703           return queuedEvent;

704         }

...

709         if (deferredReturn != null) {

710           Log.d("MonkeyStub", "Waiting for event");

711           MonkeyCommandReturn ret = deferredReturn.waitForEvent();

712           deferredReturn = null;

713           handleReturn(ret);

714         }

715

716         String command = this.input.readLine();

717         if (command == null) {

718           Log.d("MonkeyStub", "Connection dropped.");

719

720

721           command = "done";

722         }

723

724         if ("done".equals(command))

725         {

726           try {

727             stopServer();

728           } catch (IOException e) {

729             Log.e("MonkeyStub", "Got IOException shutting down!", e);

730             return null;

731           }

732

733

734           return new MonkeyNoopEvent();

735         }

736

737

738         if ("quit".equals(command))

739         {

740           Log.d("MonkeyStub", "Quit requested");

741

742           returnOk();

743           return null;

744         }

...

748

749         if (!command.startsWith("#"))

750         {

...

755           translateCommand(command);

756         }

757       }

758

759       return null;

760     }

761     catch (IOException e)

762     {

763       Log.e("MonkeyStub", "Exception: ", e);

764     }

765   }

代码6-2-2 MonkeySourceNetwork - getNextEvent

• 684-687行: 如果在此之前还没有建立和客户端的通信的话，那么调用startServer方法来建立通信

• 691行: 把通信状态保存下来。下次调用getNextEvent获取命令字串时就会在684行判断通信是否已经建立，是的话就会使用既有的通信，而不会创建新的Socket通信了

• 698行: 进入一个无限循环，直到获取到一个事件位置

• 700-703行: 如果命令队列中还有事件没有处理的话，从命令队列中取得一个事件返回

• 716行: 通过调用上面提到的input的readline方法获得一个MonkeyRunner客户端发送过来的命令字串

• 724-728行: 判断如果MonkeyRunner发送过来的命令字串是”done”的话，关闭与客户端的Socket通信

• 738-744行: 判断如果MonkeyRunner发送过来的命令字串是”quit”的话，直接退出循环

• 749-756行: 判断如果MonkeyRunner发送过来的命令字串不是上面两种情况，且不是以”#”号开始的话，调用MonkeySourceNetwork的translateCommand来进行往下的命令字串的解析翻译处理工作