<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency>
package com.miniooc.eurekafeign; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.openfeign.EnableFeignClients; /** * EurekaFeignApplication * 应用程序启动类,程序入口 * * @author 宋陆 * @version 1.0.0 */ @EnableDiscoveryClient // 启用 Eureka 服务发现 @EnableFeignClients // 启用 Feign @SpringBootApplication public class EurekaFeignApplication { public static void main(String[] args) { SpringApplication.run(EurekaFeignApplication.class, args); } }
package com.miniooc.eurekafeign.service; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.stereotype.Service; import org.springframework.web.bind.annotation.RequestMapping; /** * EurekaFeignService * 服务消费者,调用服务提供者提供的服务,实现业务 * * @author 宋陆 * @version 1.0.0 */ @FeignClient(value = "eureka-client") // 调用的服务的名称 public interface EurekaFeignService { @RequestMapping(value = "/info") String getInfo(); }
package com.miniooc.eurekafeign.controller; import com.miniooc.eurekafeign.service.EurekaFeignService; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; /** * EurekaFeignController * 服务消费控制器类,对用户提供服务 * * @author 宋陆 * @version 1.0.0 */ @RestController public class EurekaFeignController { @Resource private EurekaFeignService eurekaFeignService; @RequestMapping("/feignInfo") public String feignInfo() { String message = eurekaFeignService.getInfo(); return "获取到的信息:" + message; } }
server: port: 52620 spring: application: name: eureka-discovery-feign eureka: instance: hostname: localhost # 表示eureka client间隔多久去拉取服务注册信息,默认为30秒,若是要迅速获取服务注册状态,能够缩小该值 lease-renewal-interval-in-seconds: 5 # 表示eureka server至上一次收到client的心跳以后,等待下一次心跳的超时时间,在这个时间内若没收到下一次心跳,则将移除该instance。 # 默认为90秒 # 若是该值太大,则极可能将流量转发过去的时候,该instance已经不存活了。 # 若是该值设置过小了,则instance则极可能由于临时的网络抖动而被摘除掉。 # 该值至少应该大于 leaseRenewalIntervalInSeconds lease-expiration-duration-in-seconds: 10 client: serviceUrl: defaultZone: http://localhost:9527/eureka/,http://localhost:9528/eureka/,http://localhost:9529/eureka/
红框处,能够看到服务消费实例已经注册到了服务注册中心,服务名 EUREKA-DISCOVERY-FEIGNweb
红框处,能够看到【服务消费者】成功调用了【服务提供者】提供的服务,并实现了负载均衡,轮询请求不一样的【服务提供者】。spring
至此,一个简单的单点【服务消费者】搭建完成。浏览器