// +---------------------------------------------------------------------- declare (strict_types = 1); namespace addon\wxchat\worker\handle; use addon\wxchat\worker\enum\MsgFrame; use addon\wxchat\worker\Message; use GatewayWorker\Lib\Gateway; /** * Heartbeat 类 * * @author ywxapp */ class Heartbeat { public static function handle($client_id, $header, $payload) { if ($header->type === MsgFrame::PONG->value) { return; } $newMessage = new Message(); $newMessage->header->type = MsgFrame::PONG->value; echo "Received PING newMessage: " . json_encode($newMessage) . ", responding with PONG\n"; Gateway::sendToClient($client_id, json_encode($newMessage)); } }