cn.orionsec.kit.net.host.ssh

Class BaseHostExecutor<T extends com.jcraft.jsch.Channel>

java.lang.Object

cn.orionsec.kit.net.host.ssh.BaseHostExecutor<T>

All Implemented Interfaces:

Executable, SafeCloseable, IHostExecutor, Closeable, AutoCloseable, Runnable

Direct Known Subclasses:

CommandExecutor, ShellExecutor

public abstract class BaseHostExecutor<T extends com.jcraft.jsch.Channel>
extends Object
implements IHostExecutor

远程执行器 基类

Since:

2022/5/17 14:32

Version:

1.0.0

Author:

Jiahang Li

Field Summary

Fields

Modifier and Type	Field and Description
protected Runnable	callback 执行完毕回调
protected T	channel
protected boolean	done 是否执行完毕
protected InputStream	inputStream 标准输出流
protected OutputStream	outputStream 标准输入流
protected Consumer<InputStream>	streamHandler 标准输出流处理器

Constructor Summary

Constructors

Constructor and Description
BaseHostExecutor(T channel)

Method Summary

Modifier and Type	Method and Description
void	callback(Runnable callback) 异步完成回调
void	close() 安全关闭
T	getChannel()
InputStream	getInputStream() 获取标准输出流
OutputStream	getOutputStream() 获取标准输入流
boolean	isDone() 是否执行完成
protected abstract void	listenerOutput() 监听 标准输出/错误输出
void	sendSignal(String signal) 发送信号量
void	streamHandler(Consumer<InputStream> streamHandler) 设置标准输出流处理器
void	transfer(OutputStream out) 传输标准输出流到指定输出流
void	write(byte[] command) 写入命令

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cn.orionsec.kit.net.host.ssh.IHostExecutor

env, env, exit, exit, interrupt, run, setAgentForwarding, write, write, writeLine, writeLine, x11Forward

Methods inherited from interface cn.orionsec.kit.lang.able.Executable

exec

Field Detail

channel

protected final T extends com.jcraft.jsch.Channel channel

inputStream

protected InputStream inputStream

标准输出流

outputStream

protected OutputStream outputStream

标准输入流

streamHandler

protected Consumer<InputStream> streamHandler

标准输出流处理器

callback

protected Runnable callback

执行完毕回调

done

protected volatile boolean done

是否执行完毕

Constructor Detail

BaseHostExecutor

public BaseHostExecutor(T channel)

Method Detail

callback

public void callback(Runnable callback)

Description copied from interface: IHostExecutor

异步完成回调

Specified by:

callback in interface IHostExecutor

Parameters:

callback - 回调方法

transfer

public void transfer(OutputStream out)
              throws IOException

Description copied from interface: IHostExecutor

传输标准输出流到指定输出流

Specified by:

transfer in interface IHostExecutor

Parameters:

out - out

Throws:

IOException - IOException

streamHandler

public void streamHandler(Consumer<InputStream> streamHandler)

Description copied from interface: IHostExecutor

设置标准输出流处理器

Specified by:

streamHandler in interface IHostExecutor

Parameters:

streamHandler - 标准输入流处理器

write

public void write(byte[] command)

Description copied from interface: IHostExecutor

写入命令

Specified by:

write in interface IHostExecutor

Parameters:

command - command

sendSignal

public void sendSignal(String signal)

Description copied from interface: IHostExecutor

发送信号量

Specified by:

sendSignal in interface IHostExecutor

Parameters:

signal - 信号

listenerOutput

protected abstract void listenerOutput()

监听 标准输出/错误输出

close

public void close()

Description copied from interface: SafeCloseable

安全关闭

Specified by:

close in interface SafeCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

isDone

public boolean isDone()

Description copied from interface: IHostExecutor

是否执行完成

Specified by:

isDone in interface IHostExecutor

Returns:

isDone

getInputStream

public InputStream getInputStream()

Description copied from interface: IHostExecutor

获取标准输出流

Specified by:

getInputStream in interface IHostExecutor

Returns:

标准输出流

getOutputStream

public OutputStream getOutputStream()

Description copied from interface: IHostExecutor

获取标准输入流

Specified by:

getOutputStream in interface IHostExecutor

Returns:

标准输入流

getChannel

public T getChannel()