logback整合rabbitmq实现消息记录日志

这篇具有很好参考价值的文章主要介绍了logback整合rabbitmq实现消息记录日志。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

logback.xml文件配置

   <!-- 配置rabbitmq的信息,数据取值yml -->
 
 <springProperty name="rabbitmqHost" source="spring.rabbitmq.host"/>
 <springProperty name="rabbitmqPort" source="spring.rabbitmq.port"/>
 <springProperty name="rabbitmqUsername" source="spring.rabbitmq.username"/>
 <springProperty name="rabbitmqPassword" source="spring.rabbitmq.password"/>
 <springProperty name="rabbitmqvirtualHost" source="spring.rabbitmq.virtual-host"/>


 <!-- 配置rabbitmq的日志记录appender -->

<appender name="LogAmqpAppender" class="org.springframework.amqp.rabbit.logback.AmqpAppender">
 
        <!--Layout(纯文本)而不是格式化的JSON -->
        <layout>
            <pattern>
           {"source":"%c-%L","createtime":"%d{yyyy-MM-dd HH:mm:ss}","thread":"%thread","level":"%-5level", "logTrackId": "%X{logTrackId}", "requestUri":"%X{requestUri}", "msg":"%msg"}
            </pattern>
        </layout>
        <host>${rabbitmqHost}</host>
        <port>${rabbitmqPort}</port>
        <username>${rabbitmqUsername}</username>
        <password>${rabbitmqPassword}</password>
        <virtualHost>${rabbitmqvirtualHost}</virtualHost>
        <declareExchange>true</declareExchange>
        <exchangeType>direct</exchangeType>
        <exchangeName>log.exchange.direct</exchangeName>
        <routingKeyPattern>logDirectQueue</routingKeyPattern>
        <generateId>true</generateId>
        <charset>UTF-8</charset>
        <durable>false</durable>
        <autoDelete>false</autoDelete>
        <deliveryMode>NON_PERSISTENT</deliveryMode>
    </appender>

    <!-- root 级别的配置 -->

    <root level="INFO">
        <appender-ref ref="LogAmqpAppender" />

    </root>

yml文件配置

  # rabbitmq
  rabbitmq:
    host: 132.33.228.149
    username: admin
    password: admin@2023$
    port: 5673
        #虚拟host 可以不设置,使用server默认host
    virtual-host: /
    connection-timeout: 10000
    listener:
      simple:
        prefetch: 1 # 每次只能获取一条,处理完成才能获取下一条
        acknowledge-mode: manual #一定改为要手动确认模式

代码配置rabbitmq信息

package com.xx.weixin.rabbitmq;


import java.util.HashMap;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;




/**
* @author 作者 srp
* @version 创建时间:2023-12-1 16:42:41
* 
*/
@Configuration

public class RabbitMqLogConfig {
	
	@Autowired
    private RabbitAdmin rabbitAdmin;
    //强制用此方法生成自己希望的队列
	@Bean
    public Queue logDirectQueue() {
	     //设置过期时间,以毫秒为单位
        HashMap<String, Object> map = new HashMap<>();
        map.put("x-message-ttl", 60000);
        //true,false跟logback.xml对应
        Queue queue = new Queue( "logDirectQueue", true,false,false,map);
        rabbitAdmin.declareQueue(queue);
        return queue;

    }
 
    @Bean
    public DirectExchange logDirectExchange() {
        //true,false跟logback.xml对应

        return new DirectExchange("log.exchange.direct", false, false);
    }
 
    /**
     * 根据路由键绑定队列到交换器上
     *
     * @return
     */
    @Bean
    public Binding logDirectBinding() {
        return BindingBuilder.bind(logDirectQueue()).to(logDirectExchange()).with("logDirectQueue");
    }
    
    @Bean
    public RabbitAdmin rabbitAdmin(ConnectionFactory defaultConnectionFactory){
        return new RabbitAdmin(defaultConnectionFactory);
    }

}

测试客户端

