需要防止 GAS Web 应用实例发生冲突

Question

我正在使用 Google Apps 脚本为我的 Telegram 机器人创建一个网络应用程序。该网络应用程序由机器人通过网络挂钩调用。

我的机器人有一个内联键盘，您可以在下面的 GIF 1 中看到它的运行情况。轻按键盘按钮，您可以输入出现在屏幕上的代码。

我的问题是，当我更快地点击按钮时，对 Web 应用程序的回调查询会发生冲突，从而导致输入混乱。参见 GIF 2。

我一直在绞尽脑汁试图找出一种方法来防止网络应用程序实例发生冲突，但到目前为止我没有运气。

我在下面发布我的代码。请帮忙。

我的看法是，脚本的每个实例都需要更多时间才能完成，然后才能启动下一个实例。尽我所知，我已尝试使用 async/await 和 lockService。有人建议我尝试对查询进行排队，但遗憾的是无法使其正常工作。

var lock = LockService.getScriptLock();
    
function doPost(e){

      var contents = JSON.parse(e.postData.contents);
   
      var query_id = contents.callback_query.id;
        
      var mes_id = contents.callback_query.message.message_id;
        
      var userinput = contents.callback_query.data;
        
      var message_now = contents.callback_query.message.text;
      
      var inline_keyboard = contents.callback_query.message.reply_markup;  
      
  
      var message_upd = message_now + " " + userinput;
           
        var keydata = {
            method: "post",
            payload: {
              method: "editMessageText",
              chat_id: String(chat_id),
              message_id: mes_id,
              text: message_upd ,
              parse_mode: "HTML",
              reply_markup: JSON.stringify(inline_keyboard)
            }
          }
   
    lock.waitLock(10000);

    UrlFetchApp.fetch('https://api.telegram.org/bot' + token + '/', keydata); 
        
    UrlFetchApp.fetch(url + "/answerCallbackQuery?callback_query_id=" + query_id);
      
    lock.releaseLock();

    } 

Answer 1

问题：

我相信lock 确实有效。问题可能是电报机器人发送的回调查询。在你的第二个 gif 中，

在按2、3、4的时候，附加的消息是空的。因此，所有 4 个回调的 message.text 都将为空

var message_now = contents.callback_query.message.text; 

message_now 对于所有 4 条消息都是空的，所有 4 条 mesage_upd 都会不同：

var message_upd = message_now + " " + userinput;

即使您使用LockService 在服务器端对所有内容进行排队，如果电报提供的message_now 对于所有 4 条消息都是空的，那么排队对于创建这样的串联字符串也是无用的。

可能的解决方案：

• 队列回调应该在客户端完成。只有在收到第一个按钮按下的响应后，才应该激活第二个回调。我不确定电报是否提供如此精细的控制。但如果是这样，这是首选的解决方案。

• 使用缓存服务服务器端为特定用户的特定message.id 缓存最后一个message_now。将其保存到缓存服务 30 秒左右。如果在 30 秒后出现另一个具有相同 message_id 的回调，并且 message.text 为空，请改用缓存的消息。

  • key：某种类型的message_id 和user_id 组合
  • value：当前串联message_now

片段：

  let message_now = contents.callback_query.message.text;
  if (message_now === '') message_now = cache.get(String(mes_id)) || '';
  /*....*/
  cache.put(String(mes_id), String(message_upd), 30);

function doPost(e) {
  const lock = LockService.getScriptLock();
  lock.waitLock(10000);
  const cache = CacheService.getScriptCache();
  const contents = JSON.parse(e.postData.contents);
  const query_id = contents.callback_query.id;
  const mes_id = contents.callback_query.message.message_id;
  const userinput = contents.callback_query.data;
  let message_now = contents.callback_query.message.text;
  if (message_now === '') message_now = cache.get(String(mes_id)) || '';
  const inline_keyboard = contents.callback_query.message.reply_markup;
  const message_upd = message_now + ' ' + userinput;
  const keydata = {
    method: 'post',
    payload: {
      method: 'editMessageText',
      chat_id: String(chat_id),
      message_id: mes_id,
      text: message_upd,
      parse_mode: 'HTML',
      reply_markup: JSON.stringify(inline_keyboard),
    },
  };
  UrlFetchApp.fetch('https://api.telegram.org/bot' + token + '/', keydata);
  UrlFetchApp.fetch(url + '/answerCallbackQuery?callback_query_id=' + query_id);
  cache.put(String(mes_id), String(message_upd), 30);
  lock.releaseLock();
}

参考资料：

• Cache § put