java鏈接服務器讀取日誌

說明:一、工具在使用中可能存在BUG,能夠本身修改或者告訴我哦~~~正則表達式

           二、本文內容在最後有文檔~shell

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

1、服務器登錄公鑰祕鑰設置

步驟以下:json

一、本機生成私鑰公鑰文件

本機進入到.ssh目錄下,c:/Users/zhufengyan/.ssh, 在該目錄下執行服務器

$ ssh-keygen -t rsasession

而後一路回車便可。ssh

說明:若是原先./ssh目錄下有id_rsa  id_rsa.pub這兩個文件,以上的一路回車操做會生成新的id_rsa  id_rsa.pub來覆蓋原來的key文件。ide

或者想生成不一樣命名的key文件能夠以下操做工具

說明:命令後面的「-C ‘zhufengyan@58ganji.com’」也是能夠去掉的ui

二、將本地生成的公鑰信息放到服務器

    將本地生成的公鑰信息放置到須要訪問的服務器,操做以下:url

本地獲取公鑰信息,複製信息

Xshell登陸服務器,加入你有root權限,

Cd /root/.ssh

Vi authorized_keys

將以上覆制的內容粘貼到文件尾部。Ok完成。

說明:假設你的服務器上沒有authorized_keys這個文件,那麼就本身建立一個,建立完後將公鑰信息粘貼到這個文件中,保存,還須要進行受權,chmod 600 authorized_keys。

另外:ssh公鑰生效需知足至少下面兩個條件:
1 .ssh目錄的權限必須是700;
2 .ssh/authorized_keys文件權限必須是600;

2、鏈接服務器

步驟以下

一、        將私鑰文件放到項目的resources目錄下

則代碼中訪問的路徑是

private String privateKeypath "src/main/resources/sshkey/id_rsa";

二、        代碼實現鏈接服務器

/**
 *
創建與服務器的鏈接
 
* @param host 服務器IP  String host = "192.168.178.1";
 * @param
port 端口   int port = 22;
 * @param
userName  登陸服務器的用戶名
 
* @param password  登陸服務器的密碼
 
* @param privateKeyFile  與服務器公鑰對應的私鑰文件  String pubkeypath = "src/main/resources/sshkey/id_rsa";
 * @return 
返回登陸的鏈接, 在使用的最後必定記得關閉connect資源
 
* @throws IOException
 */
public static Connection getSSHConnection(String host, int port, String userName, String password, String privateKeyFile) throws IOException {
    Connection connection = new Connection(host, port);
    connection.connect();
    File file = new File(privateKeyFile);
    boolean b = connection.authenticateWithPublicKey(userName, file, password);
    if (b){
        return connection;
    }else {
        System.out.println("登陸鏈接失敗,請檢查用戶名、密碼、私鑰文件");
        return null;
    }
}

 

3、獲取日誌信息

/**
     *
獲取指定log文件的指定關鍵字的日誌信息
    
* @param connection SSH的鏈接
    
* @param logFile   須要讀取的log文件 全路徑 /opt/dubbo_server/risk-server-provider-xjd/logs/server-info.log
     * @param
key  關鍵字     例如  節點3150調用策略引擎開始
    
* @param timeKey  時間關鍵字   例如 09-21 14:42:1
     * @return
返回須要的日誌信息行 若是有多天日誌信息知足條件,只返回最後一天日誌信息
    
* @throws IOException
     */
   
public static String getLogInfo(Connection connection, String logFile, String key, String  timeKey) throws IOException {
        String cmd = "tail -1000 " + logFile + " | grep '" + key + "'" + " | grep '" + timeKey + "'";
        System.out.println("====cmd===" + cmd);
//                "tail -1000 /opt/dubbo_server/risk-server-provider-xjd/logs/server-info.log | grep '節點3150調用策略引擎開始,' | grep '09-21 14:42:1'";
       
Session session = connection.openSession();
        session.execCommand(cmd);//執行shell命令
       
//處理獲取的shell命令的輸出信息
       
InputStream stdout = session.getStdout();
        InputStreamReader inputStreamReader = new InputStreamReader(stdout);
        BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
        String s = bufferedReader.readLine();
        String lastLineLog = null;
        System.out.println("==========如下是獲取日誌的所有信息============");
        while(s != null){
            if (s != null){
                lastLineLog = s;
                System.out.println(s);
            }
            s = bufferedReader.readLine();
        }
        System.out.println("==========以上是獲取日誌的所有信息============");
        System.out.println("========如下是日誌的最後一行數據=======");
        System.out.println(lastLineLog);

        //最後關閉session資源
       
if (session != null){
            session.close();
        }

        return lastLineLog;
    }

4、正則匹配須要的數據

/**
     *
經過正則表達式獲取須要的子串
    
* @param logStr
    
*      例如 [09-21 14:42:17 534 INFO ] [pool-3-thread-16] com.bj58.fbu.ark.server.risk.server.provider.process.util.ProcessExecutor - 流程18442節點3150調用策略引擎開始,參數={"58XF":{"deviceIdApplyCnt":{"VALUE":4.0,"TYPE":"1"},
     * @param
regex
    
*      例如 "\\{\"58XF\".*\\}$"  就是匹配logStr中的json串  匹配風控節點3150策略引擎的參數體
    
*          "\\{.*\\}$"    匹配徵信對應接口返回查詢數據體
    
* @return 返回 日誌中的消息json
    
*/
   
public static String  useRegexGetStr(String logStr, String regex){
        Pattern p = Pattern.compile(regex);  //匹配參數體
//        Pattern p = Pattern.compile("\\{\"58XF\".*\\}$");  //匹配參數體
       
Matcher m = p.matcher(logStr);
        boolean b = m.find();
        String params = null;
        if(b){
            params = m.group();
            System.out.println(params);
        }
        return params;     }
相關文章
相關標籤/搜索