Spring Cloud 服務發布與調用
阿新 • • 發佈：2019-02-17
prope pin 總結 eth rip pre 回調 desc fig 1. 發布服務
- 引入相關依賴pom.xml
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.3.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.zws.cloud</groupId> <artifactId>Eurka-Producer</artifactId> <version>0.0.1-SNAPSHOT</version> <name>Eurka-Producer</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Greenwich.RELEASE</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- Eureka 客戶端依賴 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
- 配置Eureka Server地址 application.yml
server:
port: 8080
eureka:
client:
serviceUrl:
defaultZone: http://localhost:8761/eureka/
spring:
application:
name: Eureka-Producer- 發布一個服務，其實就是一個Http接口，如下：
package com.zws.cloud.producer; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; /** * @Author wensh.zhu * @Date 2019/2/16 19:33 */ @RestController public class HelloController { @GetMapping("/hello") public String hello() { return "hello"; } } 啟動 package com.zws.cloud.producer; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class EurekaProducerApplication { public static void main(String[] args) { SpringApplication.run(EurekaProducerApplication.class, args); } }
2. 調用服務
- 依賴配置pom.xml
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.3.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.zws.cloud</groupId> <artifactId>Eurka-Producer</artifactId> <version>0.0.1-SNAPSHOT</version> <name>Eurka-Producer</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Greenwich.RELEASE</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <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> <!-- Ribbon用於客戶端負載均衡 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-ribbon</artifactId> </dependency> <!-- Feign用於服務發現與調用 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
- 啟用Ribbon負載均衡以及Feign接口註入，application.yml
server:
port: 8088
eureka:
client:
serviceUrl:
defaultZone: http://localhost:8761/eureka/
spring:
application:
name: Eureka-Consumer- 定義Feign客戶端以及熔斷回調
package com.zws.cloud.consumer;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
/**
* @Author wensh.zhu
* @Date 2019/2/16 15:14
*/
@FeignClient(value = "Eureka-Producer", fallbackFactory = HelloClientFallbackFactory.class)
public interface HelloClient {
@GetMapping("/hello")
String hello();
}
package com.zws.cloud.consumer;
import feign.hystrix.FallbackFactory;
import org.springframework.stereotype.Component;
/**
* @Author wensh.zhu
* @Date 2019/2/16 16:12
*/
@Component
public class HelloClientFallbackFactory implements FallbackFactory<String>, HelloClient {
@Override
public String create(Throwable throwable) {
return this.hello();
}
@Override
public String hello() {
return "";
}
}@FeignClient(value = "Eureka-Producer", fallbackFactory = HelloClientFallbackFactory.class)其中Eurka-Producer為服務提供方的實例名稱（spring.application.name）
- 啟用Feign接口以及調用
package com.zws.cloud.EurkaProducer;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@RestController
@EnableFeignClients
@SpringBootApplication
public class EurkaProducerApplication {
@Resource
private HelloFeign helloFeign;
public static void main(String[] args) {
SpringApplication.run(EurkaProducerApplication.class, args);
}
@GetMapping("/hello")
public String hello() {
return helloFeign.hello();
}
}3. 總結
服務發布主要涉及如下三個方面：
- 配置Eureka Server地址：
## 多個以逗號隔開 eureka: client: serviceUrl: defaultZone: http://peer1:8761/eureka/ - 引入Eureka Client依賴
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> - 定義普通的Http接口
服務調用：
- 引入三個依賴：
<!-- Eureka客戶端 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<!-- Ribbon用於負載均衡 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>
<!-- Feign用於服務發布與調用 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>- 配置Eureka Server：
eureka:
client:
serviceUrl:
defaultZone: http://localhost:8762/eureka/- 定義FeignClient接口以及失敗的回調
- 啟動類添加@EnableFeignClients註解
@EnableFeignClients會把第三步定義的接口註入Spring上下文中 ，然後使用的時候直接註入即可。Spring Cloud 服務發布與調用