package com.xx.pyt.confg;
import java.io.IOException;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
import org.springframework.amqp.core.Message;

import com.rabbitmq.client.Channel;

///**
//* @author 作者 srp
//* @version 创建时间:2023-12-1 16:45:44
//* 
//*/
@Component

public class DirectConsumer {
	protected final Logger log = LoggerFactory.getLogger(this.getClass());
	@RabbitListener(bindings = @QueueBinding(value = @Queue(value = "logDirectQueue", durable = "false"),
			exchange = @Exchange(name = "log.exchange.direct", durable = "false", type = "direct"),key ="logDirectQueue"))

    @RabbitHandler
    public void handleMessage(String msg, Channel channel, Message message)  throws IOException {
        try {
            // 处理消息逻辑
            processMessage(msg);
            
            // 手动ack确认
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
        } catch (Exception e) {
            // 手动nack拒绝,并要求重新投递
            channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
            log.error(e.getMessage(), e);
        }
    }
 
    private void processMessage(String message) {
        // 模拟处理消息过程
        log.info("Processing message: " + message);
        
       
    }


}

此外,如果要对日志进行链路标记,可以是用MDC文章来源地址https://www.toymoban.com/news/detail-754193.html

package com.xxm.filter;

import java.io.IOException;

import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.annotation.WebFilter;
import javax.servlet.http.HttpServletRequest;

import org.slf4j.MDC;
import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.stereotype.Component;

import com.ylkh.admin.entity.MyUser;
import com.ylkh.security.dto.JwtUserDto;

import cn.hutool.core.lang.UUID;
import lombok.extern.slf4j.Slf4j;

/**
* @author 作者 srp
* @version 创建时间:2022年1月4日 下午12:52:43
* 
*/
@Slf4j
@Component
@WebFilter(urlPatterns = "/**",filterName = "tlFilter")
public class TraceLogLocalFilter implements Filter {

    @Override
    public void init(FilterConfig filterConfig) throws ServletException {
      log.debug("链路过滤器初始化");
    }

    @Override
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
    	  HttpServletRequest request = (HttpServletRequest) servletRequest;
   	if(SecurityContextHolder.getContext().getAuthentication()!=null&&!"anonymousUser".equals(SecurityContextHolder.getContext().getAuthentication().getPrincipal())) {
   		     //log.info(""+SecurityContextHolder.getContext().getAuthentication().getPrincipal());
             JwtUserDto jwtUserDto = (JwtUserDto) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
             MyUser myUser = jwtUserDto.getMyUser();
             MDC.put("user", myUser.getUserName());

    	} 
   	  String logtrackId = UUID.randomUUID(true).toString();
   	  if(!request.getRequestURI().contains(".css")&&!request.getRequestURI().contains(".js")&&!request.getRequestURI().contains(".html"))
    	//添加MDC日志
   	    { 
        MDC.put("logTrackId",logtrackId);
        MDC.put("requestUri", request.getRequestURI());
   	     }
        try {
            filterChain.doFilter(servletRequest, servletResponse);
        }finally{
            //移除MDC日志
            MDC.remove(logtrackId);
        }
    //    log.info("过滤器执行完成");
    }

    @Override
    public void destroy() {
        log.warn("过滤器销毁");

    }
}

