windows从linux拷贝下载文件的两种方式

1，通过ssh协议用scp命令拷贝
1.1 windows安装freeSSHD（使用密码登录）见博文https://blog.csdn.net/u014296316/article/details/88616023
1.2 安装git
配置windows免密登录到linux，这样从linux上scp文件时就不用输入密码了：
git 生成密钥对，gitbash命令行输入命令ssh-keygen
将生成的公钥id_rsa.pub拷贝到linux服务器上
将windows拷贝来的文件追加至authorized_keys文件中，cat /windows公钥拷贝文件所在目录/id_rsa.pub >> authorized_keys

SSHUtil工具类，用于建立远程ssh连接并执行命令

public class SSHUtil {    private static Logger logger = LoggerFactory.getLogger(SSHUtil.class);    private static int timeout = 20 * 1000; // 超时时间改成20s , 有的服务器10s 连接不上 ...    public static Session getJSchSession(String username, String host, String password, Integer port) throws JSchException {        JSch jsch = new JSch();        Session session = jsch.getSession(username, host, port);        session.setPassword(password);        session.setConfig("StrictHostKeyChecking", "no");//第一次访问服务器不用输入yes        session.setTimeout(timeout);        session.connect();        return session;    }    public static String execCommandByJSch(Session session, String command, String  resultEncoding) throws IOException,JSchException {        logger.info("执行命令：" + command);        ChannelExec channelExec = (ChannelExec) session.openChannel("exec");        channelExec.setCommand(command);        channelExec.connect();        InputStream in = channelExec.getInputStream();        InputStream err = channelExec.getErrStream();        String result = IOUtils.toString(in, resultEncoding);        String error = IOUtils.toString(err, resultEncoding);        logger.info("返回结果：" + result);        logger.info("错误结果：" + error);        channelExec.disconnect();        return result + error;    }    //上传文件    public static void uploadFile(Session session, String directory, String uploadFile) throws Exception{        Channel channel = session.openChannel("sftp");        channel.connect();        ChannelSftp sftp = (ChannelSftp) channel;        upload(directory,uploadFile,sftp);        channel.disconnect();    }    //上传文件    public static void deleteFile(Session session, String directory) throws Exception{        Channel channel = session.openChannel("sftp");        channel.connect();        ChannelSftp sftp = (ChannelSftp) channel;        delete(directory,sftp);        channel.disconnect();    }    public static void delete(String directory,ChannelSftp sftp) throws SftpException {        directory=directory.replace('\\','/');        if (!directory.endsWith("/")){            directory+="/";        }        Vector<?> content= sftp.ls(directory);        for (Iterator<?> it = content.iterator(); it.hasNext();) {            ChannelSftp.LsEntry entry = (ChannelSftp.LsEntry) it.next();            if (entry.getFilename().equals(".")){                continue;            }            if (entry.getFilename().equals("..")){                continue;            }            SftpATTRS sftpATTRS= sftp.lstat(directory+entry.getFilename());            if (sftpATTRS.isDir()){                delete(directory+entry.getFilename(),sftp);            }else{                sftp.rm(directory+entry.getFilename());            }        }        sftp.rmdir(directory);    }    //上传文件    public static void upload(String directory, String uploadFile, ChannelSftp sftp) throws Exception{        File file = new File(uploadFile);        if(file.exists()){            try {                Vector content = sftp.ls(directory);                if(content == null){                    sftp.mkdir(directory);                }            } catch (SftpException e) {                logger.info("出现异常！！");                logger.error(e.getMessage(),e);                sftp.mkdir(directory);            }            //进入目标路径            sftp.cd(directory);            if(file.isFile()){                InputStream ins = null;                try {                    ins = new FileInputStream(file);                    //中文名称的                    sftp.put(ins, new String(file.getName().getBytes(),"UTF-8"));                } catch (Exception e) {                    logger.error(e.getMessage() , e);                } finally {                    if (ins != null) {                        ins.close();                    }                }                //sftp.setFilenameEncoding("UTF-8");            }else{                File[] files = file.listFiles();                for (File file2 : files) {                    String uploadFilePath2 = file2.getAbsolutePath();                    String directory2 = directory + "";                    if(file2.isDirectory()){                        String str = uploadFilePath2.substring(uploadFilePath2.lastIndexOf(file2.separator));                        if(file2.separator.equals("\\")){                            str = str.replaceAll("\\\\","/");                        }                        directory2 += str;                    }                    upload(directory2,uploadFilePath2,sftp);                }            }        }    }}

