<dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency>

server:  port: 8761  #注册中心端口号 eureka:  instance:    hostname: localhost #主机名  client:    registerWithEureka: false #不将自己注册到eureka    serviceUrl:      defaultZone: http://localhost:${server.port}/eureka/ #eureka服务端的配置信息

@EnableEurekaServer // 开启eureka服务@SpringBootApplicationpublic class EurekaServer {    public static void main(String[] args) {        SpringApplication.run(EurekaServer.class, args);    }}

<dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency>

server:  port: 8080
spring:  application:    name: goods-center # 服务名称，在 eureka 上注册需要使用
eureka:  client:    serviceUrl:      defaultZone: http://localhost:8761/eureka/ # 注册中心地址

@SpringBootApplication@EnableEurekaClient // 启动 eureka 客户端public class GoodsApplication {    public static void main(String[] args) {        SpringApplication.run(GoodsApplication.class, args);    }}@Configurationpublic class GoodsConfig {// 可以从application.yaml中读出    @Value("${spring.application.name}")    private String serviceName;       /**     * 配置 Eureka 服务列表（url），采用多active方案，zookeeper、consul等替换即可。     */    @Bean    public DiscoveryClient.DiscoveryClientOptionalArgs discoveryClientOptionalArgs() {        DiscoveryClient.DiscoveryClientOptionalArgs args = new DiscoveryClient.DiscoveryClientOptionalArgs();              ScheduleWthFixedDelayCustomErReg soc = new ScheduleWthFixedDelayCustomErReg();        args.setRegistrationProcessSupplier(() -> soc);
        TimeIntervalJitterRetry tijr = new TimeIntervalJitterRetry(HEALTH_POLL_INTERVAL_MS, INITIAL_REGISTRATION_RETRY_DELAY_MS);        args.setRetryableHttpClient(new InterProcessOrNioHttpClient(serviceName, ServiceAddressSelector.DEFAULT, tijr, null, MESSAGE_MAX_BYTES, CONNECTION_READ_TIMEOUT_MS));                return args;    }        /**     * Er注册和心跳拉取配置     */    private class ScheduleWthFixedDelayCustomErReg extends ServerListEndpoint implements RegistrationProcessor {        private final WebClientTransport webClientTransport;            ScheduleWthFixedDelayCustomErReg() {            webClientTransport = new WebClientTransport(unsafeClientConfig(ScheduleWthFixedDelayCustomErReg.class.getSimpleName()).with(ServiceAddressEndPointListProvider.ENDPOINT_PREFIX_KEY, serviceName));        }           @Override        public void onApplicationEvent(ApplicationEvent event) {            if (event instanceof ContextStartedEvent) {                try {                    httpCatTransport.startSendTimeGestion();  //UDS记录程序启动成功日志                          } catch (Throwable tr) {                    logger.error(format("{} startSendTimeGestion error", getClass().getSimpleName()), tr);                }            } else if (event instanceof ContextClosedEvent) {                try {                    httpCatTransport.stopSendTimeGestion(); //UDS+ZK记录程序正常退出日志。                } catch (Throwable tr) {                    logger.error(format("{} stopSendTimeGestion error", getClass().getSimpleName()), tr);                }            }        }                    /**         * 定制注册周期日程的执行方法         */        @Override        public void process(Registration registration, Optional<ServiceInstance<?>> _ignored_1, Optional<RegistrationOperation> _ignored_2)                throws IOException {            Map<String, String> metadata = registration.getMetadata();            webClientTransport.writeMetadata("name", metadata.get("name"));        }    }}

<dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependency>    <groupId>com.netflix.ribbon</groupId>    <artifactId>ribbon-eureka</artifactId></dependency>

server:      port: 8081
spring:  application:    name: reservation-service   #配置产品策略  ribbon:    eureka:      enabled: true  execution:    isolation:      strategy: SEMAPHORE   

@SpringBootApplication@EnableEurekaClient@RestControllerpublic class ReservationServiceApplication {
    public static void main(String[] args) {        SpringApplication.run(ReservationServiceApplication.class, args);    }
    @Autowired    RestTemplate restTemplate;
    @Bean    @LoadBalanced     // 启用负载均衡    public RestTemplate restTemplate() {        return new RestTemplate();    }
    @GetMapping("/brands")    public String getBrands() {        String url = "http://goods-center/goods/brand/list";        return restTemplate.getForObject(url, String.class);    }
}

@Controllerpublic class QueryController {    @Autowired    private DiscoveryClient discoveryClient;
    @GetMapping("/goods/listDiscover")    @ResponseBody    public Object getServices() {        List<String> serviceNames = discoveryClient.getServices(); // 发现所有的服务名        Map<String, List<ServiceInstance>> instances = new HashMap<>();        serviceNames.forEach(serviceName -> {            List<ServiceInstance> byServiceName = discoveryClient.getInstances(serviceName); // 获取服务发现client根据服务名获取连接上其他服务提供的所有实例            instances.put(serviceName, byServiceName);        });        return instances;    }
}

<dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-netflix-zuul</artifactId></dependency>

@SpringBootApplication@EnableZuulProxy@EnableDiscoveryClientpublic class GatewayApplication {    public static void main(String[] args) {        SpringApplication.run(GatewayApplication.class, args);    }
    @Bean    public ZuulFilter zuulPreFilter() {        return new ZuulMyFilter();    }}
@Slf4jclass ZuulMyFilter extends ZuulFilter {    @Override    public boolean shouldFilter() {        return true;    }       @Override    public Object run() throws ZuulException {        return this.sendMyRequest(context());    }       private ZuulFilterResult sendMyRequest(RequestContext ctx) throws ZuulException{        HttpServletRequest req = ctx.getRequest();        performWork(req,ctx);        return ZuulFilterResult.success();    }
    void performWork(HttpServletRequest req,RequestContext context) {        String requestedApiVersion = req.getHeader("requested-api-version");                    /** API版本 2 */ {http://v2.ip.taobao.com}        if(v2部署) routeIf(specification.format("v2", ".*", ".*", evaluatedPath.toUriString(), queryString.toString()));     private void routeIf(String ifRoute) {        RequestContext.getCurrentContext().add("routeIf",new RouteSpecificInfo(ifRoute));    }}