2. 程式人生 > >java實現讀寫服務器文件

java實現讀寫服務器文件

阿新 • • 發佈：2019-03-11
lean 關閉 host lower direct ssh2 成功 1.5 integer

這個主要實現的Java遠程訪問服務器的讀寫文件操作，自動登錄讀寫文件

pom.xml中要配置

<dependency>
<groupId>ch.ethz.ganymed</groupId>
<artifactId>ganymed-ssh2</artifactId>
<version>build210</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.jcraft/jsch -->

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

文件loginServer主要類中有個getProperties這個方法是配置服務器的地址信息的，需要先配置地址信息然後調用登錄去做登錄的操作LoginServer.login（LoginServer.getProperties（Config.Alertkey1 +“。json”），false ）;

如果這個單獨的看不懂你可以看看我在項目中是怎麽使用的項目中的服務器是內網服務器需要配置成你自己的服務器

https://github.com/MAXIAODONGS/Configure

LoginServer主要的工具類


  2. package com.maxd.upload;
    import java.io.*;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Properties;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;

    import ch.ethz.ssh2.Connection;
    import ch.ethz.ssh2.SCPClient;
    import ch.ethz.ssh2.StreamGobbler;
    import com.jcraft.jsch.JSch;
    import com.jcraft.jsch.Session;
    import com.maxd.utils.Config;

    public class LoginServer {
    /**
    * @param ip 服務器IP
    * @param user 服務器用戶名
    * @param pwd 服務器密碼
    * @param port 端口
    * @param privateKeyPath 可為空
    * @param passphrase 可為空
    * @param sourcePath 本地文件路徑
    * @param destinationPath 上傳路徑
    */
    private static void downLoadFile(String ip, String user, String pwd, String port, String privateKeyPath, String passphrase, String sourcePath, String destinationPath) {
    doWrite(ip, user, pwd, port, privateKeyPath, passphrase, sourcePath, destinationPath);
    }

    /**
    * 設置配置
    * @param fileName
    * @return
    */
    public static Properties getProperties(String fileName) {
    Properties properties = new Properties();
    properties.setProperty("ip", Config.hostname);
    properties.setProperty("user", Config.username);
    properties.setProperty("pwd", Config.password);
    properties.setProperty("port", String.valueOf(Config.port));
    properties.setProperty("sourcePath", Config.sourcePath + fileName);
    properties.setProperty("destinationPath", Config.destinationPath);
    return properties;
    }

    /**
    * @param properties
    * @param isRead true表示讀取 false表示寫入
    */
    public static void login(Properties properties, boolean isRead) {
    String ip = properties.getProperty("ip");
    String user = properties.getProperty("user");
    String pwd = properties.getProperty("pwd");
    String port = properties.getProperty("port");
    String privateKeyPath = properties.getProperty("privateKeyPath");
    String passphrase = properties.getProperty("passphrase");
    String sourcePath = properties.getProperty("sourcePath");
    String destinationPath = properties.getProperty("destinationPath");
    if (!isRead) {
    //寫入本地文件到遠程服務器
    doWrite(ip, user, pwd, port, privateKeyPath, passphrase, sourcePath, destinationPath);
    } else {
    //讀取遠程文件到本地
    readConnect();
    }
    }

    /**
    * @throws IOException
    * @description 讀文件
    */
    public static String readTxtFile(File fileName) throws IOException {
    String result = null;
    FileReader fileReader = null;
    BufferedReader bufferedReader = null;
    fileReader = new FileReader(fileName);
    InputStreamReader isr = new InputStreamReader(new FileInputStream(fileName), "UTF-8");
    BufferedReader bufferedReader1 = new BufferedReader(isr);
    String read = null;
    int count = 0;
    while ((read = bufferedReader1.readLine()) != null) {
    result = read + "\r\n";
    count++;
    }
    if (bufferedReader != null) {
    bufferedReader.close();
    }
    if (fileReader != null) {
    fileReader.close();
    }
    return result;
    }

    /**
    * @throws UnsupportedEncodingException
    * @throws IOException
    * @description 寫文件
    */
    public static boolean writeTxtFile(String content, File fileName) throws UnsupportedEncodingException, IOException {
    FileOutputStream o = null;
    o = new FileOutputStream(fileName);
    o.write(content.getBytes("UTF-8"));
    o.close();
    return true;
    }

    private static void doWrite(String ip, String user, String pwd, String port, String privateKeyPath, String passphrase, String sourcePath, String destinationPath) {
    if (ip != null && !ip.equals("") && user != null && !user.equals("") && port != null && !port.equals("") && sourcePath != null && !sourcePath.equals("") && destinationPath != null && !destinationPath.equals("")) {
    if (privateKeyPath != null && !privateKeyPath.equals("")) {
    sshSftp2(ip, user, Integer.parseInt(port), privateKeyPath,
    passphrase, sourcePath, destinationPath);
    } else if (pwd != null && !pwd.equals("")) {
    sshSftp(ip, user, pwd, Integer.parseInt(port), sourcePath,
    destinationPath);
    } else {
    Console console = System.console();
    System.out.print("Enter password:");
    char[] readPassword = console.readPassword();
    sshSftp(ip, user, new String(readPassword),
    Integer.parseInt(port), sourcePath, destinationPath);
    }
    } else {
    System.out.println("請先設置配置文件");
    }
    }

    /**
    * 密碼方式登錄
    *
    * @param ip
    * @param user
    * @param psw
    * @param port
    * @param sPath
    * @param dPath
    */
    private static void sshSftp(String ip, String user, String psw, int port,
    String sPath, String dPath) {
    System.out.println("password login");
    Session session = null;

    JSch jsch = new JSch();
    try {
    if (port <= 0) {
    // 連接服務器，采用默認端口
    session = jsch.getSession(user, ip);
    } else {
    // 采用指定的端口連接服務器
    session = jsch.getSession(user, ip, port);
    }
    // 如果服務器連接不上，則拋出異常
    if (session == null) {
    throw new Exception("session is null");
    }
    // 設置登陸主機的密碼
    session.setPassword(psw);// 設置密碼
    // 設置第一次登陸的時候提示，可選值：(ask | yes | no)
    session.setConfig("StrictHostKeyChecking", "no");
    // 設置登陸超時時間
    session.connect(300000);
    UpLoadFile.upLoadFile(session, sPath, dPath);
    //DownLoadFile.downLoadFile(session, sPath, dPath);
    } catch (Exception e) {
    e.printStackTrace();
    }
    System.out.println("success");
    }

    /**
    * 密匙方式登錄
    *
    * @param ip
    * @param user
    * @param port
    * @param privateKey
    * @param passphrase
    * @param sPath
    * @param dPath
    */
    private static void sshSftp2(String ip, String user, int port,
    String privateKey, String passphrase, String sPath, String dPath) {
    System.out.println("privateKey login");
    Session session = null;
    JSch jsch = new JSch();
    try {
    // 設置密鑰和密碼
    // 支持密鑰的方式登陸，只需在jsch.getSession之前設置一下密鑰的相關信息就可以了
    if (privateKey != null && !"".equals(privateKey)) {
    if (passphrase != null && "".equals(passphrase)) {
    // 設置帶口令的密鑰
    jsch.addIdentity(privateKey, passphrase);
    } else {
    // 設置不帶口令的密鑰
    jsch.addIdentity(privateKey);
    }
    }
    if (port <= 0) {
    // 連接服務器，采用默認端口
    session = jsch.getSession(user, ip);
    } else {
    // 采用指定的端口連接服務器
    session = jsch.getSession(user, ip, port);
    }
    // 如果服務器連接不上，則拋出異常
    if (session == null) {
    throw new Exception("session is null");
    }
    // 設置第一次登陸的時候提示，可選值：(ask | yes | no)
    session.setConfig("StrictHostKeyChecking", "no");
    // 設置登陸超時時間
    session.connect(300000);
    UpLoadFile.upLoadFile(session, sPath, dPath);
    System.out.println("success");
    } catch (Exception e) {
    e.printStackTrace();
    }
    }

    /**
    * 讀取遠程文件到本地
    */
    private static void readConnect() {
    Connection conn = new Connection(Config.hostname, Config.port);
    ch.ethz.ssh2.Session ssh = null;
    try {
    //連接到主機
    conn.connect();
    //使用用戶名和密碼校驗
    boolean isconn = conn.authenticateWithPassword(Config.username, Config.password);
    if (!isconn) {
    System.out.println("用戶名稱或者是密碼不正確");
    } else {
    System.out.println("已經連接OK");
    File folder = new File(Config.writePath);
    if (!folder.exists()) {
    folder.mkdir();
    }
    SCPClient clt = conn.createSCPClient();
    ssh = conn.openSession();
    ssh.execCommand("find /app/s3-configuration/ -name ‘*.json‘");
    InputStream is = new StreamGobbler(ssh.getStdout());
    BufferedReader brs = new BufferedReader(new InputStreamReader(is));
    while (true) {
    String line = brs.readLine();
    if (line == null) {
    break;
    }
    clt.get(line, Config.writePath);
    List<File> lf = new ArrayList<File>();
    lf = getFileList(new File(Config.writePath), "json");
    for (File f : lf) {
    /*System.out.println(f.getPath());*/
    String path = f.getPath();
    File file = new File(path);
    try {
    FileReader fr = new FileReader(file);
    BufferedReader br = new BufferedReader(fr);
    String s = null;
    Pattern p = Pattern.compile(".*?error.*?");
    while ((s = br.readLine()) != null) {
    Matcher m = p.matcher(s);
    if (m.find()) {
    /*System.out.println(m.matches());*/
    System.out.println(line);
    System.out.println("find error!");
    }/*else{
    System.out.println("no error");
    } */
    }

    br.close();
    } catch (FileNotFoundException e) {
    System.err.println("file not found");
    } catch (IOException e) {
    e.printStackTrace();
    }

    }
    System.out.println("文件輸出成功，請在" + Config.writePath + "中查看");

    }

    }
    } catch (IOException e) {
    System.out.println(e.getMessage());
    e.printStackTrace();
    } finally {
    //連接的Session和Connection對象都需要關閉
    if (ssh != null) {
    ssh.close();
    }
    if (conn != null) {
    conn.close();
    }
    }
    }

    private static List<File> getFileList(File fileDir, String fileType) {
    List<File> lfile = new ArrayList<File>();
    File[] fs = fileDir.listFiles();
    for (File f : fs) {
    if (f.isFile()) {
    if (fileType.equals(f.getName().substring(f.getName().lastIndexOf(".") + 1, f.getName().length())))
    lfile.add(f);
    } else {
    List<File> ftemps = getFileList(f, fileType);
    lfile.addAll(ftemps);
    }
    }
    return lfile;
    }
    }

    package com.maxd.upload;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.util.Scanner;

    import com.jcraft.jsch.Channel;
    import com.jcraft.jsch.ChannelSftp;
    import com.jcraft.jsch.Session;
    import com.jcraft.jsch.SftpException;
    public class UpLoadFile {
    public static void upLoadFile(Session session, String sPath, String dPath) {

    Channel channel = null;
    try {
    channel = (Channel) session.openChannel("sftp");
    channel.connect(10000000);
    ChannelSftp sftp = (ChannelSftp) channel;
    try {
    //上傳
    sftp.cd(dPath);
    Scanner scanner = new Scanner(System.in);
    /* System.out.println(dPath + ":此目錄已存在,文件可能會被覆蓋!是否繼續y/n?");
    String next = scanner.next();
    if (!next.toLowerCase().equals("y")) {
    return;
    }*/

    } catch (SftpException e) {

    sftp.mkdir(dPath);
    sftp.cd(dPath);

    }
    File file = new File(sPath);
    copyFile(sftp, file, sftp.pwd());
    } catch (Exception e) {
    e.printStackTrace();
    } finally {
    session.disconnect();
    channel.disconnect();
    }
    }

    public static void copyFile(ChannelSftp sftp, File file, String pwd) {

    if (file.isDirectory()) {
    File[] list = file.listFiles();
    try {
    try {
    String fileName = file.getName();
    sftp.cd(pwd);
    System.out.println("正在創建目錄:" + sftp.pwd() + "/" + fileName);
    sftp.mkdir(fileName);
    System.out.println("目錄創建成功:" + sftp.pwd() + "/" + fileName);
    } catch (Exception e) {
    // TODO: handle exception
    }
    pwd = pwd + "/" + file.getName();
    try {

    sftp.cd(file.getName());
    } catch (SftpException e) {
    // TODO: handle exception
    e.printStackTrace();
    }
    } catch (Exception e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    }
    for (int i = 0; i < list.length; i++) {
    copyFile(sftp, list[i], pwd);
    }
    } else {

    try {
    sftp.cd(pwd);

    } catch (SftpException e1) {
    // TODO Auto-generated catch block
    e1.printStackTrace();
    }
    System.out.println("正在復制文件:" + file.getAbsolutePath());
    InputStream instream = null;
    OutputStream outstream = null;
    try {
    outstream = sftp.put(file.getName());
    instream = new FileInputStream(file);

    byte b[] = new byte[1024];
    int n;
    try {
    while ((n = instream.read(b)) != -1) {
    outstream.write(b, 0, n);
    }
    } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    }

    } catch (SftpException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    } finally {
    try {
    outstream.flush();
    outstream.close();
    instream.close();

    } catch (Exception e2) {
    // TODO: handle exception
    e2.printStackTrace();
    }
    }
    }
    }
    }

