zoukankan      html  css  js  c++  java
  • Eureka

    Eureka

    Eureka是spring cloud中的一个负责服务注册与发现的组件。遵循着CAP理论中的A(可用性)P(分区容错性)。一个Eureka中分为eureka server和eureka client。其中eureka server是作为服务的注册与发现中心。eureka client既可以作为服务的生产者,又可以作为服务的消费者

    eureka server实现

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            </dependency>
    
        <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>
    

    添加完成后,在我们的启动类中添加注解@EnableEurekaServer

    @SpringBootApplication
    @EnableEurekaServer
    public class ServiceRegistryApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(ServiceRegistryApplication.class, args);
        }
    
    }
    

    然后是一些配置信息在配置文件中配置:

    #服务端口
    server.port=8077
    #服务名称
    spring.application.name=eureka-server
    #服务地址
    eureka.instance.hostname=localhost
    
    #不向注册中心注册自己
    eureka.client.register-with-eureka=false
    #取消检索服务
    eureka.client.fetch-registry=false
    #开启注册中心的保护机制,默认是开启
    eureka.server.enable-self-preservation=true
    #设置保护机制的阈值,默认是0.85。
    eureka.server.renewal-percent-threshold=0.5
    
    #注册中心路径,如果有多个eureka server,在这里需要配置其他eureka server的地址,用","进行区分,如"http://address:8888/eureka,http://address:8887/eureka"
    eureka.client.service-url.default-zone=http://${eureka.instance.hostname}:${server.port}/eureka
    

    eureka client服务注册

    同样的先添加eureka client的包

     <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
    
        <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>
    
    

    然后在启动类中添加注解@EnableEurekaClient。

    @SpringBootApplication
    // 注意:服务端配置的是EnableEurekaServer,客户端配置的是EnableEurekaClient
    @EnableEurekaClient
    public class UserServerApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(UserServerApplication.class, args);
        }
    
    }
    
    

    在这里我们可以创建一个controller,用来提供一个服务,并填写返回值。

    @RestController
    public class UserController {
    
        @GetMapping("users/{id}")
        public String getUser(@PathVariable("id") String id) {
            System.out.println("接收到请求[/users/" + id + "]");
            return "testUser";
        }
    
    }
    
    

    在配置文件中添加配置信息:

    #服务端口
    server.port=7001
    #服务名称
    spring.application.name=user
    #服务地址
    eureka.instance.hostname=localhost
    
    #注册中心路径,表示我们向这个注册中心注册服务,如果向多个注册中心注册,用“,”进行分隔
    eureka.client.serviceUrl.defaultZone=http://localhost:8077/eureka
    #心跳间隔5s,默认30s。每一个服务配置后,心跳间隔和心跳超时时间会被保存在server端,不同服务的心跳频率可能不同,server端会根据保存的配置来分别探活
    eureka.instance.lease-renewal-interval-in-seconds=5
    #心跳超时时间10s,默认90s。从client端最后一次发出心跳后,达到这个时间没有再次发出心跳,表示服务不可用,将它的实例从注册中心移除
    eureka.instance.lease-expiration-duration-in-seconds=10
    复制代码
    

    eureka client服务消费者

    上面我们创建了一个注册中心和一个注册的服务,下面我们再通过eureka client来调用所注册的服务。

    在eureka中,实际上是不区分服务的消费者和服务生产者的,一个服务的消费者,同样也可以是一个服务的生产者。因此我们首先要做的就是再创建一个eureka client。这个enreka client命名为roleServer

    创建好eureka client后,我们创建一个配置类,创建RestTemplate来进行服务间的连接

    @Configuration
    public class RestConfig {
        
        @Bean
        @LoadBalanced //负载均衡
        public RestTemplate restTemplate() {
            return new RestTemplate();
        }
    
    }
    

    然后在Controller中进行服务的调用:

    @RestController
    public class RoleController {
    
        // 这里配置的是我们要调用的服务实例名,我们要调用USER服务,因此这里的地址是USER
        private String rest_url_prefix = "http://eureka";
    
        @Autowired
        private RestTemplate restTemplate;
    
        @GetMapping("roles/{id}")
        public String getRole(@PathVariable("id") String id) {
            System.out.println("接收到请求[/roles/" + id + "]");
    
            // 调用USER服务中的/users/{id}服务
            return restTemplate.getForObject(rest_url_prefix + "/users/" + id, String.class);
        }
    
    }
    
    代码使世界更精彩
  • 相关阅读:
    1月28日 layout_list_item
    1月27日 listview_MyListAdapter
    1月26日 listviewxml
    1月25日 textview
    1月24日 人月神话3
    体温填报(三)
    体温填报(二)
    体温填报(一)
    家庭记账本(六)
    家庭记账本(五)
  • 原文地址:https://www.cnblogs.com/lgx123/p/14861343.html
Copyright © 2011-2022 走看看