 private void uploadWindowsAgent () throws Exception{//workspace 为windows上的路径        String workspace = server.getWorkspace();        String directory = workspace + "/atp-agent";        directory=directory.replace('/','\\');        logger.info("删除旧版本的agent开始...");        String deleteFileCommand = "cmd /c call rd \\s \\q "+ directory;        SSHUtil.execCommandByJSch(session,deleteFileCommand,"gbk");        logger.info("删除旧版本的agent完成...");        String mkdirCommand = "cmd /c call mkdir "+ directory;        logger.info("-> " + mkdirCommand);        SSHUtil.execCommandByJSch(session,mkdirCommand,"gbk");//        SSHUtil.deleteFile(session,directory);        logger.info("上传最新的agent到服务器...");        String uploadFileCommand = "cmd /c call scp -r root@"+ip+":"+targetPath+" "+ workspace;        SSHUtil.execCommandByJSch(session,uploadFileCommand,"gbk");//        SSHUtil.uploadFile(session, directory, targetPath);        logger.info("上传agent完成");        FileUtil.deleteDir(targetPath);    }

Windows批处理call和start的区别参考博文 https://blog.csdn.net/sinat_34439107/article/details/79023866

2，通过http协议下载
客户端发送请求

//客户端代码downloadUtil.download(appConfig.getTestPlatformUrl()+"/api/download",workspace,"atp-agent.zip");public void download(final String requestUrl, final String destFileDir, final String destFileName) throws Exception{        FileOutputStream out = null;        InputStream in = null;        try{            URL url = new URL(requestUrl);            URLConnection urlConnection = url.openConnection();            HttpURLConnection httpURLConnection = (HttpURLConnection) urlConnection;            // true -- will setting parameters            httpURLConnection.setDoOutput(true);            // true--will allow read in from            httpURLConnection.setDoInput(true);            // will not use caches            httpURLConnection.setUseCaches(false);            // setting serialized            httpURLConnection.setRequestProperty("Content-type", "application/x-java-serialized-object");            // default is GET            httpURLConnection.setRequestMethod("POST");            httpURLConnection.setRequestProperty("connection", "Keep-Alive");            httpURLConnection.setRequestProperty("Charsert", "UTF-8");            // 1 min            httpURLConnection.setConnectTimeout(60000);            // 1 min            httpURLConnection.setReadTimeout(60000);            // connect to server (tcp)            httpURLConnection.connect();            in = httpURLConnection.getInputStream();// send request to            // server            File dir  = new File(destFileDir);            if(!dir.exists()){                dir.mkdirs();            }            File file = new File(destFileDir, destFileName);            out = new FileOutputStream(file);            byte[] buffer = new byte[4096];            int readLength;            while ((readLength=in.read(buffer)) > 0) {//                byte[] bytes = new byte[readLength];//                System.arraycopy(buffer, 0, bytes, 0, readLength);                out.write(buffer,0,readLength);            }            out.flush();        }finally{            try {                if(in != null){                    in.close();                }            } catch (IOException e) {                e.printStackTrace();            }            try {                if(out != null){                    out.close();                }            } catch (IOException e) {                e.printStackTrace();            }        }    }//服务端代码@RequestMapping(value = "/api/download",method = RequestMethod.POST)    public void processDownload(HttpServletRequest request, HttpServletResponse response){        int bufferSize = 4096;        InputStream in = null;        OutputStream out = null;        try{            request.setCharacterEncoding("utf-8");            response.setCharacterEncoding("utf-8");            response.setContentType("application/octet-stream");            String agentPath= appConfig.getAgentPath();            File file = new File(agentPath+".zip");            response.setContentLength((int) file.length());            response.setHeader("Accept-Ranges", "bytes");            int readLength;            in = new BufferedInputStream(new FileInputStream(file), bufferSize);            out = new BufferedOutputStream(response.getOutputStream());            byte[] buffer = new byte[bufferSize];            while ((readLength=in.read(buffer)) > 0) {//                byte[] bytes = new byte[readLength];//                System.arraycopy(buffer, 0, bytes, 0, readLength);                out.write(buffer,0,readLength);            }            out.flush();        }catch(Exception e){            logger.error(e.getMessage(),e);        }finally {            if (in != null) {                try {                    in.close();                } catch (IOException e) {                    logger.error(e.getMessage(),e);                }            }            if (out != null) {                try {                    out.close();                } catch (IOException e) {                    logger.error(e.getMessage(),e);                }            }        }    }

更多相关文章

随机推荐