import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
/**
 * Executes a command with a specified timeout on the device's shell and returns the result of the execution. If the
 * default timeout is grater than the requested one, default will be used.
 *
 * @param command
 *        - Shell command to be executed.
 * @param timeout
 *        - timeout to be used in the adb connection, when executing a command on the device.
 * @return Shell response from the command execution.
 * @throws CommandFailedException
 *         In case of an error in the execution
 */
public String execute(String command, int timeout) throws CommandFailedException {
    String response = "";

    int commandExecutionTimeout = Math.max(timeout, COMMAND_EXECUTION_TIMEOUT);

    try {
        CollectingOutputReceiver outputReceiver = new CollectingOutputReceiver();
        device.executeShellCommand(command, outputReceiver, commandExecutionTimeout);

        response = outputReceiver.getOutput();
    } catch (TimeoutException | AdbCommandRejectedException | ShellCommandUnresponsiveException | IOException e) {
        throw new CommandFailedException("Shell command execution failed.", e);
    }

    return response;
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
@Override
public void onData(SocketIOClient client, String data, AckRequest ackSender)
		throws Exception {
	if (data != null) {
		CommandBean commandBean = JsonUtil.jsonTobean(data,
				CommandBean.class);
		if (commandBean != null && commandBean.getSerList() != null
				&& commandBean.getCommand() != null) {
			for (String sernum : commandBean.getSerList()) {
				executorService.execute(new Runnable() {

					@Override
					public void run() {
						DeviceEntity deviceEntity = DeviceContainerHandler
								.getDevice(sernum);
						if (deviceEntity != null) {
							IDevice idevice = deviceEntity.getIdevice();
							if (idevice.isOnline()) {
								CollectingOutputReceiver receiver = new CollectingOutputReceiver();
								try {
									idevice.executeShellCommand(
											commandBean.getCommand(),
											receiver);
								} catch (TimeoutException
										| AdbCommandRejectedException
										| ShellCommandUnresponsiveException
										| IOException e) {
									logger.error("执行命令发送异常", e);
								}
								receiver.flush();
								logger.info(receiver.getOutput());
							}
						}
					}
				});
			}
		}
	}
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
public void performAction() {
  final ScreenRecorderOptionsDialog dialog = new ScreenRecorderOptionsDialog(myProject);
  if (!dialog.showAndGet()) {
    return;
  }

  final ScreenRecorderOptions options = dialog.getOptions();

  final CountDownLatch latch = new CountDownLatch(1);
  final CollectingOutputReceiver receiver = new CollectingOutputReceiver(latch);

  ApplicationManager.getApplication().executeOnPooledThread(new Runnable() {
    @Override
    public void run() {
      try {
        myDevice.startScreenRecorder(REMOTE_PATH, options, receiver);
      }
      catch (Exception e) {
        showError(myProject, "Unexpected error while launching screen recorder", e);
        latch.countDown();
      }
    }
  });

  Task.Modal screenRecorderShellTask = new ScreenRecorderTask(myProject, myDevice, latch, receiver);
  screenRecorderShellTask.setCancelText("Stop Recording");
  screenRecorderShellTask.queue();
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
public ScreenRecorderTask(@NotNull Project project,
                          @NotNull IDevice device,
                          @NotNull CountDownLatch completionLatch,
                          @NotNull CollectingOutputReceiver receiver) {
  super(project, TITLE, true);

  myDevice = device;
  myCompletionLatch = completionLatch;
  myReceiver = receiver;
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
@Nullable
public static Integer getWorkProfileId(IDevice device)
    throws TimeoutException, AdbCommandRejectedException, ShellCommandUnresponsiveException,
        IOException {
  CollectingOutputReceiver receiver = new CollectingOutputReceiver();
  device.executeShellCommand("pm list users", receiver);
  String result = receiver.getOutput();
  Matcher matcher = USER_ID_REGEX.matcher(result);
  if (matcher.find()) {
    return Integer.parseInt(matcher.group(1));
  }
  return null;
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
/**
 * Runs a command on a device and throws an exception if it fails.
 *
 * <p>This will not work if your command contains "exit" or "trap" statements.
 *
 * @param device Device to run the command on.
 * @param command Shell command to execute.  Must not use "exit" or "trap".
 * @return The full text output of the command.
 * @throws CommandFailedException if the command fails.
 */
public static String executeCommandWithErrorChecking(IDevice device, String command)
    throws
    TimeoutException,
    AdbCommandRejectedException,
    ShellCommandUnresponsiveException,
    IOException {
  CollectingOutputReceiver receiver = new CollectingOutputReceiver();
  device.executeShellCommand(command + " ; echo -n :$?", receiver);
  String realOutput = checkReceiverOutput(command, receiver);
  return realOutput;
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
/**
 * This was made public for one specific call site in ExopackageInstaller.
 * If you're reading this, you probably shouldn't call it.  Pretend this method is private.
 */
public static String checkReceiverOutput(
    String command,
    CollectingOutputReceiver receiver) throws CommandFailedException {
  String fullOutput = receiver.getOutput();
  int colon = fullOutput.lastIndexOf(':');
  String realOutput = fullOutput.substring(0, colon);
  String exitCodeStr = fullOutput.substring(colon + 1);
  int exitCode = Integer.parseInt(exitCodeStr);
  if (exitCode != 0) {
    throw new CommandFailedException(command, exitCode, realOutput);
  }
  return realOutput;
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
/**
 * Retrieves external storage location (SD card) from device.
 */
private String deviceGetExternalStorage(IDevice device) throws TimeoutException,
    AdbCommandRejectedException, ShellCommandUnresponsiveException, IOException {
  CollectingOutputReceiver receiver = new CollectingOutputReceiver();
  device.executeShellCommand(
      "echo $EXTERNAL_STORAGE",
      receiver,
      AdbHelper.GETPROP_TIMEOUT,
      TimeUnit.MILLISECONDS);
  String value = receiver.getOutput().trim();
  if (value.isEmpty()) {
    return null;
  }
  return value;
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
private static String checkReceiverOutput(String command, CollectingOutputReceiver receiver)
    throws AdbHelper.CommandFailedException {
  String fullOutput = receiver.getOutput();
  int colon = fullOutput.lastIndexOf(':');
  String realOutput = fullOutput.substring(0, colon);
  String exitCodeStr = fullOutput.substring(colon + 1);
  int exitCode = Integer.parseInt(exitCodeStr);
  if (exitCode != 0) {
    throw new AdbHelper.CommandFailedException(command, exitCode, realOutput);
  }
  return realOutput;
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
private String executeCommandWithErrorChecking(String command)
    throws TimeoutException, AdbCommandRejectedException, ShellCommandUnresponsiveException,
        IOException {
  CollectingOutputReceiver receiver = new CollectingOutputReceiver();
  device.executeShellCommand(command + ECHO_COMMAND_SUFFIX, receiver);
  return checkReceiverOutput(command, receiver);
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
/** Retrieves external storage location (SD card) from device. */
@Nullable
private String deviceGetExternalStorage()
    throws TimeoutException, AdbCommandRejectedException, ShellCommandUnresponsiveException,
        IOException {
  CollectingOutputReceiver receiver = new CollectingOutputReceiver();
  device.executeShellCommand(
      "echo $EXTERNAL_STORAGE", receiver, GETPROP_TIMEOUT, TimeUnit.MILLISECONDS);
  String value = receiver.getOutput().trim();
  if (value.isEmpty()) {
    return null;
  }
  return value;
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
@Override
	public void onData(SocketIOClient client, String str, AckRequest ackRequest) throws Exception {
		logger.info(str);
		OpenActivityBean bean = JsonUtil.jsonTobean(str, OpenActivityBean.class);
//		OpenActivityBean noAPPDevicebean = new OpenActivityBean();
		if (bean != null) {
			String packageName = bean.getPackageName();
			String activityName = bean.getActivityName();
			List<String> serialNumberList = bean.getSerialNumList();
//			noAPPDevicebean.setPackageName(packageName);
//			noAPPDevicebean.setActivityName(activityName);
			//List<String> noAppDeviceList = new ArrayList<>();
			if (packageName != null && activityName != null && serialNumberList != null) {
				for (String serialNumber : serialNumberList) {
					DeviceEntity deviceEntity = DeviceContainerHandler.getDevice(serialNumber);
					if (deviceEntity != null) {
						IDevice idevice = deviceEntity.getIdevice();
						if (idevice != null) {
							executorService.execute(new Runnable() {
								@Override
								public void run() {
									CollectingOutputReceiver receiver = new CollectingOutputReceiver();
									try {
										idevice.executeShellCommand(
												String.format(COMMAND, packageName.trim(), activityName.trim()),
												receiver);
										logger.info(String.format(COMMAND, packageName.trim(), activityName.trim()));
										String appInfo = receiver.getOutput().trim();
										if (appInfo.endsWith("does not exist.")) {
											SystemWSSender.warn(client,"该应用在设备["+serialNumber+"]上尚未安装，请先安装");
										}
									} catch (TimeoutException | AdbCommandRejectedException
											| ShellCommandUnresponsiveException | IOException e) {
										logger.error("打开应用activity出错", e);
									}
								}
							});
						}
					}
				}
//				noAPPDevicebean.setSerialNumList(noAppDeviceList);
//				String noAppDeviceStr=JsonUtil.beanToJson(noAPPDevicebean);
//				System.out.println(noAppDeviceStr);
			}
		}
	}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
/**
 * 打开minicap
 */
public void startMinicap(final int virtualWidth, final int virtualHeight) {
	MinicapEntity minicapEntity = deviceEntity.getMinicapEntity();
	if (minicapEntity != null) {
		// 新建进程，开始监听屏幕数据
		Thread thread = new Thread(new Runnable() {

			@Override
			public void run() {
				if (idevice.isOnline()) {
					// 启动程序
					CollectingOutputReceiver receiver = new CollectingOutputReceiver();
					logger.info(deviceEntity.getSerialNumber()
							+ ":minicap启动");
					try {
						String command = String.format(
								MINICAP_START_COMMAND, bin,
								deviceEntity.getScreenWidth(),
								deviceEntity.getScreenHeight(),
								virtualWidth, virtualHeight);

						// logger.info(command);
						minicapEntity.setStatus(Status.RUNNING);// 设置minicap状态为运行中
						idevice.executeShellCommand(command, receiver, 0);
					} catch (TimeoutException | AdbCommandRejectedException
							| ShellCommandUnresponsiveException
							| IOException e) {
						logger.error(deviceEntity.getSerialNumber()
								+ ":监听屏幕出错", e);
					}
					logger.info(deviceEntity.getSerialNumber()
							+ ":minicap下线");
					receiver.flush();
					logger.info(receiver.getOutput());
					receiver.cancel();
				}
			}
		}, "MinicapAndroidThread-" + deviceEntity.getSerialNumber());
		deviceEntity.getMinicapEntity().setMinicapCMDThread(thread);
		thread.start();
	}
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
public String getExternalStoragePath() throws Exception {
    CollectingOutputReceiver pathNameOutputReceiver = new CollectingOutputReceiver();
    iDevice.executeShellCommand("echo $EXTERNAL_STORAGE", pathNameOutputReceiver);
    return pathNameOutputReceiver.getOutput().trim();
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
public ShellTask(@NotNull Project project, @NotNull CountDownLatch completionLatch, @NotNull CollectingOutputReceiver receiver) {
  super(project, TITLE, true);

  myCompletionLatch = completionLatch;
  myReceiver = receiver;
}
 

import com.android.ddmlib.CollectingOutputReceiver; //导入依赖的package包/类
/**
 * 启动录制
 *
 * @throws Exception
 */
private static void record() throws Exception {
    if ((isRecording == false) && (lastItem[0] != null)
        && (lastItem[0].getData("device") != null)) {
        device = (IDevice) lastItem[0].getData("device");
        deviceIndex = (Integer) lastItem[0].getData("index");
    }

    if (device != null) {
        enableRecord(false);
        isSetCheckPoint = false;
        client = new UiAutomatorClient(device.getSerialNumber());
        if (client.connect()) {
            enableRecordButton(true, true, true, true, true, true);
            mWidth = client.getDisplayWidth();
            mHeight = client.getDisplayHeight();
            //向手机注入Minicap截图工具
            String sdk = device.getProperty("ro.build.version.sdk");
            String abi = device.getProperty("ro.product.cpu.abi");
            device.pushFile(System.getProperty("user.dir")
                            + ("/plugins/resources/minicap/bin/" + abi + "/minicap"),
                "/data/local/tmp/minicap");
            File minicapFile = new File(System.getProperty("user.dir")
                                        + ("/plugins/resources/minicap/shared/android-" + sdk
                                           + "/" + abi + "/minicap.so"));
            if (minicapFile.exists() == false)
                sdk = "M";
            device
                .pushFile(
                    System.getProperty("user.dir")
                            + ("/plugins/resources/minicap/shared/android-" + sdk + "/" + abi + "/minicap.so"),
                    "/data/local/tmp/minicap.so");

            CollectingOutputReceiver receiver = new CollectingOutputReceiver();
            device.executeShellCommand("chmod 777 /data/local/tmp/minicap", receiver);
            device.executeShellCommand("chmod 777 /data/local/tmp/minicap.so", receiver);
            device.executeShellCommand("dumpsys window displays", receiver);

            minicap = new LaunchMinicap(device.getSerialNumber(), mWidth, mHeight, mWidth,
                mHeight, 0);
            Thread thread = new Thread(minicap);
            thread.start();
            thread.join(10000);
            AdbUtil.send("adb -s " + device.getSerialNumber()
                         + " forward tcp:1313 localabstract:minicap", 3000);
            deviceClient = new DeviceSocketClient(display, gc);
            deviceClient.connect("127.0.0.1", 1313);
        } else {
            enableRecordButton(false, false, false, false, false, false);
            enableRecord(true);
        }
    } else {
        MessageBox box = new MessageBox(shell, SWT.ICON_WARNING | SWT.OK);
        box.setMessage("请先选择一个设备!");
        box.open();
    }
}