当前位置：首页 > news >正文

Spring Boot集成Spring Cloud 2024（不使用Feign）

news 2025/4/30 9:17:03

本文介绍Spring Boot集成Spring Cloud 2024，且不使用Feign，而是采用Spring 6自带的@HttpExchange方式进行服务调用的详细步骤：

环境准备

Spring Boot版本：推荐使用Spring Boot 3.4.1及以上版本，以更好地与Spring Cloud 2024适配。
Java版本：建议使用Java 21，以获得更好的性能和特性支持。

集成步骤

1. 创建项目并添加依赖

通过Spring Initializr（https://start.spring.io/）创建Spring Boot项目，在pom.xml文件中添加以下依赖：

<properties><java.version>21</java.version><springcloud.version>2024.0.0</springcloud.version><springboot.version>3.4.1</springboot.version>
</properties><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${springcloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies>
</dependencyManagement><dependencies><!-- Spring Boot Web 依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- Spring Boot WebFlux 依赖，用于 @HttpExchange --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-webflux</artifactId></dependency><!-- Spring Cloud 服务发现依赖（以 Eureka 为例） --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency>
</dependencies>

2. 配置服务注册中心（以Eureka为例）

2.1 添加Eureka Server依赖

在服务注册中心项目的pom.xml中添加以下依赖：

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

2.2 配置Eureka Server

在application.yml文件中添加如下配置：

server:port: 8761  # Eureka服务器端口
spring:application:name: eureka-server  # 服务名称
eureka:client:register-with-eureka: false  # 不将自己注册到Eurekafetch-registry: false  # 不从Eureka获取服务列表

2.3 启用Eureka Server

在Spring Boot主应用类上添加@EnableEurekaServer注解：

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);}
}

3. 配置服务提供者

3.1 添加Eureka客户端依赖

确保服务提供者项目的pom.xml中包含spring-cloud-starter-netflix-eureka-client依赖。

3.2 配置Eureka客户端

在application.yml中配置如下内容：

spring:application:name: my-service-provider  # 服务名称
eureka:client:service-url:defaultZone: http://localhost:8761/eureka/  # Eureka服务器地址register-with-eureka: true  # 注册到Eureka服务器fetch-registry: true  # 从Eureka服务器获取服务列表

3.3 创建服务接口和实现类

编写业务接口和实现类，提供具体的服务功能。例如：

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class HelloController {@GetMapping("/hello")public String hello() {return "Hello from service provider!";}
}

3.4 启用Eureka客户端

在Spring Boot主应用类上添加@EnableEurekaClient注解：

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

4. 配置服务消费者

4.1 添加依赖

服务消费者项目的pom.xml中同样需要spring-cloud-starter-netflix-eureka-client以及spring-boot-starter-webflux依赖。

4.2 配置Eureka客户端

与服务提供者类似，在application.yml中配置Eureka客户端信息，指定Eureka服务器地址等：

spring:application:name: my-service-consumer  # 服务名称
eureka:client:service-url:defaultZone: http://localhost:8761/eureka/  # Eureka服务器地址register-with-eureka: true  # 注册到Eureka服务器fetch-registry: true  # 从Eureka服务器获取服务列表

4.3 使用`@HttpExchange`进行服务调用

首先，创建一个配置类来配置WebClient和HttpServiceProxyFactory：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.function.client.WebClient;
import org.springframework.web.service.invoker.HttpServiceProxyFactory;@Configuration
public class ClientConfig {@Beanpublic WebClient webClient() {return WebClient.builder().build();}@Beanpublic HttpServiceProxyFactory httpServiceProxyFactory(WebClient webClient) {return HttpServiceProxyFactory.builder(WebClientAdapter.forClient(webClient)).build();}
}

然后，定义一个使用@HttpExchange的接口来调用服务提供者的接口：

import org.springframework.web.service.annotation.GetExchange;
import org.springframework.web.service.annotation.HttpExchange;@HttpExchange
public interface HelloServiceClient {@GetExchange("http://my-service-provider/hello")String getHelloMessage();
}

最后，在服务消费者的控制器中使用该接口进行调用：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class ConsumerController {@Autowiredprivate HelloServiceClient helloServiceClient;@GetMapping("/call-provider")public String callProvider() {return helloServiceClient.getHelloMessage();}
}