当前位置：Gxlcms > PHP教程 > [饶过]使用Java管理千台规模Linux服务器_入门

[饶过]使用Java管理千台规模Linux服务器_入门

时间：2021-07-01 10:21:17 帮助过：23人阅读

前东家是一家游戏公司，老板很好，当时工作也留下了很多自己原创的管理脚本。现在分享一下在办公环境使用Java、Jsch登录VPN管理Linux的脚本（此处实现JAVA调用Linux上备份Mysql的shell作为示例），希望对运维的朋友有帮助，尽快从繁杂的服务器管理工作中脱离出来。

主要的实现思路：

 如果需要先登录VPN才能连接游戏服务器，需要将游戏服务器的ssh端口（一般是22）映射到本地办公电脑的端口上（如5555），然后ssh连接本地办公电脑的5555端口，这样就可以连接到游戏服务器，并可以管理游戏服务器了。

当您学会通过VPN连接Linux服务器后，如果只在内网环境，不使用VPN，就更简单了，此外不再详述。Jsch的example里也有介绍。
  1. package com.daily.wednesday;
  3. import java.io.IOException;
  4. import java.io.InputStream;
  5. import java.sql.Connection;
  6. import java.sql.DriverManager;
  7. import java.sql.ResultSet;
  8. import java.sql.SQLException;
  9. import java.sql.Statement;
  11. import com.daily.util.DataBaseConnection;
  12. import com.jcraft.jsch.Channel;
  13. import com.jcraft.jsch.ChannelExec;
  14. import com.jcraft.jsch.JSch;
  15. import com.jcraft.jsch.JSchException;
  16. import com.jcraft.jsch.Session;
  18. public class BackUpMysql3 {
  19. public static void main(String args[]) {
  20. // 读取数据库配置
  21. DataBaseConnection dataBaseConnection = new DataBaseConnection();
  22. String dataBaseConfigForWrite[] = new String[3];
  23. dataBaseConfigForWrite = dataBaseConnection.loadDataConfig();
  25. Connection conn = null;// 数据库连接
  26. Statement stmt = null;// 数据库表达式
  27. ResultSet rs = null; // 结果集
  28. int rowcount = 0;// 总记录数
  29. String sql = "select * from servers_maint_wednesday";
  31. try {
  32. conn = DriverManager.getConnection(dataBaseConfigForWrite[0],
  33. dataBaseConfigForWrite[1], dataBaseConfigForWrite[2]);
  34. stmt = conn.createStatement();
  35. rs = stmt.executeQuery(sql);
  36. rs.last();
  37. rowcount = rs.getRow();// 总记录数
  38. rs = stmt.executeQuery(sql);
  39. } catch (SQLException e) {
  40. e.printStackTrace();
  41. }
  42. // 定义游戏服务器IP的数组，游戏服务器IP存在数据库中。
  43. String privateIpaddress[] = new String[rowcount];
  44. String remark[] = new String[rowcount];// 定义游戏区名称
  45. String programPath[] = new String[rowcount];// 定义程序路径
  46. String backMysqlShellPath[] = new String[rowcount];// 定义mysql备份脚本路径
  48. int j = 0;
  49. try {
  50. while (rs.next()) {
  51. privateIpaddress[j] = rs.getString("privateipaddress");
  52. remark[j] = rs.getString("remarks");
  53. programPath[j] = rs.getString("programpath");
  54. backMysqlShellPath[j] = rs.getString("backmysqlshellpath");
  55. j++;
  56. }
  57. } catch (Exception e) {
  58. e.printStackTrace();
  59. } finally {
  60. try {
  61. if (rs != null) {
  62. rs.close();
  63. }
  64. if (stmt != null) {
  65. stmt.close();
  66. }
  67. if (conn != null) {
  68. conn.close();
  69. }
  70. } catch (Exception e) {
  71. e.printStackTrace();
  72. }
  73. }
  75. // 调用mysql备份方法
  76. for (int n = 0; n < privateIpaddress.length; n++) {
  77. try {
  78. try {
  79. backUpMysql(privateIpaddress[n], backMysqlShellPath[n],remark[n]);
  80. } catch (IOException e) {
  81. // TODO Auto-generated catch block
  82. e.printStackTrace();
  83. }
  84. } catch (JSchException e) {
  85. // TODO Auto-generated catch block
  86. e.printStackTrace();
  87. }
  88. }
  90. }
  91. /**
  92. * 备份mysql数据库的方法
  93. * @param privateip
  94. * @param backMysqlShellPath
  95. * @throws JSchException
  96. * @throws IOException
  97. */
  98. public static void backUpMysql(String privateip, String backMysqlShellPath, String remark)
  99. throws JSchException, IOException {
  100. // 登录到服务器
  101. int rport;
  102. JSch jsch = new JSch();
  103. String host = "dl.dengdie.com"; //此处为VPN服务器地址
  104. String user = "admin"; //VPN用户名
  105. Session sessionForBack = jsch.getSession(user, host, 22);
  106. rport = 22;
  107. sessionForBack.setPassword("&*&&&&lalaflls"); //VPN密码
  108. java.util.Properties config = new java.util.Properties();
  109. config.put("StrictHostKeyChecking", "no");
  110. sessionForBack.setConfig(config);
  111. sessionForBack.connect();//登录到VPN服务器
  113. // 建立与游戏服务器的ssh转发连接:即将游戏服务器的22号ssh端口映射的本地办公电脑的53238端口。
  114. sessionForBack.setPortForwardingL(53238, privateip, rport);
  116. try {
  117. JSch jschToBack = new JSch();
  119. Session sessionToBack = jschToBack.getSession(user, "127.0.0.1",
  120. 53238); //连接本地办公电脑的53238端口，就相当于连接了游戏服务器的22号端口。
  121. sessionToBack.setPassword("&*&&&&lalaflls");
  122. sessionToBack.setConfig(config);
  123. sessionToBack.connect();
  124. //backMysqlShellPath实际上是游戏服务器上备份Mysql数据库的一个脚本，此脚本请您自行实现，网上很多实例。
  125. String command = backMysqlShellPath;
  126. //打开执行命令的隧道，并执行命令。
  127. Channel channel = sessionToBack.openChannel("exec");
  128. ((ChannelExec) channel).setCommand(command);
  129. channel.setInputStream(null);
  130. ((ChannelExec) channel).setErrStream(System.err);
  131. InputStream in = channel.getInputStream();
  132. channel.connect();
  134. byte[] tmp = new byte[1024];
  135. while (true) {
  136. while (in.available() > 0) {
  137. int i = in.read(tmp, 0, 1024);
  138. if (i < 0)
  139. break;
  140. System.out.print(new String(tmp, 0, i));
  141. }
  142. if (channel.isClosed()) {
  143. System.out.println(remark + "Mysql备份完毕!");
  144. System.out.println("exit-status: "
  145. + channel.getExitStatus());
  146. break;
  147. }
  148. try {
  149. Thread.sleep(1000);
  150. } catch (Exception ee) {
  151. }
  152. }
  153. channel.disconnect();
  154. sessionToBack.disconnect();
  155. sessionForBack.disconnect();
  156. } catch (Exception e) {
  157. System.out.println(e);
  158. }
  159. }
  160. }

人气教程排行

本站所有资源全部来源于网络，若本站发布的内容侵害到您的隐私或者利益，请联系我们删除！