주노의IT지식창고

com.jcraft.jsch.JSchException: java.io.IOException: Pipe closed

        at com.jcraft.jsch.ChannelSftp.start(ChannelSftp.java:242)

        at com.jcraft.jsch.Channel.connect(Channel.java:200)

        at com.jcraft.jsch.Channel.connect(Channel.java:144)

        at net.ib.paperless.common.SFTPHandler.init(SFTPHandler.java:61)

        at net.ib.paperless.service.AttachService.putFileUpload(AttachService.java:275)

        at net.ib.paperless.service.AttachService.eFormAttachFileSave(AttachService.java:72)

        at net.ib.paperless.controller.AttachFileController.attachFile(AttachFileController.java:68)

        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

        at java.lang.reflect.Method.invoke(Method.java:498)

        at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205)

        at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:133)

        at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:97)

        at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827)

        at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738)

        at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)

        at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:967)

        at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:901)

        at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:970)

        at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:872)

        at javax.servlet.http.HttpServlet.service(HttpServlet.java:648)

        at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:846)

        at javax.servlet.http.HttpServlet.service(HttpServlet.java:729)

        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:292)

        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:207)

        at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52)

        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:240)

        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:207)

        at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99)

        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:240)

        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:207)

        at org.springframework.web.filter.HttpPutFormContentFilter.doFilterInternal(HttpPutFormContentFilter.java:105)

        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:240)

        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:207)

        at org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:81)

        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:240)

        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:207)

        at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:197)

        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:240)

        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:207)

        at org.springframework.boot.web.support.ErrorPageFilter.doFilter(ErrorPageFilter.java:117)

        at org.springframework.boot.web.support.ErrorPageFilter.access$000(ErrorPageFilter.java:61)

        at org.springframework.boot.web.support.ErrorPageFilter$1.doFilterInternal(ErrorPageFilter.java:92)

        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

        at org.springframework.boot.web.support.ErrorPageFilter.doFilter(ErrorPageFilter.java:110)

        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:240)

Caused by: java.io.IOException: Pipe closed

        at java.io.PipedInputStream.read(PipedInputStream.java:307)

        at java.io.PipedInputStream.read(PipedInputStream.java:377)

        at com.jcraft.jsch.ChannelSftp.fill(ChannelSftp.java:2325)

        at com.jcraft.jsch.ChannelSftp.header(ChannelSftp.java:2351)

        at com.jcraft.jsch.ChannelSftp.start(ChannelSftp.java:211)

# override default of no subsystems 
Subsystem sftp /usr/libexec/openssh/sftp-server

(logback using java file time rolling)

#로그백 타임롤링은 1초단위, 1분단위, 1시간단위, 1일단위, 1달단위, 1년단위로는 로그파일을 자유롭게 생성 할 수 있지만 내가 원하는 시간에 맞추어서 할 수는 없다. 그래서 구글링을 해보니 자바를 불러와서 어느정도 내 마음대로 할 수 있도록 구현을 하는 방법이 있었음.

아래 예제는 10분단위로 로그파일 생성되도록 구현한 내용임.  내가 기억하려고 블로그에 남김 ㅋㅋ

1.logback.xml 에 어펜더 추가. 굵은 글씨의 클래스 적용

    <appender name="test-appender" class="com.test.TestAppender">
        <file>/test/test.log</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <fileNamePattern>

               /test/%d{yyyyMMdd,aux}/%d{yyyyMMddHHmm}.log

            </fileNamePattern>
        </rollingPolicy>
        <encoder>
            <pattern>%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{5} - %msg%n
            </pattern>
        </encoder>
    </appender>

2. TestAppender.java  생성

package com.test;

import java.text.SimpleDateFormat;
import java.util.Date;

import ch.qos.logback.core.rolling.RollingFileAppender;

public class TestAppender<E> extends RollingFileAppender<E>{

 
 private static long start = System.currentTimeMillis(); // minutes
 private int rollOverTimeInMinutes = 10; // 여기에 설정한 10분마다 롤링됨
 
  @Override
 public void rollover(){
  
  try{
   
   int maxIntervalSinceLastLoggingInMillis = rollOverTimeInMinutes * 60 * 1000;
   long currentTime = System.currentTimeMillis();
   long start_rtn_str = getProc(start);
   

   if ((currentTime - start_rtn_str) >= maxIntervalSinceLastLoggingInMillis){
    super.rollover();
    start = System.currentTimeMillis();
   }
   
  }catch(Exception e){
   
  }
  

 }
 
 
 // currentTimeMillis 를 받아서 yyyyMMddHHmm 으로 변환 후에 분단위를 0으로 만든 후에 다시 currentTimeMillis 형태로 리턴(분단위 절삭).
 public static long getProc(long in_str) throws Exception {
  SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmm");
  String fmt1 = sdf.format(new Date(in_str));
  String fmt2 = fmt1.substring(0, 11)+"0";
  long rtn_str = cast_sdf_ctm(fmt2);
  return rtn_str;
 }
 
