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

/A\xXlx0　　主要的实现思路：51Testing软件测试网6{CXN,I%ps&I;i

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

$t+h1L] bG'y0　　当您学会通过VPN连接Linux服务器后，如果只在内网环境，不使用VPN，就更简单了，此外不再详述。Jsch的example里也有介绍。51Testing软件测试网4dqJ Q#i];j

WRD(U.h5^;o$@i'z0　　代码：使用Jsch透过VPN51Testing软件测试网.~|x7Rt!N$o1U o

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