异常教程

Ratpacked：使用异步日志记录

更新时间:

💡一则或许对你有用的小广告

欢迎加入小哈的星球 ，你将获得：专属的项目实战 / 1v1 提问 / Java 学习路线 / 学习打卡 / 每月赠书 / 社群讨论

  • 新项目:《从零手撸：仿小红书（微服务架构）》 正在持续爆肝中，基于 Spring Cloud Alibaba + Spring Boot 3.x + JDK 17...，点击查看项目介绍 ;
  • 《从零手撸：前后端分离博客项目（全栈开发）》 2 期已完结，演示链接： http://116.62.199.48/ ;

截止目前， 星球 内专栏累计输出 82w+ 字，讲解图 3441+ 张，还在持续爆肝中.. 后续还会上新更多项目，目标是将 Java 领域典型的项目都整一波，如秒杀系统, 在线商城, IM 即时通讯，权限管理，Spring Cloud Alibaba 微服务等等，已有 2800+ 小伙伴加入学习 ，欢迎点击围观

Ratpack 从头开始​​构建为高性能和异步的。让我们添加一个符合 Ratpack 异步特性的日志记录实现。 Ratpack 使用 SLF4J API 进行日志记录，如果我们在自己的代码中编写日志记录语句，我们应该使用相同的 API。对于 Groovy 开发人员来说，无非是将 @Slf4j AST 注释添加到我们的类中。 Logback 库有一个异步附加程序，它有一个队列来存储传入的日志记录事件。然后不同线程上的工作人员将调用经典的阻塞附加程序，如文件或控制台附加程序，以实际记录消息。但在我们的示例中，我们不使用来自 Logback 的标准异步附加程序，而是使用来自 Reactor 项目的异步日志附加程序。现在我们的队列由一个非常高效的反应器环形缓冲区实现支持。

以下 Logback 配置文件显示了我们如何配置 reactor.logback.AsyncAppender ： 



 <!-- File: src/main/resources/logback.xml -->
<configuration>

&lt;appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"&gt;
    &lt;encoder&gt;
        &lt;pattern&gt;%-30(%d{HH:mm:ss.SSS} [%thread]) %-5level %logger{32} - %msg%n&lt;/pattern&gt;
    &lt;/encoder&gt;
&lt;/appender&gt;

&lt;!-- Create new asynchronous Logback appender backed by Reactor RingBufferProcessor. --&gt;
&lt;appender name="ASYNC" class="reactor.logback.AsyncAppender"&gt;
    &lt;!-- Backlog size for logging events. Change size if they are picked up slowly.
         Default is 1024 * 1024 --&gt;
    &lt;backlog&gt;1048576&lt;/backlog&gt;

    &lt;!-- Caller data is relatively slow, so per default disabled --&gt;
    &lt;includeCallerData&gt;false&lt;/includeCallerData&gt;

    &lt;!-- Redirect logging messages to STDOUT --&gt;
    &lt;appender-ref ref="STDOUT"/&gt;
&lt;/appender&gt;

&lt;root level="INFO"&gt;
    &lt;appender-ref ref="ASYNC"/&gt;
&lt;/root&gt;



</configuration>

我们需要在我们的 build.gradle 文件中为 io.projectreactor:reactor-logback 添加一个运行时依赖来使用 AsyncAppender ： 


 <!-- File: src/main/resources/logback.xml -->
<configuration>

&lt;appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"&gt;
    &lt;encoder&gt;
        &lt;pattern&gt;%-30(%d{HH:mm:ss.SSS} [%thread]) %-5level %logger{32} - %msg%n&lt;/pattern&gt;
    &lt;/encoder&gt;
&lt;/appender&gt;

&lt;!-- Create new asynchronous Logback appender backed by Reactor RingBufferProcessor. --&gt;
&lt;appender name="ASYNC" class="reactor.logback.AsyncAppender"&gt;
    &lt;!-- Backlog size for logging events. Change size if they are picked up slowly.
         Default is 1024 * 1024 --&gt;
    &lt;backlog&gt;1048576&lt;/backlog&gt;

    &lt;!-- Caller data is relatively slow, so per default disabled --&gt;
    &lt;includeCallerData&gt;false&lt;/includeCallerData&gt;

    &lt;!-- Redirect logging messages to STDOUT --&gt;
    &lt;appender-ref ref="STDOUT"/&gt;
&lt;/appender&gt;

&lt;root level="INFO"&gt;
    &lt;appender-ref ref="ASYNC"/&gt;
&lt;/root&gt;



</configuration>