FTP/FTPSを使用してVB（Variable Block）ファイルにデータを書き込む

Question

package base; 

import java.io.BufferedInputStream; 
import java.io.BufferedOutputStream; 
import java.io.ByteArrayInputStream; 
import java.io.IOException; 
import java.io.PrintWriter; 
import org.apache.commons.net.PrintCommandListener; 
import org.apache.commons.net.ftp.FTP; 
import org.apache.commons.net.ftp.FTPConnectionClosedException; 
import org.apache.commons.net.ftp.FTPReply; 
import org.apache.commons.net.ftp.FTPSClient; 
import com.ibm.jzos.ZFile; 

public class FTPSVB { 

public static void main(String[] args) { 
    BufferedInputStream binp=null; 
    BufferedOutputStream bout=null; 

    String server, username, password, fileTgt, fileSrc; 
    String protocol = "TLS"; // SSL/TLS 
    FTPSClient ftps = new FTPSClient(protocol); 
    FTPSClient ftps2 = new FTPSClient(protocol); 
    server="***"; 
    username="***"; 
    password="***"; 
    fileSrc="ABC00T.SMP.SAVE.ULRL"; 
    fileTgt="ABC00T.SMP.SAVE.OUT.ULRL"; 
    try 
    { 
     int reply; 
     ftps.connect(server); 
     ftps2.connect(server); 
     reply = ftps.getReplyCode(); 
     reply = ftps2.getReplyCode(); 
    } 
    try 
    { 
     ftps.setBufferSize(200); 
     ftps.setFileType(FTP.BINARY_FILE_TYPE); 
     if (!ftps.login(username, password)) 
     { 
      ftps.logout(); 
      System.out.println("ERROR.."); 
      System.exit(-1); 
     } 
     ftps.execPBSZ(0); 
     ftps.execPROT("P"); 

     ftps.enterLocalPassiveMode(); 
     ftps.setAutodetectUTF8(true); 
     ftps.site("QUOTE RDW"); 
     ftps2.setBufferSize(200); 
     ftps2.setFileType(FTP.BINARY_FILE_TYPE);  
     ftps2.site("QUOTE RDW"); 
     ftps2.site("QUOTE recfm=VB lrecl=106 blksize=27998"); 
     if (!ftps2.login(username, password)) 
     { 
      ftps2.logout(); 
      System.out.println("ERROR.."); 
      System.exit(-1); 
     } 
     ftps2.execPBSZ(0); 
     ftps2.execPROT("P"); 
     ftps2.enterLocalPassiveMode(); 
     ftps2.setAutodetectUTF8(true); 
     binp=new BufferedInputStream(ftps.retrieveFileStream(fileSrc)); 
     bout=new BufferedOutputStream(ftps2.storeFileStream(fileTgt)); 
     final byte []bufLen= new byte[4]; 
     int readLen=binp.read(bufLen, 0, 4);// Read len 
     int recCounter=1; 
     while(readLen!=-1){ 
     ByteArrayInputStream ba2=new ByteArrayInputStream (bufLen,0,4); 
      int z=ba2.read(); 
      int reclen=0; 
      int li=0; 
      while(z!=-1){ 
       if(li==0) 
        reclen+=z*256; 
       else if(li==1) 
        reclen+=z; 
       li++; 
       z=ba2.read(); 
      } 
      ba2.close(); 
      reclen-=4; 
      byte []buf=new byte[reclen]; 
      readLen=binp.read(buf, 0, reclen); 
      boolean isEOF=false; 
      while(readLen<reclen) { 
       int nextLen=binp.read(buf, readLen, reclen-readLen); 
       if(nextLen==-1){// End of file is reached. 
        isEOF=true; 
        break; 
       } 
       readLen=readLen+nextLen; 
      } 
      String a=new String(buf, ZFile.DEFAULT_EBCDIC_CODE_PAGE); 
      StringBuilder str=new StringBuilder(a); 
      //str.append(System.getProperty("line.separator")); 
      System.out.println(""+str); 
     //appending extra space for record till its length matches file record length 
      if(str.length()<102) { 
       for (int i = str.length(); i < 102; i++) { 
        str.append(" "); 
       } 
      } 
      byte []outBytes=new byte[102]; 
     outBytes=str.toString().getBytes(ZFile.DEFAULT_EBCDIC_CODE_PAGE); 
      bout.write(outBytes); 
      if(isEOF){ 
       break; 
      } 
      readLen=binp.read(bufLen, 0, 4);// Read length- RDW 
      recCounter++; 
     } 
     bout.flush(); 
     bout.close(); 
     binp.close(); 
     ftps.completePendingCommand(); 
     ftps2.completePendingCommand(); 
     ftps.logout(); 
    } 
    catch (FTPConnectionClosedException e) 
    { 
     System.err.println("Server closed connection."); 
     e.printStackTrace(); 
    } 
    catch (IOException e) 
    { 
     e.printStackTrace(); 
    } 
    finally 
    { 
     if (ftps.isConnected()) 
     { 
      try 
      { 
       ftps.disconnect(); 
      } 
      catch (IOException f) 
      { 
       // do nothing 
       f.printStackTrace(); 
      } 
     } 
    } 
    } 
} 

私は上記のコードを使用してVBファイルを読み書きしています。私は可変ブロックレコードを読むことができます。しかし、私はファイルのレコードの長さに一致する余分なスペースを追加しないで書くと、データが混乱している。私は余分なスペースを追加すると、それは多くのメモリを消費します。私はここに何かを逃していますかこの問題を解決するにはどうすればよいですか？

Answer 1

あなたの問題はftps2.setFileType(FTP.BINARY_FILE_TYPE);であると思います。

Windows/Unix/Linuxファイルは「レコード」について何も知らないため、すべてのファイルは単なるバイトストリームです。テキストファイルで作業する場合、ストリームには行末文字（x0A,x0Dまたはx0D0A ASCII）が含まれている可能性があります。これらは、レコードの終了と新しいファイルの開始と解釈される可能性があります。したがって、ほとんどのFTPツールは、テキストモードののいずれかに遭遇したときにz/OS側で新しいレコードを開始します（逆の場合は、 を z/OSから転送するときに新しいレコードを開始する）。

x0Dとx0Aは特別な方法では扱われませんが、とりわけ2バイトの値であるため、バイナリファイルの場合は少し異なります。

1. テキストモードを使用してファイルを転送しますが、これはおそらく行われているコード・ページ変換のいくつかの並べ替えになります：だからあなたはあなたがこれらのposibilitiesを持って欲しいものを得るために

   。可能であれば、変換を一切行わないカスタム変換テーブルを構成することもできます。

2. ファイルをバイナリ形式でFBデータセットに転送し、連続したバイトストリームを正しい行終了文字に分割し、その結果のレコードをVBデータセットに書き込むツールを作成します。