增加 spring cloud 用例

spring-cloud/spring-cloud-eureka-cluster/eureka-client/pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <parent>
-        <groupId>com.heibaiying</groupId>
+        <groupId>com.heibaiying.eureka.cluster</groupId>
         <artifactId>eureka-cluster</artifactId>
         <version>0.0.1-SNAPSHOT</version>
     </parent>

spring-cloud/spring-cloud-eureka-cluster/eureka-server/pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <parent>
-        <groupId>com.heibaiying</groupId>
+        <groupId>com.heibaiying.eureka.cluster</groupId>
         <artifactId>eureka-cluster</artifactId>
         <version>0.0.1-SNAPSHOT</version>
     </parent>

spring-cloud/spring-cloud-eureka-cluster/pom.xml

@@ -11,7 +11,7 @@
         <relativePath/> <!-- lookup parent from repository -->
     </parent>
 
-    <groupId>com.heibaiying</groupId>
+    <groupId>com.heibaiying.eureka.cluster</groupId>
     <artifactId>eureka-cluster</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <name>eureka-cluster</name>

spring-cloud/spring-cloud-eureka/eureka-client/pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <parent>
-        <groupId>com.heibaiying</groupId>
+        <groupId>com.heibaiying.eureka</groupId>
         <artifactId>eureka</artifactId>
         <version>0.0.1-SNAPSHOT</version>
     </parent>

spring-cloud/spring-cloud-eureka/eureka-server/pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <parent>
-        <groupId>com.heibaiying</groupId>
+        <groupId>com.heibaiying.eureka</groupId>
         <artifactId>eureka</artifactId>
         <version>0.0.1-SNAPSHOT</version>
     </parent>

spring-cloud/spring-cloud-eureka/pom.xml

@@ -11,7 +11,7 @@
         <relativePath/> <!-- lookup parent from repository -->
     </parent>
 
-    <groupId>com.heibaiying</groupId>
+    <groupId>com.heibaiying.eureka</groupId>
     <artifactId>eureka</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <name>eureka</name>

spring-cloud/spring-cloud-feign/common/src/main/java/com/heibaiying/common/bean/Product.java

@@ -17,7 +17,7 @@ import java.util.Date;
 public class Product implements Serializable {
 
     // 产品序列号
-    private int id;
+    private long id;
 
     // 产品名称
     private String name;

spring-cloud/spring-cloud-feign/common/src/main/java/com/heibaiying/common/feign/ProductFeign.java

@@ -1,8 +1,7 @@
 package com.heibaiying.common.feign;
 
 import com.heibaiying.common.bean.Product;
-import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.RequestMapping;
 
 import java.util.List;
 
@@ -12,13 +11,17 @@ import java.util.List;
  */
 public interface ProductFeign {
 
-    @RequestMapping("products")
+    @GetMapping("products")
     List<Product> productList();
 
     /**
      * 这是需要强调的是使用feign时候@PathVariable一定要用value指明参数，
      * 不然会抛出.IllegalStateException: PathVariable annotation was empty on param 异常
      */
-    @RequestMapping("product/{id}")
+    @GetMapping("product/{id}")
     Product productDetail(@PathVariable(value = "id") int id);
+
+
+    @PostMapping("product")
+    void save(@RequestBody Product product);
 }

spring-cloud/spring-cloud-feign/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);
+    }
+}

spring-cloud/spring-cloud-feign/consumer/src/main/java/com/heibaiying/consumer/controller/SellController.java

@@ -6,9 +6,9 @@ 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.PathVariable;
+import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.RequestMapping;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -21,17 +21,26 @@ public class SellController {
     @Autowired
     private CProductFeign cproductFeign;
 
-    @RequestMapping
+    @GetMapping("products")
     public String productList(Model model) {
         List<Product> products = cproductFeign.productList();
         model.addAttribute("products", products);
         return "products";
     }
 
-    @RequestMapping("product/{id}")
+    @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";
+    }
 }

spring-cloud/spring-cloud-feign/consumer/src/main/java/com/heibaiying/consumer/feign/CProductFeign.java

@@ -1,13 +1,14 @@
 package com.heibaiying.consumer.feign;
 
 import com.heibaiying.common.feign.ProductFeign;
+import com.heibaiying.consumer.config.FeignConfig;
 import org.springframework.cloud.openfeign.FeignClient;
 
 /**
  * @author : heibaiying
  * @description : 声明式接口调用
  */
-@FeignClient("producer")
+@FeignClient(value = "producer",configuration = FeignConfig.class)
 public interface CProductFeign extends ProductFeign {
 
 }

spring-cloud/spring-cloud-feign/consumer/src/main/resources/application.yml

@@ -1,5 +1,5 @@
 server:
-  port: 8030
+  port: 8080
 # 指定服务命名
 spring:
   application:

