Spring Boot与Netflix Eureka的集成

简介: Spring Boot与Netflix Eureka的集成

Spring Boot与Netflix Eureka的集成

今天我们来探讨一下如何在Spring Boot中集成Netflix Eureka。Netflix Eureka是一个用于服务注册与发现的工具,在微服务架构中扮演着重要角色。通过Eureka,微服务能够方便地发现彼此,从而实现负载均衡和故障转移等功能。

一、Eureka简介

Netflix Eureka是一个REST服务,主要用于定位服务,以实现中间层服务器的负载均衡和故障转移。Eureka包含两个组件:Eureka Server和Eureka Client。Eureka Server用作服务注册中心,而Eureka Client则是一个注册到Eureka Server上的服务。

二、创建Eureka Server

  1. 新建Spring Boot项目
    首先,我们创建一个Spring Boot项目,用作Eureka Server。在pom.xml中添加以下依赖:

     <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
     </dependency>
     <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-web</artifactId>
     </dependency>
    
  2. 配置Eureka Server
    application.properties中添加Eureka Server的配置:

     server.port=8761
     eureka.client.register-with-eureka=false
     eureka.client.fetch-registry=false
     eureka.server.enable-self-preservation=false
    
  3. 启用Eureka Server
    在Spring Boot应用主类中添加@EnableEurekaServer注解:

     package cn.juwatech;
    
     import org.springframework.boot.SpringApplication;
     import org.springframework.boot.autoconfigure.SpringBootApplication;
     import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
     @SpringBootApplication
     @EnableEurekaServer
     public class EurekaServerApplication {
         
         public static void main(String[] args) {
         
             SpringApplication.run(EurekaServerApplication.class, args);
         }
     }
    

三、创建Eureka Client

  1. 新建Spring Boot项目
    创建一个Spring Boot项目,用作Eureka Client。在pom.xml中添加以下依赖:

     <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
     </dependency>
     <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-web</artifactId>
     </dependency>
    
  2. 配置Eureka Client
    application.properties中添加Eureka Client的配置:

     server.port=8080
     eureka.client.service-url.defaultZone=http://localhost:8761/eureka/
     eureka.instance.prefer-ip-address=true
    
  3. 启用Eureka Client
    在Spring Boot应用主类中添加@EnableEurekaClient注解:

     package cn.juwatech;
    
     import org.springframework.boot.SpringApplication;
     import org.springframework.boot.autoconfigure.SpringBootApplication;
     import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
     @SpringBootApplication
     @EnableEurekaClient
     public class EurekaClientApplication {
         
         public static void main(String[] args) {
         
             SpringApplication.run(EurekaClientApplication.class, args);
         }
     }
    

四、验证Eureka集成

  1. 启动Eureka Server
    运行Eureka Server项目,在浏览器中访问http://localhost:8761,你应该能够看到Eureka仪表盘。

  2. 启动Eureka Client
    运行Eureka Client项目,稍等片刻,然后刷新Eureka仪表盘,你应该能够看到Eureka Client已经注册到Eureka Server。

五、使用Eureka Client进行服务发现

在实际项目中,我们通常需要在Eureka Client中调用其他服务。下面我们展示如何使用Eureka Client进行服务发现和调用。

  1. 创建一个REST控制器
    在Eureka Client项目中,创建一个简单的REST控制器:

     package cn.juwatech.controller;
    
     import org.springframework.web.bind.annotation.GetMapping;
     import org.springframework.web.bind.annotation.RestController;
    
     @RestController
     public class HelloController {
         
         @GetMapping("/hello")
         public String sayHello() {
         
             return "Hello from Eureka Client!";
         }
     }
    
  2. 创建一个Feign Client
    为了调用其他服务,我们可以使用Feign Client。首先,在pom.xml中添加Feign依赖:

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

    然后,创建一个Feign Client接口:

     package cn.juwatech.client;
    
     import org.springframework.cloud.openfeign.FeignClient;
     import org.springframework.web.bind.annotation.GetMapping;
    
     @FeignClient(name = "eureka-client")
     public interface HelloClient {
         
         @GetMapping("/hello")
         String sayHello();
     }
    
  3. 启用Feign Client
    在Spring Boot应用主类中添加@EnableFeignClients注解:

     package cn.juwatech;
    
     import org.springframework.boot.SpringApplication;
     import org.springframework.boot.autoconfigure.SpringBootApplication;
     import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
     import org.springframework.cloud.openfeign.EnableFeignClients;
    
     @SpringBootApplication
     @EnableEurekaClient
     @EnableFeignClients
     public class EurekaClientApplication {
         
         public static void main(String[] args) {
         
             SpringApplication.run(EurekaClientApplication.class, args);
         }
     }
    
  4. 使用Feign Client
    创建一个REST控制器,使用Feign Client调用其他服务:

     package cn.juwatech.controller;
    
     import cn.juwatech.client.HelloClient;
     import org.springframework.beans.factory.annotation.Autowired;
     import org.springframework.web.bind.annotation.GetMapping;
     import org.springframework.web.bind.annotation.RestController;
    
     @RestController
     public class FeignController {
         
    
         @Autowired
         private HelloClient helloClient;
    
         @GetMapping("/feign-hello")
         public String feignHello() {
         
             return helloClient.sayHello();
         }
     }
    

总结

