ReactPHP - 使用Laravel和Timers

问题描述 投票：1回答：1

所以这是一个非常有趣的问题。我试图弄清楚如何将websocket客户端集成到Laravel 5.5中以允许通过我的应用程序和Discord Gateway之间的websocket进行通信。我花了一个新的Laravel应用程序，需要这个library，通过作曲家，它建立在Ratchet PHP之上。

我试图在我使用的bot之后构建一个PHP Discord Bot，但在它使用的主要dependency之后也被放弃了。

我已经想出如何添加一个计时器，以便像这样发送heartbeats

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

这非常有效，直到我的应用程序收到Discord的活动。然后同步丢失，而不是从hello event确定的间隔发送心跳，我的应用程序开始每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());
        });
    }

});

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

另外，有人对我这样做有什么建议或批评吗？我找不到任何关于如何做到这一点的可靠文档，所以我就像我要去的那样拼凑它。

laravel websocket reactphp
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);
        });
    }
}

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

接下来，我重新构建了is_ready if语句，如下所示：

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链接。

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.