1_Eureka_服务注册_服务提供者_服务消费

布满荆棘的人生 2022-04-13 11:45 305阅读 0赞

## 1、服务注册中心的搭建 ##

### 1.1、项目名称为one-eurekas-erver ###

#### 1…1.2、pom.xml依赖 ####

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

<?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.eureka.server.first</groupId>
       <artifactId>one-eurekas-erver</artifactId>
       <version>0.0.1-SNAPSHOT</version>
       <packaging>jar</packaging>
    
       <name>one-eurekas-erver</name>
       <description>Demo project for Spring Boot</description>
    
       <parent>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-parent</artifactId>
          <version>1.5.3.RELEASE</version>
          <relativePath/> 
       </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.RELEASE</spring-cloud.version>
       </properties>
    
       <dependencies>
          
          <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-eureka-server</artifactId>
          </dependency>
        
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-thymeleaf</artifactId>
          </dependency>
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
          </dependency>
    
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
          </dependency>
    
    
    
          <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-eureka-server</artifactId>
          </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>

### 1.2、注解启动服务注册中心为其他的应用提供服务 ###

\*\*`@EnableEurekaServer`\*\*开启Eureka服务注册中心的支持,用来供给其他应用进行对话

@EnableEurekaServer  //开启Eureka服务注册中心的支持,用来供给其他应用进行对话
    @SpringBootApplication
    public class OneEurekasErverApplication { 
    
       public static void main(String[] args) { 
          SpringApplication.run(OneEurekasErverApplication.class, args);
       }
    }

### 1.3、开始配置和服务注册中心 ###

spring.application.name=one-eurekas-erver
    
    
    #默认设置下，这个服务注册中心会将自己作为客户端，所以需要禁用它的客户端注册行为 下面5个
    # 服务注册中心 端口
    server.port=1111
    #主机
    eureka.instance.hostname=localhost
    #这个为注册中心，false代表不向注册中心注册自己 ##直接启动之后会发现这个是空的，说明注册中心没有注册任何服务
    eureka.client.register-with-eureka=false 
    #注册中心的职责就是维护服务实例，并不需要它去检索服务，所以将它关闭
    eureka.client.fetch-registry=false
    eureka.client.serviceUrl.defaultZone=http://${ eureka.instance.hostname}:${ server.port}/eureka/

### 1.4、启动这个服务注册中心 ###

![TFrUyIcwZi6Bngaj][]

## 2、搭建一个简单的服务提供者 ##

### 2.1、项目名称为 eureka-server-ha ###

#### 2.1.1、pom.xml依赖为 ####

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

### 2.2、注解启动服务发现 ###

**`@EnableDiscoveryClient`** /支持服务发现

//支持服务发现
    @EnableDiscoveryClient
    @SpringBootApplication
    public class Application { 
    
       public static void main(String[] args) { 
          new SpringApplicationBuilder(Application.class).web(true).run(args);
       }
    
    }

### 2.3、自动化配置DiscoveryClient发现服务后，提供一个http请求接口，作为服务提供者提供的接口 ###

@RestController
    public class HomeController { 
    
    
        @Autowired
        private DiscoveryClient client;
    
        @RequestMapping(value = "hello",method = RequestMethod.GET)
        public  ServiceInstance index(){ 
            ServiceInstance serviceInstance = client.getLocalServiceInstance();
            System.out.println(
                    "host："+serviceInstance.getHost()+"/n " +
                    "service_id :"+serviceInstance.getServiceId());
            return serviceInstance;
        }
    
    }

### 2.4、指定提供的服务命名、指定服务注册中心 ###

spring.application.name=hello-service
    eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/
    server.port=8080

### 2.5、在已经启动了服务注册中心之后可启动这个服务提供者 ###

#### 2.5.1、[http://localhost:1111][http_localhost_1111] 观察服务注册中心浏览器状态，发现有服务注册进来的 ####

![rRs3Y4bmK8qhu0B][]

#### 2.5.2、[http://localhost:8080/hello][http_localhost_8080_hello] ，查看服务提供者控制台 ####

![qzMFrIwvyU3ohxVi][]

## 3、高可用注册中心 ##

解释：讲自己作为服务向其他服务注册中心注册自己，这样就会形成一组互相注册的注册中心，用来实心服务清单的互相同步

### 3.1、修改host文件 ###

127.0.0.1 peer1
    	127.0.0.1 peer2

### 3.2、创建配置文件`application-peer1.properties` ###

spring.application.name=one-eurekas-erver
    server.port=1111
    eureka.instance.hostname=peer1
    
    eureka.client.serviceUrl.defaultZone=http://peer2:1112/eureka/

### 3.3、创建配置文件 `application-peer2.properties` ###

spring.application.name=one-eurekas-erver
    server.port=1112
    eureka.instance.hostname=peer2
    
    eureka.client.serviceUrl.defaultZone=http://peer1:1111/eureka/

### 3.4、分别利用这2两个配置文件进行启动（复制项目，修改spring.profiles.active 利用idea启动） ###

![0bVzmve2YuFJOZpy][]

![imF5SWM2h3Ubkneq][]

### 3.5、启动上面的（项目2，服务提供者hello-service） ###

spring.application.name=hello-service
    eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/
    server.port=8080

#### 3.5.1、即使这个服务提供者所指定的注册中心只有一个，但是因为上面的配置的高可用，其实二者共享了  ####

![b1l5YJ2WRI7Zxz4a][]

![zyi0WCdtVbXp9mAe][]

#### 3.5.2、现在为这个服务提供者指定上面的两个注册中心 ，这样即使一个注册中心挂掉了，另外的一个注册中心还能够继续提供服务 ####

