diff --git a/pictures/zipkin-detail.png b/pictures/zipkin-detail.png new file mode 100644 index 0000000..61a9259 Binary files /dev/null and b/pictures/zipkin-detail.png differ diff --git a/pictures/zipkin.png b/pictures/zipkin.png new file mode 100644 index 0000000..ae5007f Binary files /dev/null and b/pictures/zipkin.png differ diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/README.md b/spring-cloud/spring-cloud-sleuth-zipkin/README.md new file mode 100644 index 0000000..f097484 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/README.md @@ -0,0 +1,8 @@ +https://zipkin.io/pages/quickstart + +```$xslt +INFO [zuul,ecdee56c885e0d3b,ecdee56c885e0d3b,false] 16312 --- [nio-8090-exec-1] +INFO [zuul,ecdee56c885e0d3b,ecdee56c885e0d3b,false] 16312 --- [nio-8090-exec-1] +INFO [zuul,e2d282108f861cf4,e2d282108f861cf4,false] 16312 --- [nio-8090-exec-4] +INFO [zuul,e2d282108f861cf4,e2d282108f861cf4,false] 16312 --- [nio-8090-exec-4] +``` \ No newline at end of file diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/common/pom.xml b/spring-cloud/spring-cloud-sleuth-zipkin/common/pom.xml new file mode 100644 index 0000000..8353392 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/common/pom.xml @@ -0,0 +1,22 @@ + + + 4.0.0 + + + com.heibaiying.sleuth.zipkin + spring-cloud-sleuth-zipkin + 0.0.1-SNAPSHOT + + + common + + + + org.springframework.boot + spring-boot-starter-web + + + + + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/common/src/main/java/com/heibaiying/common/CommonApplication.java b/spring-cloud/spring-cloud-sleuth-zipkin/common/src/main/java/com/heibaiying/common/CommonApplication.java new file mode 100644 index 0000000..3675fb8 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/common/src/main/java/com/heibaiying/common/CommonApplication.java @@ -0,0 +1,14 @@ +package com.heibaiying.common; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +@SpringBootApplication +public class CommonApplication { + + public static void main(String[] args) { + SpringApplication.run(CommonApplication.class, args); + } + +} + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/common/src/main/java/com/heibaiying/common/bean/Product.java b/spring-cloud/spring-cloud-sleuth-zipkin/common/src/main/java/com/heibaiying/common/bean/Product.java new file mode 100644 index 0000000..75c3f5b --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/common/src/main/java/com/heibaiying/common/bean/Product.java @@ -0,0 +1,33 @@ +package com.heibaiying.common.bean; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.io.Serializable; +import java.util.Date; + +/** + * @author : heibaiying + * @description : 产品实体类 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +public class Product implements Serializable { + + // 产品序列号 + private long id; + + // 产品名称 + private String name; + + // 是否贵重品 + private Boolean isPrecious; + + //生产日期 + private Date dateInProduced; + + //产品价格 + private float price; +} diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/common/src/main/java/com/heibaiying/common/feign/ProductFeign.java b/spring-cloud/spring-cloud-sleuth-zipkin/common/src/main/java/com/heibaiying/common/feign/ProductFeign.java new file mode 100644 index 0000000..ddcb2e3 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/common/src/main/java/com/heibaiying/common/feign/ProductFeign.java @@ -0,0 +1,27 @@ +package com.heibaiying.common.feign; + +import com.heibaiying.common.bean.Product; +import org.springframework.web.bind.annotation.*; + +import java.util.List; + +/** + * @author : heibaiying + * @description : 声明式接口调用 + */ +public interface ProductFeign { + + @GetMapping("products") + List productList(); + + /** + * 这是需要强调的是使用feign时候@PathVariable一定要用value指明参数， + * 不然会抛出.IllegalStateException: PathVariable annotation was empty on param 异常 + */ + @GetMapping("product/{id}") + Product productDetail(@PathVariable(value = "id") int id); + + + @PostMapping("product") + void save(@RequestBody Product product); +} diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/common/src/test/java/com/heibaiying/common/CommonApplicationTests.java b/spring-cloud/spring-cloud-sleuth-zipkin/common/src/test/java/com/heibaiying/common/CommonApplicationTests.java new file mode 100644 index 0000000..b02d448 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/common/src/test/java/com/heibaiying/common/CommonApplicationTests.java @@ -0,0 +1,17 @@ +package com.heibaiying.common; + +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.test.context.junit4.SpringRunner; + +@RunWith(SpringRunner.class) +@SpringBootTest +public class CommonApplicationTests { + + @Test + public void contextLoads() { + } + +} + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/consumer/pom.xml b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/pom.xml new file mode 100644 index 0000000..966f514 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/pom.xml @@ -0,0 +1,55 @@ + + + 4.0.0 + + + com.heibaiying.sleuth.zipkin + spring-cloud-sleuth-zipkin + 0.0.1-SNAPSHOT + + + consumer + + + + org.springframework.boot + spring-boot-starter-web + + + org.springframework.cloud + spring-cloud-starter-netflix-eureka-client + + + org.springframework.boot + spring-boot-starter-freemarker + + + + org.springframework.cloud + spring-cloud-starter-openfeign + + + + com.heibaiying.sleuth.zipkin + common + 0.0.1-SNAPSHOT + compile + + + + org.springframework.cloud + spring-cloud-starter-zipkin + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/ConsumerApplication.java b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/ConsumerApplication.java new file mode 100644 index 0000000..8116bec --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/ConsumerApplication.java @@ -0,0 +1,18 @@ +package com.heibaiying.consumer; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.cloud.client.discovery.EnableDiscoveryClient; +import org.springframework.cloud.openfeign.EnableFeignClients; + +@SpringBootApplication +@EnableDiscoveryClient +@EnableFeignClients +public class ConsumerApplication { + + public static void main(String[] args) { + SpringApplication.run(ConsumerApplication.class, args); + } + +} + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/config/FeignConfig.java b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/config/FeignConfig.java new file mode 100644 index 0000000..e0ba1cc --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/config/FeignConfig.java @@ -0,0 +1,20 @@ +package com.heibaiying.consumer.config; + +import feign.Retryer; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import static java.util.concurrent.TimeUnit.SECONDS; + +/** + * @author : heibaiying + * @description : feign 配置 + */ +@Configuration +public class FeignConfig { + + @Bean + public Retryer retryer(){ + //重试间隔为 100ms，最大重试时间为 1s, 重试次数为 5 次 + return new Retryer.Default(100,SECONDS.toMillis(1),5); + } +} diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/controller/SellController.java b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/controller/SellController.java new file mode 100644 index 0000000..88cf933 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/controller/SellController.java @@ -0,0 +1,48 @@ +package com.heibaiying.consumer.controller; + + +import com.heibaiying.common.bean.Product; +import com.heibaiying.consumer.feign.CProductFeign; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Controller; +import org.springframework.ui.Model; +import org.springframework.web.bind.annotation.*; + +import java.util.Date; +import java.util.List; +import java.util.stream.Collectors; + +/** + * @author : heibaiying + */ +@Controller +@RequestMapping("sell") +public class SellController { + + @Autowired + private CProductFeign cproductFeign; + + @GetMapping("products") + public String productList(Model model) { + List products = cproductFeign.productList(); + model.addAttribute("products", products); + return "products"; + } + + + @GetMapping("product/{id}") + public String productDetail(@PathVariable int id, Model model) { + Product product = cproductFeign.productDetail(id); + model.addAttribute("product", product); + return "product"; + } + + + @PostMapping("product") + public String save(@RequestParam String productName) { + long id = Math.round(Math.random() * 100); + Product product = new Product(id, productName, false, new Date(), 88); + cproductFeign.save(product); + return "redirect:products"; + } +} diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/feign/CProductFeign.java b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/feign/CProductFeign.java new file mode 100644 index 0000000..9dcbff5 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/feign/CProductFeign.java @@ -0,0 +1,15 @@ +package com.heibaiying.consumer.feign; + +import com.heibaiying.common.feign.ProductFeign; +import com.heibaiying.consumer.config.FeignConfig; +import com.heibaiying.consumer.feign.impl.CProductFeignImpl; +import org.springframework.cloud.openfeign.FeignClient; + +/** + * @author : heibaiying + * @description : 声明式接口调用 + */ +@FeignClient(value = "producer",configuration = FeignConfig.class,fallback = CProductFeignImpl.class) +public interface CProductFeign extends ProductFeign { + +} diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/feign/impl/CProductFeignImpl.java b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/feign/impl/CProductFeignImpl.java new file mode 100644 index 0000000..8196a8e --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/java/com/heibaiying/consumer/feign/impl/CProductFeignImpl.java @@ -0,0 +1,31 @@ +package com.heibaiying.consumer.feign.impl; + +import com.heibaiying.common.bean.Product; +import com.heibaiying.consumer.feign.CProductFeign; +import org.springframework.stereotype.Component; + +import java.util.ArrayList; +import java.util.List; + +/** + * @author : heibaiying + * @description : 定义发生错误时候的熔断处理。除了继承自CProductFeign,还需要用@Component声明为spring的组件 + */ +@Component +public class CProductFeignImpl implements CProductFeign { + + @Override + public List productList() { + return new ArrayList<>(); + } + + @Override + public Product productDetail(int id) { + return null; + } + + @Override + public void save(Product product) { + + } +} diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/resources/application.yml b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/resources/application.yml new file mode 100644 index 0000000..c7d0fdc --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/resources/application.yml @@ -0,0 +1,18 @@ +server: + port: 8080 +# 指定服务命名 +spring: + application: + name: consumer + # 指定zipkin地址 默认就是http://localhost:9411/ + zipkin: + base-url: http://localhost:9411/ +# 指定注册中心地址 +eureka: + client: + serviceUrl: + defaultZone: http://localhost:8010/eureka/ +feign: + hystrix: + # 如果为true，则OpenFign客户端将使用Hystrix断路器进行封装 默认为false + enabled: true \ No newline at end of file diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/resources/templates/product.ftl b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/resources/templates/product.ftl new file mode 100644 index 0000000..729f516 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/resources/templates/product.ftl @@ -0,0 +1,15 @@ + + + + 产品详情 + + +
    +
  • 产品名称:${product.name}
    • +
  • 产品序列号:${product.id}
    • +
  • 是否贵重品:${product.isPrecious?string('是','否')}
    • +
  • 生产日期: ${product.dateInProduced?string("yyyy-MM-dd HH:mm:ss")}
    • +
  • 产品价格:${product.price}
    • +
+ + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/resources/templates/products.ftl b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/resources/templates/products.ftl new file mode 100644 index 0000000..c83dc5d --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/main/resources/templates/products.ftl @@ -0,0 +1,24 @@ + + + + 产品列表 + + +

产品列表:点击查看详情

+
+ + +
+
    + <#if (products?size>0) > + <#list products as product> +
  • + ${product.name} +
    • + + <#else> +

    当前排队人数过多，请之后再购买！

    + +
+ + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/test/java/com/heibaiying/consumer/ConsumerApplicationTests.java b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/test/java/com/heibaiying/consumer/ConsumerApplicationTests.java new file mode 100644 index 0000000..82f5399 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/consumer/src/test/java/com/heibaiying/consumer/ConsumerApplicationTests.java @@ -0,0 +1,17 @@ +package com.heibaiying.consumer; + +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.test.context.junit4.SpringRunner; + +@RunWith(SpringRunner.class) +@SpringBootTest +public class ConsumerApplicationTests { + + @Test + public void contextLoads() { + } + +} + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/eureka/pom.xml b/spring-cloud/spring-cloud-sleuth-zipkin/eureka/pom.xml new file mode 100644 index 0000000..e126c96 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/eureka/pom.xml @@ -0,0 +1,31 @@ + + + 4.0.0 + + + com.heibaiying.sleuth.zipkin + spring-cloud-sleuth-zipkin + 0.0.1-SNAPSHOT + + + eureka + + + + org.springframework.cloud + spring-cloud-starter-netflix-eureka-server + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + + + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/eureka/src/main/java/com/heibaiying/eureka/EurekaApplication.java b/spring-cloud/spring-cloud-sleuth-zipkin/eureka/src/main/java/com/heibaiying/eureka/EurekaApplication.java new file mode 100644 index 0000000..bd54938 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/eureka/src/main/java/com/heibaiying/eureka/EurekaApplication.java @@ -0,0 +1,16 @@ +package com.heibaiying.eureka; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; + +@SpringBootApplication +@EnableEurekaServer +public class EurekaApplication { + + public static void main(String[] args) { + SpringApplication.run(EurekaApplication.class, args); + } + +} + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/eureka/src/main/resources/application.yml b/spring-cloud/spring-cloud-sleuth-zipkin/eureka/src/main/resources/application.yml new file mode 100644 index 0000000..817356d --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/eureka/src/main/resources/application.yml @@ -0,0 +1,12 @@ +server: + port: 8010 +eureka: + instance: + hostname: localhost + client: + # 设置为false,代表不向注册中心注册自己 + register-with-eureka: false + # 注册中心主要用于维护服务，并不需要检索服务，所以设置为false + fetch-registry: false + serviceUrl: + defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ \ No newline at end of file diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/eureka/src/test/java/com/heibaiying/eureka/EurekaApplicationTests.java b/spring-cloud/spring-cloud-sleuth-zipkin/eureka/src/test/java/com/heibaiying/eureka/EurekaApplicationTests.java new file mode 100644 index 0000000..b3e2d73 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/eureka/src/test/java/com/heibaiying/eureka/EurekaApplicationTests.java @@ -0,0 +1,17 @@ +package com.heibaiying.eureka; + +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.test.context.junit4.SpringRunner; + +@RunWith(SpringRunner.class) +@SpringBootTest +public class EurekaApplicationTests { + + @Test + public void contextLoads() { + } + +} + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/pom.xml b/spring-cloud/spring-cloud-sleuth-zipkin/pom.xml new file mode 100644 index 0000000..961a97c --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/pom.xml @@ -0,0 +1,64 @@ + + + 4.0.0 + pom + + + org.springframework.boot + spring-boot-starter-parent + 2.1.2.RELEASE + + + + com.heibaiying.sleuth.zipkin + spring-cloud-sleuth-zipkin + 0.0.1-SNAPSHOT + spring-cloud-zuul + zuul project for Spring Boot + + + eureka + common + consumer + producer + + + + 1.8 + Finchley.SR2 + + + + + org.springframework.boot + spring-boot-starter + + + + org.projectlombok + lombok + true + + + org.springframework.boot + spring-boot-starter-test + test + + + + + + + org.springframework.cloud + spring-cloud-dependencies + ${spring-cloud.version} + pom + import + + + + + + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/producer/pom.xml b/spring-cloud/spring-cloud-sleuth-zipkin/producer/pom.xml new file mode 100644 index 0000000..eda5f83 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/producer/pom.xml @@ -0,0 +1,48 @@ + + + 4.0.0 + + + com.heibaiying.sleuth.zipkin + spring-cloud-sleuth-zipkin + 0.0.1-SNAPSHOT + + + producer + + + + org.springframework.boot + spring-boot-starter-web + + + org.springframework.cloud + spring-cloud-starter-netflix-eureka-client + + + + com.heibaiying.sleuth.zipkin + common + 0.0.1-SNAPSHOT + compile + + + + org.springframework.cloud + spring-cloud-starter-zipkin + + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + + + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/ProducerApplication.java b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/ProducerApplication.java new file mode 100644 index 0000000..cb8e8fc --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/ProducerApplication.java @@ -0,0 +1,16 @@ +package com.heibaiying.producer; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.cloud.client.discovery.EnableDiscoveryClient; + +@SpringBootApplication +@EnableDiscoveryClient +public class ProducerApplication { + + public static void main(String[] args) { + SpringApplication.run(ProducerApplication.class, args); + } + +} + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/controller/ProducerController.java b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/controller/ProducerController.java new file mode 100644 index 0000000..7827491 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/controller/ProducerController.java @@ -0,0 +1,35 @@ +package com.heibaiying.producer.controller; + + +import com.heibaiying.common.bean.Product; +import com.heibaiying.common.feign.ProductFeign; +import com.heibaiying.producer.service.IProductService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import java.util.List; + +/** + * @author : heibaiying + */ +@RestController +public class ProducerController implements ProductFeign { + + @Autowired + private IProductService productService; + + @GetMapping("products") + public List productList() { + return productService.queryAllProducts(); + } + + @GetMapping("product/{id}") + public Product productDetail(@PathVariable int id) { + return productService.queryProductById(id); + } + + @PostMapping("product") + public void save(@RequestBody Product product) { + productService.saveProduct(product); + } +} diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/service/IProductService.java b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/service/IProductService.java new file mode 100644 index 0000000..0a55013 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/service/IProductService.java @@ -0,0 +1,13 @@ +package com.heibaiying.producer.service; + +import com.heibaiying.common.bean.Product; + +import java.util.List; +public interface IProductService { + + Product queryProductById(int id) ; + + List queryAllProducts(); + + void saveProduct(Product product); +} diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/service/impl/ProductService.java b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/service/impl/ProductService.java new file mode 100644 index 0000000..caef1cf --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/java/com/heibaiying/producer/service/impl/ProductService.java @@ -0,0 +1,44 @@ +package com.heibaiying.producer.service.impl; + +import com.heibaiying.common.bean.Product; +import com.heibaiying.producer.service.IProductService; +import org.springframework.boot.web.context.WebServerInitializedEvent; +import org.springframework.context.ApplicationListener; +import org.springframework.stereotype.Service; + +import java.util.ArrayList; +import java.util.Date; +import java.util.List; +import java.util.stream.Collectors; + +/** + * @author : heibaiying + * @description : 产品提供接口实现类 + */ +@Service +public class ProductService implements IProductService, ApplicationListener { + + private static List productList = new ArrayList<>(); + + public Product queryProductById(int id) { + return productList.stream().filter(p->p.getId()==id).collect(Collectors.toList()).get(0); + } + + + public List queryAllProducts() { + return productList; + } + + @Override + public void saveProduct(Product product) { + productList.add(product); + } + + @Override + public void onApplicationEvent(WebServerInitializedEvent event) { + int port = event.getWebServer().getPort(); + for (long i = 0; i < 20; i++) { + productList.add(new Product(i, port + "产品" + i, i / 2 == 0, new Date(), 66.66f * i)); + } + } +} \ No newline at end of file diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/resources/application.yml b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/resources/application.yml new file mode 100644 index 0000000..3471fdb --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/main/resources/application.yml @@ -0,0 +1,13 @@ +server: + port: 8020 +# 指定服务命名 +spring: + application: + name: producer + zipkin: + base-url: http://localhost:9411/ +# 指定注册中心地址 +eureka: + client: + serviceUrl: + defaultZone: http://localhost:8010/eureka/ diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/test/java/com/heibaiying/producer/ProducerApplicationTests.java b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/test/java/com/heibaiying/producer/ProducerApplicationTests.java new file mode 100644 index 0000000..54cac2d --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/producer/src/test/java/com/heibaiying/producer/ProducerApplicationTests.java @@ -0,0 +1,17 @@ +package com.heibaiying.producer; + +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.test.context.junit4.SpringRunner; + +@RunWith(SpringRunner.class) +@SpringBootTest +public class ProducerApplicationTests { + + @Test + public void contextLoads() { + } + +} + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/zuul/pom.xml b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/pom.xml new file mode 100644 index 0000000..32177ba --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/pom.xml @@ -0,0 +1,74 @@ + + + 4.0.0 + + + + org.springframework.boot + spring-boot-starter-parent + 2.0.8.RELEASE + + + + zuul + + + 1.8 + Finchley.SR2 + + + + + org.springframework.boot + spring-boot-starter-web + + + org.springframework.boot + spring-boot-starter-freemarker + + + org.springframework.boot + spring-boot-starter-test + test + + + + org.springframework.cloud + spring-cloud-starter-netflix-eureka-client + + + + org.springframework.cloud + spring-cloud-starter-netflix-zuul + + + + org.springframework.cloud + spring-cloud-starter-zipkin + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + + + + + + org.springframework.cloud + spring-cloud-dependencies + ${spring-cloud.version} + pom + import + + + + + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/ZuulApplication.java b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/ZuulApplication.java new file mode 100644 index 0000000..ba19b9d --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/ZuulApplication.java @@ -0,0 +1,18 @@ +package com.heibaiying.zuul; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.cloud.client.discovery.EnableDiscoveryClient; +import org.springframework.cloud.netflix.zuul.EnableZuulProxy; + +@SpringBootApplication +@EnableZuulProxy +@EnableDiscoveryClient +public class ZuulApplication { + + public static void main(String[] args) { + SpringApplication.run(ZuulApplication.class, args); + } + +} + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/config/CustomZuulFallbackProvider.java b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/config/CustomZuulFallbackProvider.java new file mode 100644 index 0000000..0955398 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/config/CustomZuulFallbackProvider.java @@ -0,0 +1,81 @@ +package com.heibaiying.zuul.config; + +import org.springframework.cloud.netflix.zuul.filters.route.FallbackProvider; +import org.springframework.http.HttpHeaders; +import org.springframework.http.HttpStatus; +import org.springframework.http.MediaType; +import org.springframework.http.client.ClientHttpResponse; +import org.springframework.stereotype.Component; + +import java.io.ByteArrayInputStream; +import java.io.IOException; +import java.io.InputStream; + +/** + * @author : heibaiying + * @description : zuul 的熔断器 + */ +@Component +public class CustomZuulFallbackProvider implements FallbackProvider { + + /* + * 定义熔断将用于哪些路由的服务 + */ + @Override + public String getRoute() { + return "consumer"; + } + + @Override + public ClientHttpResponse fallbackResponse(String route, Throwable cause) { + return new ClientHttpResponse() { + + /** + * 返回响应的HTTP状态代码 + */ + @Override + public HttpStatus getStatusCode() throws IOException { + return HttpStatus.SERVICE_UNAVAILABLE; + } + + /** + * 返回HTTP状态代码 + */ + @Override + public int getRawStatusCode() throws IOException { + return HttpStatus.SERVICE_UNAVAILABLE.value(); + } + + /** + * 返回响应的HTTP状态文本 + */ + @Override + public String getStatusText() throws IOException { + return HttpStatus.SERVICE_UNAVAILABLE.getReasonPhrase(); + } + + @Override + public void close() { + + } + + /** + * 将消息正文作为输入流返回 + */ + @Override + public InputStream getBody() throws IOException { + return new ByteArrayInputStream("商城崩溃了,请稍后重试！".getBytes()); + } + + /** + * 将消息正文作为输入流返回 + */ + @Override + public HttpHeaders getHeaders() { + HttpHeaders httpHeaders = new HttpHeaders(); + httpHeaders.setContentType(MediaType.APPLICATION_JSON_UTF8); + return httpHeaders; + } + }; + } +} diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/controller/LoginController.java b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/controller/LoginController.java new file mode 100644 index 0000000..0c5d75d --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/controller/LoginController.java @@ -0,0 +1,26 @@ +package com.heibaiying.zuul.controller; + +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.RequestMapping; + +import javax.servlet.http.HttpSession; +import java.util.Random; + +/** + * @author : heibaiying + * @description : 登录 + */ +@Controller +public class LoginController { + + @RequestMapping("index") + public String login(){ + return "index"; + } + + @RequestMapping("login") + public String login(String username,HttpSession session){ + session.setAttribute("code",username+String.valueOf(new Random().nextInt(10*1000))); + return "redirect:/consumer/sell/products"; + } +} diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/filter/CustomZuulFilter.java b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/filter/CustomZuulFilter.java new file mode 100644 index 0000000..70c9036 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/java/com/heibaiying/zuul/filter/CustomZuulFilter.java @@ -0,0 +1,71 @@ +package com.heibaiying.zuul.filter; + +import com.netflix.zuul.ZuulFilter; +import com.netflix.zuul.context.RequestContext; +import com.netflix.zuul.exception.ZuulException; +import org.omg.CORBA.Request; +import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants; +import org.springframework.http.HttpStatus; +import org.springframework.stereotype.Component; +import org.springframework.util.StringUtils; + +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import java.io.IOException; + +/** + * @author : heibaiying + * @description : 自定义filter过滤器 + */ + +@Component +public class CustomZuulFilter extends ZuulFilter { + + /** + * 返回过滤器的类型 + */ + @Override + public String filterType() { + return FilterConstants.PRE_TYPE; + } + + /** + * 返回过滤器的优先级顺序 + */ + @Override + public int filterOrder() { + return 0; + } + + /** + * 从此方法返回“true”意味着应该调用下面的 run（）方法 + */ + @Override + public boolean shouldFilter() { + return true; + } + + /** + * ZuulFilter的核心校验方法 + */ + @Override + public Object run() throws ZuulException { + RequestContext currentContext = RequestContext.getCurrentContext(); + HttpServletRequest request = currentContext.getRequest(); + String code = (String)request.getSession().getAttribute("code"); + if (StringUtils.isEmpty(code)){ + // 设置值为false 不将请求转发到对应的服务上 + currentContext.setSendZuulResponse(false); + // 设置返回的状态码 + currentContext.setResponseStatusCode(HttpStatus.NON_AUTHORITATIVE_INFORMATION.value()); + HttpServletResponse response = currentContext.getResponse(); + try { + // 跳转到登录页面 + response.sendRedirect("/index"); + } catch (IOException e) { + e.printStackTrace(); + } + } + return null; + } +} diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/resources/application.yml b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/resources/application.yml new file mode 100644 index 0000000..239f795 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/resources/application.yml @@ -0,0 +1,25 @@ +server: + port: 8090 +# 指定服务命名 +spring: + application: + name: zuul + zipkin: + base-url: http://localhost:9411/ +# 指定注册中心地址 +eureka: + client: + serviceUrl: + defaultZone: http://localhost:8010/eureka/ +# 网关的路由 +zuul: + routes: + xxxx: #这个地方的值是可以任意的字符串 + path: /producer/** + serviceId: producer + consumer: + path: /consumer/** + serviceId: consumer + # 指定前缀 + # prefix: /v1 + diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/resources/templates/index.ftl b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/resources/templates/index.ftl new file mode 100644 index 0000000..a6e2308 --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/main/resources/templates/index.ftl @@ -0,0 +1,12 @@ + + + + Title + + +
+ + +
+ + \ No newline at end of file diff --git a/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/test/java/com/heibaiying/zuul/ZuulApplicationTests.java b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/test/java/com/heibaiying/zuul/ZuulApplicationTests.java new file mode 100644 index 0000000..488c93a --- /dev/null +++ b/spring-cloud/spring-cloud-sleuth-zipkin/zuul/src/test/java/com/heibaiying/zuul/ZuulApplicationTests.java @@ -0,0 +1,17 @@ +package com.heibaiying.zuul; + +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.test.context.junit4.SpringRunner; + +@RunWith(SpringRunner.class) +@SpringBootTest +public class ZuulApplicationTests { + + @Test + public void contextLoads() { + } + +} + diff --git a/spring-cloud/spring-cloud-stream/pom.xml b/spring-cloud/spring-cloud-stream/pom.xml new file mode 100644 index 0000000..01f606d --- /dev/null +++ b/spring-cloud/spring-cloud-stream/pom.xml @@ -0,0 +1,72 @@ + + + 4.0.0 + + org.springframework.boot + spring-boot-starter-parent + 2.0.8.RELEASE + + + com.heibaiying.stream + spring-cloud-stream + 0.0.1-SNAPSHOT + spring-cloud-stream + spring cloud stream project for Spring Boot + + + 1.8 + Finchley.SR2 + + + + + + org.springframework.boot + spring-boot-starter-amqp + + + org.springframework.cloud + spring-cloud-starter-stream-rabbit + + + org.springframework.boot + spring-boot-starter-web + + + + org.projectlombok + lombok + true + + + org.springframework.boot + spring-boot-starter-test + test + + + + + + + + org.springframework.cloud + spring-cloud-dependencies + ${spring-cloud.version} + pom + import + + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + + + diff --git a/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/SpringCloudStreamApplication.java b/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/SpringCloudStreamApplication.java new file mode 100644 index 0000000..7addbf5 --- /dev/null +++ b/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/SpringCloudStreamApplication.java @@ -0,0 +1,14 @@ +package com.heibaiying.stream; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +@SpringBootApplication +public class SpringCloudStreamApplication { + + public static void main(String[] args) { + SpringApplication.run(SpringCloudStreamApplication.class, args); + } + +} + diff --git a/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/bean/Programmer.java b/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/bean/Programmer.java new file mode 100644 index 0000000..a098dc9 --- /dev/null +++ b/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/bean/Programmer.java @@ -0,0 +1,23 @@ +package com.heibaiying.stream.bean; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; + +import java.io.Serializable; +import java.util.Date; + +@Data +@AllArgsConstructor +@NoArgsConstructor +public class Programmer implements Serializable { + + private String name; + + private int age; + + private float salary; + + private Date birthday; +} diff --git a/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/controller/MessageController.java b/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/controller/MessageController.java new file mode 100644 index 0000000..e7207da --- /dev/null +++ b/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/controller/MessageController.java @@ -0,0 +1,78 @@ +package com.heibaiying.stream.controller; + +import com.heibaiying.stream.bean.Programmer; +import com.heibaiying.stream.stream.Custom; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.messaging.Message; +import org.springframework.messaging.MessageHeaders; +import org.springframework.messaging.support.MessageBuilder; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.Date; +import java.util.HashMap; +import java.util.Map; + +/** + * @author : heibaiying + * @description : 发送测试消息 + */ +@RestController +public class MessageController { + + @Autowired + private Custom custom; + + /*** + * 发送简单消息 + */ + @RequestMapping("sendSimpleMessage") + public void sendSimpleMessage() { + custom.input().send(MessageBuilder.withPayload("hell spring cloud stream").build()); + } + + + /*** + * 发送消息体为对象的消息 + * + */ + @RequestMapping("sendObject") + public void sendObject() { + Programmer programmer=new Programmer("pro",12,212.2f,new Date()); + custom.input().send(MessageBuilder.withPayload(programmer).build()); + } + + /** + * 发送带有消息头的消息 + */ + @RequestMapping("sendWithHeads") + public void sendWithHeads() { + Programmer programmer=new Programmer("pro",12,212.2f,new Date()); + Map map=new HashMap<>(); + map.put("code","868686"); + MessageHeaders messageHeaders=new MessageHeaders(map); + Message message= MessageBuilder.createMessage(programmer,messageHeaders); + custom.input().send(message); + } + + /** + * 条件消息 可以看做是消息路由键的一种实现 + */ + @RequestMapping("sendWithKey") + public void sendWithKey() { + // 创建消息头key 为 01 的消息 + Programmer programmer=new Programmer("key01",12,212.2f,new Date()); + Map map=new HashMap<>(); + map.put("key","01"); + MessageHeaders messageHeaders=new MessageHeaders(map); + Message message= MessageBuilder.createMessage(programmer,messageHeaders); + custom.input().send(message); + + // 创建消息头key 为 02 的消息 + programmer.setName("key02"); + map.put("key","02"); + MessageHeaders messageHeaders02=new MessageHeaders(map); + Message message02= MessageBuilder.createMessage(programmer,messageHeaders02); + custom.input().send(message02); + } +} diff --git a/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/stream/Custom.java b/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/stream/Custom.java new file mode 100644 index 0000000..edf972e --- /dev/null +++ b/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/stream/Custom.java @@ -0,0 +1,22 @@ +package com.heibaiying.stream.stream; + +import org.springframework.cloud.stream.annotation.Input; +import org.springframework.cloud.stream.annotation.Output; +import org.springframework.messaging.MessageChannel; +import org.springframework.messaging.SubscribableChannel; + +/** + * @author : heibaiying + */ +public interface Custom { + + String INPUT = "input"; + String OUTPUT = "output"; + + @Input(Custom.INPUT) + SubscribableChannel input(); + + @Output(Custom.OUTPUT) + MessageChannel output(); + +} diff --git a/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/stream/StreamReceived.java b/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/stream/StreamReceived.java new file mode 100644 index 0000000..55f100d --- /dev/null +++ b/spring-cloud/spring-cloud-stream/src/main/java/com/heibaiying/stream/stream/StreamReceived.java @@ -0,0 +1,62 @@ +package com.heibaiying.stream.stream; + +import com.heibaiying.stream.bean.Programmer; +import lombok.extern.slf4j.Slf4j; +import org.springframework.cloud.stream.annotation.EnableBinding; +import org.springframework.cloud.stream.annotation.StreamListener; +import org.springframework.messaging.handler.annotation.Header; +import org.springframework.messaging.handler.annotation.Headers; +import org.springframework.messaging.handler.annotation.Payload; +import org.springframework.stereotype.Component; + +import java.util.Map; + +/** + * @author : heibaiying + * @description :消息的监听 + */ + +@Component +@EnableBinding(Custom.class) +@Slf4j +public class StreamReceived { + + @StreamListener(value = Custom.INPUT) + public void simple(Object payload) { + log.info("收到简单消息: {}", payload); + } + + @StreamListener(value = Custom.INPUT) + public void object(Programmer programmer) { + log.info("收到对象消息: {}", programmer); + } + + /** + * 用 @Header 监听时候需要注意，指定名称的属性必须在消息头中存在 不然就会抛出异常 MessageHandlingException: Missing header 'XXXX' for method parameter type [class java.lang.String] + */ + @StreamListener(value = Custom.INPUT) + public void heads(@Payload Programmer programmer, @Headers Map map, @Header(name = "code") String code) { + log.info("收到对象消息: {}", programmer); + map.forEach((key, value) -> { + log.info("消息头{}的值为{}", key, value); + }); + log.info("绑定指定消息头: code = {}", code); + } + + + /** + * 监听消息头key = 01 的消息 + */ + @StreamListener(target = Custom.INPUT, condition = "headers['key']=='01'") + public void key01(@Payload Programmer programmer) { + log.info("key01 监听器接收到消息: {}", programmer.getName()); + } + + /** + * 监听消息头key = 02 的消息 + */ + @StreamListener(target = Custom.INPUT, condition = "headers['key']=='01'") + public void key02(@Payload Programmer programmer) { + log.info("key02 监听器接收到消息: {}", programmer.getName()); + } +} diff --git a/spring-cloud/spring-cloud-stream/src/main/resources/application.yml b/spring-cloud/spring-cloud-stream/src/main/resources/application.yml new file mode 100644 index 0000000..37bb938 --- /dev/null +++ b/spring-cloud/spring-cloud-stream/src/main/resources/application.yml @@ -0,0 +1,6 @@ +spring: + rabbitmq: + host: localhost + port: 5672 + username: guest + password: guest \ No newline at end of file diff --git a/spring-cloud/spring-cloud-stream/src/test/java/com/heibaiying/stream/SpringCloudStreamApplicationTests.java b/spring-cloud/spring-cloud-stream/src/test/java/com/heibaiying/stream/SpringCloudStreamApplicationTests.java new file mode 100644 index 0000000..2efa878 --- /dev/null +++ b/spring-cloud/spring-cloud-stream/src/test/java/com/heibaiying/stream/SpringCloudStreamApplicationTests.java @@ -0,0 +1,17 @@ +package com.heibaiying.stream; + +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.test.context.junit4.SpringRunner; + +@RunWith(SpringRunner.class) +@SpringBootTest +public class SpringCloudStreamApplicationTests { + + @Test + public void contextLoads() { + } + +} +