Avec le développement rapide d'Internet, les services de journalisation sont devenus un module essentiel pour toute application Web à grande échelle. Afin de faciliter divers besoins tels que le dépannage des erreurs et la surveillance des performances, cet article explique comment utiliser le framework ThinkPHP6 pour effectuer des opérations de journalisation asynchrone.

1. Qu'est-ce que la journalisation

Dans le domaine de l'informatique, la journalisation fait référence à l'enregistrement d'événements et d'informations qui se produisent dans un système informatique. Généralement, ces enregistrements sont stockés dans des fichiers ou des bases de données. La journalisation permet de comprendre l'état de fonctionnement du système, de découvrir et de résoudre les problèmes en temps opportun et d'améliorer ainsi la fiabilité et la stabilité du système.

Dans les applications Web, la journalisation peut aider les développeurs à mieux comprendre les problèmes et les erreurs rencontrés par le système. Grace à la journalisation, les développeurs peuvent clairement comprendre le comportement de l'application ainsi que l'endroit et le moment où les erreurs se produisent.

2. Journalisation asynchrone ThinkPHP6

Dans le processus de développement d'applications, la journalisation est un module essentiel. De plus, la journalisation est souvent une opération fastidieuse qui peut affecter les performances du système si elle est effectuée de manière synchrone. à cette fin, ThinkPHP6 introduit la fonction de journalisation asynchrone, afin que la journalisation n'affecte plus la vitesse de réponse de l'application.

En nous connectant généralement au contr?leur ou au modèle, nous utilisons l'interface PsrLogLoggerInterface injectée pour y parvenir. PsrLogLoggerInterface 接口來實(shí)現(xiàn)。

// Controller或Model中
use PsrLogLoggerInterface;

public function index(LoggerInterface $logger){
    $logger->info('hello world');
}

簡單的使用方式。使用異步日志記錄，定義一個異步日志記錄器：

use MonologLogger;
use MonologHandlerStreamHandler;

$logger=new Logger("AsyncLogger");
$logger->pushHandler(new StreamHandler('runtime/log/async.log'), Logger::INFO);

日志記錄器定義好后，使用隊(duì)列發(fā)送日志記錄信息，這里我們選擇使用 RabbitMQ 當(dāng)做隊(duì)列服務(wù)。

// Message類
namespace appcommon;

class Message
{
    /**
     * 記錄日志
     * @param $level
     * @param $message
     * @param array $context
     * @return bool
     */
    public static function log($level,$message,array $context=[]){
        $data=[
            'level'=>$level,
            'message'=>$message,
            'context'=>$context,
            'channel'=>'AsyncLogger',
            'datetime'=>date('Y-m-d H:i:s'),
            'host'=>$_SERVER['SERVER_ADDR'] ?? '',
            'uri'=>$_SERVER['REQUEST_URI'] ?? '',
        ];

        $producer=Queue::getConnection('AsyncLogger',true);
        $producer->setExchangeOptions(['name'=>'async_logs','type'=>'topic','durable'=>true])->declareExchange();

        try{
            $producer->publish(json_encode($data),[
                'routing_key' =>'log',
                'exchange' =>'async_logs',
            ]);
            return true;
        }catch (Exception $e){
            return false;
        }
    }
}

其中，我們使用 appcommonQueue 類來提供 rabbitmq 的連接實(shí)例；data中除了記錄日志的信息外，還包含一些環(huán)境信息，比如時間、IP地址、請求的uri地址等。

隊(duì)列處理程序：

// Consumer類
use BunnyMessage;
use PsrLogLoggerInterface;

class Consumer
{
    /**
     * @param Message $message
     * @param LoggerInterface $logger
     */
    public function process(Message $message,LoggerInterface $logger){
        $body=$message->content;
        $data= json_decode($body,true);
        $channel=$data['channel'] ?? 'default_logger';

        $logger->notice($data['message'], $data);
    }
}

當(dāng)然，我們還需要一個輔助處理日志的類。

// Queue類
namespace appcommon;

