2. 程式人生 > 其它 >java實現連線 SFTP 上傳下載檔案

java實現連線 SFTP 上傳下載檔案

阿新 • • 發佈：2021-10-21

1、引入maven依賴

<!-- sftp -->
<dependency>
    <groupId>com.jcraft</groupId>
    <artifactId>jsch</artifactId>
    <version>0.1.54</version>
</dependency>

2、程式碼實現如下

package com.test.sftp;

import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;

 
import com.jcraft.jsch.Session;
import lombok.extern.slf4j.Slf4j;

import java.io.*;
import java.util.*;

/**
 * @author: void
 * @date: 2021-10-15 16:08
 * @description: sftp伺服器檔案操作
 * @version: 1.0
 *
 */
@Slf4j
public class SftpUtil {

    private String loginName = "sftp1";
    private String loginPassword = "123456";
    
 
private String server = "192.169.2.15";
    private Integer port = 22;


    public static void main(String[] args) {
        SftpUtil sftpUtil = new SftpUtil();
        //上傳檔案
        sftpUtil.uploadFile();
        //下載檔案
        sftpUtil.downloadFile();
        //寫檔案
        sftpUtil.writeFile();
        
 
//讀檔案
        sftpUtil.readFile();
        //刪除檔案
        sftpUtil.deleteFile();


    }



    /**
     * 連線登陸遠端伺服器
     *
     * @return
     */
    public ChannelSftp connect()  {
        JSch jSch = new JSch();
        Session session = null;
        ChannelSftp sftp = null;
        try {
            session = jSch.getSession(loginName, server, port);
            session.setPassword(loginPassword);
            session.setConfig(this.getSshConfig());
            session.connect();

            sftp = (ChannelSftp)session.openChannel("sftp");
            sftp.connect();

            log.error("結果："+session.equals(sftp.getSession()));
            log.info("登入成功:" + sftp.getServerVersion());

        } catch (Exception e) {
            log.error("SSH方式連線FTP伺服器時有JSchException異常!",e);
            return null;
        }
        return sftp;
    }

    /**
     * 獲取服務配置
     * @return
     */
    private Properties getSshConfig() {
        Properties sshConfig =  new Properties();
        sshConfig.put("StrictHostKeyChecking", "no");
        return sshConfig;
    }


    /**
     * 關閉連線
     * @param sftp
     */
    public void disconnect(ChannelSftp sftp) {
        try {
            if(sftp!=null){
                if(sftp.getSession().isConnected()){
                    sftp.getSession().disconnect();
                }
            }
        } catch (Exception e) {
            log.error("關閉與sftp伺服器會話連線異常",e);
        }
    }



    /**
     * 下載遠端sftp伺服器檔案
     *
     * @return
     */
    public void downloadFile() {
        FileOutputStream output = null;
        ChannelSftp sftp = null;
        try {
            sftp = connect();
            if(sftp == null){
                return ;
            }
            //sftp伺服器上檔案路徑
            String remoteFilename = "/test1/測試.txt";
            //下載至本地路徑
            File localFile = new File("./file/sftp/從sftp伺服器上下載.txt");
            output = new FileOutputStream(localFile);

            sftp.get(remoteFilename, output);
            System.out.println("成功接收檔案,本地路徑：" + localFile.getAbsolutePath());
        } catch (Exception e) {
            log.error("接收檔案異常!",e);
        } finally {
            try {
                if (null != output) {
                    output.flush();
                    output.close();
                }
                // 關閉連線
                disconnect(sftp);
            } catch (IOException e) {
                log.error("關閉檔案時出錯!",e);
            }
        }
    }



    /**
     * 讀取遠端sftp伺服器檔案
     *
     * @return
     */
    public void readFile() {
        InputStream in = null;
        ArrayList<String> strings = new ArrayList<>();
        ChannelSftp sftp = null;
        try {
            sftp = connect();
            if(sftp == null){
                return;
            }
            String remotePath = "/test1/";
            String remoteFilename = "測試1.txt";
            sftp.cd(remotePath);
            if(!listFiles(remotePath).contains(remoteFilename)){
                log.error("no such file");
                return;
            }
            in = sftp.get(remoteFilename);
            if (in != null) {
                BufferedReader br = new BufferedReader(new InputStreamReader(in,"utf-8"));
                String str = null;
                while ((str = br.readLine()) != null) {
                    System.out.println(str);
                }
            }else{
                log.error("in為空，不能讀取。");
            }
        } catch (Exception e) {
            log.error("接收檔案時異常!",e);
        }  finally {
            try {
                if(in !=null){
                    in.close();
                }
                // 關閉連線
                disconnect(sftp);
            } catch (Exception e) {
                log.error("關閉檔案流時出現異常!",e);
            }
        }
    }


