一键所有VPS升级内核.py

import time
import paramiko

# 定义服务器列表，包括服务器名称、IP地址、端口号、用户名和密码
servers = [
    {"name": "美国", "hostname": "1.1.1.1", "port": 22, "username": "root", "password": "123456"},   
    {"name": "不丹", "hostname": "1.1.1.1", "port": 22, "username": "root", "password": "123456"},   
    {"name": "毛里求斯", "hostname": "1.1.1.1", "port": 22, "username": "root", "password": "123456"},   
    # 添加更多服务器
]


# 定义更新操作
def update_server(name, hostname, port, username, password):
    try:

        # 连接服务器
        client = paramiko.SSHClient()
        client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        client.connect(hostname, port=port, username=username, password=password)

        # 设置 DEBIAN_FRONTEND 环境变量
        print(f"{name} 开始更新")
        stdin, stdout, stderr = client.exec_command('apt update -y && apt install -y wget sudo')
 
        while not stdout.channel.exit_status_ready():
            if stdout.channel.recv_ready():
                print(stdout.channel.recv(1024).decode(), end="")

        # 检查更新状态
        if stderr.channel.recv_exit_status() == 0:
            print(f"更新成功")
        else:
            print(f"更新失败")

        print()        

        print(f"{name} 下载内核")
        stdin, stdout, stderr = client.exec_command('wget --no-check-certificate -O tcpx.sh https://raw.githubusercontent.com/ylx2016/Linux-NetSpeed/master/tcpx.sh')

        while not stdout.channel.exit_status_ready():
            if stdout.channel.recv_ready():
                print(stdout.channel.recv(4096).decode(), end="")

        # 检查更新状态
        if stderr.channel.recv_exit_status() == 0:
            print(f"下载成功")
        else:
            print(f"下载失败")


        print()  

        print(f"{name} 赋予权限")                                                    
        stdin, stdout, stderr = client.exec_command('chmod +x tcpx.sh')

        while not stdout.channel.exit_status_ready():
            if stdout.channel.recv_ready():
                print(stdout.channel.recv(4096).decode(), end="")

        # 检查更新状态
        if stderr.channel.recv_exit_status() == 0:
            print(f"赋予权限成功")
        else:
            print(f"赋予权限失败")

        print()  

        print(f"{name} 升级内核")                                                    
        stdin, stdout, stderr = client.exec_command('./tcpx.sh')

        time.sleep(5)

        stdin.write('1\n')
        stdin.flush()
 
        while not stdout.channel.exit_status_ready():
            if stdout.channel.recv_ready():
                print(stdout.channel.recv(4096).decode(), end="")

        # 检查更新状态
        if stderr.channel.recv_exit_status() == 0:
            print(f"升级成功")
        else:
            print(f"升级失败")

        time.sleep(5)
        print()  

        # 检查更新状态
        print(f"{name} 重启服务器")        
        stdin, stdout, stderr = client.exec_command("reboot")
        print()  
        print()  



        # 关闭 SSH 连接
        client.close()

        print()        
    
    except Exception as e:
        print(f"连接 {name} 失败 \n")

# 遍历服务器列表，逐一更新
for server in servers:
    name = server["name"]
    hostname = server["hostname"]
    port = server["port"]
    username = server["username"]
    password = server["password"]
    update_server(name, hostname, port, username, password)

# 等待用户按下任意键后关闭窗口
input("按任意键关闭窗口...")