设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

SpringCloud微服务实战

2016-8-16 12:48| 发布者: zhangjf| 查看: 788| 评论: 0

摘要: 序 主要有eureka做服务发现、config做分布式配置、zuul做api-gateway、feign做客户端负载均衡、hystrix做断路器、turbine做聚合的monitor、graphite做指标监控。 eureka pom配置dependencies dependency ...
序

主要有eureka做服务发现、config做分布式配置、zuul做api-gateway、feign做客户端负载均衡、hystrix做断路器、turbine做聚合的monitor、graphite做指标监控。

eureka

pom配置

  1. <dependencies>
  2. <dependency>
  3. <groupId>org.springframework.boot</groupId>
  4. <artifactId>spring-boot-starter-web</artifactId>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.springframework.boot</groupId>
  8. <artifactId>spring-boot-starter-actuator</artifactId>
  9. </dependency>
  10. <dependency>
  11. <groupId>org.springframework.cloud</groupId>
  12. <artifactId>spring-cloud-starter-eureka-server</artifactId>
  13. </dependency>
  14. <dependency>
  15. <groupId>junit</groupId>
  16. <artifactId>junit</artifactId>
  17. <scope>test</scope>
  18. </dependency>
  19. </dependencies>
复制代码

application.yml

  1. server:
  2. port: 8761
  4. eureka:
  5. instance:
  6. hostname: discovery
  7. client:
  8. registerWithEureka: false
  9. fetchRegistry: false
  10. serviceUrl:
  11. defaultZone: http://discovery:${server.port}/eureka/
  13. spring.cloud.config.discovery.enabled: true
复制代码

bootstrap.yml

  1. spring:
  2. application:
  3. name: discovery
复制代码

application

  1. @SpringBootApplication
  2. @EnableEurekaServer
  3. public class EurekaApplication {
  4. public static void main( String[] args ) {
  5. SpringApplication.run(EurekaApplication.class, args);
  6. }
  7. }
复制代码

访问
http://192.168.99.100:8761/

config

pom配置

  1. <dependencies>
  2. <dependency>
  3. <groupId>org.springframework.cloud</groupId>
  4. <artifactId>spring-cloud-starter</artifactId>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.springframework.cloud</groupId>
  8. <artifactId>spring-cloud-config-server</artifactId>
  9. </dependency>
  10. <dependency>
  11. <groupId>org.springframework.cloud</groupId>
  12. <artifactId>spring-cloud-starter-eureka</artifactId>
  13. </dependency>
  14. </dependencies>
复制代码

application.yml

  1. spring:
  2. cloud:
  3. config:
  4. server:
  5. native:
  6. search-locations: classpath:/config
  8. server:
  9. port: 8888
复制代码

bootstrap.yml

  1. spring:
  2. application:
  3. name: config
  4. profiles:
  5. active: native
  7. eureka:
  8. instance:
  9. preferIpAddress: true
  10. client:
  11. service-url:
  12. defaultZone: http://discovery:8761/eureka/
复制代码

application

  1. @SpringBootApplication
  2. @EnableConfigServer
  3. @EnableEurekaClient
  4. public class ConfigApplication {
  5. public static void main( String[] args ) {
  6. SpringApplication.run(ConfigApplication.class,args);
  7. }
  8. }
复制代码

访问
http://192.168.99.100:8888/review/default/master

feign实例

pom

  1. <dependencies>
  2. <dependency>
  3. <groupId>org.springframework.cloud</groupId>
  4. <artifactId>spring-cloud-starter</artifactId>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.springframework.boot</groupId>
  8. <artifactId>spring-boot-starter-web</artifactId>
  9. </dependency>
  10. <dependency>
  11. <groupId>org.springframework.boot</groupId>
  12. <artifactId>spring-boot-starter-actuator</artifactId>
  13. </dependency>
  14. <dependency>
  15. <groupId>org.springframework.cloud</groupId>
  16. <artifactId>spring-cloud-config-client</artifactId>
  17. </dependency>
  18. <dependency>
  19. <groupId>org.springframework.cloud</groupId>
  20. <artifactId>spring-cloud-starter-eureka</artifactId>
  21. </dependency>
  22. <dependency>
  23. <groupId>com.patterncat</groupId>
  24. <artifactId>common</artifactId>
  25. <version>1.0-SNAPSHOT</version>
  26. </dependency>
  28. <!--调用其他微服务-->
  29. <dependency>
  30. <groupId>org.springframework.cloud</groupId>
  31. <artifactId>spring-cloud-starter-ribbon</artifactId>
  32. </dependency>
  33. <dependency>
  34. <groupId>org.springframework.cloud</groupId>
  35. <artifactId>spring-cloud-starter-feign</artifactId>
  36. </dependency>
  38. <!--使用hystrix-->
  39. <dependency>
  40. <groupId>org.springframework.cloud</groupId>
  41. <artifactId>spring-cloud-starter-hystrix</artifactId>
  42. </dependency>
  43. <dependency>
  44. <groupId>org.springframework.cloud</groupId>
  45. <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
  46. </dependency>
  48. </dependencies>
