Springboot+springCloud単純クラスタの構築
49673 ワード
ソース:https://github.com/LM917178900/spring-boot-hello https://github.com/LM917178900/eureka-server https://github.com/LM917178900/ribbon-consumer
1クライアントクラスタの構築
1.1新しいspringbootマイクロサービス、spring-boot-hello
1.2 pom
1.3 aplication.properties
Clientはサービス側であり消費側であり、clientを2台の登録センターに登録する.
1.4起動クラス
1.5 controller
1.6起動
異なるshellウィンドウで、2つのインスタンスを同時に起動
2 eurekaクラスタの構築
2.1新しいspringbootマイクロサービス、eureka-server
2.2 pom
2.3 application.properties
2つのアプリケーションを構成し、互いに登録して検索し、登録同期と高可用性を実現する.それぞれ:アプリケーション-peer 1である.properties
application-peer2.properties
2.4起動クラス
2.5起動
異なるshellウィンドウで、2つの登録センターを同時に起動します.
3 ribbon消費者負荷の均衡を実現
3.1新しいspringbootマイクロサービス、ribbon-consumer
3.2 pom
3.3 application
3.4起動クラス
3.5 controller
3.6直接功績
次に使用を開始し、consumerでspring-boot-helloのインタフェースを呼び出します.
1クライアントクラスタの構築
1.1新しいspringbootマイクロサービス、spring-boot-hello
1.2 pom
<dependencies>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starterartifactId>
dependency>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-webartifactId>
dependency>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-testartifactId>
<scope>testscope>
dependency>
<dependency>
<groupId>org.springframework.cloudgroupId>
<artifactId>spring-cloud-starter-eureka-serverartifactId>
dependency>
dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloudgroupId>
<artifactId>spring-cloud-dependenciesartifactId>
<version>Brixton.SR5version>
<type>pomtype>
<scope>importscope>
dependency>
dependencies>
dependencyManagement>
1.3 aplication.properties
Clientはサービス側であり消費側であり、clientを2台の登録センターに登録する.
spring.application.name=hello-service
#
eureka.client.service-url.defaultZone=http://peer1:1111/eureka/,http://peer2:1112/eureka
1.4起動クラス
package com.didispace.springboothello;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
/**
*
*/
@EnableDiscoveryClient
@SpringBootApplication
public class SpringBootHelloApplication {
public static void main(String[] args) {
SpringApplication.run(SpringBootHelloApplication.class, args);
}
}
1.5 controller
package com.didispace.springboothello.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import java.util.logging.Logger;
/**
* @Author: leimin
* @Description: new class
* @Date: 2020/6/8 9:08
* @Version: 1.0
*/
@RestController
public class HelloController {
/**
* xx
*/
private final Logger logger = Logger.getLogger(String.valueOf(getClass()));
/**
* xx
*/
@Autowired
private DiscoveryClient client;
/**
* xx
* @return xx
*/
@RequestMapping(value = "/hello",method = RequestMethod.GET)
public String index(){
ServiceInstance instance = client.getLocalServiceInstance();
logger.info("/hello,host:" + instance.getHost()+", service_id:" +instance.getServiceId());
return "hello World !";
}
}
1.6起動
異なるshellウィンドウで、2つのインスタンスを同時に起動
java -jar ./spring-boot-hello-0.0.1.SANPSHOT.jar --server.port=8081
java -jar ./spring-boot-hello-0.0.1.SANPSHOT.jar --server.port=8082
2 eurekaクラスタの構築
2.1新しいspringbootマイクロサービス、eureka-server
2.2 pom
<dependencies>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starterartifactId>
dependency>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-testartifactId>
<scope>testscope>
<exclusions>
<exclusion>
<groupId>org.junit.vintagegroupId>
<artifactId>junit-vintage-engineartifactId>
exclusion>
exclusions>
dependency>
<dependency>
<groupId>org.springframework.cloudgroupId>
<artifactId>spring-cloud-starter-eureka-serverartifactId>
dependency>
dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloudgroupId>
<artifactId>spring-cloud-dependenciesartifactId>
<version>Brixton.SR5version>
<type>pomtype>
<scope>importscope>
dependency>
dependencies>
dependencyManagement>
2.3 application.properties
2つのアプリケーションを構成し、互いに登録して検索し、登録同期と高可用性を実現する.それぞれ:アプリケーション-peer 1である.properties
# ,
eureka.client.register-with-eureka=true
#
eureka.client.fetch-registry=true
spring.application.name=eureka-server
server.port=1111
eureka.instance.hostname=peer1
eureka.client.service-url.defaultZone=http://peer2:1112/eureka/
application-peer2.properties
# ,
eureka.client.register-with-eureka=true
#
eureka.client.fetch-registry=true
spring.application.name=eureka-server
server.port=1112
eureka.instance.hostname=peer2
eureka.client.service-url.defaultZone=http://peer1:1111/eureka/
2.4起動クラス
package com.huahua.demo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
/**
*
*/
@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaServerApplication.class, args);
}
}
2.5起動
異なるshellウィンドウで、2つの登録センターを同時に起動します.
java -jar ./demo-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer1
java -jar ./demo-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer2
3 ribbon消費者負荷の均衡を実現
3.1新しいspringbootマイクロサービス、ribbon-consumer
3.2 pom
<dependencies>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starterartifactId>
dependency>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-webartifactId>
dependency>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-testartifactId>
<scope>testscope>
dependency>
<dependency>
<groupId>org.springframework.cloudgroupId>
<artifactId>spring-cloud-starter-eurekaartifactId>
dependency>
<dependency>
<groupId>org.springframework.cloudgroupId>
<artifactId>spring-cloud-starter-ribbonartifactId>
dependency>
dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloudgroupId>
<artifactId>spring-cloud-dependenciesartifactId>
<version>Brixton.SR5version>
<type>pomtype>
<scope>importscope>
dependency>
dependencies>
dependencyManagement>
3.3 application
spring.application.name=ribbon-consumer
server.port=9000
# ,
eureka.client.service-url.defaultZone=http://localhost:1111/eureka/
3.4起動クラス
package com.example.lei;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
@EnableDiscoveryClient
@SpringBootApplication
public class RibbonConsumerApplication {
@Bean
@LoadBalanced
RestTemplate restTemplate(){
return new RestTemplate();
}
public static void main(String[] args) {
SpringApplication.run(RibbonConsumerApplication.class, args);
}
}
3.5 controller
package com.example.lei.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
/**
* @Author: leimin
* @Description: new class
* @Date: 2020/6/8 16:04
* @Version: 1.0
*/
@RestController
public class ConsumerController {
/**
* xx
*/
@Autowired
RestTemplate restTemplate;
/**
* yyy
* @return rr
*/
@RequestMapping(value = "/ribbon-consumer", method = RequestMethod.GET)
private String helloConsumer(){
return restTemplate.getForEntity("http://HELLO-SERVICE/hello",String.class).getBody();
}
}
3.6直接功績
次に使用を開始し、consumerでspring-boot-helloのインタフェースを呼び出します.