import com.pty4j.PtyProcess; //导入依赖的package包/类
public void connect() throws IOException {
    if (localTerminalPanel == null) {
        throw new IllegalStateException("local terminal panel is not set");
    }
    if (pty != null && pty.isAlive()) {
        return;
    }

    String[] cmd = {"/bin/bash", "-i"};
    Map<String, String> envs = new HashMap<>(System.getenv());
    envs.remove("TERM_PROGRAM"); // for OS X
    envs.put("TERM", "vt102");

    pty = PtyProcess.exec(cmd, envs, System.getProperty("user.home"));

    OutputStream os = pty.getOutputStream();
    InputStream is = pty.getInputStream();

    PrintStream printStream = new PrintStream(os, true);
    localTerminalPanel.setPrintStream(printStream);

    Runnable run = new TerminalWatcher(is, localTerminalPanel.getTextArea());
    thread = new Thread(run);
    thread.start();
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
public TtyConnector createTtyConnector() {
  try {
    Map<String, String> envs = Maps.newHashMap(System.getenv());
    String[] command;

    if (UIUtil.isWindows) {
      command = new String[]{"cmd.exe"};
    } else {
      command = new String[]{"/bin/bash", "--login"};
      envs.put("TERM", "xterm");
    }

    PtyProcess process = PtyProcess.exec(command, envs, null);

    return new LoggingPtyProcessTtyConnector(process, Charset.forName("UTF-8"));
  } catch (Exception e) {
    throw new IllegalStateException(e);
  }
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
private void initializeProcess() throws Exception {

        String userHome = System.getProperty("user.home");
        Path dataDir = Paths.get(userHome).resolve(".terminalfx");
        IOHelper.copyLibPty(dataDir);

        if (Platform.isWindows()) {
            this.termCommand = "cmd.exe".split("\\s+");
        } else {
            this.termCommand = "/bin/bash -i".split("\\s+");
        }

        if(Objects.nonNull(shellStarter)){
            this.termCommand = shellStarter.split("\\s+");
        }

        Map<String, String> envs = new HashMap<>(System.getenv());
        envs.put("TERM", "xterm");

        System.setProperty("PTY_LIB_FOLDER", dataDir.resolve("libpty").toString());

        this.process = PtyProcess.exec(termCommand, envs, userHome);

        process.setWinSize(new WinSize(columns, rows));
        this.inputReader = new BufferedReader(new InputStreamReader(process.getInputStream()));
        this.errorReader = new BufferedReader(new InputStreamReader(process.getErrorStream()));
        this.outputWriter = new BufferedWriter(new OutputStreamWriter(process.getOutputStream()));

        ThreadHelper.start(() -> {
            printReader(inputReader);
        });

        ThreadHelper.start(() -> {
            printReader(errorReader);
        });

        process.waitFor();

    }
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
public ProcessTtyConnector(PtyProcess process, Charset charset) {
    this.process = process;
    this.charset = charset;
    this.inputStream = process.getInputStream();
    this.outputStream = process.getOutputStream();
    this.reader = new InputStreamReader(inputStream, charset);
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
public TerminalEmulator(String termId, SocketIOSessionOutbound outbound, String[]command, Map<String, String> envs, String workingDirectory) throws IOException {
    PtyProcess pty = PtyProcess.exec(command, envs, workingDirectory);// working dir

    this.termId = termId;
    this.outbound = outbound;
    this.ttyConnector = new ProcessTtyConnector(pty, charset);
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@NotNull
public Process startProcessWithPty(@NotNull List<String> commands, boolean console) throws IOException {
  Map<String, String> env = new HashMap<String, String>();
  setupEnvironment(env);

  if (isRedirectErrorStream()) {
    LOG.error("Launching process with PTY and redirected error stream is unsupported yet");
  }

  File workDirectory = getWorkDirectory();
  boolean cygwin = myUseCygwinLaunch && SystemInfo.isWindows;
  return PtyProcess.exec(ArrayUtil.toStringArray(commands), env, workDirectory != null ? workDirectory.getPath() : null, console, cygwin,
                         ApplicationManager.getApplication().isEAP() ? getPtyLogFile() : null);
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
protected PtyProcess createProcess(@Nullable String directory) throws ExecutionException {
  Map<String, String> envs = new HashMap<String, String>(System.getenv());
  envs.put("TERM", "xterm-256color");
  EncodingEnvironmentUtil.setLocaleEnvironmentIfMac(envs, myDefaultCharset);
  try {
    return PtyProcess.exec(getCommand(), envs, directory != null ? directory : currentProjectFolder());
  }
  catch (IOException e) {
    throw new ExecutionException(e);
  }
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
protected PtyProcess createProcess() throws ExecutionException {
  Map<String, String> envs = new HashMap<String, String>(System.getenv());
  envs.put("TERM", "xterm");
  try {
    return PtyProcess.exec(myCommand, envs, null);
  }
  catch (IOException e) {
    throw new ExecutionException(e);
  }
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
protected PtyProcess createProcess(@Nullable String directory) throws ExecutionException
{
	Map<String, String> envs = new HashMap<String, String>(System.getenv());
	envs.put("TERM", "xterm-256color");
	//EncodingEnvironmentUtil.setLocaleEnvironmentIfMac(envs, myDefaultCharset);
	try
	{
		return PtyProcess.exec(getCommand(), envs, directory != null ? directory : currentProjectFolder());
	}
	catch(IOException e)
	{
		throw new ExecutionException(e);
	}
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Nonnull
public Process startProcessWithPty(@Nonnull List<String> commands, boolean console) throws IOException {
  Map<String, String> env = new HashMap<>();
  setupEnvironment(env);

  if (isRedirectErrorStream()) {
    LOG.error("Launching process with PTY and redirected error stream is unsupported yet");
  }

  String[] command = ArrayUtil.toStringArray(commands);
  File workDirectory = getWorkDirectory();
  String directory = workDirectory != null ? workDirectory.getPath() : null;
  boolean cygwin = myUseCygwinLaunch && SystemInfo.isWindows;
  return PtyProcess.exec(command, env, directory, console, cygwin, getPtyLogFile());
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
RocTtyConnector(PtyProcess process, Charset charset)
{
    super(process, charset);
    this.myProcess = process;
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
protected TtyConnector createTtyConnector(PtyProcess process)
{
    return new RocTtyConnector(process, CharsetToolkit.UTF8_CHARSET);
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
protected ProcessHandler createProcessHandler(final PtyProcess process) {
  return new PtyProcessHandler(process);
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
protected TtyConnector createTtyConnector(PtyProcess process) {
  return new PtyProcessTtyConnector(process, myDefaultCharset);
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
protected String getTerminalConnectionName(PtyProcess process) {
  return "Local Terminal";
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
public PtyProcessHandler(PtyProcess process) {
  myProcess = process;
  myWaitFor = new ProcessWaitFor(process, this);
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
protected String getTerminalConnectionName(PtyProcess process) {
  return StringUtil.join(myCommand);
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
protected ProcessHandler createProcessHandler(final PtyProcess process)
{
	return new PtyProcessHandler(process);
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
protected TtyConnector createTtyConnector(PtyProcess process)
{
	return new PtyProcessTtyConnector(process, myDefaultCharset);
}
 

import com.pty4j.PtyProcess; //导入依赖的package包/类
@Override
protected String getTerminalConnectionName(PtyProcess process)
{
	return "Local Terminal";
}