开发者社区云原生 Serverless 正文

EMSA云函数如何多次回复一个请求

我把应用研发平台EMAS中的云函数用于微信公众号消息的自动回复，微信有服务器有以下要求：

【微信服务器在五秒内收不到响应会断掉连接，并且重新发起请求，总共重试三次。假如服务器无法保证在五秒内处理并回复，可以直接回复空串，微信服务器不会对此作任何处理，并且不会发起重试。详情请见“发送消息-被动回复消息”。】

但是云函数在一次return后就会结束，请问使用云函数怎样才能做到多次向微信服务器回复空串？

展开

收起

zeroydw 2023-12-11 10:32:07 64 版权

阿里云 AI 助理回答

要实现微信公众号消息的自动回复功能，并满足微信服务器的要求（在5秒内返回响应，否则重试三次），可以结合云函数和HTTP触发功能来完成。以下是详细的解决方案：

1. 问题分析

微信服务器要求在5秒内返回响应，否则会断开连接并重试三次。如果无法在5秒内处理完成，可以直接返回空字符串以避免重试。然而，云函数在一次return后即结束执行，无法直接支持多次向微信服务器发送响应。

为了解决这一问题，可以通过以下方式实现： - 首次快速响应：在云函数中立即返回空字符串，确保微信服务器不会重试。 - 异步处理逻辑：将实际的消息处理逻辑放到异步任务中执行，避免阻塞云函数的响应时间。

2. 解决方案

步骤一：开启云函数的HTTP触发功能

为了使云函数能够接收来自微信服务器的请求，需要开启云函数的HTTP触发功能： 1. 登录EMAS管理控制台。 2. 在顶部导航栏选择平台服务，左侧导航栏选择EMAS Serverless > 云函数。 3. 找到目标云函数，单击函数名称进入详情页。 4. 在触发页签中，开启HTTP路径触发功能，并配置触发路径（如/wechat/callback）。 5. 确保HTTP触发功能的默认域名或自定义域名已正确配置。

步骤二：编写云函数代码

在云函数中实现以下逻辑： 1. 快速响应：接收到微信服务器的请求后，立即返回空字符串。 2. 异步处理：将消息处理逻辑放入异步任务中执行。

示例代码如下：

module.exports = async (ctx) => {
  const { body, httpMethod } = ctx.args;

  // 快速响应：直接返回空字符串
  if (httpMethod === 'POST') {
    // 异步处理逻辑
    processMessageAsync(body);
    return ''; // 返回空字符串，避免微信服务器重试
  }

  // 非POST请求直接返回错误
  return { error: 'Invalid request method' };
};

// 异步处理消息的函数
async function processMessageAsync(messageBody) {
  try {
    // 模拟耗时操作（例如解析消息、调用其他服务等）
    console.log('Processing message:', messageBody);
    await new Promise(resolve => setTimeout(resolve, 5000)); // 模拟5秒延迟

    // 实际业务逻辑（例如回复用户消息）
    console.log('Message processed successfully');
  } catch (error) {
    console.error('Error processing message:', error);
  }
}

步骤三：部署云函数

将上述代码打包为.zip文件，确保包含index.js文件。
在EMAS管理控制台中上传代码包并完成部署。

步骤四：配置微信服务器回调URL

在微信公众平台中，将回调URL设置为云函数的HTTP触发地址，格式如下：
```
https://${DefaultEndpoint}${HttpTriggerPath}
```
其中${DefaultEndpoint}为云函数的默认域名，${HttpTriggerPath}为配置的触发路径。
确保回调URL已通过微信服务器的验证。