春JUnit测试：com.jcraft.jsch.JSchException：包腐败

Question

我一直在重建我的本地这个例子：https://github.com/spring-projects/spring-integration-samples/tree/master/basic/sftp

但这次仅仅使用注解，而不是XML配置。我有这样的事情：

@Configuration 
public class SftpExampleBeanClasses extends SftpConfig { 

@Bean 
public CachingSessionFactory<LsEntry> sftpSessionFactory() throws IOException { 
    DefaultSftpSessionFactory sftpSessionFactory = new DefaultSftpSessionFactory(); 
    sftpSessionFactory.setHost(this.host); 
    sftpSessionFactory.setPort(this.port); 
    sftpSessionFactory.setUser(this.username); 
    InputStream stream = new ClassPathResource(this.privatekey).getInputStream(); 
    sftpSessionFactory.setPrivateKey(new ByteArrayResource(StreamUtils.copyToByteArray(stream))); 
    sftpSessionFactory.setPrivateKeyPassphrase(this.passphrase); 
    sftpSessionFactory.setAllowUnknownKeys(true); 
    return new CachingSessionFactory<LsEntry>(sftpSessionFactory); 

    //return sftpSessionFactory; 
} 

@SuppressWarnings({ "unchecked", "rawtypes" }) 
@Bean 
@ServiceActivator(inputChannel = "ftpChannel", adviceChain = "retryAdvice") 
public MessageHandler ftpHandler() throws IOException { 
    FileTransferringMessageHandler handler = new FileTransferringMessageHandler(this.sftpSessionFactory()); 
    handler.setRemoteDirectoryExpression(new LiteralExpression("/")); 
    return handler; 
} 

} 

SftpCommon类：

@Configuration 
public class SftpCommon extends SftpConfig { 

    @Bean 
    public int serverPort(){ 
     if(this.port == -1){ 
      return EmbeddedSftpServer.PORT; 
     } 
     return this.port; 
    } 

    @Bean 
    public EmbeddedSftpServer embeddedSftpServer(){ 
     EmbeddedSftpServer embeddedSftpServer = new EmbeddedSftpServer(); 
     embeddedSftpServer.setPort(serverPort()); 
     return embeddedSftpServer; 
    } 
} 

SftpConfig类：

@Configuration 
@PropertySource(value="classpath:user.properties") 
public class SftpConfig { 

    @Value("${port}") 
    protected 
    int port; 

    @Value("${username}") 
    protected 
    String username; 

    @Value("${passphrase}") 
    protected 
    String passphrase; 

    @Value("${host}") 
    protected 
    String host; 

    @Value("${private.keyfile}") 
    protected 
    String privatekey; 

    public String getHost() { 
     return host; 
    } 

    @Bean 
    public String getUsername() { 
     return this.username; 
    } 

    @Bean 
    public String getPassphrase() { 
     return this.passphrase; 
    } 

    @Bean 
    public static PropertySourcesPlaceholderConfigurer placeHolderConfigurer() { 
     return new PropertySourcesPlaceholderConfigurer(); 
    } 

    @Bean 
    public String getPrivatekey() { 
     return privatekey; 
    } 
} 

而在我的测试中，我有这样的事情：

