Spring для подключения SFTP: 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(); 
    } 

Мой стекTrace - это один:

org.springframework.messaging.MessagingException: Не удалось получить объединенный элемент; Вложенное исключение - это java.lang.IllegalStateException: не удалось создать сеанс SFTP в org.springframework.integration.util.SimplePool.getItem (SimplePool.java:178) в org.springframework.integration.file.remote.session.CachingSessionFactory.getSession (CachingSessionFactory.java:123) на com.spring.example.sftp.SftpOutboundTransferSample.testOutbound (SftpOutboundTransferSample.java:62) на sun.reflect.NativeMethodAccessorImpl.invoke0 (собственный метод) на sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java: 57) на sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43) в java.lang.reflect.Method.invoke (Method.java:606) на org.junit.runners.model.FrameworkMethod $ 1.runReflectiveCall (FrameworkMethod. java: 50) at org.junit.internal.runners.model.ReflectiveCallable.run (ReflectiveCallable.java:12) на org.junit.runners.model.FrameworkMethod.invokeExplosively (FrameworkMethod.java:47) на org.junit.internal .runners.statements.InvokeMethod.evaluate (I 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) в org.junit.runners.ParentRunner.runLeaf (ParentRunner.java:325) в org.springframework.test.context .junit4.SpringJUnit4ClassRunner.runChild (SpringJUnit4ClassRunner.java:252) в org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild (SpringJUnit4ClassRunner.java:94) на org.junit.runners.ParentRunner $ 3.run (ParentRunner.java: 290) на org.junit.runners.ParentRunner $ 1.schedule (ParentRunner.java:71) на org.junit.runners.ParentRunner.runChildren (ParentRunner.java:288) на 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) в org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate (RunAfterTestClassCallbacks.java:70) в org.junit. runners.ParentRunner.run (ParentRunner.java:363) в org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run (SpringJUnit4ClassRunner.java:191) на org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run (JUnit4TestReference.java:50) в org.eclipse.jdt.internal.junit.runner.TestExecution.run (TestExecution.java:38) на org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests (RemoteTestRunner.java: 459) в org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests (RemoteTestRunner.java:675) в org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run (RemoteTestRunner.java:382) в 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) в org.springframework.integration.file.remote.session.CachingSessionFactory $ 1.createForPool (CachingSessionFactory.java:81) в org.springframework.integration.file.remote.session.CachingSessionFactory $ 1.createForPool (CachingSessionFactory.java:78) в org.springframework.integration.util. SimplePool.doGetItem (SimplePool.java:188) в org.springframework.integration.util.SimplePool.getItem (SimplePool.java:169) ... 31 more Причиняется: java.lang.IllegalStateException: не удалось подключиться на org.springframework .integration.sftp.session.SftpSession.connect (SftpSession.java:273) в org.springframework.integration.sftp.session.DefaultSftpSessionFactory.getSession (DefaultSftpSessionFactory.java:388) ... 36 more Причиненный: com.jcraft. jsch.JSchException: Пакет поврежден Ма на com.jcraft.jsch.Session.start_discard (Session.java:1067) на com.jcraft.jsch.Session.read (Session.java:937) на com.jcraft.jsch.Session. connect (Session.java:309) в com.jcraft.jsch.Session.connect (Session.java:183) на org.springframework.integration.sftp.session. SftpSession.connect (SftpSession.java:264) ... более 37

Я искал в Интернете, но если честно, я не undestand, почему я получаю это исключение:

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> 

[ОБНОВЛЕНО] ВЫВОД Затмения ПОЛНОГО (CONSOLE) ЗДЕСЬ: https://gist.github.com/columb1a/fe2d4dccabb6a5d9cecd3225d2a591dc

Answer 1

Я решил моего вопроса:

В моем * .properties файл номер порт сервера является -1. Затем сервер пытается запустить, если он может найти порт (случайный порт), отличный от -1, затем он запускается автоматически. Затем я должен ввести этот случайный номер порта в мой сеанс SFTP. Дело в том, что я использовал значение «-1» (объявленное в файле * .properties) в моем сеансе sftp вместо использования случайного значения, которое было создано сервером. Тогда моя сессия не смогла подключиться к серверу.

Очки для считать:

• В этом случае, к сожалению, "отладка" уровень для jsch не было полезным.
• Трассировка стека была «подсказкой», так как каким-то образом, если вы не можете подключиться, значит, это означает, что вы используете неправильные параметры для подключения (возможно). Поэтому, по крайней мере, в моем случае, я использовал неправильный номер порта в своей сессии.