springcloud學習筆記二：服務提供、消費與ribbon
阿新 • • 發佈：2018-12-10
在學習筆記一里，我們簡單實現了一個註冊中心，我們就可以在上面進行服務的註冊與訂閱消費。
編寫服務，進行註冊
同樣，我們可以在STS中右鍵New->Spring Starter Project ，填寫相應內容->點選next
選擇需要的依賴包，我們這裡由於是構建一個服務提供者，要發現註冊中心，所以我們勾選Eureka Dicovery，然後點選finish
這樣STS就幫我們建立了一個服務提供者應用，下面是完整的pom檔案。
我們還需要配置一些功能完成我們的服務註冊。<?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> <groupId>com.point</groupId> <artifactId>point-provider</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>point-provider</name> <description>test provider</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.6.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> <spring-cloud.version>Dalston.SR2</spring-cloud.version> </properties> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
在入口類添加註解@EnableDiscoveryClient，用於發現註冊中心。
@EnableDiscoveryClient
@SpringBootApplication
public class PointProviderApplication {
public static void main(String[] args) {
SpringApplication.run(PointProviderApplication.class, args);
}
}在application.properties中新增相應配置
spring.application.name=point-provider
server.port=2000
eureka.client.serviceUrl.defaultZone=http://localhost:1000/eureka/server.port：服務埠
eureka.client.serviceUrl.defaultZone：註冊中心註冊地址
配置完以上後，我們啟動該服務，然後訪問我們的註冊中心(註冊中心的建立可以參考上一篇文章http://blog.csdn.net/u011890101/article/details/77116090)。
我們發現名稱為point-provider的服務已經成功在註冊中心完成註冊，這樣我們就可以編寫消費端來消費我們已經註冊的服務。
服務消費端
編寫消費端不得不提到的一個技術就是Ribbon，它能幫我們實現負載均衡，即我們可以部署多個同樣的服務提供者，通過ribbon，消費者可以根據多種負載策略去消費其中一個服務提供者。
我們先在服務提供者中編寫一個服務方法
@RestController
@RequestMapping("provider")
public class ProviderController {
@GetMapping("getName")
public String getName(){
System.out.println("服務被呼叫2000");
return "meepoGuan";
}
}
訪問註冊中心，可以看到名稱為point-provider的服務，已經有2000、2001兩個例項在執行。
下一步我們就可以編寫我們的消費者，通過ribbon進行負載均衡來訪問我們的point-provider服務。
還是通過STS進行建立
右鍵New->Spring Starter Project ，填寫相應內容->點選next
選擇需要的依賴包，我們這裡選擇Eureka Dicovery與Ribbon
點選finish建立完畢，完整pom為：
<?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>
<groupId>com.point</groupId>
<artifactId>point-consumer</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>point-consumer</name>
<description>test consumer</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.6.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<spring-cloud.version>Dalston.SR2</spring-cloud.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-ribbon</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
與服務提供者一樣，在入口類新增@EnableDiscoveryClient，用於發現註冊中心。
由於我們服務提供者是提供rest服務，所以我們需要引入下RestTemplate類，進行遠端訪問，同時加入@LoadBalanced，用ribbon幫我們實現負載均衡，訪問服務列表。
@EnableDiscoveryClient
@SpringBootApplication
public class PointConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(PointConsumerApplication.class, args);
}
@Bean
@LoadBalanced
public RestTemplate restTemplate(){
return new RestTemplate();
}
}server.port=3000
spring.application.name=point-consumer
eureka.client.serviceUrl.defaultZone=http://localhost:1000/eureka/
eureka.client.register-with-eureka=falsespring.application.name：服務名稱
eureka.client.serviceUrl.defaultZone：註冊中心地址
eureka.client.register-with-eureka：是否註冊到註冊中心，因為我們這裡是編寫的消費端，所以不需要。
編寫controller遠端訪問服務提供者提供的方法。
@RestController
@RequestMapping("consumer")
public class ConsumerController {
@Autowired
private RestTemplate restTemplate;
@GetMapping("getName")
public String getName(){
return restTemplate.getForObject("http://point-provider/provider/getName", String.class);
}
}http://point-provider/provider/getName訪問消費端的方法http://localhost:3000/consumer/getName，訪問兩次。
可以看到兩個例項分別都被呼叫到了一次，這樣我們就實現了在消費者端用ribbon對服務呼叫的負載均衡。