老李推荐：第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来进行往下的命令字串的解析翻译处理工作