文件地址

https://github.com/MAXIAODONGS/Remote-operation-of-static-resources

java實現讀寫服務器文件

相關推薦

java實現讀寫服務器文件

lean 關閉 host lower direct ssh2 成功 1.5 integer 這個主要實現的Java遠程訪問服務器的讀寫文件操作，自動登錄讀寫文件 pom.xml中要配置 <dependency>

Web服務器文件傳輸程序客戶端程序實現

匹配 admin 復制 賦值 連續 反饋 sock 用戶輸入 mat 1、 客戶端程序--主函數 客戶端主程序的流程圖如下： 主程序主要是分析輸入的命令，根據不同命令調用不同的函數處理或者進行出錯處理，函數代碼如下： #include "common.h" in

Java 讀寫Properties配置文件

int true copy nbsp sys util 保存時間 實現 hashtable 1.Properties類與Properties配置文件 　　Properties類繼承自Hashtable類並且實現了Map接口，也是使用一種鍵值對的形式來保存屬性集。不過Prop

多臺服務器文件同步實現

創建目錄 zed error host 屬組 殺死 dup comm read 一、rsync特性 可以鏡像保存整個目錄樹和文件系統。 可以很容易做到保持原來文件的權限、時間、軟硬鏈接等等。 無須特殊權限即可安裝。 快速：第一次同步時rsync會復制全部內容，但在下

