Go调用openconnect启动VPN后如何在连接成功后执行证书检查函数

核心逻辑是在VPN启动后，确认连接建立成功再执行后续操作，不需要将VPN进程切后台，也不会阻塞主流程，以下是两种可直接落地的实现方案：

方案1：监控OpenConnect输出触发通知 #

OpenConnect连接成功时会输出固定格式的日志，你可以先手动运行一次连接命令，找到连接成功的标志性输出字符串（常见标记有Connected as 、Established DTLS connection、Tunnel enabled等，根据你的环境替换即可），通过扫描进程输出匹配到标记后发送通知信号。

修改后的ConnectVpn实现：

import (
    "bufio"
    "bytes"
    "io"
    "os"
    "os/exec"
    "strings"
)

func (c *Connection) ConnectVpn() (<-chan struct{}, error) {
    cmd := exec.Command(c.Command, c.Args...)

    var password bytes.Buffer
    password.WriteString(os.Getenv("PASSWORD"))
    cmd.Stdin = &password

    // 初始化连接成功通知通道，带1个缓冲避免发送阻塞
    connected := make(chan struct{}, 1)

    // 绑定输出管道，同时保留原有的终端日志输出能力
    stdout, err := cmd.StdoutPipe()
    if err != nil {
        close(connected)
        return connected, err
    }
    stderr, err := cmd.StderrPipe()
    if err != nil {
        close(connected)
        return connected, err
    }
    // 异步输出日志到终端，和原有体验一致
    go io.Copy(os.Stdout, stdout)
    go io.Copy(os.Stderr, stderr)

    // 异步扫描进程输出，匹配连接成功标记
    go func() {
        // 替换为你环境中OpenConnect连接成功的标志性输出
        const successMark = "Connected as "
        scanner := bufio.NewScanner(io.MultiReader(stdout, stderr))
        for scanner.Scan() {
            if strings.Contains(scanner.Text(), successMark) {
                connected <- struct{}{}
                close(connected)
                break
            }
        }
    }()

    // 启动VPN进程
    if err := cmd.Start(); err != nil {
        close(connected)
        return connected, err
    }

    // 异步等待进程退出，避免产生僵尸进程
    go func() { _ = cmd.Wait() }()

    return connected, nil
}

调用逻辑：

// 启动VPN
connectedChan, err := conn.ConnectVpn()
if err != nil {
    log.Fatalln("VPN进程启动失败:", err)
}

// 可选：添加超时机制避免无限等待
select {
case <-connectedChan:
    // 连接成功，继续执行后续逻辑
case <-time.After(30 * time.Second):
    log.Fatalln("VPN连接超时")
}

// 此时VPN已连接完成，可正常执行证书检查
days, err := domain.CheckCertificate()
if err != nil {
    log.Fatalln(err)
}

方案2：探测目标服务可用性触发通知 #

如果不想依赖OpenConnect的输出变化，可以直接定时探测你要访问的目标服务端口，连通即说明VPN连接生效，这种方案更通用，不受VPN客户端版本影响。

添加端口探测辅助函数：

import (
    "fmt"
    "net"
    "time"
)

// targetAddr格式为 域名:端口，比如 "your-cert-server.com:443"
func waitForTargetReady(targetAddr string, timeout time.Duration) error {
    deadline := time.Now().Add(timeout)
    for time.Now().Before(deadline) {
        conn, err := net.DialTimeout("tcp", targetAddr, 2*time.Second)
        if err == nil {
            _ = conn.Close()
            return nil
        }
        time.Sleep(1 * time.Second)
    }
    return fmt.Errorf("等待目标服务可达超时")
}

调用逻辑：

// 原有ConnectVpn不用修改，直接启动VPN
err := conn.ConnectVpn()
if err != nil {
    log.Fatalln("VPN进程启动失败:", err)
}

// 等待目标服务可达，超时时间设为30秒可按需调整
if err := waitForTargetReady("your-cert-server.com:443", 30*time.Second); err != nil {
    log.Fatalln(err)
}

// 此时可正常执行证书检查
days, err := domain.CheckCertificate()
if err != nil {
    log.Fatalln(err)
}

内容的提问来源于stack exchange，提问作者MrByte