如何检测Google Compute Engine VM已就绪可接收Firebase函数的HTTP请求

问题原因 #

GCE实例启动操作的DONE状态仅代表Google Cloud平台完成了实例资源分配、虚拟化层启动流程，不代表实例内部的操作系统、你部署的HTTP应用服务已经完成初始化并可以接收请求。你遇到的三个错误正好对应了启动的三个阶段：

• 立即请求超时：实例网络还未完成配置，流量无法到达实例
• 30秒后连接被拒绝：实例网络已通，但HTTP服务进程还未启动完成，端口未开放监听
• 60秒后正常：HTTP服务完成启动，端口正常监听

解决方案 #

可以直接在Firebase函数内增加HTTP端点轮询检测逻辑，确认服务就绪后再返回结果给前端，实现代码如下：

首先安装请求依赖：
npm install axios

修改后的完整函数代码：

const functions = require('firebase-functions');
const compute = require('@google-cloud/compute');
const axios = require('axios');

// 配置参数，替换为你的实际值
const VM_HTTP_ENDPOINT = 'http://你的VM公网IP/health'; // 建议专门做一个轻量健康检查接口，服务启动成功后返回200即可
const POLL_INTERVAL = 3000; // 每次轮询间隔3秒
const MAX_RETRIES = 30; // 最多重试30次，最长等待90秒，可根据你的服务启动时间调整

// 原有启动实例函数
async function startComputeEngine() {
    const instancesClient = new compute.InstancesClient();
    const [response] = await instancesClient.start({
        project: projectId,
        zone,
        instance: instanceName,
    });
    let operation = response.latestResponse;
    const operationsClient = new compute.ZoneOperationsClient();

    while (operation.status !== 'DONE') {
        operation = await operationsClient.wait({
            operation: operation.name,
            project: projectId,
            zone: operation.zone.split('/').pop(),
        });
        if (Array.isArray(operation)) {
            operation = operation[0]
        }
    }
    return "Success: Instance started"
}

// 新增端点就绪检测函数
async function waitForEndpointReady() {
    let retries = 0;
    while (retries < MAX_RETRIES) {
        try {
            // 发起GET请求，超时设置为2秒避免长时间等待
            await axios.get(VM_HTTP_ENDPOINT, { timeout: 2000 });
            return true;
        } catch (err) {
            // 连接超时、连接被拒绝都属于未就绪状态，继续重试
            if (err.code === 'ECONNREFUSED' || err.code === 'ECONNABORTED' || err.code === 'ETIMEDOUT') {
                retries++;
                // 等待指定间隔后再次重试
                await new Promise(resolve => setTimeout(resolve, POLL_INTERVAL));
                continue;
            }
            // 其他错误（比如权限错误、路径错误）直接抛出
            throw new Error(`Endpoint check failed with unexpected error: ${err.message}`);
        }
    }
    throw new Error('Endpoint did not become ready within the maximum wait time');
}

// 最终对外暴露的Firebase函数
exports.startVmAndWaitForReady = functions.https.onCall(async (data, context) => {
    try {
        await startComputeEngine();
        await waitForEndpointReady();
        return { success: true, message: 'Instance and service are ready' };
    } catch (err) {
        return { success: false, error: err.message };
    }
});

优化建议 #

• 建议在VM的HTTP服务中新增专门的/health健康检查接口，不需要业务逻辑，只要服务启动完成就返回200状态码，比直接请求业务接口更稳定
• 确保VPC防火墙规则已经放通Firebase函数的出口IP到VM对应HTTP端口的访问权限
• 如果你的服务启动时间波动较大，可以根据实际情况调整MAX_RETRIES和POLL_INTERVAL参数

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