复制代码

application.yml

  1. server:
  2. port: 9001
  4. endpoints:
  5. restart:
  6. enabled: true
  7. shutdown:
  8. enabled: true
  9. health:
  10. sensitive: false
  12. ribbon:
  13. eureka:
  14. enabled: true
复制代码

bootstrap.yml

  1. spring:
  2. application:
  3. name: product
  4. cloud:
  5. config:
  6. uri: http://config:8888
  7. encrypt:
  8. failOnError: false
  10. eureka:
  11. instance:
  12. preferIpAddress: true
  13. client:
  14. registerWithEureka: true
  15. fetchRegistry: true
  16. serviceUrl:
  17. defaultZone: http://discovery:8761/eureka/
复制代码

FeignClient

  1. @FeignClient("recommend")
  2. public interface RemoteRecommendService {
  3. @RequestMapping(method = RequestMethod.GET,value = "/recommend")
  4. public List<Recommendation> getRecommendations(
  5. @RequestParam(value = "productId", required = true) int productId);
  6. }
复制代码

feign使用

  1. @RestController
  2. public class ProductController {
  4. private static final Logger LOG = LoggerFactory.getLogger(ProductController.class);
  6. @Autowired
  7. private SetProcTimeBean setProcTimeBean;
  9. @Autowired
  10. RemoteRecommendService remoteRecommendService;
  12. @RequestMapping("/product/recommends")
  13. @HystrixCommand(fallbackMethod = "callRecommendFallback", commandProperties = {
  14. @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "100")
  15. })
  16. public List<Recommendation> remoteRecommends(@RequestParam(value = "productId", required = true) int productId){
  17. return remoteRecommendService.getRecommendations(productId);
  18. }
  20. public List<Recommendation> callRecommendFallback(int productId) {
  21. return Collections.emptyList();
  22. }
  24. @RequestMapping("/product/{productId}")
  25. public Product getProduct(@PathVariable int productId) {
  27. int pt = setProcTimeBean.calculateProcessingTime();
  28. LOG.info("/product called, processing time: {}", pt);
  30. sleep(pt);
  32. LOG.debug("/product return the found product");
  33. return new Product(productId, "name", 123);
  34. }
  35. }
复制代码

application

  1. @SpringBootApplication
  2. @EnableDiscoveryClient
  3. @EnableFeignClients
  4. @EnableCircuitBreaker
  5. @EnableHystrix
  6. @EnableHystrixDashboard
  7. public class ProductApplication {
  8. private static final Logger LOG = LoggerFactory.getLogger(ProductApplication.class);
  10. public static void main(String[] args){
  11. SpringApplication.run(ProductApplication.class,args);
  12. LOG.info("Register ShutdownHook");
  13. Runtime.getRuntime().addShutdownHook(new Thread(){
  14. @Override
  15. public void run() {
  16. LOG.info("Shutting down product service, unregister from Eureka!");
  17. DiscoveryManager.getInstance().shutdownComponent();
  18. }
  19. });
  20. }
  21. }
复制代码
api-gateway

pom

  1. <dependencies>
  2. <dependency>
  3. <groupId>org.springframework.cloud</groupId>
  4. <artifactId>spring-cloud-starter-zuul</artifactId>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.springframework.cloud</groupId>
  8. <artifactId>spring-cloud-starter-eureka</artifactId>
  9. </dependency>
  10. <dependency>
  11. <groupId>org.springframework.cloud</groupId>
  12. <artifactId>spring-cloud-starter</artifactId>
  13. </dependency>
  14. <dependency>
  15. <groupId>org.springframework.cloud</groupId>
  16. <artifactId>spring-cloud-starter-config</artifactId>
  17. </dependency>
  18. <dependency>
  19. <groupId>org.springframework.boot</groupId>
  20. <artifactId>spring-boot-starter-web</artifactId>
  21. </dependency>
  22. <dependency>
  23. <groupId>org.springframework.boot</groupId>
  24. <artifactId>spring-boot-starter-actuator</artifactId>
  25. </dependency>
  26. </dependencies>
复制代码