use BunnyAsyncClient;
use BunnyChannel;
use BunnyMessage;
use BunnyProtocolMethodBasicConsumeOkFrame;
use BunnyProtocolMethodChannelCloseFrame;
use BunnyProtocolMethodChannelCloseOkFrame;
use BunnyProtocolMethodConnectionCloseFrame;
use BunnyProtocolMethodConnectionCloseOkFrame;
use BunnyProtocolMethodConnectionStartFrame;
use BunnyClientStateEnum;
use BunnyMessage as BunnyMessage;

class Queue
{
    /**
     * @param string $queueName
     * @return Client|null
     */
    public static function getConnection(string $routingKey, bool $persistent=false):?Client
    {
        $config=config('rabbitmq.async_log');
        $client=new Client([
            'host' => $config['host'],
            'port' => $config['port'],
            'user' => $config['user'],
            'password' => $config['password'],
            'vhost' => $config['vhost'],//注意此處改為需要的 VHOST
            'concurrency' => 2,
        ]);

        try{
            $client->connect();
            $client->channel()
                ->then(function (Channel $channel) use($client,$routingKey,$persistent){
                    $channel->exchangeDeclare('async_logs','topic',true,true);
                    $channel->queueDeclare($routingKey, $passive=false,$durable=true,$exclusive=false,$autoDelete=false,$nowait=false);
                    $channel->queueBind($routingKey, 'async_logs', $routingKey);

                    $channel->consume(
                        function ($msg, Channel $channel, BunnyMessage $message) use($client,$routingKey){
                            $className=config('rabbitmq.async_log.consumer');
                            $consumer=new $className($client,$routingKey);
                            $consumer->process($message,app('log.async_logger'));
                            $channel->ack($msg);//處理消息
                        },
                        $routingKey,//隊(duì)列Name
                        '',//消費(fèi)Tag
                        false,//no_local
                        false,//no_ack
                        false,//exclusive
                        $persistent ? ['delivery_mode'=>2] : []
                    );
                });
        }catch (Exception $e){
            return null;
        }finally{
            return $client;
        }
    }
}

上面這段代碼中定義了隊(duì)列連接的 host、port 等，通過 $client->channel() 創(chuàng)建了一個 channel 對象，通過 $channel->exchangeDeclare() 和 $channel->queueDeclare() 創(chuàng)建了 exchange 和 queue，并將它們進(jìn)行了綁定。最后，使用 $channel->consume()rrreee

Facile à utiliser. Utilisez la journalisation asynchrone pour définir un enregistreur asynchrone?:

rrreee

Une fois l'enregistreur défini, utilisez une file d'attente pour envoyer les informations de journalisation. Ici, nous choisissons d'utiliser RabbitMQ comme service de file d'attente.

rrreee

Parmi eux, nous utilisons la classe appcommonQueue pour fournir des instances de connexion Rabbitmq?; en plus de l'enregistrement des informations de journal, data contient également des informations environnementales, telles que l'heure et l'adresse IP?; adresse, adresse uri demandée, etc.

1. Gestionnaire de file d'attente?:
rrreee
2. Bien s?r, nous avons également besoin d'une classe pour nous aider dans le traitement des journaux.
rrreee
3. Le code ci-dessus définit l'h?te, le port, etc. de la connexion à la file d'attente. Un objet canal est créé via $client->channel(), et un objet canal est créé via $channel->exchangeDeclare () et $channel->queueDeclare() créent un échange et une file d'attente et les lient. Enfin, utilisez $channel->consume() pour consommer de manière asynchrone les messages de la file d'attente et envoyer les messages à la classe de traitement des messages.

3. Résumé

Cet article explique comment utiliser le framework ThinkPHP6 pour effectuer des opérations de journalisation asynchrone afin que la journalisation n'affecte plus la vitesse de réponse de l'application. En général, voici les étapes?: ??????Développez votre propre enregistreur asynchrone ????Utilisez RabbitMQ pour le traitement de la file d'attente des messages ????écrivez un gestionnaire de messages ??????Dans les projets réels, nous devons optimiser le code en fonction des besoins spécifiques et l'ajuster la configuration de la file d'attente. Grace à la journalisation asynchrone, l'efficacité opérationnelle des applications Web peut être efficacement améliorée, ainsi que la stabilité et la fiabilité du système. ??

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!