java 讀寫操作大文件 BufferedReader和RandomAccessFile

chan 支持 tput close input oot tar for循環次數控制 art 一 老問這問題，兩個都答出來算加分項？ 二 具體代碼如下，沒什麽好說的直接說對比。 BufferedReader和RandomAccessFile的區別RandomAcce

python服務器文件上傳下載+GUI【tkinter】

pat com 方法 __main__ mat 服務器 rom 練手 scl 大概就是一個通過應用程序來和服務器打交道的這麽一個，小東西 1.GUI 用的是tkinter 1 # -*- coding: UTF-8 -*- 2 from tkinter impor

服務器文件夾配置方案

com 服務 .com .cn cnblogs images 服務器文件 bsp image 1. 2.這個就是根 3. 服務器文件夾配置方案

如何用python讀寫CSV 格式文件

文件 原理 color print 讀取 python 數據 pytho bold 工作中經常會碰到讀寫CSV文件的情況。記錄下，方便自己以後查詢並與大家一起分享： 寫CSV文件方法一： import csv #導入CSV with open("D:\eg

關於wamp服務器文件的配置

保存 lin spa eof pac 配置 host clas amp 有的前端朋友想在手機端看PC端開發的html5頁面，這時候會在本地PC下載一個wamp,這時候在PC端輸入電腦的IP地址或者是直接輸入localhost，可以訪問www目錄下的文件（開發項目必須放置在這

