/**
 * @ClassName: ApplicationContextConfig
 * @Description: 程序配置類，用于開啟RestTemplate服務(wù)，以供后面使用
 * @author: chenhao
 * @date: 2022/7/17
 */
@Configuration
public class ApplicationContextConfig {
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
}

@RestController
@Slf4j
@RequestMapping("consumer")
@Api("消費者的訂單管理類")
public class OrderController {
	// 先注入RestTemplate對象
    @Resource
    private RestTemplate restTemplate;
	// 使用API實現(xiàn)負載均衡
    @ApiOperation(value = "創(chuàng)建一條支付記錄", tags = ApiVersionConstant.v1_0)
    @PostMapping(value = "/payment/create", produces = {"application/json;charset=UTF-8"})
    public CommonResult<Integer> create(@RequestBody Payment payment) {
        return restTemplate.postForObject(UrlConstant.CLUSTER_PAYMENT_URL + "/payment/create", payment, CommonResult.class);
    }
    @ApiOperation(value = "根據(jù)ID查詢支付記錄", tags = ApiVersionConstant.v1_0)
    @GetMapping(value = "/payment/get/{id}", produces = {"application/json;charset=UTF-8"})
    public CommonResult<Payment> getPayment(@PathVariable("id") Integer id) {
        return restTemplate.getForObject(UrlConstant.CLUSTER_PAYMENT_URL + "/payment/get/" + id, CommonResult.class);
    }
    @ApiOperation(value = "根據(jù)ID查詢支付記錄Entity", tags = ApiVersionConstant.v1_0)
    @GetMapping(value = "/payment/getForEntity/{id}", produces = {"application/json;charset=UTF-8"})
    public CommonResult<Payment> getPaymentEntity(@PathVariable("id") Integer id) {
        ResponseEntity<CommonResult> entity = restTemplate.getForEntity(UrlConstant.CLUSTER_PAYMENT_URL + "/payment/get/" + id, CommonResult.class);
        if (entity.getStatusCode().is2xxSuccessful()) {
            return entity.getBody();
        } else {
            return new CommonResult<>(444, "操作失敗");
        }
    }
    @ApiOperation(value = "創(chuàng)建一條支付記錄Entity", tags = ApiVersionConstant.v1_0)
    @PostMapping(value = "/payment/createEntity", produces = {"application/json;charset=UTF-8"})
    public CommonResult<Integer> createEntity(@RequestBody Payment payment) {
        return restTemplate.postForEntity(UrlConstant.CLUSTER_PAYMENT_URL + "/payment/create", payment, CommonResult.class)
                .getBody();
    }
}

@Configuration
public class MySelfRule {
    @Bean
    public IRule myRule() {
        // 修改輪詢算法為隨機算法
        return new RandomRule();
    }
}

@SpringBootApplication
@EnableEurekaClient
@RibbonClient(name = "CLOUD-PAYMENT-SERVICE", configuration = MySelfRule.class)
public class OrderMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderMain80.class, args);
    }
}

<!--openfeign-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

@SpringBootApplication
@EnableFeignClients
public class OrderFeignMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderFeignMain80.class, args);
    }
}

@Component
@FeignClient(value = "CLOUD-PAYMENT-SERVICE") // 用于指定服務(wù)名，可在eureka或者服務(wù)的配置文件中查看
public interface PaymentFeignService {
    @GetMapping(value = "/payment/get/{id}", produces = {"application/json;charset=UTF-8"})
    CommonResult<Payment> getPaymentById(@PathVariable("id") Integer id);
}

@RestController
@RequestMapping("consumer")
public class OrderFeignController {
    @Autowired
    private PaymentFeignService paymentFeignService;
    @GetMapping(value = "/payment/get/{id}", produces = {"application/json;charset=UTF-8"})
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Integer id) {
        return paymentFeignService.getPaymentById(id);
    }
}

@Configuration
public class FeignConfig {
    /**
     * 日志級別
     * NONE：默認的，不顯示任何日志
     * BASIC：僅記錄請求方法、URL、響應(yīng)狀態(tài)碼以及執(zhí)行時間
     * HEADERS：請求方法、URL、響應(yīng)狀態(tài)碼、執(zhí)行時間、請求和響應(yīng)的頭信息
     * FULL：請求方法、URL、響應(yīng)狀態(tài)碼、執(zhí)行時間、請求和響應(yīng)的頭信息、正文以及元數(shù)據(jù)
     */
    @Bean
    Logger.Level feignLoggerLevel() {
        return Logger.Level.FULL;
    }
}