import org.apache.sshd.server.channel.ChannelSession; //导入依赖的package包/类
@Override
public int data(ChannelSession channel, byte[] buf, int start, int len) throws IOException {
    if (decoder != null) {
        lastAccessedTime = System.currentTimeMillis();
        decoder.write(buf, start, len);
    } else {
        // Data send too early ?
    }
    return len;
}
 

import org.apache.sshd.server.channel.ChannelSession; //导入依赖的package包/类
@Override
public int data(ChannelSession channel, byte[] buf, int start, int len) throws IOException {
  if (decoder != null) {
    lastAccessedTime = System.currentTimeMillis();
    decoder.write(buf, start, len);
  } else {
    // Data send too early ?
  }
  return len;
}
 

import org.apache.sshd.server.channel.ChannelSession; //导入依赖的package包/类
@Override
public int data(final ChannelSession channel, byte[] buf, int start, int len) throws IOException {
    buffer.append(new String(buf, start, len));
    for (int i = 0; i < buffer.length(); i++) {
        if (buffer.charAt(i) == '\n') {
            final String s = buffer.substring(0, i + 1);
            final byte[] bytes = s.getBytes(StandardCharsets.UTF_8);
            out.write(new ByteArrayBuffer(bytes)).addListener(new SshFutureListener<IoWriteFuture>() {
                @Override
                public void operationComplete(IoWriteFuture future) {
                    Session session = channel.getSession();
                    if (future.isWritten()) {
                        try {
                            Window wLocal = channel.getLocalWindow();
                            wLocal.consumeAndCheck(bytes.length);
                        } catch (IOException e) {
                            session.exceptionCaught(e);
                        }
                    } else {
                        Throwable t = future.getException();
                        session.exceptionCaught(t);
                    }
                }
            });
            buffer = new StringBuilder(buffer.substring(i + 1));
            i = 0;
        }
    }
    return 0;
}
 

import org.apache.sshd.server.channel.ChannelSession; //导入依赖的package包/类
@Override
public void setChannelSession(ChannelSession session) {
    this.session = session;
}
 

import org.apache.sshd.server.channel.ChannelSession; //导入依赖的package包/类
@Override
public void setChannelSession(ChannelSession session) {
  this.session = session;
}