SpringCloud一:提供者架构Eureka+Sleuth+RabbitMQ

浅浅的花香味﹌ 2022-05-15 05:49 109阅读 0赞

SpringCloud真是微服务的集大成者,与springBoot的一样,都是基于一些开源框架之上,这几天都在搞springcloud,网上资料很多,但都是基于一些零散的知识点,没有串起来一些组件,本次写的博客会总结springcloud的实战场景,分几个微服务将springcloud串起来,我会连载几篇博客供读者参考  
本次写基于springcloud的消费者如何架构,  
我们使用Eureka来注册服务,可以查看我之前写的文章  
[SpringCloud之Eureka服务注册中心,服务注册和服务发现][SpringCloud_Eureka]  
对于微服务的调用日志跟踪,我们使用sleuth来跟踪,并把产生的消息发布到RabbitMQ中,最后让Zipkin来订阅分析,  
对于消费者的架构可以查看我的博客  
[SpringCloud之消费者架构Eureka+Ribbon+Feign+Hystrix+Sleuth+RabbitMQ][SpringCloud_Eureka_Ribbon_Feign_Hystrix_Sleuth_RabbitMQ]  
对于Zipkin的搭建有很多方式,使用docker较为简单,但自定义的SpringBoot微服务则更灵活,对于如何构建Zipkin,可以查看我的博客  
[SpringCloud之提供者和消费者的日志分析Zipkin+RabbitMQ][SpringCloud_Zipkin_RabbitMQ]

在pom.xml 引入依赖  
SpringBoot使用1.5.15版本  
SpringCloud使用Edgware.SR4版本

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-sleuth</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-sleuth-stream</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
            </dependency>
            
            <dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-eureka</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-actuator</artifactId>
    		</dependency>

在 application.yml配置eureka,RabbitMQ,sleuth 注意sleuth的采样使用100%

server:
      port: 8001
    eureka:
      instance:
        prefer-ip-address: true
        instance-id: provider:8001
      client:
        service-url:
          defaultZone: http://localhost:7001/eureka/
    spring:
      application:
        name: provider
      sleuth:
        sampler:
          percentage: 1
      rabbitmq:
        host: 120.77.115.104
        port: 5672
        username: guest
        password: guest

写一个controller暴露RestAPI,由于整合了slueth,打印的日志格式如下

INFO [provider,4d1e35c6a06ba501,9a06137d4e205b5b,true]

其中第一个代表应用名,  
第二个代表Trace ID,标识一条请求链路,  
第三个代表基本工作单元  
第三个代表是否将日志输出到Zipkin等服务中来收集和展示,注意采用使用1才为true,默认为0.1,则为false

我们也可以从请求头中获取信息,其中常用的请求头代表的信息如下  
\* X-B3-TraceId：一条请求链路（Trace）的唯一标识，必须值  
\* X-B3-SpanId：一个工作单元（Span）的唯一标识，必须值  
\* X-B3-ParentSpanId:：标识当前工作单元所属的上一个工作单元  
\* X-Span-Name： 请求的url

@RestController public class UserController { private final Logger logger = Logger.getLogger(getClass()); @GetMapping("/getMsg") public String getMsg(HttpServletRequest request){ logger.info("provider1 "+request.getHeader("X-Span-Name")+request.getHeader("X-B3-ParentSpanId")+ request.getHeader("X-B3-TraceId")+request.getHeader("X-B3-SpanId")); return "provider1 8001"; } }

[SpringCloud_Eureka]: https://blog.csdn.net/lhc0512/article/details/81109158
[SpringCloud_Eureka_Ribbon_Feign_Hystrix_Sleuth_RabbitMQ]: https://blog.csdn.net/lhc0512/article/details/82053419
[SpringCloud_Zipkin_RabbitMQ]: https://blog.csdn.net/lhc0512/article/details/82053567