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);
}
}
测试客户端文章来源:https://www.toymoban.com/news/detail-754193.html
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模板网!