@SentinelResource // d进去自己看
// fallback 后被隐藏能源
// blockhandler 不管了，开摆

@FeignClient(value = "demo", path = "/test", fallback = DemoServiceFeignFallback.class)
// 写一个DemoServiceFeignFallback类继承当前类（DemoServiceFeign）

package cn.sdadgz.exception;

import cn.sdadgz.common.Result;
import com.alibaba.csp.sentinel.adapter.spring.webmvc.callback.BlockExceptionHandler;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.alibaba.csp.sentinel.slots.block.authority.AuthorityException;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeException;
import com.alibaba.csp.sentinel.slots.block.flow.FlowException;
import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowException;
import com.alibaba.fastjson.JSON;
import lombok.Cleanup;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;

/**
 * <p>
 * 废物本物
 * </p>
 *
 * @author sdadgz
 * @since 2023/2/16 00:52:36
 */
@Component
@Slf4j
public class DefaultBlockExceptionHandler implements BlockExceptionHandler {

    @Override
    public void handle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, BlockException e) throws Exception {
        //getRule返回资源、规则的详细信息
        log.info("BlockExceptionHandler BlockException================" + e.getRule());

        Result r = null;
        if (e instanceof FlowException) {
            r = Result.error(100, "接口被限流了");
        } else if (e instanceof DegradeException) {
            r = Result.error(101, "服务降级了");
        } else if (e instanceof ParamFlowException) {
            r = Result.error(102, "热点参数限流了");
        } else if (e instanceof AuthorityException) {
            r = Result.error(104, "授权规则不通过");
        }

        //返回Json数据
        httpServletResponse.setStatus(500);
        httpServletResponse.setCharacterEncoding("UTF-8");
        httpServletResponse.setContentType(MediaType.APPLICATION_JSON_VALUE);
        try (PrintWriter writer = httpServletResponse.getWriter()) {
            writer.write(JSON.toJSONString(r));
            writer.flush();
        } catch (IOException ioException) {
            log.error("异常：{}", ioException.toString());
        }
    }
}

package cn.sdadgz;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
 * @author sdadgz
 * @since 2023/2/12
 */
@SpringBootApplication
@EnableFeignClients // 重中之重
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

package cn.sdadgz.feign;

import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;

/**
 * @author sdadgz
 * @since 2023/2/13
 */

@FeignClient(name = "demo-02",path = "/test")
public interface TestService {

    @GetMapping("/m")
    String m();

}

package cn.sdadgz.controller;

import cn.sdadgz.feign.TestService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;

/**
 * @author sdadgz
 * @since 2023/2/12
 */

@RestController
@RequestMapping("/test")
public class TestController {

    // 其他服务
    @Resource
    private TestService testService;

    @GetMapping("/hello")
    public String test(){
        // 就像自己人一样调用
        String m = testService.m();
        return "hello world:" + m;
    }
    
}

// 照抄就完事了
CuratorFramework client = CuratorFrameworkFactory.builder().connectString("[ip:port]").sesionTimeoutMs([ms]).connectionTimeoutMs([ms]).retryPolicy([重试策略]).namespace("[类似工作目录]").build();
client.start();