Monkey源碼分析之事件源

上一篇文章《Monkey源碼分析之運行流程》給出了monkey運行的整個流程，讓我們有一個概貌，那么往后的文章我們會嘗試進一步的闡述相關的一些知識點。

這里先把整個monkey類的結構圖給出來供大家參考，該圖源自網上（我自己的backbook pro上沒有安裝OmniGraffle工具，55美金，不舍得，所以直接貼網上的)

圖中有幾點需要注意下的：

• MonkeyEventScript應該是MonkeySourceScript
• MonkeyEventRandom應該是MonkeySourceRandom
• 這里沒有列出其他源，比如我們今天描述的重點MonkeySourceNetwork，因為它不是由MonkeyEventQueque這個類維護的，但其維護的事件隊列和MonkeyEventQueque一樣都是繼承于LinkedList的，所以大同小異

本文我們重點是以處理來來自網絡sokcet也就是monkeyrunner的命令為例子來闡述事件源是怎么處理的，其他的源大同小異。

1. 事件隊列維護者CommandQueque

在開始之前我們需要先去了解幾個基礎類，這樣子我們才方便分析。

我們在獲取了事件源之后，會把這些事件排隊放入一個隊列，然后其他地方就可以去把隊列里面的事件取出來進一步進行處理了。那么這里我們先看下維護這個事件隊列的相應代碼：

    public static interface CommandQueue {         /**          * Enqueue an event to be returned later.  This allows a          * command to return multiple events.  Commands using the          * command queue still have to return a valid event from their          * translateCommand method.  The returned command will be          * executed before anything put into the queue.          *          * @param e the event to be enqueued.          */         public void enqueueEvent(MonkeyEvent e);     };      // Queue of Events to be processed.  This allows commands to push     // multiple events into the queue to be processed.     private static class CommandQueueImpl implements CommandQueue{         private final Queue<MonkeyEvent> queuedEvents = new LinkedList<MonkeyEvent>();          public void enqueueEvent(MonkeyEvent e) {             queuedEvents.offer(e);         }          /**          * Get the next queued event to excecute.          *          * @return the next event, or null if there aren't any more.          */         public MonkeyEvent getNextQueuedEvent() {             return queuedEvents.poll();         }     }; 

接口CommandQueue只定義個了一個方法enqueueEvent,由實現類CommandQueueImpl來實現，而實現類維護了一個MonkeyEvent類型的由LinkedList實現的隊列quequeEvents,然后實現了兩個方法來分別往這個隊列里面放和取事件。挺簡單的實現，這里主要是要提醒大家queueEvents這個隊列的重要性。這里要注意的是MonkeyEventScript和monkeyEventRandom這兩個事件源維護隊列的類稍微有些不一樣，用的是MonkeyEventQueue這個類，但是其實這個類也是繼承自上面描述的LinkedList的，所以原理是一樣的。

最后創建和維護一個CommandQueueImple這個實現類的一個實例commandQueque來轉被對里面的quequeEvents進行管理。

    private final CommandQueueImpl commandQueue = new CommandQueueImpl();

2. 事件翻譯員MonkeyCommand

下一個我們需要了解的基礎內部類就是MonkeCommand。從數據源過來的命令都是一串字符串，我們需要把它轉換成對應的monkey事件并存入到我們上面提到的由CommandQueque維護的事件隊列quequeEvents里面。首先我們看下MonkeyCommand這個接口：

    /**      * Interface that MonkeyCommands must implement.      */     public interface MonkeyCommand {         /**          * Translate the command line into a sequence of MonkeyEvents.          *          * @param command the command line.          * @param queue the command queue.          * @return MonkeyCommandReturn indicating what happened.          */         MonkeyCommandReturn translateCommand(List<String> command, CommandQueue queue);     }

