log4j2精华之异步日志MQ篇

缺乏、安全感 2023-10-10 17:06 60阅读 0赞

#### 解耦性能优化杠杆滴 ####

*   *  在springboot中如何通过 rabbitMq 实现日志异步记录呢?

> 做一个特别简单的人，不期待突如其来的好运，只希望所有的努力终有回报

### 在springboot中如何通过 rabbitMq 实现日志异步记录呢? ###

要在Spring Boot中使用RabbitMQ实现日志异步记录，你需要将Log4j2与Spring Boot集成，然后通过RabbitMQ Appender将日志发送到RabbitMQ消息队列。以下是一个简单的例子来展示如何实现这一过程：

1.  添加依赖

在你的Spring Boot项目的`pom.xml`文件中添加以下依赖：

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-log4j2</artifactId>
    </dependency>
    
    
    <dependency>
        <groupId>com.rabbitmq</groupId>
        <artifactId>amqp-client</artifactId>
        <version>5.13.0</version>
    </dependency>
    
    
    <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j2-rabbitmq-appender</artifactId>
        <version>2.14.1</version>
    </dependency>

1.  配置RabbitMQ Appender

在`src/main/resources`目录下创建一个`log4j2.xml`文件，然后配置RabbitMQ Appender：

<?xml version="1.0" encoding="UTF-8"?>
    <Configuration status="WARN">
        <Appenders>
            <RabbitMQ name="rabbitMQAppender" host="localhost" port="5672" user="guest" password="guest" exchange="logs.exchange" routingKey="logs.routing.key" virtualHost="/" />
        </Appenders>
        <Loggers>
            <Root level="info">
                <AppenderRef ref="rabbitMQAppender"/>
            </Root>
        </Loggers>
    </Configuration>

这里我们配置了一个RabbitMQ Appender，并设置了RabbitMQ服务器的地址、端口、用户名、密码、交换机和路由键。你需要根据实际情况填写正确的配置信息。

1.  配置RabbitMQ监听器

接下来，创建一个RabbitMQ监听器来接收并处理日志消息。首先，在`application.properties`中添加RabbitMQ相关配置：

spring.rabbitmq.host=localhost
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest

然后创建一个`RabbitMQConfig`类来配置RabbitMQ：

import org.springframework.amqp.core.Binding;
    import org.springframework.amqp.core.BindingBuilder;
    import org.springframework.amqp.core.Queue;
    import org.springframework.amqp.core.TopicExchange;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class RabbitMQConfig {
        
    
        @Bean
        public TopicExchange logsExchange() {
        
            return new TopicExchange("logs.exchange");
        }
    
        @Bean
        public Queue logsQueue() {
        
            return new Queue("logs.queue");
        }
    
        @Bean
        public Binding logsBinding(TopicExchange logsExchange, Queue logsQueue) {
        
            return BindingBuilder.bind(logsQueue).to(logsExchange).with("logs.routing.key");
        }
    
    }

1.  创建一个消费者来处理日志消息

import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    @Component
    public class LogConsumer {
        
    
        @RabbitListener(queues = "logs.queue")
        public void consumeLog(String logMessage) {
        
    
            System.out.println("Received log message: " + logMessage);
        }
    }

在这个示例中，我们创建了一个名为`LogConsumer`的消费者类，并使用`@RabbitListener`注解指定监听的队列。当从队列中接收到日志消息时，`consumeLog`方法将被调用，并打印接收到的日志消息。

1.  在应用程序中使用日志

现在你可以在应用程序中使用Log4j2记录日志。例如，在一个名为`ExampleController`的控制器类中：

import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class ExampleController {
        
    
        private static final Logger logger = LogManager.getLogger(ExampleController.class);
    
        @GetMapping("/log")
        public String log() {
        
            logger.info("This is a log message from ExampleController.");
            return "Log message sent";
        }
    
    }

当你访问`/log`端点时，应用程序将记录一个日志消息。该消息将被发送到RabbitMQ队列，并由`LogConsumer`处理。

这就是如何在Spring Boot中通过RabbitMQ实现日志异步记录的一个简单示例。你可以根据实际需求对其进行扩展和优化。

发表评论取消回复

表情：

评论列表（有 0 条评论，60人围观）

还没有评论，来说两句吧...

相关阅读

相关 Log4j2异步日志配置

简介 > Apache Log4j 2 is an upgrade to Log4j that provides significant improvements o...

谁践踏了优雅/ 2024年04月17日 16:33/ 0 赞/ 92 阅读

相关 log4j2精华之异步日志MQ篇

解耦性能优化杠杆滴在springboot中如何通过 rabbitMq 实现日志异步记录呢? > 做一个特别简单的人，不期待突如其来的好运，只希望所有的努力

缺乏、安全感/ 2023年10月10日 17:06/ 0 赞/ 61 阅读

相关 log4j2精华之异步日志

提高性能杠杆的 log4j2 异步日志示例 | AsyncLogger > 我想把最好的一面展现给你，因为我怕我错过你；我想把最坏的一面展现

亦凉/ 2023年10月10日 17:06/ 0 赞/ 67 阅读

相关【Log4j2】Spring 整合 Log4j2 日志框架

![在这里插入图片描述][8d8e0d8a542946af858489a536162608.gif_pic_center] > 个人简介：Java领域新星创作者；阿里云技术博

超、凢脫俗/ 2023年10月07日 23:08/ 0 赞/ 34 阅读

相关 Log4j,Log4j2,logback,slf4j日志学习

日志学习笔记 Log4j Log4j是Apache的一个开放源代码项目，通过使用Log4j，我们可以控制日志信息输送的目的地是控制台、文件、[数据库][Link

我会带着你远行/ 2022年06月10日 12:44/ 0 赞/ 612 阅读

相关 log4j2异步Logger

1 异步Logger的意义之前的日志框架基本都实现了AsyncAppender，被证明对性能的提升作用非常明显。在log4j2日志框架中，增加了对Logger

雨点打透心脏的1/2处/ 2022年05月30日 11:47/ 0 赞/ 223 阅读

相关 log4j2异步发送error日志邮件配置

从高可用性方面考虑，大的平台通常都会配置错误日志发送邮件的功能，由于发送邮件比较慢，同步发邮件会影响用户体验，通常会配置成异步发日志邮件。网上只有零散的一些文章配置，没有一个完

左手的ㄟ右手/ 2022年03月30日 07:58/ 0 赞/ 596 阅读

相关日志之log4j

日志之log4j 1.1 简介 Log4j是一个由Java编写可靠、灵活的日志框架，是Apache旗下的一个开源项目；现如今，Log4j已经被移植到了C、C++、P

小鱼儿/ 2022年03月26日 09:54/ 0 赞/ 341 阅读

相关日志之log4j2

日志之log4j2 1.1 简介 log4j2，一个日志的实现框架，是log4j的升级版本，于2014年7月正式亮相。与第一代log4j不同，log4j2完全重写了

我会带着你远行/ 2022年03月25日 04:58/ 0 赞/ 476 阅读

相关 log4j2日志异步打印（3）

log4j2支持日志的异步打印，日志异步输出的好处在于，使用单独的进程来执行日志打印的功能，可以提高日志执行效率，减少日志功能对正常业务的影响。异步日志在程序的class

分手后的思念是犯贱/ 2021年06月24日 15:57/ 0 赞/ 506 阅读