spring.application.name=hello-service
    eureka.client.serviceUrl.defaultZone=http://peer1:1111/eureka/,http://peer2:1111/eureka/
    
    server.port=8080

## 4、服务发现和消费 ##

解释：根据上面的操作，我们其实已经有了服务注册中心和服务提供者，下面就是开始构建一个服务消费者，它主要完成两个目标，发现服务和消费服务，Eureka为客户端可以发现服务，Ribbon则作为消费服务，它同时也作为辅助均衡器

### 4.1、服务提供者复制一个出来，并设置端口设置为8081 ，这样就有两个端口了8080，8081 ###

![U8MBfy6phqwZ7eA][]

![AHSZ2YsNxLXQ9dn][]

### 4.2、创建服务消费者 ###

#### 4.2.1、pom.xml为 ####

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

<?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.didispace</groupId>
       <artifactId>ribbon-consumer</artifactId>
       <version>0.0.1-SNAPSHOT</version>
       <packaging>jar</packaging>
    
       <name>ribbon-consumer</name>
       <description>Demo project for Spring Boot</description>
    
       <parent>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-parent</artifactId>
          <version>1.3.7.RELEASE</version>
          <relativePath/> 
       </parent>
    
       <properties>
          <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
          <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
          <java.version>1.8</java.version>
       </properties>
    
       <dependencies>
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
          </dependency>
    
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
          </dependency>
    
          <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-actuator</artifactId>
          </dependency>
    
          <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-hystrix</artifactId>
          </dependency>
    
          <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-netflix-hystrix-amqp</artifactId>
          </dependency>
       </dependencies>
    
       <dependencyManagement>
          <dependencies>
             <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Brixton.SR5</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>

### 5.2.2、注解服务发现和@LoadBalanced客户端负载均衡，这样就可以随机的访问8080 和8081了 ###

#### `@EnableDiscoveryClient` 服务发现 ####

#### `@LoadBalanced` 开启客户端负载均衡 ####

@EnableDiscoveryClient
    @SpringBootApplication
    public class ConsumerApplication { 
    
       //开启客户端负载均衡
       @Bean
       @LoadBalanced
       RestTemplate restTemplate() { 
          return new RestTemplate();
       }
       public static void main(String[] args) { 
          SpringApplication.run(ConsumerApplication.class, args);
       }
    
    }

#### 5.2.3、对服务提供者提供的接口进行调用http://HELLO-SERVICE/hello/ ####

解释：HELLO-SERVICE 为服务提供者应用名称，hello 为提供者的url地址

@RestController
    public class ConsumerController { 
    
    
        @Autowired
        RestTemplate restTemplate;
    
        @RequestMapping(value = "/ribbon-consumer", method = RequestMethod.GET)
        public String helloConsumer() { 
            return restTemplate.getForEntity("http://HELLO-SERVICE/hello/",String.class).getBody();
        }
    }

#### 5.2.4、指定服服务消费名称、配置端口9000，指定注册中心，一个注册中心挂掉，还能用另外的一个 ####

spring.application.name=ribbon-consumer
    server.port=9000
    
    eureka.client.serviceUrl.defaultZone=http://peer1:1111/eureka/,http://peer2:1112/eureka/,

#### 5.2.5、启动这个服务消费者，观察1111和1112注册中心 ####

![format_png][]

![format_png 1][]

### 5.3、3、浏览器访问这个服务消费者提供发http接口 [http://localhost:9000/ribbon-consumer][http_localhost_9000_ribbon-consumer] ###

解释 可以观察到，访问的时候，调用的服务提供者是随机被我们访问的，8080和8081 是随机出现的，这就是负载均衡喽   
![format_png 2][]

![format_png 3][]

## [HealerJean-代码下载][HealerJean-] ##

![ContactAuthor][]

[TFrUyIcwZi6Bngaj]: /images/20220413/a9667f58238341a78b9d0cd9361370a1.png
[http_localhost_1111]: http://localhost:1111
[rRs3Y4bmK8qhu0B]: /images/20220413/f007f67805f9424f96f6a81fd611330d.png
[http_localhost_8080_hello]: http://localhost:8080/hello
[qzMFrIwvyU3ohxVi]: /images/20220413/e34ca9ce40b74a6789680e10b37f2812.png
[0bVzmve2YuFJOZpy]: /images/20220413/e63435ce4a4b402ebd835cf673f4d3f5.png
[imF5SWM2h3Ubkneq]: /images/20220413/b9098d54300e483d98721d1a6fb30a19.png
[b1l5YJ2WRI7Zxz4a]: /images/20220413/0f8390c2fb2747d5a20a1dc1ca942e90.png
[zyi0WCdtVbXp9mAe]: /images/20220413/5ed119c65e37446eaaad35fc5826bf92.png
[U8MBfy6phqwZ7eA]: /images/20220413/4fa8a1d4f00d48f9a5a1e0905d74d932.png
[AHSZ2YsNxLXQ9dn]: /images/20220413/c05c2f6268a8474a9d834e3dd3254749.png
[format_png]: /images/20220413/0af1fb25d4a3439291c245be586726c3.png
[format_png 1]: /images/20220413/f4044d13d8ee4efba788f071acb0ee96.png
[http_localhost_9000_ribbon-consumer]: http://localhost:9000/ribbon-consumer
[format_png 2]: /images/20220413/5710888d12204970bc59b1c2726db4cb.png
[format_png 3]: /images/20220413/b0635ce4e770459f80ff490754d254c9.png
[HealerJean-]: https://github.com/HealerJean/com-hlj-springcloud/tree/master/1
[ContactAuthor]: /images/20220413/ad007e3a011a494d98831b9a9eb16fd1.png