Eureka 注册中心 & 服务注册 & 服务发现

收心

发布于 2022-08-24 16:25:36

2.3K0

文章被收录于专栏：Java实战博客Java实战博客

Eureka分为Eureka-Server，其他服务就变成Eureka-Client

Eureka基本原理：

Eureka实际就是一个注册中心，相当于我们的生活中的媒婆。

Eureka实际运行机制

如果我们要启动登陆服务3个。
我们每个登陆服务都会向eureka发送注册信息
Eureka-Server就会记录这些ip、端口信息。
如果有请求登陆服务，就会随机从3个健康的登陆服务抽取一个进行处理登陆业务。
同时每个Eureka-Client每30秒会向Eureka-Server发送心跳包，如果超过30秒没法，就会被Eureka-Server剔除

综合上述机制，就是实现了注册中心的功能。

代码实现

服务端

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

配置文件

# Eureka-Server配置信息
server.port=8090
spring.application.name=Eureka-Server
# 将自己注册到Eureka，自己即是服务端，也是客户端，作为客户端到原因时为了方便Eureka服务端集群使用，多个使用逗号隔开
eureka.client.service-url.defaultZone=http://127.0.0.1:8090/eureka

启动类

@SpringBootApplication
@EnableEurekaServer // 指定为Eureka-Server
@Slf4j
public class XxEurekaServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(XxEurekaServerApplication.class, args);
        System.out.println("项目启动成功后去访问本服务http://localhost:8090/ 就会展示Eureka的Dashpoard");
    }

}

启动项目，等待30秒，访问：127.0.0.1:8090

客户端使用

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

# Eureka-Client配置信息
server.port=8091
spring.application.name=Eureka-Client
# 将自己注册到Eureka
eureka.client.service-url.defaultZone=http://127.0.0.1:8090/eureka

启动类

@SpringBootApplication
@EnableEurekaClient // 指定为Eureka-Client
@Slf4j
public class XxEurekaClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(XxEurekaClientApplication.class, args);
    }

    @Bean
    @LoadBalanced // 默认也就是负载均衡
    public RestTemplate initRest() {
        return new RestTemplate();
    }

}

任意一个Controller

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class DiyController {

    @RequestMapping("/abc")
    public String hello() {
        System.out.println("请求进来了");
        return "OK";
    }

    @Autowired
    private RestTemplate restTemplate;

    @RequestMapping("/go")
    public String 模拟负载均衡请求() {
        // 测试远程调用
        ResponseEntity<Object> forEntity = restTemplate.getForEntity("http://EUREKA-CLIENT/abc", null);
        System.out.println("请求进来了");
        return "OK";
    }
}

启动项目，等待30秒，访问：127.0.0.1:8090 Eureka注册其中心就有个下文