它只定義了一個實現類需要實現的方法translateCommand，從它的描述和接受的的參數可以知道，這個方法要做的事情就是把從事件源接受到的字符串命令轉換成上面說的CommandQueue類型維護的那個eventQueues。以monkeyrunner發過來的press這個命令為例子，傳過來給monkey的字串是"press KEY_COKDE"(請查看《MonkeyRunner源碼分析之與Android設備通訊方式》）

針對每一個命令都會有一個對應的MonkeyCommand的實現類來做真正的字串到事件的翻譯工作，以剛才提到的press這個命令為例子，我們看下它的實現代碼：

    /**      * Command to "press" a buttons (Sends an up and down key event.)      */     private static class PressCommand implements MonkeyCommand {         // press keycode         public MonkeyCommandReturn translateCommand(List<String> command,                                                     CommandQueue queue) {             if (command.size() == 2) {                 int keyCode = getKeyCode(command.get(1));                 if (keyCode < 0) {                     // Ok, you gave us something bad.                     Log.e(TAG, "Can't find keyname: " + command.get(1));                     return EARG;                 }                  queue.enqueueEvent(new MonkeyKeyEvent(KeyEvent.ACTION_DOWN, keyCode));                 queue.enqueueEvent(new MonkeyKeyEvent(KeyEvent.ACTION_UP, keyCode));                 return OK;              }             return EARG;         }     }

• 從字串中得到第1個參數，也就是key_code
• 判斷key_code是否有效
• 建立按下按鍵的MonkeyKeyEvent事件并存入到CommandQueque維護的quequeEvents
• 建立彈起按鍵的MonkeyKeyEvent事件并存入到CommandQueque維護的quequeEvents(press這個動作會出發按下和彈起按鍵兩個動作）

private static final Map<String, MonkeyCommand> COMMAND_MAP = new HashMap<String, MonkeyCommand>();      static {         // Add in all the commands we support         COMMAND_MAP.put("flip", new FlipCommand());         COMMAND_MAP.put("touch", new TouchCommand());         COMMAND_MAP.put("trackball", new TrackballCommand());         COMMAND_MAP.put("key", new KeyCommand());         COMMAND_MAP.put("sleep", new SleepCommand());         COMMAND_MAP.put("wake", new WakeCommand());         COMMAND_MAP.put("tap", new TapCommand());         COMMAND_MAP.put("press", new PressCommand());         COMMAND_MAP.put("type", new TypeCommand());         COMMAND_MAP.put("listvar", new MonkeySourceNetworkVars.ListVarCommand());         COMMAND_MAP.put("getvar", new MonkeySourceNetworkVars.GetVarCommand());         COMMAND_MAP.put("listviews", new MonkeySourceNetworkViews.ListViewsCommand());         COMMAND_MAP.put("queryview", new MonkeySourceNetworkViews.QueryViewCommand());         COMMAND_MAP.put("getrootview", new MonkeySourceNetworkViews.GetRootViewCommand());         COMMAND_MAP.put("getviewswithtext",                         new MonkeySourceNetworkViews.GetViewsWithTextCommand());         COMMAND_MAP.put("deferreturn", new DeferReturnCommand());     }

3. 事件源獲取者之getNextEvent

終于到了如何獲取事件的分析了，我們繼續以MonkeySourceNetwork這個處理monkeyrunner過來的網絡命令為例子，看下它是如何處理monkeyrunner過來的命令的。我們先看下它實現的接口類MonkeyEventSource

/**  * event source interface  */ public interface MonkeyEventSource {     /**      * @return the next monkey event from the source      */     public MonkeyEvent getNextEvent();      /**      * set verbose to allow different level of log      *      * @param verbose output mode? 1= verbose, 2=very verbose      */     public void setVerbose(int verbose);      /**      * check whether precondition is satisfied      *      * @return false if something fails, e.g. factor failure in random source or      *         file can not open from script source etc      */     public boolean validate(); }

    public MonkeySourceNetwork(int port) throws IOException {         // Only bind this to local host.  This means that you can only         // talk to the monkey locally, or though adb port forwarding.         serverSocket = new ServerSocket(port,                                         0, // default backlog                                         InetAddress.getLocalHost());     }

這里只是實例化了一個socket，現在為止還沒有真正啟動起來的，也就是說還沒有開始真正的啟動對指定端口的監聽的。真正開始監聽是startServer這個方法觸發的：

    /**      * Start a network server listening on the specified port.  The      * network protocol is a line oriented protocol, where each line      * is a different command that can be run.      *      * @param port the port to listen on      */     private void startServer() throws IOException {         clientSocket = serverSocket.accept();         // At this point, we have a client connected.         // Attach the accessibility listeners so that we can start receiving         // view events. Do this before wake so we can catch the wake event         // if possible.         MonkeySourceNetworkViews.setup();         // Wake the device up in preparation for doing some commands.         wake();          input = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));         // auto-flush         output = new PrintWriter(clientSocket.getOutputStream(), true);     }

    public MonkeyEvent getNextEvent() {         if (!started) {             try {                 startServer();             } catch (IOException e) {                 Log.e(TAG, "Got IOException from server", e);                 return null;             }             started = true;         }          // Now, get the next command.  This call may block, but that's OK         try {             while (true) {                 // Check to see if we have any events queued up.  If                 // we do, use those until we have no more.  Then get                 // more input from the user.                 MonkeyEvent queuedEvent = commandQueue.getNextQueuedEvent();                 if (queuedEvent != null) {                     // dispatch the event                     return queuedEvent;                 }                  // Check to see if we have any returns that have been deferred. If so, now that                 // we've run the queued commands, wait for the given event to happen (or the timeout                 // to be reached), and handle the deferred MonkeyCommandReturn.                 if (deferredReturn != null) {                     Log.d(TAG, "Waiting for event");                     MonkeyCommandReturn ret = deferredReturn.waitForEvent();                     deferredReturn = null;                     handleReturn(ret);                 }                  String command = input.readLine();                 if (command == null) {                     Log.d(TAG, "Connection dropped.");                     // Treat this exactly the same as if the user had                     // ended the session cleanly with a done commant.                     command = DONE;                 }                  if (DONE.equals(command)) {                     // stop the server so it can accept new connections                     try {                         stopServer();                     } catch (IOException e) {                         Log.e(TAG, "Got IOException shutting down!", e);                         return null;                     }                     // return a noop event so we keep executing the main                     // loop                     return new MonkeyNoopEvent();                 }                  // Do quit checking here                 if (QUIT.equals(command)) {                     // then we're done                     Log.d(TAG, "Quit requested");                     // let the host know the command ran OK                     returnOk();                     return null;                 }                  // Do comment checking here.  Comments aren't a                 // command, so we don't echo anything back to the                 // user.                 if (command.startsWith("#")) {                     // keep going                     continue;                 }                  // Translate the command line.  This will handle returning error/ok to the user                 translateCommand(command);             }         } catch (IOException e) {             Log.e(TAG, "Exception: ", e);             return null;         }     }

• 啟動socket端口監聽monkeyrunner過來的連接和數據
• 進入無限循環
  • 調用最上面描述的commandQueque這個事件隊列維護者實例來嘗試來從隊列獲得一個事件
  • 如果隊列由事件的話就立刻返回給上一篇文章《MonkeyRunner源碼分析之啟動》描述的runMonkeyCles那個方法取調用執行
  • 如果隊列沒有事件的話，調用上面描述的socket讀寫變量input來獲得socket中monkeyrunner發過來的一行數據（也就是一個命令字串）
  • 調用translateCommand這個私有方法來針對不同的命令調用不同的MonkeyCommand實現類接口的translateCommand把字串命令翻譯成對應的事件并放到命令隊列里面（這個命令上面還沒有描述，往下我會分析下）
  • 如果確實沒有命令了或者收到信號要退出了等情況下就跳出循環，否則回到循環開始繼續以上步驟

    /**      * Translate the given command line into a MonkeyEvent.      *      * @param commandLine the full command line given.      */     private void translateCommand(String commandLine) {         Log.d(TAG, "translateCommand: " + commandLine);         List<String> parts = commandLineSplit(commandLine);         if (parts.size() > 0) {             MonkeyCommand command = COMMAND_MAP.get(parts.get(0));             if (command != null) {                 MonkeyCommandReturn ret = command.translateCommand(parts, commandQueue);                 handleReturn(ret);             }         }     }

COMMAND_MAP.put("press", new PressCommand());

作者	自主博客	微信	CSDN
天地會珠海分舵	http://techgogogo.com	服務號:TechGoGoGo 掃描碼:	向AI問一下細節 推薦閱讀： 玩轉Android monkey之環境配置和ADB命令 shell monkey 免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。 monkey monkeyrunner monkeyeventsource 上一篇新聞： postgresql學習筆記（五）備份與恢復 下一篇新聞： redis參數配置說明 猜你喜歡 sql文件太大如何打開 oracle中insert select語句怎么使用 sqlserver怎么導入sql文件 sqlserver如何導入本地數據庫 sqlserver數據庫怎么導出表 c#中object轉指定的類型怎么實現 winform如何調用其他窗口 c++中set容器有哪些特點 java中charsequence的用法是什么 java中charsequence的作用是什么 最新資訊 pycharm在ubuntu怎樣啟用代碼導航工具 ubuntu中pycharm如何禁用代碼導航工具 在ubuntu用pycharm怎樣啟用代碼重構工具 ubuntu下pycharm如何禁用代碼重構工具 pycharm ubuntu版怎樣啟用代碼優化工具 ubuntu上pycharm如何禁用代碼優化工具 在ubuntu pycharm怎樣啟用代碼審查工具 ubuntu下pycharm如何禁用代碼審查工具 pycharm在ubuntu怎樣啟用代碼覆蓋率工具 ubuntu中pycharm如何禁用代碼覆蓋率工具 相關推薦 Clever Monkey - Fun Game 源碼分析系列之PomeloForEgret Monkey工具怎么用 Android之monkey Test monkey源碼分析之事件注入方法變化 Monkey源碼分析之事件注入 Monkey源碼分析番外篇之Android注入事件的三種方法比較 Monkey源碼分析番外篇之WindowManager注入事件如何跳出進程間安全限制 Monkey源碼分析之運行流程 javaScript事件源是什么 相關標簽 mongodb mongodb安裝 mongodump monitor next-key foreign key mongodb3 mongodb查詢 mongodb事務 mongodb啟動報錯 monogodb commonjs mongodb性能 mongorestore mongoexport keycloak mongodb分片 key判斷 .mongorc.js waitkey AI 助 手 產品服務 云服務器 高防服務器 高防IP 裸金屬服務器 機柜租用 SSL證書 高防CDN 彈性IP 地區劃分 中國香港服務器 美國服務器 德國服務器 日本服務器 韓國服務器 新加坡服務器 專題活動 控制臺 應用市場 最新活動 九馬 智能直播 幫助支持 幫助中心 網站備案 法律條款 全國服務 安全漏洞 主題地圖 關于我們 關于億速云 客戶案例 新聞資訊 資訊地圖 問答地圖 聯系我們 人才招聘 售后咨詢 7*24小時在線電話：400-100-2938 7*24小時在線 QQ：800811969 關注億速云 億速云公眾號 手機網站二維碼 Copyright ? Yisu Cloud Ltd. All Rights Reserved. 2018 版權所有 廣州億速云計算有限公司粵ICP備17096448號-1 粵公網安備 44010402001142號增值電信業務經營許可證編號：B1-20181529 夏河县| 荣成市| 瓦房店市| 武胜县| 尉犁县| 岑溪市| 武冈市| 罗源县| 富川| 潮州市| 涟水县| 瑞丽市| 永福县| 彩票| 黄浦区| 宜兰市| 金山区| 东兴市| 平顶山市| 肃北| 大洼县| 永泰县| 宁阳县| 胶南市| 开封县| 济南市| 吕梁市| 唐山市| 金平| 萨迦县| 清新县| 利川市| 龙游县| 嘉荫县| 太白县| 万源市| 于都县| 闻喜县| 合川市| 灌云县| 师宗县|