import org.apache.sshd.ClientChannel; //导入依赖的package包/类
/**
 * Constructor that creates creates the terminal and
 * connects the I/O streams to the server
 * @throws IOException
 */
public SessionTerminal() throws IOException {
	try {
		this.terminal = new Terminal(TERM_WIDTH, TERM_HEIGHT);
		in = new NoClosePipedOutputStream();
		out = new NoClosePipedInputStream();
		NoClosePipedOutputStream pipedOut = new NoClosePipedOutputStream(out);
		NoClosePipedInputStream pipedIn = new NoClosePipedInputStream(in);
		channel = session.createChannel(ClientChannel.CHANNEL_SHELL);
		channel.setIn(pipedIn);
		channel.setOut(pipedOut);
		channel.setErr(pipedOut);
		new Thread(this).start();
		channel.open();
	} catch (Exception e) {
		e.printStackTrace();
	}
}
 

import org.apache.sshd.ClientChannel; //导入依赖的package包/类
@Test(timeout = 10000L)
public void call() throws Exception {
    final SshClient client = SshClient.setUpDefaultClient();
    client.start();
    try {
        final ClientSession session = client.connect("localhost", 4222).await().getSession();
        session.authPassword("jonathan", "secret");

        final ClientChannel channel = session.createChannel("shell");
        ByteArrayOutputStream sent = new ByteArrayOutputStream();
        PipedOutputStream pipedIn = new TeePipedOutputStream(sent);
        channel.setIn(new PipedInputStream(pipedIn));
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        ByteArrayOutputStream err = new ByteArrayOutputStream();
        channel.setOut(out);
        channel.setErr(err);
        channel.open();

        pipedIn.write("properties\r\n".getBytes());
        pipedIn.flush();

        pipedIn.write("exit\r\n".getBytes());
        pipedIn.flush();

        channel.waitFor(ClientChannel.CLOSED, 0);
        channel.close(false);
        client.stop();

        assertTrue(new String(sent.toByteArray()).contains("properties\r\nexit\r\n"));
        assertTrue(new String(out.toByteArray()).contains("ServerService(id=ssh)"));
    } catch (Exception e) {
        e.printStackTrace();
        fail();
    }
}
 

import org.apache.sshd.ClientChannel; //导入依赖的package包/类
/**
 * Should be called after setting {@link #setIn(InputStream)}
 * {@link #setOut(OutputStream)} {@link #setErr(OutputStream)}
 * 
 * @since 1.0
 * @throws SshProxyJException
 */
public void open() throws SshProxyJException {
	try {
		this.channel.open();
		new Thread(new Runnable() {

			public void run() {
				channel.waitFor(ClientChannel.CLOSED, 0);
				close();
			}

		}).start();
	} catch (Exception e) {
		throw new SshProxyJException("Failed to open channel", e);
	}
}
 

import org.apache.sshd.ClientChannel; //导入依赖的package包/类
@Override
public void messageReceived(IoSession session, Readable message) throws Exception {
    TcpipClientChannel channel = (TcpipClientChannel) session.getAttribute(TcpipClientChannel.class);
    Buffer buffer = new Buffer();
    buffer.putBuffer(message);
    channel.waitFor(ClientChannel.OPENED | ClientChannel.CLOSED, Long.MAX_VALUE);
    channel.getOut().write(buffer.array(), buffer.rpos(), buffer.available());
    channel.getOut().flush();
}
 

import org.apache.sshd.ClientChannel; //导入依赖的package包/类
public ClientChannel getClientChannel() {
	return channel;
}
 

import org.apache.sshd.ClientChannel; //导入依赖的package包/类
public void setClientChannel(ClientChannel channel) {
	this.channel = channel;
}
 

import org.apache.sshd.ClientChannel; //导入依赖的package包/类
public SshConnection(ClientSession session, ClientChannel channel)
		throws SshProxyJException {
	this.session = session;
	this.channel = channel;
}