    /**
     * 寫檔案至遠端sftp伺服器
     *
     * @return
     */
    public void writeFile(){
        ChannelSftp sftp = null;
        ByteArrayInputStream input = null;
        try {
            sftp = connect();
            if(sftp == null){
                return;
            }
            // 更改伺服器目錄
            String remotePath = "/test1/";
            sftp.cd(remotePath);
            // 傳送檔案
            String remoteFilename = "寫檔案.txt";
            String content = "測試內容";
            input = new ByteArrayInputStream(content.getBytes());
            sftp.put(input, remoteFilename);
        } catch (Exception e) {
            log.error("傳送檔案時有異常!",e);
        } finally {
            try {
                if (null != input) {
                    input.close();
                }
                // 關閉連線
                disconnect(sftp);
            } catch (Exception e) {
                log.error("關閉檔案時出錯!",e);
            }
        }
    }



    /**
     * 上傳檔案至sftp伺服器
     * @return
     */
    public void uploadFile() {
        FileInputStream fis = null;
        ChannelSftp sftp = null;
        // 上傳檔案至伺服器此目錄
        String remotePath = "./file/sftp/從sftp伺服器上下載.txt";
        String remoteFilename = "/test1/上傳至sftp伺服器.txt";
        try {
            sftp = connect();
            if(sftp == null){
                return ;
            }

            File localFile = new File(remotePath);
            fis = new FileInputStream(localFile);
            //傳送檔案
            sftp.put(fis, remoteFilename);
            log.info("成功上傳檔案" );
        } catch (Exception e) {
            log.error("上傳檔案時異常!",e);
        } finally {
            try {
                if (fis != null) {
                    fis.close();
                }
                // 關閉連線
                disconnect(sftp);
            } catch (Exception e) {
                log.error("關閉檔案時出錯!",e);
            }
        }
    }


    /**
     * 遍歷遠端檔案
     *
     * @param remotePath
     * @return
     * @throws Exception
     */
    public List<String> listFiles(String remotePath){
        List<String> ftpFileNameList = new ArrayList<String>();
        ChannelSftp.LsEntry isEntity = null;
        String fileName = null;
        ChannelSftp sftp = null;
        try{
            sftp = connect();
            if(sftp == null){
                return null;
            }
            Vector<ChannelSftp.LsEntry> sftpFile = sftp.ls(remotePath);
            Iterator<ChannelSftp.LsEntry> sftpFileNames = sftpFile.iterator();
            while (sftpFileNames.hasNext()) {
                isEntity = (ChannelSftp.LsEntry) sftpFileNames.next();
                fileName = isEntity.getFilename();
                ftpFileNameList.add(fileName);
            }
            return ftpFileNameList;
        }catch (Exception e){
            log.error("遍歷查詢sftp伺服器上檔案異常",e);
            return null;
        }finally {
            disconnect(sftp);
        }

    }


    /**
     * 刪除遠端檔案
     * @return
     */
    public void deleteFile() {
        boolean success = false;
        ChannelSftp sftp = null;
        try {
            sftp = connect();
            if(sftp == null){
                return;
            }
            String remotePath = "/test1/";
            String remoteFilename = "limit.lua";
            // 更改伺服器目錄
            sftp.cd(remotePath);
            //判斷檔案是否存在
            if(listFiles(remotePath).contains(remoteFilename)){
                // 刪除檔案
                sftp.rm(remoteFilename);
                log.info("刪除遠端檔案" + remoteFilename + "成功!");
            }

        } catch (Exception e) {
            log.error("刪除檔案時有異常!",e);
        } finally {
            // 關閉連線
            disconnect(sftp);
        }
    }
}

相關內容

LINUX搭建SFTP伺服器

作者：小念 出處：https://www.cnblogs.com/kiko2014551511/ 本文版權歸作者和部落格園共有，歡迎轉載，但必須給出原文連結，並保留此段宣告，否則保留追究法律責任的權利。

