2

所以这是我遇到的一个非常有趣的问题。我一心想弄清楚如何将 websocket 客户端集成到 Laravel 5.5 中，以允许在我的应用程序和Discord Gateway之间通过 websocket 进行通信。我通过 Composer 构建了一个新的 Laravel 应用程序并需要这个库，它构建在Ratchet PHP之上。

我正在尝试在我使用的这个机器人之后构建一个 PHP Discord Bot，但在它使用的主要依赖项也被终止后被放弃。

我已经想出了如何添加一个计时器来发送这样的心跳

$app->addTimer(x, function ($thing) use ($etc) {});

在我的应用程序收到来自 Discord 的事件之前，这非常有效。然后同步丢失，而不是以hello 事件的确定间隔发送心跳，我的应用程序开始每 3-9 秒发送一次，有时一次发送 2 或 3 个。这是出于调试原因从控制台输出的一些输出，但它显示了我的问题：

"Sending Heartbeat - 41 - 2017-12-31 05:26:42"
"Sending Heartbeat - 41 - 2017-12-31 05:26:42"
Illuminate\Support\Collection {#679
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
Illuminate\Support\Collection {#679
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:26:51"
Illuminate\Support\Collection {#602
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:26:55"
Illuminate\Support\Collection {#695
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:26:56"
Illuminate\Support\Collection {#688
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
Illuminate\Support\Collection {#688
  #items: array:4 [
    "t" => "TYPING_START"
    "s" => 7
    "op" => 0
    "d" => array:3 [
      "user_id" => "277968564827324416"
      "timestamp" => 1514698064
      "channel_id" => "394991263344230411"
    ]
  ]
}
Illuminate\Support\Collection {#688
  #items: array:4 [
    "t" => "MESSAGE_CREATE"
    "s" => 8
    "op" => 0
    "d" => array:15 [
      "type" => 0
      "tts" => false
      "timestamp" => "2017-12-31T05:27:47.057000+00:00"
      "pinned" => false
      "nonce" => "396897209817235456"
      "mentions" => []
      "mention_roles" => []
      "mention_everyone" => false
      "id" => "396897202448105494"
      "embeds" => []
      "edited_timestamp" => null
      "content" => "!about"
      "channel_id" => "394991263344230411"
      "author" => array:4 [
        "username" => "David Davaham"
        "id" => "277968564827324416"
        "discriminator" => "2471"
        "avatar" => "0c27e1bed49121e8aaf3f284d6b74e55"
      ]
      "attachments" => []
    ]
  ]
}
Illuminate\Support\Collection {#688
  #items: array:4 [
    "t" => "MESSAGE_CREATE"
    "s" => 9
    "op" => 0
    "d" => array:15 [
      "type" => 0
      "tts" => false
      "timestamp" => "2017-12-31T05:27:49.382000+00:00"
      "pinned" => false
      "nonce" => null
      "mentions" => array:1 [
        0 => array:4 [
          "username" => "David Davaham"
          "id" => "277968564827324416"
          "discriminator" => "2471"
          "avatar" => "0c27e1bed49121e8aaf3f284d6b74e55"
        ]
      ]
      "mention_roles" => []
      "mention_everyone" => false
      "id" => "396897212199862276"
      "embeds" => []
      "edited_timestamp" => null
      "content" => "<@!277968564827324416> Unfortunately That is not a command I recognize. Please try again. Reply with `!help` for a list of commands"
      "channel_id" => "394991263344230411"
      "author" => array:5 [
        "username" => "Claire Underwood (Dev)"
        "id" => "394988052360986635"
        "discriminator" => "8397"
        "bot" => true
        "avatar" => null
      ]
      "attachments" => []
    ]
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:27:12"
Illuminate\Support\Collection {#616
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:27:23"
"Sending Heartbeat - 41 - 2017-12-31 05:27:23"
Illuminate\Support\Collection {#622
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
Illuminate\Support\Collection {#622
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:27:32"
Illuminate\Support\Collection {#652
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:27:36"
Illuminate\Support\Collection {#667
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:27:37"
Illuminate\Support\Collection {#661
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:27:46"
Illuminate\Support\Collection {#663
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:27:49"
Illuminate\Support\Collection {#660
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:27:51"
Illuminate\Support\Collection {#656
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:27:53"
Illuminate\Support\Collection {#698
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:28:04"
"Sending Heartbeat - 41 - 2017-12-31 05:28:04"
Illuminate\Support\Collection {#701
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
Illuminate\Support\Collection {#701
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:28:13"
Illuminate\Support\Collection {#706
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:28:17"
Illuminate\Support\Collection {#707
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41 - 2017-12-31 05:28:18"
Illuminate\Support\Collection {#709
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}

这是代码：

$conn->on('message', function(MessageInterface $msg) use ($conn, $socket, $loop) {
    $message = collect(json_decode($msg, true));
    dump($message);
    if ($message->has('s') && $message->get('s') !== null) {
        $this->seq = $message->get('s');
    }
    if (!$this->is_ready) {
        if (!$message->has('op')) {
            $conn->close();
        }
        if ($message->get('op') == 0) {
            if ($message->get('t') === "READY" || $message->get('t') === "GUILD_CREATE") {
                $this->is_ready = true;
                $this->seq = $message->get('s');
            }
        }
        if ($message->get('op') == 10) {
            $this->connOpened = Carbon::now();
            $this->heartbeat = (int)floor($message->get('d')['heartbeat_interval'] / 1000);
            $socket->sendIdentify();
            sleep(1);
        }
        if ($message->get('op') == 11) {
            $now = Carbon::now()->timestamp;
            if (!$this->heartbeatACK) {
                $this->heartbeatACK = true;
            }
        }
    }
    if ($this->is_ready) {
        if ($message->get('op') == 0) {
            if ($message->get('t') === "MESSAGE_CREATE") {
                $trigger = config('discord.message.trigger');
                $data = $message->get('d');
                $msgContent = $data['content'];
                if (starts_with($msgContent, $trigger)) {
                    ProcessMessage::dispatch($data);
                }
            }
        }
        $now = Carbon::now();
        $loop->addTimer($this->heartbeat, function ($x) use ($now, $conn, $socket) {
            dump("Sending Heartbeat - " . $this->heartbeat . " - " .$now->toDateTimeString());
            $payload = collect([
                'op' => 1,
                'd' => (int)$this->seq,
            ]);
            $conn->send($payload->toJson());
        });
    }

});

有没有人知道可以更好地管理心跳，或者这只是我需要忍受的事情？

另外，有人对我的做法有什么建议或批评吗？我找不到任何关于如何执行此操作的可靠文档，所以我在进行过程中将其拼凑起来。

4

1 回答 1

0

所以这已经解决了。这是我发现的：

使用概述的代码，当执行以下代码块时：

if (!$this->is_ready) {
    ...
    if ($message->get('op') == 0) {
        if ($message->get('t') === "READY" || $message->get('t') === "GUILD_CREATE") {
            $this->is_ready = true;
            $this->seq = $message->get('s');
        }
    }
    ...
}

紧随其后的是这个片段，因为$this->is_ready它被设置为true，它将导致添加两个计时器。除此之外，因为我有这样的代码is_ready：

if ($this->is_ready) {
     if ($message->get('op') == 0) {
         if ($message->get('t') === "MESSAGE_CREATE") {
             $trigger = config('discord.message.trigger');
             $data = $message->get('d');
             $msgContent = $data['content'];
             if (starts_with($msgContent, $trigger)) {
                 ProcessMessage::dispatch($data);
             }
         }
     }
     $now = Carbon::now();
     $loop->addTimer($this->heartbeat, function ($x) use ($now, $conn, $socket) {
         dump("Sending Heartbeat - " . $this->heartbeat . " - " .$now->toDateTimeString());
         $payload = collect([
             'op' => 1,
             'd' => (int)$this->seq,
         ]);
         $conn->send($payload->toJson());
     });
 }

每次我收到一个新事件时，都会安排另一个计时器，导致计时器堆积起来，并在这些计时器到期时发送心跳。这导致计时器最终每秒发送多次，如果我愿意这样的话。以下是我所做的更改：

我在这里的第一个块中添加了一个计时器，如下所示：

if ($message->get('op') == 0) {
    if ($message->get('t') === "READY" || $message->get('t') === "GUILD_CREATE") {
        $this->is_ready = true;
        $loop->addTimer(20, function ($x) use ($conn,$loop) {
            dump("Sending Heartbeat - " . $this->heartbeat . " - " .Carbon::now()->toDateTimeString());
            $payload = collect([
                'op' => 1,
                'd' => (int)$this->seq,
            ]);
            $conn->send($payload->toJson());
            $loop->cancelTimer($x);
        });
    }
}

这会导致循环停止处理此计时器，但在底部，我在发送心跳后取消计时器。我不确定这是否重要，因为它只是 atimer而不是 a periodicTimer，但我认为这不会造成伤害。

接下来，我像这样重组了is_readyif 语句：

if ($this->is_ready) {
    if ($message->get('op') == 0) {
        if ($message->get('t') === "MESSAGE_CREATE") {
            $trigger = config('discord.message.trigger');
            $data = $message->get('d');
            $msgContent = $data['content'];
            if (starts_with($msgContent, $trigger)) {
                ProcessMessage::dispatch($data);
            }
        }
    } else {
        $now = Carbon::now();
        $loop->addTimer(20, function ($x) use ($conn,$loop) {
            dump("Sending Heartbeat - " . $this->heartbeat . " - " .Carbon::now()->toDateTimeString());
            $payload = collect([
                'op' => 1,
                'd' => (int)$this->seq,
            ]);
            $conn->send($payload->toJson());
            $loop->cancelTimer($x);
        });
    }
}

op请注意，如果代码不等于 0 ，我只会安排一个计时器。我依赖于一个事实，即前一个heartbeat已被安排并将运行。这几乎可以保证，只要在服务器启动时执行第一个。

这是到目前为止控制台的输出，它已经使用这个配置运行了大约五到十分钟，没有双心跳或任何东西。

"Sending Heartbeat - 41.25 - 2017-12-31 08:41:18"
Illuminate\Support\Collection {#702
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41.25 - 2017-12-31 08:41:38"
Illuminate\Support\Collection {#704
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41.25 - 2017-12-31 08:41:58"
Illuminate\Support\Collection {#706
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41.25 - 2017-12-31 08:42:18"
Illuminate\Support\Collection {#708
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41.25 - 2017-12-31 08:42:39"
Illuminate\Support\Collection {#710
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
Illuminate\Support\Collection {#712
  #items: array:4 [
    "t" => "PRESENCE_UPDATE"
    "s" => 7
    "op" => 0
    "d" => array:6 [
      "user" => array:1 [
        "id" => "277968564827324416"
      ]
      "status" => "idle"
      "roles" => []
      "nick" => null
      "guild_id" => "394991263344230409"
      "game" => null
    ]
  ]
}
"Sending Heartbeat - 41.25 - 2017-12-31 08:42:59"
Illuminate\Support\Collection {#712
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}
"Sending Heartbeat - 41.25 - 2017-12-31 08:43:19"
Illuminate\Support\Collection {#717
  #items: array:4 [
    "t" => null
    "s" => null
    "op" => 11
    "d" => null
  ]
}

如果您有任何问题，请随时与我联系。如果您想查看，此代码最终将提交到我的 Github 上的公共存储库。目前，回购是私有的。检查我的个人资料以获取指向我的 GitHub 的链接。

于 2017-12-31T08:44:45.553 回答