application.yml

  1. server:
  2. port: 10000
  4. #sidecar:
  5. #port: 8000
  7. endpoints:
  8. restart:
  9. enabled: true
  10. shutdown:
  11. enabled: true
  12. health:
  13. sensitive: false
  16. zuul:
  17. ignored-services: "*"
  18. routes:
  19. product:
  20. path: /product/**
  21. url: http://product:9001/product
  22. recommend:
  23. path: /recommend/**
  24. url: http://recommend:9002/recommend
  25. review:
  26. path: /review/**
  27. url: http://review:9003/review
复制代码

bootstrap.yml

  1. spring:
  2. application:
  3. name: gateway
  4. cloud:
  5. config:
  6. uri: http://config:8888
  7. encrypt:
  8. failOnError: false
  10. eureka:
  11. instance:
  12. preferIpAddress: true
  13. client:
  14. registerWithEureka: true
  15. fetchRegistry: true
  16. serviceUrl:
  17. defaultZone: http://discovery:8761/eureka/
复制代码

application

  1. @SpringBootApplication
  2. @EnableCircuitBreaker
  3. @EnableDiscoveryClient
  4. @EnableZuulProxy
  5. public class ApiGatewayApplication {
  6. public static void main( String[] args ) {
  7. new SpringApplicationBuilder(ApiGatewayApplication.class).web(true).run(args);
  8. }
  9. }
复制代码

访问
http://192.168.99.100:10000/recommend?productId=1

转向
http://192.168.99.100:9002/recommend?productId=1

hystrix

http://192.168.99.100:9001/product/recommends?productId=1
http://192.168.99.100:9001/hystrix

http://192.168.99.100:9003/hystrix/monitor?stream=http%3A%2F%2F192.168.99.100%3A9001%2Fhystrix.stream

turbine

pom

  1. <dependencies>
  2. <dependency>
  3. <groupId>org.springframework.boot</groupId>
  4. <artifactId>spring-boot-starter-web</artifactId>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.springframework.cloud</groupId>
  8. <artifactId>spring-cloud-starter</artifactId>
  9. </dependency>
  10. <dependency>
  11. <groupId>org.springframework.cloud</groupId>
  12. <artifactId>spring-cloud-starter-turbine</artifactId>
  13. </dependency>
  14. <dependency>
  15. <groupId>org.springframework.boot</groupId>
  16. <artifactId>spring-boot-starter-actuator</artifactId>
  17. </dependency>
  18. <dependency>
  19. <groupId>org.springframework.cloud</groupId>
  20. <artifactId>spring-cloud-config-client</artifactId>
  21. </dependency>
  22. <dependency>
  23. <groupId>org.springframework.cloud</groupId>
  24. <artifactId>spring-cloud-starter-eureka</artifactId>
  25. </dependency>
  27. <!--使用hystrix-->
  28. <dependency>
  29. <groupId>org.springframework.cloud</groupId>
  30. <artifactId>spring-cloud-starter-hystrix</artifactId>
  31. </dependency>
  32. <dependency>
  33. <groupId>org.springframework.cloud</groupId>
  34. <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
  35. </dependency>
  37. </dependencies>
复制代码

application.yml

  1. server:
  2. port: 8889
  4. eureka:
  5. instance:
  6. preferIpAddress: true
  7. client:
  8. registerWithEureka: true
  9. fetchRegistry: true
  10. serviceUrl:
  11. defaultZone: http://discovery:8761/eureka/
  13. turbine:
  14. appConfig: product,review
  15. clusterNameExpression: new String("default")
复制代码

bootstrap.yml

  1. spring:
  2. application:
  3. name: turbine
  4. cloud:
  5. config:
  6. uri: http://config:8888
  7. encrypt:
  8. failOnError: false
复制代码

application

  1. @SpringCloudApplication
  2. @EnableTurbine
  3. @EnableHystrixDashboard
  4. public class TurbineApplication {
  5. public static void main(String[] args){
  6. SpringApplication.run(TurbineApplication.class,args);
  7. }
  8. }
复制代码

访问

http://192.168.99.100:9001/hystrix

http://192.168.99.100:9001/product/recommends?productId=1
http://192.168.99.100:9003/review/product/100

graphite配置

pom

  1. <dependencies>
  2. <dependency>
  3. <groupId>org.springframework.boot</groupId>
  4. <artifactId>spring-boot-starter-actuator</artifactId>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.springframework.boot</groupId>
  8. <artifactId>spring-boot-starter-test</artifactId>
  9. <scope>test</scope>
  10. </dependency>
  11. <!-- metrics -->
  12. <dependency>
  13. <groupId>io.dropwizard.metrics</groupId>
  14. <artifactId>metrics-core</artifactId>
  15. <version>${dropwizard-metrics.version}</version>
  16. </dependency>
  17. <dependency>
  18. <groupId>io.dropwizard.metrics</groupId>
  19. <artifactId>metrics-graphite</artifactId>
  20. <version>${dropwizard-metrics.version}</version>
  21. </dependency>
  22. <dependency>
  23. <groupId>io.dropwizard.metrics</groupId>
  24. <artifactId>metrics-annotation</artifactId>
  25. <version>${dropwizard-metrics.version}</version>
  26. </dependency>
  27. <dependency>
  28. <groupId>io.dropwizard.metrics</groupId>
  29. <artifactId>metrics-jvm</artifactId>
  30. <version>${dropwizard-metrics.version}</version>
  31. </dependency>
  33. <dependency>
  34. <groupId>com.ryantenney.metrics</groupId>
  35. <artifactId>metrics-spring</artifactId>
  36. <version>3.1.0</version>
  37. <exclusions>
  38. <exclusion>
  39. <artifactId>spring-beans</artifactId>
  40. <groupId>org.springframework</groupId>
  41. </exclusion>
  42. <exclusion>
  43. <artifactId>spring-aop</artifactId>
  44. <groupId>org.springframework</groupId>
  45. </exclusion>
  46. </exclusions>
  47. </dependency>
  49. </dependencies>
复制代码

configuration

  1. @Configuration
  2. @AutoConfigureAfter(MetricRepositoryAutoConfiguration.class)
  3. @ConditionalOnProperty(prefix = "graphite", name = "enabled", matchIfMissing = true)
  4. @EnableConfigurationProperties(GraphiteProperties.class)
  5. @EnableScheduling
  6. @EnableMetrics
  7. public class GraphiteAutoConfiguration {
  9. private static final Logger logger = LoggerFactory.getLogger(GraphiteAutoConfiguration.class);
  11. @Bean
  12. public MetricsConfigurerAdapter metricsConfigurerAdapter(final GraphiteProperties graphiteProperties) {
  13. return new GraphiteReportingManager(graphiteProperties);
  14. }
  16. /**
  17. * https://qbgbook.gitbooks.io/spring-boot-reference-guide-zh/content/IV.%20Spring%20Boot%20features/36.3.3.%20Property%20conditions.html
  18. * @param graphiteProperties
  19. * @param metricRegistry
  20. * @return
  21. */
  22. @Bean
  23. @ConditionalOnProperty(value = "graphite.host",matchIfMissing = true)
  24. public ConsoleReporter consoleReporter(GraphiteProperties graphiteProperties,MetricRegistry metricRegistry) {
  25. ConsoleReporter.Builder builder = ConsoleReporter.forRegistry(metricRegistry);
  26. ConsoleReporter reporter = builder.build();
  27. reporter.start(graphiteProperties.getReportInterval(), TimeUnit.MILLISECONDS);
  28. return reporter;
  29. }
  30. }
