配置HTTP触发器并使用WebSocket触发

步骤一：创建函数

1. 登录函数计算控制台，在左侧导航栏，单击服务及函数。
2. 在顶部菜单栏，选择地域，然后在服务列表页面，单击目标服务。
3. 在函数管理页面，单击创建函数。
4. 在创建函数页面，选择使用自定义运行时创建，设置相关参数，然后单击创建。
   需要设置的参数说明如下，其余参数保持默认值即可，更多参数说明，请参见创建函数。

   • 函数名称：设置您要创建的函数名称，例如WEBSOCKET-DEMO。
   • 请求处理程序类型：选择处理 HTTP 请求。
   • 运行环境：选择Node.js 14。

步骤二：编写并部署代码

1. 在函数详情页面，单击函数代码页签，在代码编辑器中编写代码。
   在控制台WebIDE的当前目录，将下面的代码复制到index.js文件中。代码示例如下：

   const WebSocket = require('ws');
   
   const WebSocketServer = WebSocket.Server;
   
   const wss = new WebSocketServer({
     host: "0.0.0.0",
     port: 9000,
   });
   
   wss.on('connection', function (ws, req) {
     console.log(`[SERVER] connection()`);
     ws.on('message', function (message) {
       ws.send(`${message}`, (err) => {
         if (err) {
           console.log(`[SERVER] error: ${err}`);
         }
       });
     })
   });

   说明 WebSocket Server监听的IP地址是0.0.0.0，不能是127.0.0.1或localhost。如果您没有配置自定义监听端口，默认使用9000端口。

   此时，WebIDE的目录结构如下图所示：
2. 在WebIDE的终端窗口，执行npm install ws命令来安装依赖。
   安装完成后，会自动生成文件package-lock.json，目录结构如下图所示：
3. 单击部署代码，将您的代码部署到函数计算中。

步骤三：测试函数

1. 在函数详情页面，单击触发器管理页签，查看并复制触发器的公网访问地址。
   
2. 使用Postman来测试函数的正确性。
   将该URL复制到Postman中，并将Scheme由HTTPS变更成WSS。更多信息，请参见Postman。

计费方式

使用WebSocket的计费方式与使用HTTP的计费方式完全一致，您可以将WebSocket看作连接时间较长的HTTP调用。

• 对于并发度设置为1的函数，计费时间从WebSocket连接建立开始到WebSocket连接断开结束。
• 对于并发度大于1的函数，实例的计费时间从收到第一个WebSocket连接建立开始，到最后一个WebSocket连接断开结束。一个实例中多个连接同时存在期间，不会被重复计费。
  如下图所示，一个函数的并发度设置为2，第一个请求到达的时间为T1，结束时间为T3，第二个请求到达时间为T2，结束时间为T4，计费时间为T4-T1，其中T2到T3这段时间只会被计费一次，不会被重复计费。

更多说明

请求超时

函数计算在执行超时时间上，并不会区分WebSocket请求和HTTP请求。如果您的WebSocket连接存活时间超过了您设置的执行超时时间，WebSocket连接会被强制关闭，您的客户端会收到1006状态码。

连接保活和超时重连

当您的WebSocket连接建立之后，除了在连接时长超过您设置的执行超时时间会断开连接之外，函数计算不会干涉您的任何逻辑。如果在存续期间，您的WebSocket连接在一段时间内没有数据传输，则该连接可能会被网络中的中间节点（比如NAT网关）关闭。这种情况下，您可能需要通过WebSocket协议提供的Ping、Pong帧来对连接进行保活或者验证WebSocket连接是否可用。

如果您的业务需要设置超过函数计算能够提供的最大请求超时时间，或者您的应用期望在运行期间保持逻辑上的连接稳定，您可以在客户端代码中加上超时重连机制。您可以借助Reconnecting-WebSocket的库或SocketIO库来实现该机制。

关于粘性会话（会话亲和性）

函数计算是无状态的，当函数的并发请求度较大的时候，函数计算无法保证来自同一客户端的多个请求会被同一个容器处理。您可能需要通过外部存储（Redis、Memcached、Kafka、数据库等）来维持WebSocket请求在多个容器实例之间的状态。

例如，对于聊天室应用，函数计算无法保证所有的用户同时连接到同一个函数实例上。所以用户的函数可以借助Redis的发布订阅功能来实现聊天室，用户加入一个聊天室的时候，会订阅（Sub）该聊天室所在的频道，当用户1发送信息的时候，函数收到该消息，将其发布（Pub）到Redis中聊天室所在的频道，因为在相同的聊天室的用户均已经订阅（Sub）了该聊天室的频道，所以该聊天室的所有用户都会收到用户1刚才发送的消息。

更多示例

常见问题

为什么WebSocket函数无法执行？

• 如果是您新创建的触发器，会有10s左右的缓存更新时间，请稍后再试。
• 请检查函数代码中的依赖包是否正确安装，更多信息，请参见为函数安装第三方依赖。
• 请检查函数监听的端口和IP地址是否正确。监听的IP地址可以是0.0.0.0，不能是127.0.0.1或localhost。如果您没有配置自定义监听端口，默认使用9000端口。

错误排查

WebSocket握手完成之后的错误，均为函数代码产生或引起的错误，您可以仔细检查您的代码，或者查看代码运行中产生的日志。更多信息，请参见查看调用日志。

更多信息

如需对创建的触发器进行修改或删除，具体操作，请参见触发器管理。