import com.hwadee.springcloud.entity.Product;
import com.hwadee.springcloud.service.IOrderFeignService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/order")
public class OrderController {
    @Autowired
    IOrderFeignService orderFeignService;
    @RequestMapping("/buy/{id}")
    public Product buy(@PathVariable Long id) {
        System.out.println("進(jìn)入OrderController的buy方法， orderFeignService 準(zhǔn)備調(diào)用遠(yuǎn)端接口 findById");
        Product product = orderFeignService.findOrderById(id);
        return product;
    }
    @RequestMapping(value = "/delete/{id}")
    public Product deleteOrderById(@PathVariable Long id) {
        System.out.println("進(jìn)入OrderController的deleteOrderById方法， orderFeignService 準(zhǔn)備調(diào)用遠(yuǎn)端接口deleteOrderById");
        Product product = orderFeignService.deleteOrderById(id);
        return product;
    }
}

import com.hwadee.springcloud.entity.Product;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.math.BigDecimal;
@RestController
@RequestMapping("/product")
public class ProductController {
    //方便后面講負(fù)載均衡，查看ip，此處獲取配置中的端口號(hào)和ip
    @Value("${server.port}")
    private String port;
    @Value("${spring.cloud.client.ip-address}")
    private String ip;
    @RequestMapping("/buy/{id}")
    public Product findById(@PathVariable Long id) {
        Product product = new Product();
        product.setId(id);
        // 后面需要測(cè)試負(fù)載均衡，所以返回 ip 地址及端口號(hào)
        product.setName("當(dāng)前訪(fǎng)問(wèn)服務(wù)地址：" + ip + ":" + port + "  " + "查詢(xún)商品訂單，訂單號(hào)：" + id);
        product.setPrice(new BigDecimal(10000.0));
        System.out.println(product);
        //測(cè)試超時(shí)熔斷
        try {
            Thread.sleep(5000);
            //測(cè)試并發(fā)熔斷
            //Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return product;
    }
    @RequestMapping(value = "/delete/{id}")
    public Product deleteOrderById(@PathVariable Long id) {
        Product product = new Product();
        product.setId(id);
        // 后面需要測(cè)試負(fù)載均衡，所以返回 ip 地址及端口號(hào)
        product.setName("當(dāng)前訪(fǎng)問(wèn)服務(wù)地址：" + ip + ":" + port + "  " + "從購(gòu)物車(chē)刪除訂單，訂單號(hào)：" + id);
        product.setPrice(new BigDecimal(10000.0));
        System.out.println(product);
        //測(cè)試異常熔斷
        System.out.println(10 / 0);
        return product;
    }
}

import com.hwadee.springcloud.entity.Product;
import com.hwadee.springcloud.service.IOrderFeignService;
import org.springframework.stereotype.Component;
@Component
public class OrderFeignServiceFallBack implements IOrderFeignService {
    @Override
    public Product findOrderById(Long id) {
        Product product = new Product();
        product.setId(id);
        product.setName("當(dāng)前訂單服務(wù)訪(fǎng)問(wèn)/order/buy/1 超時(shí)："+id);
        return product;
    }
    @Override
    public Product deleteOrderById(Long id) {
        Product product = new Product();
        product.setId(id);
        product.setName("當(dāng)前訂單服務(wù)訪(fǎng)問(wèn)/order/delete/1 10/0異常："+id);
        return product;
    }
}

@Component // 讓 spring 可以識(shí)別，不加也行，但是在注入的時(shí)候 IDEA 會(huì)報(bào)錯(cuò)，不會(huì)影響運(yùn)行，但有條紅線(xiàn)讓自己不舒服
@FeignClient(value = "PRODUCT-SERVICE",fallback = OrderFeignServiceFallBack.class)
public interface IOrderFeignService {
    @RequestMapping(value = "/product/buy/{id}")
    Product findOrderById(@PathVariable Long id);
    @RequestMapping(value = "/product/delete/{id}")
    Product deleteOrderById(@PathVariable Long id);
}

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
@SpringBootApplication
@EnableEurekaClient// 啟動(dòng) eureka 客戶(hù)端
@EnableFeignClients  // 啟動(dòng) feign
public class OrderServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderServerApplication.class, args);
    }
}

@SpringBootApplication
@EnableEurekaClient// 啟動(dòng) eureka 客戶(hù)端
public class ProductServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProductServerApplication.class, args);
    }
}