1.新建项目
利用idea创建一个父项目,三个子项目,其中一个项目为生产者,一个项目为消费者,一个为接口等公共服务项目,生产者和消费者需要有web依赖,可以作为tomcat容器启动。
2.项目依赖
<dependencies> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.6</version> </dependency> <!-- zk的依赖 --> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-dependencies-zookeeper</artifactId> <version>2.7.6</version> <type>pom</type> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-aop</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjweaver</artifactId> </dependency>
3.在facade项目中新建接口
4.编写生产者
4.1 增加dubbo配置
server.port=8081 dubbo.registry.address=zookeeper://localhost:2181 dubbo.protocol.name=dubbo dubbo.protocol.port=20880 dubbo.registry.timeout=30000 dubbo.application.name=dubbo-provider-ll
4.2 编写生产者dubbo filter
public class ProviderFilter implements Filter { @Override public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException { Object threadName= invocation.getAttachment("ThreadName"); if(null!=threadName){ Thread thread = Thread.currentThread(); thread.setName(threadName.toString()); } return invoker.invoke(invocation); } }
注意:此处Filter 是dubbo的filter,不是servlet的filter
这里代码的目的是将从消费端传来的线程名称设置为线程名称
在resources目录下新建META-INF/dubbo/com.alibaba.dubbo.rpc.Filter 文件
即新增目录META-INF/dubbo和文件 com.alibaba.dubbo.rpc.Filter
在文件中增加,等号后面为实现dubbo filter的实现类路径
providerFilter=com.dubbo.spring.provider.filter.ProviderFilter
4.3编写dubbo生产者实现类
@Service(filter = {"providerFilter"}) public class DemoServiceImpl implements IDemoService { public Logger LOGGER= LoggerFactory.getLogger(DemoServiceImpl.class); @Override public String getName() { LOGGER.info("provider ThreadName : "+Thread.currentThread().getName()); return "dubbo-test"; } }
5.编写消费者
5.1编写消费者filter
public class DubboFilter implements Filter { @Override public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException { String name = Thread.currentThread().getName(); invocation.setAttachment("ThreadName",name); return invoker.invoke(invocation); } }
此处是将线程名称放入到attachment中,attachment底层是hashmap,后续使用dubbo请求生产者时,会把attachment给到生产者,故在生产中中可以通过key ThreadName来获取消费者端的线程名称
在resources目录下新建META-INF/dubbo/com.alibaba.dubbo.rpc.Filter 文件
即新增目录META-INF/dubbo和文件 com.alibaba.dubbo.rpc.Filter
在文件中增加,等号后面为实现dubbo filter的实现类路径
consumerFilter=com.dubbo.spring.consumer.filter.DubboFilter
5.2 编写response对象
public class Response implements Serializable { private static final long serialVersionUID = -3186818832535757509L; private String code; private String message; private Object result; private String index; public String getCode() { return code; } public void setCode(String code) { this.code = code; } public String getMessage() { return message; } public void setMessage(String message) { this.message = message; } public Object getResult() { return result; } public void setResult(Object result) { this.result = result; } public String getIndex() { return index; } public void setIndex(String index) { this.index = index; } }
此response为web端返回到页面统一对象
5.3 编写aop切面
@Aspect @Component public class AopContext { @Before("execution(* com.dubbo.spring..*.*(..))") public void before(){ Thread thread = Thread.currentThread(); thread.setName(UUIDUtil.getUUID()); } @Around("execution(* com.dubbo.spring..*.*(..))") public Object around(ProceedingJoinPoint pjp){ Response response=new Response(); try { Object proceed = pjp.proceed(); if(proceed instanceof Response){ response=(Response) proceed; response.setIndex(Thread.currentThread().getName()); } } catch (Throwable throwable) { throwable.printStackTrace(); } return response; } }
1.before是在请求进入时给线程设置名称,为随机生成的uuid
2.around是环绕通知,在执行完之后,在返回的结果中将线程名称设置进去,便于以后异常追踪
5.4 编写web
@RestController public class WebController { private Logger LOGGER= LoggerFactory.getLogger(WebController.class); @Reference(filter = {"consumerFilter"}) private IDemoService iDemoService; @GetMapping("/getName") public Response getName(){ LOGGER.info("consumer ThreadName : "+Thread.currentThread().getName()); String name = iDemoService.getName(); Response response=new Response(); response.setResult(name); response.setCode("1001"); response.setMessage("success"); return response; } }
请求结果
此处为postman响应的,index 为1ca55cb7a17148879923265b89102ccf
生产者线程名称:
消费者线程名称:
可以看到从web页面到生产者,消费者,都有一个全局唯一id进行贯穿,如果在web页面提示有异常时,可以通过这个uuid进行日志追踪
到此这篇关于springboot整合dubbo设置全局唯一ID进行日志追踪的文章就介绍到这了,更多相关springboot整合dubbo内容请搜索小牛知识库以前的文章或继续浏览下面的相关文章希望大家以后多多支持小牛知识库!
本文向大家介绍springboot2.0整合dubbo的示例代码,包括了springboot2.0整合dubbo的示例代码的使用技巧和注意事项,需要的朋友参考一下 写在前面: 使用springboot作为web框架,方便开发许多,做分布式开发,dubbo又不可少,那么怎么整合在一起呢, 跟我学一遍,至少会用 注意,springboot2.0和springboot1.x与dubbo整合不一样, 1.
本文向大家介绍SpringBoot应用整合ELK实现日志收集的示例代码,包括了SpringBoot应用整合ELK实现日志收集的示例代码的使用技巧和注意事项,需要的朋友参考一下 ELK即Elasticsearch、Logstash、Kibana,组合起来可以搭建线上日志系统,本文主要讲解使用ELK来收集SpringBoot应用产生的日志。 ELK中各个服务的作用 Elasticsearch:用于存储
本文向大家介绍SpringBoot整合UEditor的示例代码,包括了SpringBoot整合UEditor的示例代码的使用技巧和注意事项,需要的朋友参考一下 当前开发项目涉及到富文本框,了解了不少富文本编辑器之后,最终决定使用度娘的UEditor。原因:功能强大,并且自带适配java后端的图片和视频上传。 项目地址 不多说,上一下该项目的地址: http://ueditor.baidu.com/
本文向大家介绍Springboot整合log4j2日志全解总结,包括了Springboot整合log4j2日志全解总结的使用技巧和注意事项,需要的朋友参考一下 在项目推进中,如果说第一件事是搭Spring框架的话,那么第二件事情就是在Sring基础上搭建日志框架,我想很多人都知道日志对于一个项目的重要性,尤其是线上Web项目,因为日志可能是我们了解应用如何执行的唯一方式。 在18年大环境下,更多的
本文向大家介绍springboot整合Mybatis、JPA、Redis的示例代码,包括了springboot整合Mybatis、JPA、Redis的示例代码的使用技巧和注意事项,需要的朋友参考一下 引言 在springboot 项目中,我们是用ORM 框架来操作数据库变的非常方便。下面我们分别整合mysql ,spring data jpa 以及redis 。让我们感受下快车道。 我们首先创建一
本文向大家介绍springBoot整合RocketMQ及坑的示例代码,包括了springBoot整合RocketMQ及坑的示例代码的使用技巧和注意事项,需要的朋友参考一下 版本: JDK:1.8 springBoot:1.5.10 rocketMQ:4.2.0 pom 配置: application.properties 配置: java代码: 生产者 消费者: 掉坑总结: 1.roc