Ideal版SpringCloud框架参考---分布式微服务架构参考

      package com.atguigu.springcloud.controller;

import cn.hutool.core.swing.clipboard.ClipboardUtil;
import com.atguigu.springcloud.entities.CommonResult;
import com.atguigu.springcloud.entities.Payment;
import com.atguigu.springcloud.service.PaymentService;
import com.atguigu.springcloud.tool.RandomCode;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.List;
import java.util.concurrent.TimeUnit;

@RestController
@Slf4j
public class PaymentController {

    @Resource
    private PaymentService paymentService;

    @Value("${server.port}")
    private String serverPort;

    @Resource
    private DiscoveryClient discoveryClient;

    @PostMapping("/payment/create")
    public CommonResult create(@RequestBody Payment payment){
        log.info("******传过来的payment是：【"+payment+"】");
        int result= paymentService.create(payment);
        log.info("******插入结果：【"+result+"】");

        if(result>0){
            return new CommonResult(200,"插入成功,serverPort是："+serverPort,result);
        }else {
            return new CommonResult(444,"插入失败",result);
        }

    }

    @GetMapping("/payment/get/{id}")
    public CommonResult getPaymentById(@PathVariable("id") Long id){

        Payment payment= paymentService.getPaymentById(id);
        log.info("******插入结果："+payment);

        if(payment!=null){
            return new CommonResult(200,"查询成功,serverPort是："+serverPort,payment);
        }else {
            return new CommonResult(444,"查询失败，查询id："+id,null);
        }

    }

    @GetMapping("/payment/discovery")
    public Object discovery(){
        //看当前注册中心的服务有哪些
        List<String> services = discoveryClient.getServices();
        for (String service:services) {
            log.info("当前服务名字是为："+service);
            //看当前服务名下的有哪些服务
            List<ServiceInstance> instances = discoveryClient.getInstances(service);
            for (ServiceInstance instance:instances) {
                //service服务名称、instance.getServiceId()id、instance.getHost()主机名、instance.getPort()端口号、instance.getUri()地址
                log.info("当前服务【"+service+"】下的服务id："+instance.getServiceId()+"主机名："+instance.getHost()+"端口号："+instance.getPort()+"地址："+instance.getUri());
            }
        }
        return this.discoveryClient;
    }

    @GetMapping("/payment/lb")
    public String getPaymentLB(){
        return serverPort;
    }

    @GetMapping("/payment/feign/timeout")
    public String paymentFeignTimeout(){
        try {
            TimeUnit.SECONDS.sleep(3);
        }catch (InterruptedException e){
            e.printStackTrace();
        }
        return serverPort;
    }

    //生成随机码
    @GetMapping("/payment/getcode/{length}")
    public String getCode(@PathVariable("length") int length){
        System.out.println("length的值是："+length);
        return RandomCode.CreateCode(length);
    }

}