相關推薦

java實現連線 SFTP 上傳下載檔案

1、引入maven依賴 <!-- sftp --> <dependency> <groupId>com.jcraft</groupId> <artifactId>jsch</artifactId>

Java實現SFTP上傳下載檔案及遇到的問題

最近工作中用到了JSch去操作SFTP檔案的上傳和下載，本文記錄一下封裝的一個工具類，以及實際遇到的兩個問題。

curl實現SFTP上傳下載檔案

摘自：https://blog.csdn.net/swj9099/article/details/85292444 1 #pragma once 2 #include <stdio.h>

.net 如何連線linux上傳下載檔案？

1.net連線linux上傳下載檔案可以通過scp命令來實現，首先需要我們引入“Renci.SshNet.dll”

linux端到linux端通過SFTP上傳下載檔案

技術標籤：FTPlinux客戶端sftp上傳下載 環境和需求 1. 環境 1.linux客戶端A：192.168.50.112

SFTP上傳下載檔案、資料夾常用操作

  SFTP上傳下載檔案、資料夾常用操作 1.檢視上傳下載目錄lpwd 2.改變上傳和下載的目錄（例如D盤）：lcd  d:/  

Java上傳下載檔案並實現加密解密

使用 Jersey 伺服器實現上傳，使用 HTTP 請求實現下載 引入依賴 在 pom.xml 中新增 Jersey 相關依賴

基於Java寫minio客戶端實現上傳下載檔案

前言： 　　確保已經安裝了minio的服務端 程式碼： pom.xml <dependency> <groupId>io.minio</groupId>

Java fastdfs客戶端實現上傳下載檔案

一、專案結構 二、pom.xml <?xml version=\"1.0\" encoding=\"UTF-8\"?> <project xmlns=\"http://maven.apache.org/POM/4.0.0\"

springboot整合vue實現上傳下載檔案

springboot整合vue實現上傳下載檔案，供大家參考，具體內容如下 環境 springboot 1.5.x

Java使用FTPClient上傳下載檔案

package com.founder.mrp.util; import com.founder.mrp.util.storage.StorageFile; import org.apache.commons.net.ftp.FTPClient;

java web上傳下載檔案模組

技術標籤：java基礎javaservletjavawebjsp 基於java web的檔案上傳下載工具 初步構想是實現從頁面選擇上傳路徑，若不選擇，則上傳到預設路徑，選擇上傳的檔案，點選上傳，上傳成功。

java【Socket】【上傳下載檔案】

public class TCPClient { public static void main(String[] args)throws IOException { Socket socket = new Socket(\"127.0.0.1\",5000);

java實現視訊斷點上傳檔案

​ 4GB以上超大檔案上傳和斷點續傳伺服器的實現 隨著視訊網站和大資料應用的普及，特別是高清視訊和4K視訊應用的到來，超大檔案上傳已經成為了日常的基礎應用需求。

JAVA實現連線本地印表機並列印檔案的實現程式碼

實現程式碼一 import javax.print.*; import javax.print.attribute.DocAttributeSet; import javax.print.attribute.HashDocAttributeSet;

SFTP上傳下載

1、匯入jar包ora-sftp-1.4.jar 2、編譯package和執行sql檔案 cux_1_pm_sftp_util.pck，ORA_SFTP_FILE.sql

MVC 上傳下載檔案

首先，需要引用DBHelper輔助類,便於實現SQL語句的增刪改差以及連線到資料庫。

Linux利用ftp命令上傳下載檔案

Linux中如何使用ftp命令，包括如何連線ftp伺服器，上傳or下載檔案以及建立資料夾。雖然現在有很多ftp桌面應用（例如：FlashFXP），但是在伺服器、SSH、遠端會話中掌握命令列ftp的使用還是很有必要的。

sftp 上傳下載指令碼

概述 因公司專案由之前的ftp換位sftp，且之前的UDP函式未開發出來，使用指令碼實現部分功能（sftp檔案下載）。一次連線和多次連線均為指定檔名下載，下載最新的檔案即下載修改時間最新的檔案，因每天最多更新一份，在

NX二次開發-NX客戶端與伺服器FTP上傳下載檔案

版本： 客戶端NX11+VS2013 伺服器windowsServer2012R2 1.部署伺服器FTP： 在桌面左下角點選“伺服器管理器”。