python 自动化部署SpringBoot到远程linux系统

import os
import datetime
from paramiko import SFTPClient, Transport, SSHClient, AutoAddPolicy
from sshtunnel import SSHTunnelForwarder
 
 
# 清理
def mvn_clean(project_path: str) -> str:
    pos_command = f'{project_path[:2]} & cd {project_path}'
    result = os.popen(f'{pos_command} & mvn clean')
    return result.read()
 
 
# 打包
def mvn_package(project_path: str) -> str:
    pos_command = f'{project_path[:2]} & cd {project_path}'
    result = os.popen(f'{pos_command} & mvn package -f pom.xml')
    return result.read()
 
 
# 连接SSH跳板机
def login_ssh_tunnel() -> SSHTunnelForwarder:
    server = SSHTunnelForwarder(
        ('123.157.139.150', 12307),  # 跳板机IP、端口
        ssh_username='goodluck',  # 跳板机 用户名
        ssh_password='CIIH@2020@dev',  # 跳板机 密码
        remote_bind_address=('192.168.1.76', 7021),  # 目标 IP、端口号
    )
    return server
 
 
# 连接目标服务器-sftp
def login_linux_ftp(server: SSHTunnelForwarder):
    transport = Transport(('localhost', server.local_bind_port))
    transport.banner_timeout = 60
    transport.connect(username='root', password='ADMIN@ciih')
    sftp = SFTPClient.from_transport(transport)
    #   上传文件：sftp.put(local_path, remote_path)
    #   下载文件  sftp.get(remote_path, local_path)
    #   列出目录及文件    sftp.listdir(remote_path)
    return sftp
 
 
# 连接目标服务器-shell
def login_linux_shell(server: SSHTunnelForwarder):
    ssh_client = SSHClient()
    ssh_client.set_missing_host_key_policy(AutoAddPolicy())
    ssh_client.connect(hostname='127.0.0.1', port=server.local_bind_port, username='root', password="ADMIN@ciih")
 
    #   执行命令：stdin, stdout, stderr = ssh_client.exec_command("cd /home/webapps/;ls")
    #   stdout.read()
 
    return ssh_client
 
 
# 创建多级文件（不含文件）
def create_dir(file_path):
    if os.path.exists(file_path) is False:
        os.makedirs(file_path)
 
 
# 修改部分文件：比如环境参数
def edit_some_file():
    # 将海康SDK设置成linux
    HCNetSDK_path = 'D:/workspaceweb/workshop-java/src/main/java/com/ciih/workshop/utils/hk/HCNetSDK.java'
    HCNetSDK_content: str = ''
    with open(HCNetSDK_path, "r", encoding="utf-8") as f1:
        for line in f1:
            if 'boolean isLinux = false;' in line:
                line = line.replace('boolean isLinux = false;', 'boolean isLinux = true;')
            HCNetSDK_content += line
 
    with open(HCNetSDK_path, "w", encoding="utf-8") as f2:
        f2.write(HCNetSDK_content)
    # 激活test配置文件
    application_path = 'D:/workspaceweb/workshop-java/src/main/resources/application.yml'
    application_content: str = ''
    with open(application_path, "r", encoding="utf-8") as f1:
        for line in f1:
            if 'active: pro' in line:
                line = line.replace('active: pro', 'active: test')
            application_content += line
 
    with open(application_path, "w", encoding="utf-8") as f2:
        f2.write(application_content)
 
 
if __name__ == '__main__':
    # 修改部分文件
    edit_some_file()
 
    # 清理
    clean: str = mvn_clean(project_path='D:/workspaceweb/workshop-java')
    print('清理')
 
    # 打包
    package: str = mvn_package(project_path='D:/workspaceweb/workshop-java')
    print('打包')
 
    # 备份数据库 TODO
    print('备库')
    # 登录跳板机
    tunnel: SSHTunnelForwarder = login_ssh_tunnel()
    tunnel.start()
 
    # 登录服务器-sftp
    ftp: SFTPClient = login_linux_ftp(tunnel)
 
    # 备份旧JAR包
    back_path = 'E:/DevOps/test/' + datetime.datetime.now().strftime('%Y-%m-%d-%Hh%Mm%Ss')
    create_dir(back_path)
    ftp.get('/home/webapps/workshop-0.0.1-SNAPSHOT.jar', back_path + '/workshop-0.0.1-SNAPSHOT.jar')
 
    # 上传新JAR包
    ftp.put('D:/workspaceweb/workshop-java/target/workshop-0.0.1-SNAPSHOT.jar',
            '/home/webapps/workshop-0.0.1-SNAPSHOT.jar')
 
    # 登录服务器-shell
    shell: SSHClient = login_linux_shell(tunnel)
    # 重启脚本
    command = shell.exec_command("kill -9 `netstat -nlp | grep :8088 | awk '{print $7}' | awk -F'/' '{ print $1 }'`")
    print('关闭服务')
    stdin, stdout, stderr = shell.exec_command(
        'nohup java -Dfile.encoding=utf-8 -jar -Duser.timezone=GMT+08 /home/webapps/workshop-0.0.1-SNAPSHOT.jar > /home/webapps/nohup.out 2>&1 &')
    print('服务启动中...')
 
    # 关闭连接
    ftp.close()
    shell.close()
    tunnel.stop()