到了这里,关于logback整合rabbitmq实现消息记录日志的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 搭建RabbitMQ消息服务,整合SpringBoot实现收发消息

    作者主页 :Designer 小郑 作者简介 :3年JAVA全栈开发经验,专注JAVA技术、系统定制、远程指导,致力于企业数字化转型,CSDN博客专家,蓝桥云课认证讲师。 消息队列是一种在应用程序之间传递数据的通信机制 ,它基于 发布-订阅 模式,将消息发送者(发布者)和消息接收者

    2024年02月09日
    浏览(53)
  • SpringBoot整合Logback日志框架配置全解析

    SpringBoot使用 Commons Logging 进行所有内部日志的记录,但默认配置也提供了对常用日志的支持,如 Java Util Logging,Log4J2,和Logback. 每种logger都可以通过配置使用控制台或文件输出日志内容。 Logback是log4j框架的作者开发的新一代日志框架,它效率更高、能够适应诸多的运行环境

    2024年02月02日
    浏览(57)
  • Spring Boot 整合 RabbitMQ 实现延迟消息

    消息队列(Message Queuing,简写为 MQ)最初是为了解决金融行业的特定业务需求而产生的。慢慢的,MQ 被应用到了更多的领域,然而商业 MQ 高昂的价格让很多初创公司望而却步,于是 AMQP(Advanced Message Queuing Protocol,高级消息队列协议)应运而生。 随着 AMQP 草案的发布,两个月

    2024年04月08日
    浏览(47)
  • springboot整合rabbitmq 实现消息发送和消费

    Spring Boot提供了RabbitMQ的自动化配置,使得整合RabbitMQ变得非常容易。 首先,需要在pom.xml文件中引入amqp-client和spring-boot-starter-amqp依赖: 接下来需要在application.properties文件中配置RabbitMQ连接信息: 然后编写消息发送者: 其中,my-exchange和my-routing-key是需要自己定义的交换机和

    2024年02月07日
    浏览(40)
  • SpringBoot 整合RabbitMq 自定义消息监听容器来实现消息批量处理

    RabbitMQ是一种常用的消息队列,Spring Boot对其进行了深度的整合,可以快速地实现消息的发送和接收。在RabbitMQ中,消息的发送和接收都是异步的,因此需要使用监听器来监听消息的到来。Spring Boot中提供了默认的监听器容器,但是有时候我们需要自定义监听器容器,来满足一

    2024年02月16日
    浏览(48)
  • 消息队列-RabbitMQ:延迟队列、rabbitmq 插件方式实现延迟队列、整合SpringBoot

    1、延迟队列概念 延时队列内部是有序的 , 最重要的特性 就体现在它的 延时属性 上,延时队列中的元素是希望在指定时间到了以后或之前取出和处理,简单来说, 延时队列就是用来存放需要在指定时间被处理的元素的队列。 延迟队列使用场景: 订单在十分钟之内未支付则

    2024年02月22日
    浏览(52)
  • 统一日志管理方案:Spring项目logback日志与logstash和Elasticsearch整合

    原创/朱季谦 最近在做一个将分布式系统的日志数据通过logstash传到kafka的功能,做完之后决定业余搭一个ELK日志分析系统,将logstash采集到的日志传给Elasticsearch。经过一番捣鼓,也把这个过程给走通了,于是写了这篇总结,可按照以下步骤搭建logstash采集spring日志数据并传输

    2024年02月03日
    浏览(38)
  • logback日志记录器

    logback是log4j团队创建的开源日志组件,与log4j类似但是比log4j更强大,是log4j的改良版本。主要优势在于: a) 更快的实现,logback内核重写过,是的性能有了很大的提升,内存占用也更小。 b) logback-classic对slf4j进行了更好的集成 c) 自动重新加载配置文件,当配置文件修改后,

    2024年01月19日
    浏览(33)
  • Springboot整合logback多节点日志文件加端口号区分

    描述: 正常情况下:在Springboot 项目的resources目录下创建一个logback-spring.xml的日志配置文件,简单配置如下: 项目启动后日志都会存储在:部署目录下的 logs 文件夹下面: !--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径-- property name=\\\"LOG_HOME\\\" value=\\\"./logs\\\" / 文件名

    2024年02月09日
    浏览(47)
  • 207、SpringBoot 整合 RabbitMQ 实现消息的发送 与 接收(监听器)

    1、ContentUtil 先定义常量 2、RabbitMQConfig 创建队列的两种方式之一: 配置式: 在容器中配置 org.springframework.amqp.core.Queue 类型的Bean,RabbitMQ将会自动为该Bean创建对应的队列。 就是在配置类中创建一个生成消息队列的@Bean。 问题: 用 @Configuration 注解声明为配置类,但是项目启动

    2024年02月06日
    浏览(52)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包