标签：ftp hasRead zip ZipEntry 写入 write zos new import
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Iterator;
import java.util.Vector;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;
import java.util.zip.ZipOutputStream;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import com.jcraft.jsch.ChannelSftp;
public class Iotest {
public static void main(String[] args) throws IOException {
try {
testZip();
}catch(Exception e) {
e.printStackTrace();
}
}
public static void testZip() throws Exception {
// FileOutputStream fos = new FileOutputStream("D:\\back\\MotionProSetup_win64\\zhaotest.zip") ;
/* FTPClient ftpClient = new FTPClient();
ftpClient.connect("139.196.174.174", 22);
ftpClient.login("root", "zhao1234.");
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
int reply = ftpClient.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
ftpClient.disconnect();
}
ftpClient.changeWorkingDirectory("/opt/iotest/");*/
// ZipOutputStream zipOut = null;
// zipOut = new ZipOutputStream(ftpClient.storeFileStream("a.zip"));
NasUtils client = new NasUtils();
ChannelSftp sftp1 = client.connect("139.196.174.174", 22, "root","zhao1234.");
ZipOutputStream zos= new ZipOutputStream(sftp1.put("/opt/iotest/zhaotest1.zip"));
InputStream inputStream = sftp1.get("/mnt/test/MotionProSetup_win64/application.ico");
zos.putNextEntry(new ZipEntry("connected1.ico"));
byte[] b=new byte[1024];
int hasRead=0;
int count = 0;
//循环从输入流中取出数据
while((hasRead=inputStream.read(b))>0){
//每读取一次，即写入文件输入流，读了多少，就写多少。
zos.write(b,0,hasRead);
System.out.println("--hasRead---"+hasRead);
count++;
System.out.println("--count---"+count);
}
zos.closeEntry();
Vector vector = client.listFiles("/mnt/test/MotionProSetup_win64",sftp1);
Iterator iterator = vector.iterator();
while (iterator.hasNext()) {
ChannelSftp.LsEntry file = (ChannelSftp.LsEntry) iterator.next();
//文件名称
String fileName = file.getFilename();
if(fileName.length()>3 ) {
//todo 这里可使用if或正则不下载一些文件
// InputStream inputStream = sftp1.get("/mnt/test/MotionProSetup_win64/" + fileName);
FileInputStream inputStream1 = new FileInputStream("D:\\back\\MotionProSetup_win64\\MotionProSetup_win64\\"+fileName);
if (inputStream != null) {
zos.putNextEntry(new ZipEntry(fileName));
write(inputStream, zos);
zos.closeEntry();
}
}
}
zos.close();
/*
//写入一个条目，我们需要给这个条目起个名字，相当于起一个文件名称
zos.putNextEntry(new ZipEntry("application1.ico"));
//往这个条目中写入一定的数据
write("application.ico", zos);
// zos.write("尹正杰".getBytes());
//关闭条目
zos.closeEntry();
zos.putNextEntry(new ZipEntry("connected1.ico"));
write("connected.ico", zos);
zos.closeEntry();
zos.putNextEntry(new ZipEntry("disconnected.ico"));
write("disconnected.ico", zos);
zos.closeEntry();
zos.putNextEntry(new ZipEntry("license.txt"));
write("license.txt", zos);
zos.closeEntry();
zos.putNextEntry(new ZipEntry("logo.bmp"));
write("logo.bmp", zos);
zos.closeEntry();
zos.putNextEntry(new ZipEntry("motionpro_templete.ini"));
write("motionpro_templete.ini", zos);
zos.closeEntry();
zos.putNextEntry(new ZipEntry("MotionProSetup_x64.exe"));
write("MotionProSetup_x64.exe", zos);
zos.closeEntry();
zos.putNextEntry(new ZipEntry("OEM.ini"));
write("OEM.ini", zos);
zos.closeEntry();
zos.putNextEntry(new ZipEntry("OEM_Help.pdf"));
write("OEM_Help.pdf", zos);
zos.closeEntry();
zos.putNextEntry(new ZipEntry("reconnecting.ico"));
write("reconnecting.ico", zos);
zos.closeEntry();*/
// zos.close();
}
public static void testUnzip() throws Exception {
FileInputStream fis = new FileInputStream("D:\\back\\MotionProSetup_win64\\zhaotest.zip");
ZipInputStream zis = new ZipInputStream(fis);
ZipEntry entry = null ;
byte[] buf = new byte[1024] ;
int len = 0 ;
//此处我们需要判断是否zis流中存在条目，你可以理解为是否存在文件内容
while((entry = zis.getNextEntry()) != null){
//此处我们获取条目名称
String name = entry.getName();
System.out.println(name);
//我们将每一个条目进行解压，我们需要指定一个输出路径
FileOutputStream fos = new FileOutputStream("D:\\back\\MotionProSetup_win64\\unzip\\"+ name) ;
while((len = zis.read(buf)) != -1){
fos.write(buf , 0 , len);
}
fos.close();
}
zis.close();
fis.close();
}
public static void write(InputStream fileInputStream, ZipOutputStream zos) {
try {
DataInputStream in = new DataInputStream(new BufferedInputStream(fileInputStream ));
byte[] b=new byte[1024];
int hasRead=0;
int count = 0;
//循环从输入流中取出数据
while((hasRead=in.read(b))>0){
//每读取一次，即写入文件输入流，读了多少，就写多少。
zos.write(b,0,hasRead);
System.out.println("--hasRead---"+hasRead);
count++;
System.out.println("--count---"+count);
}
in.close();
}catch(Exception e) {
e.printStackTrace();
}
}
public static void main1(String[] args) throws IOException {
try {
// 节点流FileOutputStream直接以A.txt作为数据源操作
FileOutputStream fileOutputStream = new FileOutputStream("D:/back/ccbsetup123.exe");
// 过滤流BufferedOutputStream进一步装饰节点流，提供缓冲写
BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(
fileOutputStream);
// 过滤流DataOutputStream进一步装饰过滤流，使其提供基本数据类型的写
DataOutputStream out = new DataOutputStream(bufferedOutputStream);
// 此处输入节点流，过滤流正好跟上边输出对应，读者可举一反三
DataInputStream in = new DataInputStream(new BufferedInputStream(
new FileInputStream("D:/back/ccbsetup.exe")));
byte[] b=new byte[1024];
int hasRead=0;
int count = 0;
//循环从输入流中取出数据
while((hasRead=in.read(b))>0){
//每读取一次，即写入文件输入流，读了多少，就写多少。
out.write(b,0,hasRead);
System.out.println("--hasRead---"+hasRead);
count++;
System.out.println("--count---"+count);
}
in.close();
out.close();
}catch (IOException e){
e.printStackTrace();
}finally {
}
}
}
标签：ftp,hasRead,zip,ZipEntry,写入,write,zos,new,import 来源： https://www.cnblogs.com/zhaoblog/p/15840719.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。