說明：1、工具在使用中可能存在BUG，可以自己修改或者告訴我哦~~~
2、本文內容在最后有文檔~
<!-- https://mvnrepository.com/artifact/ch.ethz.ganymed/ganymed-ssh2 -->
<dependency>
<groupId>ch.ethz.ganymed</groupId>
<artifactId>ganymed-ssh2</artifactId>
<version>build210</version>
</dependency>
一、服務器登陸公鑰秘鑰設置
步驟如下：
1、本機生成私鑰公鑰文件
本機進入到.ssh目錄下，c:/Users/zhufengyan/.ssh， 在該目錄下執行
$ ssh-keygen -t rsa
然后一路回車即可。
說明：如果原先./ssh目錄下有id_rsa id_rsa.pub這兩個文件，以上的一路回車操作會生成新的id_rsa id_rsa.pub來覆蓋原來的key文件。
或者想生成不同命名的key文件可以如下操作
說明：命令后面的“-C ‘zhufengyan@58ganji.com’”也是可以去掉的
2、將本地生成的公鑰信息放到服務器
將本地生成的公鑰信息放置到需要訪問的服務器，操作如下：
本地獲取公鑰信息，復制信息
Xshell登錄服務器，加入你有root權限，
Cd /root/.ssh
Vi authorized_keys
將以上復制的內容粘貼到文件尾部。Ok完成。
說明：假設你的服務器上沒有authorized_keys這個文件，那么就自己創建一個，創建完后將公鑰信息粘貼到這個文件中，保存，還需要進行授權，chmod 600 authorized_keys。
另外：ssh公鑰生效需滿足至少下面兩個條件：
1 .ssh目錄的權限必須是700；
2 .ssh/authorized_keys文件權限必須是600；
二、連接服務器
步驟如下
1、 將私鑰文件放到項目的resources目錄下
則代碼中訪問的路徑是
private String privateKeypath = "src/main/resources/sshkey/id_rsa";
2、 代碼實現連接服務器
/**
* 建立與服務器的連接
* @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;
}
}
三、獲取日志信息
/**
* 獲取指定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;
}
四、正則匹配需要的數據
/**
* 通過正則表達式獲取需要的子串
* @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;
}