spring-cloud/spring-cloud-feign/consumer/src/main/resources/templates/products.ftl

@@ -5,10 +5,14 @@
 </head>
 <body>
 <h3>产品列表:点击查看详情</h3>
+<form action="/sell/product" method="post">
+    <input type="text" name="productName">
+    <input type="submit" value="新增产品">
+</form>
 <ul>
     <#list products as product>
         <li>
-           <a href="sell/product/${product.id}">${product.name}</a>
+            <a href="/sell/product/${product.id}">${product.name}</a>
         </li>
     </#list>
 </ul>

spring-cloud/spring-cloud-feign/producer/src/main/java/com/heibaiying/producer/controller/ProducerController.java

@@ -5,9 +5,7 @@ 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.PathVariable;
+import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
 
 import java.util.List;
 
@@ -15,18 +13,23 @@ import java.util.List;
  * @author : heibaiying
  */
 @RestController
-public class ProducerController{
+public class ProducerController implements ProductFeign {
 
     @Autowired
     private IProductService productService;
 
-    @RequestMapping("products")
+    @GetMapping("products")
     public List<Product> productList() {
         return productService.queryAllProducts();
     }
 
-    @RequestMapping("product/{id}")
+    @GetMapping("product/{id}")
     public Product productDetail(@PathVariable int id) {
         return productService.queryProductById(id);
     }
+
+    @PostMapping("product")
+    public void save(@RequestBody Product product) {
+        productService.saveProduct(product);
+    }
 }

spring-cloud/spring-cloud-feign/producer/src/main/java/com/heibaiying/producer/service/IProductService.java

@@ -8,4 +8,6 @@ public interface IProductService {
     Product queryProductById(int id) ;
 
     List<Product> queryAllProducts();
+
+    void saveProduct(Product product);
 }

spring-cloud/spring-cloud-feign/producer/src/main/java/com/heibaiying/producer/service/impl/ProductService.java

@@ -2,6 +2,8 @@ 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;
@@ -13,16 +15,10 @@ import java.util.List;
  * @description : 产品提供接口实现类
  */
 @Service
-public class ProductService implements IProductService {
+public class ProductService implements IProductService, ApplicationListener<WebServerInitializedEvent> {
 
     private static List<Product> productList = new ArrayList<>();
 
-    static {
-        for (int i = 0; i < 20; i++) {
-            productList.add(new Product(i, "产品" + i, i / 2 == 0, new Date(), 66.66f * i));
-        }
-    }
-
     public Product queryProductById(int id) {
         for (Product product : productList) {
             if (product.getId() == id) {
@@ -36,4 +32,17 @@ public class ProductService implements IProductService {
     public List<Product> 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));
+        }
+    }
 }

spring-cloud/spring-cloud-ribbon/common/pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <parent>
-        <groupId>com.heibaiying</groupId>
+        <groupId>com.heibaiying.ribbon</groupId>
         <artifactId>spring-cloud-ribbon</artifactId>
         <version>0.0.1-SNAPSHOT</version>
     </parent>

spring-cloud/spring-cloud-ribbon/common/src/main/java/com/heibaiying/common/api/IProductService.java

@@ -13,4 +13,6 @@ public interface IProductService {
     Product queryProductById(int id);
 
     List<Product> queryAllProducts();
+
+    void saveProduct(Product product);
 }

spring-cloud/spring-cloud-ribbon/common/src/main/java/com/heibaiying/common/bean/Product.java

@@ -17,7 +17,7 @@ import java.util.Date;
 public class Product implements Serializable {
 
     // 产品序列号
-    private int id;
+    private long id;
 
     // 产品名称
     private String name;

spring-cloud/spring-cloud-ribbon/consumer/pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <parent>
-        <groupId>com.heibaiying</groupId>
+        <groupId>com.heibaiying.ribbon</groupId>
         <artifactId>spring-cloud-ribbon</artifactId>
         <version>0.0.1-SNAPSHOT</version>
     </parent>
@@ -31,7 +31,7 @@
         </dependency>
         <!--引入对公共模块的依赖-->
         <dependency>
-            <groupId>com.heibaiying.eureka</groupId>
+            <groupId>com.heibaiying.ribbon</groupId>
             <artifactId>common</artifactId>
             <version>0.0.1-SNAPSHOT</version>
             <scope>compile</scope>

spring-cloud/spring-cloud-ribbon/consumer/src/main/java/com/heibaiying/consumer/controller/SellController.java

@@ -6,9 +6,9 @@ import com.heibaiying.common.bean.Product;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
 import org.springframework.ui.Model;
-import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.RequestMapping;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -21,17 +21,25 @@ public class SellController {
     @Autowired
     private IProductService productService;
 
-    @RequestMapping
+    @GetMapping("products")
     public String productList(Model model) {
         List<Product> products = productService.queryAllProducts();
         model.addAttribute("products", products);
         return "products";
     }
 
-    @RequestMapping("product/{id}")
+    @GetMapping("product/{id}")
     public String productDetail(@PathVariable int id, Model model) {
         Product product = productService.queryProductById(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);
+        productService.saveProduct(product);
+        return "redirect:products";
+    }
 }

spring-cloud/spring-cloud-ribbon/consumer/src/main/java/com/heibaiying/consumer/service/ProductService.java

@@ -31,4 +31,7 @@ public class ProductService implements IProductService {
         return productList;
     }
 
+    public void saveProduct(Product product) {
+        restTemplate.postForObject("http://producer/product", product, Void.class);
+    }
 }

spring-cloud/spring-cloud-ribbon/consumer/src/main/resources/application.yml

@@ -1,5 +1,5 @@
 server:
-  port: 8030
+  port: 8080
 # 指定服务命名
 spring:
   application:

spring-cloud/spring-cloud-ribbon/consumer/src/main/resources/templates/products.ftl

@@ -5,10 +5,14 @@
 </head>
 <body>
 <h3>产品列表:点击查看详情</h3>
+<form action="/sell/product" method="post">
+    <input type="text" name="productName">
+    <input type="submit" value="新增产品">
+</form>
 <ul>
     <#list products as product>
         <li>
-           <a href="sell/product/${product.id}">${product.name}</a>
+            <a href="/sell/product/${product.id}">${product.name}</a>
         </li>
     </#list>
 </ul>

spring-cloud/spring-cloud-ribbon/eureka/pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <parent>
-        <groupId>com.heibaiying</groupId>
+        <groupId>com.heibaiying.ribbon</groupId>
         <artifactId>spring-cloud-ribbon</artifactId>
         <version>0.0.1-SNAPSHOT</version>
     </parent>

spring-cloud/spring-cloud-ribbon/pom.xml

@@ -11,7 +11,7 @@
         <relativePath/> <!-- lookup parent from repository -->
     </parent>
 
-    <groupId>com.heibaiying</groupId>
+    <groupId>com.heibaiying.ribbon</groupId>
     <artifactId>spring-cloud-ribbon</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <name>spring-cloud-ribbon</name>

spring-cloud/spring-cloud-ribbon/producer/pom.xml

@@ -22,7 +22,7 @@
         </dependency>
         <!--引入对公共模块的依赖-->
         <dependency>
-            <groupId>com.heibaiying.eureka</groupId>
+            <groupId>com.heibaiying.ribbon</groupId>
             <artifactId>common</artifactId>
             <version>0.0.1-SNAPSHOT</version>
             <scope>compile</scope>

spring-cloud/spring-cloud-ribbon/producer/src/main/java/com/heibaiying/producer/controller/ProducerController.java

@@ -4,9 +4,7 @@ package com.heibaiying.producer.controller;
 import com.heibaiying.common.api.IProductService;
 import com.heibaiying.common.bean.Product;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
 
 import java.util.List;
 
@@ -19,13 +17,18 @@ public class ProducerController {
     @Autowired
     private IProductService productService;
 
-    @RequestMapping("products")
+    @GetMapping("products")
     public List<Product> productList() {
         return productService.queryAllProducts();
     }
 
-    @RequestMapping("product/{id}")
+    @GetMapping("product/{id}")
     public Product productDetail(@PathVariable int id) {
         return productService.queryProductById(id);
     }
+
+    @PostMapping("product")
+    public void save(@RequestBody Product product) {
+        productService.saveProduct(product);
+    }
 }

spring-cloud/spring-cloud-ribbon/producer/src/main/java/com/heibaiying/producer/service/ProductService.java

@@ -2,6 +2,8 @@ package com.heibaiying.producer.service;
 
 import com.heibaiying.common.api.IProductService;
 import com.heibaiying.common.bean.Product;
+import org.springframework.boot.web.context.WebServerInitializedEvent;
+import org.springframework.context.ApplicationListener;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
@@ -13,16 +15,10 @@ import java.util.List;
  * @description : 产品提供接口实现类
  */
 @Service
-public class ProductService implements IProductService {
+public class ProductService implements IProductService, ApplicationListener<WebServerInitializedEvent> {
 
     private static List<Product> productList = new ArrayList<>();
 
-    static {
-        for (int i = 0; i < 20; i++) {
-            productList.add(new Product(i, "产品" + i, i / 2 == 0, new Date(), 66.66f * i));
-        }
-    }
-
     public Product queryProductById(int id) {
         for (Product product : productList) {
             if (product.getId() == id) {
@@ -36,4 +32,17 @@ public class ProductService implements IProductService {
     public List<Product> 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));
+        }
+    }
 }