通過瀏覽器下載服務器文件(日誌)

服務器文件 logs windows server 運行 科技 ron n) pytho 下載服務器的文件是經常需要進行的操作. 可以通過FTP工具進行(如Filezilla等). 以下提供一種通過瀏覽器下載服務器文件的黑科技: 1. 在windows/linux/sola

SSH連接下復制遠程linux服務器文件到本地的命令（zz）

bsp 客戶 tar oot static 遠程服務器 ofo install 拷貝 原文 （1）將本地文件拷貝到遠程 scp 文件名用戶名@計算機IP或者計算機名稱:遠程路徑 本地192.168.1.8客戶端 scp /root/install.* [emai

在C#中讀寫INI配置文件(轉)

換行 value .config pri mas 文本 data- ini文件 def 在作應用系統開發時，管理配置是必不可少的。例如數據庫服務器的配置、安裝和更新配置等等。由於Xml的興起，現在的配置文件大都是以xml文檔來存儲。比如Visual Studio.Net自身

Ubuntu14.04 使用scp遠程傳輸命令進行服務器文件互傳

另一個 spa 參數 aaa 文件 端口號 拷貝文件 nbsp clas 1.將另一個服務器上的文件拷貝到本地 sudo scp [email protected]_ip:/home/aaa/bbb /ccc/ddd/bbb 上面命令的意思是將遠程服務器/ho

2.7 清除FTP服務器文件

files run nal 文件 判斷 iss miss logs name 清除服務器文件 from ftptools import FtpTools class CleanAll(FtpTools): ‘‘‘delete an entire remote t

清理服務器文件典型案例

問題解決 microsoft 什麽 find命令 刪除 文件 大文件 pat nbsp 操作環境 SuSE11 問題現象 根目錄空間使用率即將達到100%，空間不足，需要清理根目錄下無用的文件 問題解決 1、利用find命令查找大於100M的文件，手工刪除。 f

python--ConfigParser讀寫改配置文件

得到 pen with open ring 文件 open 打開 work add from configparser import ConfigParser fp = ‘conf.ini‘ #定義配置文件名 conf = ConfigParser() #實例化

如何配置FTP服務器，方便操作服務器文件

media 點擊 step tar d3d 雙擊 .com one fault 1 進入“控制面板”->“程序”->"打開或關閉Windows功能"，找到“Internet信息服務”選項 2 將“Internet信息服務

java實現反向代理服務器

response connect enc char exception pos httputil let commons 1.寫的一個簡單的例子 package forword; import java.io.IOException; import javax.ser

VC++讀寫*.ini配置文件

自己 dst 初始化 strong 返回 i++ 連續 read ted ini文件(即Initialization file)，這種類型的文件中通常存放的是一個程序的初始化信息。ini文件由若幹個節(Section)組成，每個Section由若幹鍵(Ke

Linux 服務器文件上傳下載 rz/sz命令

rz/sz命令我們一般可以或者使用xftp或者其他的上傳工具，但這樣的話我們一般就得使用兩個工具使用起來比較繁瑣，看到有的小夥伴使用rz感覺合適不錯，現在來試試：1[root@localhost ~]# rz -y-bash: rz: command not found什麽情況，難道xshell沒有這個命令？