 // SimpleDateFormat 형태의 스트링을 받아서 currentTimeMillis 형태로 변환. ex) cast_sdf_ctm("20151008165215");
 public static long cast_sdf_ctm(String str) throws Exception {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmm");
        Date date = sdf.parse(str);
        long rtn_str = date.getTime();
  return rtn_str;
 }
 
 // currentTimeMillis 형태의 스트링을 받아서  SimpleDateFormat 형태로 변환. ex) cast_ctm_sdf( 1444300680353, "yyyyMMddHHmmss")
 public static String cast_ctm_sdf(long str, String fmt) throws Exception {
        SimpleDateFormat sdf = new SimpleDateFormat(fmt);
        String rtn_str = sdf.format(new Date(str));
  return rtn_str;
 }
 

}

SFTPHandler.java

  /**

     * 서버와 연결에 필요한 값들을 가져와 초기화 시킴

     *

     * @param host

     *            서버 주소

     * @param userName

     *            접속에 사용될 아이디

     * @param password

     *            비밀번호

     * @param port

     *            포트번호

     */

    public void init(String host, String userName, String password, int port) {

        JSch jsch = new JSch();

        try {

            session = jsch.getSession(userName, host, port);

            session.setPassword(password);

            java.util.Properties config = new java.util.Properties();

            config.put("StrictHostKeyChecking", "no");

            session.setConfig(config);

            session.connect();

            channel = session.openChannel("sftp");

            channel.connect();

            channelSftp = (ChannelSftp) channel;            

        } catch (JSchException e) {

            e.printStackTrace();

        }

    }

 /** create by Junho

     * 헤당 경로가 없으면 mkdir 하는 함수 리턴값 : fullpath

     * @param path

     * @return

     * @throws SftpException

     */

    public String mkdirDir(String path) throws SftpException {

    String[] pathArray = path.split("/");

    String currentDirectory = channelSftp.pwd();

    String totPathArray = "";

    for(int i =0; i< pathArray.length; i++) {

    totPathArray += pathArray[i] + "/";

String currentPath = currentDirectory+ "/" + totPathArray;

    try {

channelSftp.mkdir(currentPath);

channelSftp.cd(currentPath);

} catch (Exception e) {

channelSftp.cd(currentPath);

}

    }

    return currentDirectory+ "/" + totPathArray;

}

/**

     * 단일 파일을 업로드

     *

     * @param file

     *            저장시킬 파일

     * @param dir

     *            저장시킬 주소(서버)

     */

    public boolean uploadFile(MultipartFile file, String fileName, String dir) {

    boolean result = true;

        InputStream in = null;

        try {

            //fileName = URLEncoder.encode(fileName,"EUC-KR");

            in = file.getInputStream();

            channelSftp.cd(dir);

            channelSftp.put(in, fileName);

        } catch (Exception e) {

            e.printStackTrace();

            result = false;

        } finally {

            try {

                in.close();

            } catch (IOException e) {

                e.printStackTrace();

            }

        }

        return result;

    }

 /**

     * 단일 파일 다운로드

     *

     * @param dir

     *            저장할 경로(서버)

     * @param downloadFileName

     *            다운로드할 파일

     * @param path

     *            저장될 공간

     */

    public boolean download(String dir, String downloadFileName, String path) {

    boolean result = true;

        InputStream in = null;

        FileOutputStream out = null;

        try {

            channelSftp.cd(dir);

            in = channelSftp.get(downloadFileName);

        } catch (SftpException e) {

            e.printStackTrace();

            result = false;

        }

        try {

            out = new FileOutputStream(new File(path));

            int data; 

byte b[] = new byte[2048];

while((data = in.read(b, 0, 2048)) != -1) { 

out.write(b, 0, data); 

out.flush();

}

        } catch (IOException e) {

            e.printStackTrace();

            result = false;

        } finally {

            try {

                out.close();

                in.close();

            } catch (IOException e) {

                e.printStackTrace();

            }

        }

        return result;

    }

  /**

     * 서버와의 연결을 끊는다.

     */

    public void disconnection() {

        channelSftp.quit();

    }