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

前东家是一家游戏公司，老板很好，当时工作也留下了很多自己原创的管理脚本。现在分享一下在办公环境使用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 try {
77. try {
78. backUpMysql(privateIpaddress[n], backMysqlShellPath[n],remark[n]);
79. } catch (IOException e) {
80. // TODO Auto-generated catch block
81. e.printStackTrace();
82. }
83. } catch (JSchException e) {
84. // TODO Auto-generated catch block
85. e.printStackTrace();
86. }
87. }
89. }
90. /**
91. * 备份mysql数据库的方法
92. * @param privateip
93. * @param backMysqlShellPath
94. * @throws JSchException
95. * @throws IOException
96. */
97. public static void backUpMysql(String privateip, String backMysqlShellPath, String remark)
98. throws JSchException, IOException {
99. // 登录到服务器
100. int rport;
101. JSch jsch = new JSch();
102. String host = "dl.dengdie.com"; //此处为VPN服务器地址
103. String user = "admin"; //VPN用户名
104. Session sessionForBack = jsch.getSession(user, host, 22);
105. rport = 22;
106. sessionForBack.setPassword("&*&&&&lalaflls"); //VPN密码
107. java.util.Properties config = new java.util.Properties();
108. config.put("StrictHostKeyChecking", "no");
109. sessionForBack.setConfig(config);
110. sessionForBack.connect();//登录到VPN服务器
112. // 建立与游戏服务器的ssh转发连接:即将游戏服务器的22号ssh端口映射的本地办公电脑的53238端口。
113. sessionForBack.setPortForwardingL(53238, privateip, rport);
115. try {
116. JSch jschToBack = new JSch();
118. Session sessionToBack = jschToBack.getSession(user, "127.0.0.1",
119. 53238); //连接本地办公电脑的53238端口，就相当于连接了游戏服务器的22号端口。
120. sessionToBack.setPassword("&*&&&&lalaflls");
121. sessionToBack.setConfig(config);
122. sessionToBack.connect();
123. //backMysqlShellPath实际上是游戏服务器上备份Mysql数据库的一个脚本，此脚本请您自行实现，网上很多实例。
124. String command = backMysqlShellPath;
125. //打开执行命令的隧道，并执行命令。
126. Channel channel = sessionToBack.openChannel("exec");
127. ((ChannelExec) channel).setCommand(command);
128. channel.setInputStream(null);
129. ((ChannelExec) channel).setErrStream(System.err);
130. InputStream in = channel.getInputStream();
131. channel.connect();
133. byte[] tmp = new byte[1024];
134. while (true) {
135. while (in.available() > 0) {
136. int i = in.read(tmp, 0, 1024);
137. if (i break;
138. System.out.print(new String(tmp, 0, i));
139. }
140. if (channel.isClosed()) {
141. System.out.println(remark + "Mysql备份完毕!");
142. System.out.println("exit-status: "
143. + channel.getExitStatus());
144. break;
145. }
146. try {
147. Thread.sleep(1000);
148. } catch (Exception ee) {
149. }
150. }
151. channel.disconnect();
152. sessionToBack.disconnect();
153. sessionForBack.disconnect();
154. } catch (Exception e) {
155. System.out.println(e);
156. }
157. }
158. }

复制代码