@RunWith(SpringJUnit4ClassRunner.class) 
    @ContextConfiguration(classes ={SftpExampleBeanClasses.class,SftpCommon.class, SftpConfig.class}) 
    public class SftpOutboundTransferSample { 

    @Autowired 
    ApplicationContext applicationContext; 

    @Test 
    public void testOutbound() throws Exception{ 

     final String sourceFileName = "README.md"; 
     final String destinationFileName = sourceFileName +"_foo"; 

     @SuppressWarnings("unchecked") 
     SessionFactory<LsEntry> sessionFactory = (SessionFactory<LsEntry>) 


     applicationContext.getBean(CachingSessionFactory.class); 
     /* this is the line where I'm getting issues */ 
     sessionFactory.getSession(); 
    } 

我的stackTrace是这样的：

org.springframework.messaging.MessagingException：无法获取共用项目;嵌套异常是java.lang.IllegalStateException：无法在org.springframework.integration.util.SimplePool.getItem（SimplePool.java:178）上创建SFTP会话，位于org.springframework.integration.file.remote.session.CachingSessionFactory.getSession（ （NativeMethodAccessorImpl.java：CachingSessionFactory.java:123）at com.spring.example.sftp.SftpOutboundTransferSample.testOutbound（SftpOutboundTransferSample.java:62）at sun.reflect.NativeMethodAccessorImpl.invoke0（Native Method）at sun.reflect.NativeMethodAccessorImpl.invoke（NativeMethodAccessorImpl.java：在org.junit.runners.model.FrameworkMethod $ 1.runReflectiveCall（FrameworkMethod。）上的java.lang.reflect.Method.invoke（Method.java:606）上的sun.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMethodAccessorImpl.java:43） java：50）在org.junit.runners.model.FrameworkMethod.invokeExplosively（org.junit.internal.FrameworkMethod.java:47）org.junit.internal.runners.model.ReflectiveCallable.run（ReflectiveCallable.java:12） .runners.statements.InvokeMethod.evaluate（我nvokeMethod.java:17）在org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate（RunBeforeTestMethodCallbacks.java:75）在org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate（RunAfterTestMethodCallbacks.java： 86）org.springframework.test.context.junit4.statements.SpringRepeat.evaluate（SpringRepeat.java:84）at org.junit.runners.ParentRunner.runLeaf（ParentRunner.java:325）at org.springframework.test.context （org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild（SpringJUnit4ClassRunner.java:94）at org.junit.runners.ParentRunner $ 3.run（ParentRunner.java： 290）org.junit.runners.ParentRunner $ 1.schedule（ParentRunner.java:71）at org.junit.runners.ParentRunner.runChildren（ParentRunner.java:288）at org.junit.runners.ParentRunner.access $ 000（ParentRunner .java：58）at org.junit.runners.ParentRunner $ 2.evaluate（ParentRunner.java:268）at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate（RunBeforeTestClassCallbacks.java:61）at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate（RunAfterTestClassCallbacks.java:70）at org.junit。 runner.ParentRunner.run（ParentRunner.java:363）at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run（SpringJUnit4ClassRunner.java:191）at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run（ JUnit4TestReference.java:50）org.eclipse.jdt.internal.junit.runner.TestExecution.run（TestExecution.java:38）at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests（RemoteTestRunner.java： 459）at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests（RemoteTestRunner.java:675）at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run（RemoteTestRunner.java:382）at org .eclipse.jdt.internal.junit.runner.RemoteTestRunner.main（RemoteTestRunner.java:192）引起：java.lang.IllegalStateExcep重刑：无法创建SFTP会话在org.springframework.integration.sftp.session.DefaultSftpSessionFactory.getSession（DefaultSftpSessionFactory.java:393）在org.springframework.integration.sftp.session.DefaultSftpSessionFactory.getSession（DefaultSftpSessionFactory.java:57）at org.springframework.integration。file.remote.session.CachingSessionFactory $ 1.createForPool（CachingSessionFactory.java:81）位于org.springframework.integration.file.remote.session.CachingSessionFactory $ 1.createForPool（CachingSessionFactory.java:78）at org.springframework.integration.util。 SimplePool.doGetItem（SimplePool.java:188）at org.springframework.integration.util.SimplePool.getItem（SimplePool.java:169）... 31更多原因：java.lang.IllegalStateException：无法在org.springframework连接.integration.sftp.session.SftpSession.connect（SftpSession.java:273）at org.springframework.integration.sftp.session.DefaultSftpSessionFactory.getSession（DefaultSftpSessionFactory.java:388）... 36 more引起：com.jcraft。 jsch.JSchException：在com.jcraft.jsch.Session的com.jcraft.jsch.Session.read（Session.java:937）com.jcraft.jsch.Session.start_discard（Session.java:1067）处发生数据包损坏。通过com.jcraft.jsch.Session.connect（Session.java:183）在org.springframework.integration.sftp.session处连接（Session.java:309）。 SftpSession.connect（SftpSession.java:264）... 37多个

我一直在寻找在互联网上，但说实话，我不为什么已了解我得到这个异常：

com.jcraft.jsch.JSchException：包腐败

我的log4j.xml配置：

<?xml version="1.0" encoding="UTF-8"?> 
<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd"> 
<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/"> 

    <!-- Appenders --> 
    <appender name="console" class="org.apache.log4j.ConsoleAppender"> 
     <param name="Target" value="System.out" /> 
     <layout class="org.apache.log4j.PatternLayout"> 
      <param name="ConversionPattern" value="%d{HH:mm:ss.SSS} %-5p [%t][%c] %m%n" /> 
     </layout> 
    </appender> 

    <!-- Loggers --> 
    <logger name="org.springframework.integration"> 
     <level value="warn" /> 
    </logger> 

    <logger name="org.springframework.integration.samples"> 
     <level value="info" /> 
    </logger> 

    <logger name="log4j.category.com.jcraft.jsch"> 
     <level value="debug" /> 
     <appender-ref ref="console" /> 
    </logger> 

    <!-- Root Logger --> 
    <root> 
     <priority value="debug" /> 
     <appender-ref ref="console" /> 
    </root> 

</log4j:configuration> 

[修订] FULL ECLIPSE输出（控制台）这里：https://gist.github.com/columb1a/fe2d4dccabb6a5d9cecd3225d2a591dc

Answer 1

我解决我的问题：

在我的* .properties文件服务器的端口号为-1。然后服务器尝试启动，如果它能够找到非-1的端口（随机端口），则它会自动启动。然后我必须在我的SFTP会话中注入该随机端口号。重点是，我在我的sftp会话中使用了“-1”值（在我的* .properties文件中声明），而不是使用服务器生成的随机值。然后我的会话无法连接到服务器。要考虑

点：

• 在这种情况下，不幸的是， “调试” 级别jsch是没有用的。
• 堆栈跟踪是“提示”，因为不知何故，如果你无法连接，那么，这可能意味着你正在使用错误的参数来连接（也许）。因此，至少在我的情况下，我在会话中使用了错误的端口号。