package com.artisan;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;
import org.springframework.boot.web.server.WebServer;
import org.springframework.boot.web.servlet.ServletContextInitializer;
import org.springframework.boot.web.servlet.ServletContextInitializerBeans;
import org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext;
import org.springframework.boot.web.servlet.server.ServletWebServerFactory;
import org.springframework.context.ConfigurableApplicationContext;

import java.io.IOException;
import java.net.ServerSocket;
import java.util.Collections;

@SpringBootApplication()
public class BootMainApplication {
    public static void main(String[] args) {
        // 默認(rèn)端口設(shè)置
        int defaultPort = 8080;
        // 備選端口設(shè)置
        int alternativePort = 9090;
        // 檢查默認(rèn)端口是否已被占用
        boolean isPortOccupied = isPortInUse(defaultPort);

        // 動(dòng)態(tài)端口分配
        int portToUse = isPortOccupied ? alternativePort : defaultPort;
        // 創(chuàng)建Spring Boot應(yīng)用實(shí)例
        SpringApplication app = new SpringApplication(WebMainApplication2.class);
        // 設(shè)置端口配置
        app.setDefaultProperties(Collections.singletonMap("server.port", portToUse));
        // 運(yùn)行應(yīng)用并獲取上下文
        ConfigurableApplicationContext context = app.run(args);

        // 如果默認(rèn)端口被占用，則嘗試切換回默認(rèn)端口
        if (isPortOccupied) {
            switchToDefaultPort(context, defaultPort, portToUse);
        }
    }

    /**
     * 切換到默認(rèn)端口
     *
     * 當(dāng)默認(rèn)端口被其他進(jìn)程占用時(shí)，此方法嘗試釋放該端口，并啟動(dòng)一個(gè)新的Web服務(wù)器實(shí)例綁定到默認(rèn)端口
     * 同時(shí)，它會(huì)停止當(dāng)前的Web服務(wù)器實(shí)例
     *
     * @param context 當(dāng)前應(yīng)用上下文，用于訪問(wèn)Web服務(wù)器工廠和停止當(dāng)前Web服務(wù)器
     * @param defaultPort 默認(rèn)端口號(hào)，希望切換到的目標(biāo)端口
     * @param currentPort 當(dāng)前Web服務(wù)器正在使用的端口號(hào)
     */
    private static void switchToDefaultPort(ConfigurableApplicationContext context, int defaultPort, int currentPort) {
        try {
            // 釋放默認(rèn)端口
            terminateProcessUsingPort(defaultPort);

            // 等待端口釋放
            while (isPortInUse(defaultPort)) {
                Thread.sleep(100);
            }

            // 啟動(dòng)新容器綁定默認(rèn)端口
            ServletWebServerFactory webServerFactory = getWebServerFactory(context);
            ((TomcatServletWebServerFactory) webServerFactory).setPort(defaultPort);

            WebServer newServer = webServerFactory.getWebServer(getServletContextInitializers(context));
            newServer.start();

            // 停止當(dāng)前容器
            ((ServletWebServerApplicationContext) context).getWebServer().stop();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 檢查指定的端口是否正在使用
     *
     * @param port 要檢查的端口號(hào)
     * @return 如果端口正在使用，則返回true；否則返回false
     */
    private static boolean isPortInUse(int port) {
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            // 如果能夠成功創(chuàng)建ServerSocket實(shí)例，說(shuō)明端口可用，返回false
            return false;
        } catch (IOException e) {
            // 如果創(chuàng)建ServerSocket實(shí)例時(shí)拋出IOException，說(shuō)明端口已被占用，返回true
            return true;
        }
    }

    /**
     * 終止使用指定端口的進(jìn)程
     *
     * @param port 需要釋放的端口號(hào)
     * @throws IOException 如果執(zhí)行命令發(fā)生錯(cuò)誤
     * @throws InterruptedException 如果線程被中斷
     */
    private static void terminateProcessUsingPort(int port) throws IOException, InterruptedException {
        // 構(gòu)建終止使用指定端口的進(jìn)程的命令
        String command = String.format("lsof -i :%d | grep LISTEN | awk '{print $2}' | xargs kill -9", port);
        // 執(zhí)行命令并等待命令執(zhí)行完成
        Runtime.getRuntime().exec(new String[]{"sh", "-c", command}).waitFor();
    }

    /**
     * 獲取ServletContextInitializer實(shí)例
     * 該方法用于將Spring應(yīng)用上下文中的所有ServletContextInitializerBeans實(shí)例
     * 轉(zhuǎn)換為ServletContextInitializer接口的實(shí)現(xiàn)，以便在應(yīng)用啟動(dòng)時(shí)初始化ServletContext
     *
     * @param context Spring的應(yīng)用上下文，用于獲取BeanFactory
     * @return 返回一個(gè)實(shí)現(xiàn)了ServletContextInitializer接口的實(shí)例
     */
    private static ServletContextInitializer getServletContextInitializers(ConfigurableApplicationContext context) {
        // 使用ApplicationContext中的BeanFactory創(chuàng)建ServletContextInitializerBeans實(shí)例
        // 這里將ServletContextInitializerBeans作為ServletContextInitializer的實(shí)現(xiàn)類(lèi)返回
        // ServletContextInitializerBeans將會(huì)負(fù)責(zé)收集應(yīng)用上下文中所有ServletContextInitializer的實(shí)現(xiàn)
        // 并在應(yīng)用啟動(dòng)時(shí)依次調(diào)用它們的onStartup方法來(lái)初始化ServletContext
        return (ServletContextInitializer) new ServletContextInitializerBeans(context.getBeanFactory());
    }

    /**
     * 獲取Servlet Web服務(wù)器工廠
     *
     * @param context 可配置的應(yīng)用上下文，用于獲取Bean工廠
     * @return ServletWebServerFactory實(shí)例，用于配置和創(chuàng)建Web服務(wù)器
     */
    private static ServletWebServerFactory getWebServerFactory(ConfigurableApplicationContext context) {
        // 從應(yīng)用上下文中獲取Bean工廠，并從中獲取ServletWebServerFactory實(shí)例
        return context.getBeanFactory().getBean(ServletWebServerFactory.class);
    }
}

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController()
@RequestMapping("port/")
public class TestPortController {
    @GetMapping("test")
    public String test() {
        return "artisan-old";
    }
}