spring boot整合log4j2及MQ消费处理系统日志示例

< dependency >

             < groupId >org.springframework.boot</ groupId >

             < artifactId >spring-boot-starter-amqp</ artifactId >

             < exclusions >

                 < exclusion >

                     < groupId >org.springframework.boot</ groupId >

                     < artifactId >spring-boot-starter-logging</ artifactId >

                 </ exclusion >

             </ exclusions >

         </ dependency >

         < dependency >

             < groupId >org.springframework.boot</ groupId >

             < artifactId >spring-boot-starter-log4j2</ artifactId >

</ dependency >

<? xml version = "1.0" encoding = "UTF-8" ?>

< Configuration >

     < Appenders >

         < Console name = "STDOUT" target = "SYSTEM_OUT" >

             < PatternLayout pattern = "%m%n" />

         </ Console >

         < RabbitMQ name = "rabbitmq"

                   addresses = "localhost:5672"

                   user = "guest"

                   password = "guest"

                   virtualHost = "/"

                   exchange = "log4j2Sample"

                   applicationId = "log4j2SampleAppId"

                   routingKeyPattern = "%X{applicationId}.%c.%p"

                   contentType = "text/plain"

                   contentEncoding = "UTF-8"

                   generateId = "false"

                   deliveryMode = "PERSISTENT"

                   charset = "UTF-8"

                   senderPoolSize = "3"

                   maxSenderRetries = "5" >

         </ RabbitMQ >

     </ Appenders >

     < Loggers >

         < Logger name = "org.springframework.amqp.samples.log4j2" level = "info" >

             < AppenderRef ref = "rabbitmq" />

         </ Logger >

         < Root >

             < AppenderRef ref = "STDOUT" />

         </ Root >

     </ Loggers >

</ Configuration >

@RabbitListener (bindings = @QueueBinding (

             exchange = @Exchange (value = "log4j2Sample" , type = ExchangeTypes.FANOUT),

             value = @org .springframework.amqp.rabbit.annotation.Queue))

     public void echoLogs(String logMessage) {

         System.out.println( "在这里处理消费你的日志信息" + logMessage);

     }