Chinaunix首页 | 论坛 | 博客
  • 博客访问: 138730
  • 博文数量: 114
  • 博客积分: 0
  • 博客等级: 民兵
  • 技术积分: 1116
  • 用 户 组: 普通用户
  • 注册时间: 2015-11-09 09:49
文章分类

全部博文(114)

文章存档

2016年(74)

2015年(40)

我的朋友

分类: 服务器与存储

2015-12-17 10:22:24

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

主要的实现思路:

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

当您学会通过VPN连接Linux服务器后,如果只在内网环境,不使用VPN,就更简单了,此外不再详述。Jsch的example里也有介绍。

代码:使用Jsch透过VPN

  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.  
  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.  
  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.  
  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.  
  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.  
  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.  
  113.         try {  
  114.             JSch jschToBack = new JSch();  
  115.  
  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.  
  131.             byte[] tmp = new byte[1024];  
  132.             while (true) {  
  133.                 while (in.available() > 0) {  
  134.                     int i = in.read(tmp, 01024);  
  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.     }  

原文链接:


如果想深入体验LINUX系统的新手,也可以先下载一个方德Linux软件中心试用一下。
免费下载地址:

阅读(579) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~