如何在Pentaho的User Defined Java Class中运行SFTP Java代码

我碰到过好几个类似的Pentaho自定义Java类的坑，结合你的情况，咱们一步步拆解问题：

1. 先确认jar包的放置位置是否正确 #

Pentaho的类加载机制和普通Eclipse项目完全不一样，不是随便丢个jar就能被识别的：

• 对于PDI（Pentaho Data Integration），你需要把jsch.jar及其依赖jar放到正确的目录：
  • 全局生效路径：data-integration/lib/（这个目录下的jar会被所有转换/Job加载）
  • 专属插件路径：如果是和大数据相关的SFTP场景，放到data-integration/plugins/pentaho-big-data-plugin/lib/
• 重要提醒：放完jar包后必须重启Pentaho Spoon，否则类加载器不会感知到新加入的jar文件。

2. 排查类依赖冲突 #

Eclipse的依赖是项目隔离的，但Pentaho本身自带了不少第三方jar，很可能和你的jsch版本冲突：

• 先去data-integration/lib/目录下找有没有jsch-xxx.jar，对比它和你Eclipse项目中使用的版本是否一致
  • 如果版本不匹配，要么替换Pentaho自带的jar为你Eclipse用的版本，要么修改代码适配Pentaho的jsch版本
• 可以在自定义Java类里加一行代码，确认实际加载的是哪个jar：

  System.out.println(ChannelSftp.class.getProtectionDomain().getCodeSource().getLocation());
  

  运行转换后看控制台输出，就能明确知道类加载器到底加载了哪个jsch jar，是不是你预期的那个。

3. 检查运行权限与路径问题 #

你的代码是从Linux服务器下载文件到Windows本地，Pentaho可能没有足够的写入权限：

• 确保代码里指定的Windows本地路径是存在的，并且避开系统保护目录（比如不要写到C:\Windows，换成用户目录下的文件夹，比如C:\Users\你的用户名\Downloads\）
• 一定要补全异常捕获逻辑，打印完整的错误堆栈，别把异常吞掉：

  try {
      // 你的SFTP下载逻辑
  } catch (Exception e) {
      e.printStackTrace(); // 打印完整错误信息，方便定位问题
      throw new RuntimeException("SFTP下载失败：" + e.getMessage(), e);
  }
  

  然后查看Pentaho的日志（转换运行时的Console输出，或者data-integration/logs/下的日志文件），看具体是哪一步抛出了异常。

4. 修正自定义Java类的代码结构 #

Pentaho的User Defined Java Class有特定的代码要求，很多人在这里踩坑：

• 不要写package声明！你代码里的package sftp;会直接导致类加载失败，因为Pentaho自定义Java类默认是在默认包下的
• 所有import语句要写完整，不能省略（比如你写的com.jcraft....要补全为com.jcraft.jsch.JSch、com.jcraft.jsch.Session等）
• 确保核心逻辑是在processRow()方法里执行的，Pentaho的自定义Java类是通过这个方法触发业务逻辑的，示例正确结构：

  import java.io.BufferedInputStream;
  import java.io.BufferedOutputStream;
  import java.io.File;
  import java.io.FileOutputStream;
  import java.io.OutputStream;
  import com.jcraft.jsch.Channel;
  import com.jcraft.jsch.ChannelSftp;
  import com.jcraft.jsch.JSch;
  import com.jcraft.jsch.Session;
  
  public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {
      Object[] r = getRow();
      if (r == null) {
          setOutputDone();
          return false;
      }
  
      // 在这里编写你的SFTP下载逻辑
      try {
          JSch jsch = new JSch();
          Session session = jsch.getSession("你的Linux用户名", "Linux服务器IP", 22);
          session.setConfig("StrictHostKeyChecking", "no"); // 跳过主机密钥检查，测试用，生产建议配置密钥
          session.setPassword("你的Linux密码");
          session.connect();
  
          Channel channel = session.openChannel("sftp");
          channel.connect();
          ChannelSftp sftpChannel = (ChannelSftp) channel;
  
          String remoteFilePath = "/Linux服务器上的文件路径/xxx.txt";
          String localFilePath = "Windows本地路径/xxx.txt";
  
          BufferedInputStream bis = new BufferedInputStream(sftpChannel.get(remoteFilePath));
          OutputStream os = new BufferedOutputStream(new FileOutputStream(new File(localFilePath)));
  
          byte[] buffer = new byte[1024];
          int readLen;
          while ((readLen = bis.read(buffer)) != -1) {
              os.write(buffer, 0, readLen);
          }
  
          // 关闭资源
          os.close();
          bis.close();
          sftpChannel.disconnect();
          session.disconnect();
      } catch (Exception e) {
          e.printStackTrace();
          throw new KettleException("SFTP操作失败", e);
      }
  
      putRow(data.outputRowMeta, r);
      return true;
  }
  

5. 用最小化代码测试 #

先写一个最简单的SFTP连接测试代码，排除业务逻辑的干扰：

import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {
    Object[] r = getRow();
    if (r == null) {
        setOutputDone();
        return false;
    }

    try {
        JSch jsch = new JSch();
        Session session = jsch.getSession("测试用户名", "服务器IP", 22);
        session.setPassword("测试密码");
        session.setConfig("StrictHostKeyChecking", "no");
        session.connect(3000); // 3秒超时
        System.out.println("SFTP连接成功！");
        session.disconnect();
    } catch (Exception e) {
        e.printStackTrace();
        throw new KettleException("SFTP连接失败", e);
    }

    putRow(data.outputRowMeta, r);
    return true;
}

如果这个最小化代码能运行，说明是你原来的下载逻辑有问题；如果还是不行，那大概率是依赖或者类加载的问题，回到前面的步骤排查。

内容的提问来源于stack exchange，提问作者Arun