复制代码

report

  1. public class GraphiteReportingManager extends MetricsConfigurerAdapter implements DisposableBean {
  3. private final Logger logger = LoggerFactory.getLogger(getClass());
  5. private GraphiteProperties props;
  8. public GraphiteReportingManager(GraphiteProperties props) {
  9. this.props = props;
  10. }
  12. @Override
  13. public void configureReporters(MetricRegistry metricRegistry) {
  14. //gc的metrics,目前看来每秒发送一次貌似太频繁,可以另起一个reporter进行
  15. metricRegistry.register("jvm.gc", new GarbageCollectorMetricSet());
  16. metricRegistry.register("jvm.mem", new MemoryUsageGaugeSet());
  17. metricRegistry.register("jvm.thread-states", new ThreadStatesGaugeSet());
  19. logger.info("graphite host:{},port:{}", props.getHost(), props.getPort());
  20. GraphiteReporter reporter = GraphiteReporter.forRegistry(metricRegistry)
  21. .prefixedWith(props.getPrefix())
  22. // .convertRatesTo(TimeUnit.SECONDS)
  23. .convertDurationsTo(TimeUnit.MILLISECONDS)
  24. .filter(MetricFilter.ALL)
  25. .build(createSender(props));
  26. registerReporter(reporter);
  27. reporter.start(1L, TimeUnit.SECONDS);
  28. }
  30. @Override
  31. public void destroy() throws Exception {
  32. super.destroy();
  33. }
  35. private GraphiteSender createSender(GraphiteProperties props) {
  36. switch (props.getSenderType()) {
  37. case udp:
  38. return new GraphiteUDP(props.getHost(), props.getPort());
  39. case tcp:
  40. return new Graphite(props.getHost(), props.getPort());
  41. case pickled:
  42. return new PickledGraphite(props.getHost(), props.getPort());
  43. default:
  44. return new GraphiteUDP(props.getHost(), props.getPort());
  45. }
  46. }
  48. }
复制代码

访问

http://192.168.99.100:8070/

参考

Blog Series - Building Microservices

git.blog-microservices

exposing-jvm-metrics-in-spring-boot

git.spring-boot-jvm-monitoring-demo

exporting-to-graphite-with-the-prometheus-java-client

收藏 邀请
上一篇：号称史上最牛逼的几篇博客整理(python+java+js等)下一篇：java+lucene中文分词，搜索引擎搜词剖析

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-5-6 15:32

Copyright 2015-2025 djqfx

返回顶部