使用 firebase 函数和 express 连接到 socket.io 时出现问题

Question

我正在尝试利用 socket.io 与 firebase hosting/functions 的连接，但我运行遇到了一些问题。它开始是一个 CORS 问题（我确定仍然是问题）但现在我完全不知道出了什么问题，下面是我的 firebase.json、index.js（firebase 函数文件），甚至angular 初始化与服务器的连接的客户端文件。

firebase.json

{
  "hosting": {
    "public": "public",
    "ignore": [
      "firebase.json",
      "**/.*",
      "**/node_modules/**"
    ],
    "headers": [ 

      {
        "source" : "**",
        "headers" : [ {
          "key" : "Access-Control-Allow-Headers",
          "value" : "Origin"
        } ]
      },
      {
        "source" : "**",
        "headers" : [ {
          "key" : "Access-Control-Allow-Origin",
          "value" : "http://localhost:4200"
        } ]
      }
    ],
    "rewrites": [
      {
        "source": "**",
        "function": "app"
      }
    ]
  },
  "functions": {
    "predeploy": [
      "npm --prefix \"$RESOURCE_DIR\" run lint"
    ],
    "source": "functions"
  }
}

index.js

const functions = require('firebase-functions');
const express = require('express');
var app = express();

const http = require('http').Server(express);
const socketio = require('socket.io')(http);
const cors = require('cors');


app.use(cors({credentials: true, origin: '*:*'}));
app.get('/tester', (request, response) => {

    //response.header('Access-Control-Allow-Origin', '*');
    response.send('Hello!');

    socketio.on('connection', socket => {
        connections.push(socket);
        console.log('New client connected ('+connections.length+' connections).');
        //console.log(socket);
        socket.emit('port', 'LIVE SHIT');
    });
})

exports.app = functions.https.onRequest(app)

app.component.ts（用于连接的客户端组件）

import { Component } from '@angular/core';
import io from 'socket.io-client';

@Component({
  selector: 'app-root',
  templateUrl: './app.component.html',
  styleUrls: ['./app.component.scss']
})
export class AppComponent {
  title = 'multi-client';
  port: number = 0;
  socket: any;
  width: number = 100;
  updateVal: number = 5;
  constructor()
  {
    this.socket = io('http://localhost:5000/tester');

    this.socket.on('port', port => {
      this.port = port;
    })
  }

  updateWidth(val)
  {
    this.width += val;
  }
}

这是我遇到的错误。

我在 Whosebug 和其他各种网站上查看了一些帖子，它们都有类似的问题，但似乎没有任何效果。我确定我做错了，但我迷失了实现这一目标所缺少的东西。请帮忙！

Answer 1

Cloud Functions 适用于生命周期相对较短且结局明确的操作。您不能使用 Cloud Functions 来保持与客户端的连接打开。

原因是 Cloud Functions 会在它认为您已完成时关闭容器的资源。对于像您这样的 HTTP 函数，这意味着这些资源在您调用 response.send('Hello!');.

时消失了

那么是可能的是，一旦建立了这样的套接字连接，就将响应发送到客户端：

app.get('/tester', (request, response) => {


    socketio.on('connection', socket => {
        connections.push(socket);
        console.log('New client connected ('+connections.length+' connections).');
        //console.log(socket);
        socket.emit('port', 'LIVE SHIT');

        response.send('Hello!');
    });
})

但在那种情况下，连接也会在调用 response.send('Hello!'); 后关闭。虽然您可以不发送响应，但即使在那种情况下 connection/resources 也会在 9 分钟后关闭，因为这是 Cloud Function 可以运行.

这一切都可以追溯到我最初的声明，即 Cloud Functions 仅适用于具有明确结束时刻的短期操作。对于长运行ning 流程，请使用其他平台，例如 App Engine、Compute Engine 或您可以管理自己的流程的众多其他产品之一。

另见：

使用 firebase 函数和 express 连接到 socket.io 时出现问题

Problems connecting to socket.io using firebase functions and express

node.js

express

firebase

firebase-hosting

google-cloud-functions