通过本文,我们了解了如何在Spring Boot中集成Netflix Eureka,从创建Eureka Server和Eureka Client开始,到使用Feign Client进行服务发现和调用。Eureka作为服务注册与发现的核心组件,能够极大地简化微服务架构中的服务管理,提升系统的可扩展性和容错能力。

相关文章
|
2月前
|
安全 Java 数据库
第16课:Spring Boot中集成 Shiro
第16课:Spring Boot中集成 Shiro
467 0
|
2月前
|
消息中间件 存储 Java
第15课: Spring Boot中集成ActiveMQ
第15课: Spring Boot中集成ActiveMQ
267 0
|
3月前
|
人工智能 Java 测试技术
Spring Boot 集成 JUnit 单元测试
本文介绍了在Spring Boot中使用JUnit 5进行单元测试的常用方法与技巧,包括添加依赖、编写测试类、使用@SpringBootTest参数、自动装配测试模块(如JSON、MVC、WebFlux、JDBC等),以及@MockBean和@SpyBean的应用。内容实用,适合Java开发者参考学习。
414 0
|
6月前
|
安全 Java Apache
微服务——SpringBoot使用归纳——Spring Boot中集成 Shiro——Shiro 身份和权限认证
本文介绍了 Apache Shiro 的身份认证与权限认证机制。在身份认证部分,分析了 Shiro 的认证流程,包括应用程序调用 `Subject.login(token)` 方法、SecurityManager 接管认证以及通过 Realm 进行具体的安全验证。权限认证部分阐述了权限(permission)、角色(role)和用户(user)三者的关系,其中用户可拥有多个角色,角色则对应不同的权限组合,例如普通用户仅能查看或添加信息,而管理员可执行所有操作。
297 0
|
6月前
|
安全 Java 数据安全/隐私保护
微服务——SpringBoot使用归纳——Spring Boot中集成 Shiro——Shiro 三大核心组件
本课程介绍如何在Spring Boot中集成Shiro框架,主要讲解Shiro的认证与授权功能。Shiro是一个简单易用的Java安全框架,用于认证、授权、加密和会话管理等。其核心组件包括Subject(认证主体)、SecurityManager(安全管理员)和Realm(域)。Subject负责身份认证,包含Principals(身份)和Credentials(凭证);SecurityManager是架构核心,协调内部组件运作;Realm则是连接Shiro与应用数据的桥梁,用于访问用户账户及权限信息。通过学习,您将掌握Shiro的基本原理及其在项目中的应用。
234 0
|
6月前
|
NoSQL Java 关系型数据库
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 介绍
本文介绍在 Spring Boot 中集成 Redis 的方法。Redis 是一种支持多种数据结构的非关系型数据库(NoSQL),具备高并发、高性能和灵活扩展的特点,适用于缓存、实时数据分析等场景。其数据以键值对形式存储,支持字符串、哈希、列表、集合等类型。通过将 Redis 与 Mysql 集群结合使用,可实现数据同步,提升系统稳定性。例如,在网站架构中优先从 Redis 获取数据,故障时回退至 Mysql,确保服务不中断。
253 0
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 介绍
|
2月前
|
缓存 JSON 前端开发
第07课:Spring Boot集成Thymeleaf模板引擎
第07课:Spring Boot集成Thymeleaf模板引擎
354 0
第07课:Spring Boot集成Thymeleaf模板引擎
|
6月前
|
XML Java 数据库连接
微服务——SpringBoot使用归纳——Spring Boot集成MyBatis——基于 xml 的整合
本教程介绍了基于XML的MyBatis整合方式。首先在`application.yml`中配置XML路径,如`classpath:mapper/*.xml`,然后创建`UserMapper.xml`文件定义SQL映射,包括`resultMap`和查询语句。通过设置`namespace`关联Mapper接口,实现如`getUserByName`的方法。Controller层调用Service完成测试,访问`/getUserByName/{name}`即可返回用户信息。为简化Mapper扫描,推荐在Spring Boot启动类用`@MapperScan`注解指定包路径避免逐个添加`@Mapper`
251 0
|
3月前
|
监控 安全 Java
Java 开发中基于 Spring Boot 3.2 框架集成 MQTT 5.0 协议实现消息推送与订阅功能的技术方案解析
本文介绍基于Spring Boot 3.2集成MQTT 5.0的消息推送与订阅技术方案,涵盖核心技术栈选型(Spring Boot、Eclipse Paho、HiveMQ)、项目搭建与配置、消息发布与订阅服务实现,以及在智能家居控制系统中的应用实例。同时,详细探讨了安全增强(TLS/SSL)、性能优化(异步处理与背压控制)、测试监控及生产环境部署方案,为构建高可用、高性能的消息通信系统提供全面指导。附资源下载链接:[https://pan.quark.cn/s/14fcf913bae6](https://pan.quark.cn/s/14fcf913bae6)。
491 0
|
5月前
|
Java 开发工具 Spring
【Azure Application Insights】为Spring Boot应用集成Application Insight SDK
本文以Java Spring Boot项目为例,详细说明如何集成Azure Application Insights SDK以收集和展示日志。内容包括三步配置:1) 在`pom.xml`中添加依赖项`applicationinsights-runtime-attach`和`applicationinsights-core`;2) 在main函数中调用`ApplicationInsights.attach()`;3) 配置`applicationinsights.json`文件。同时提供问题排查建议及自定义日志方法示例,帮助用户顺利集成并使用Application Insights服务。
122 8

热门文章

最新文章