主页 / coding / 问题 / 76920125
Accepted
ans06
Asked: 2023-08-17 17:21:12 +0800 CST

想要使用eureka服务器使用微服务名称而不使用端口号来访问微服务

  • 772

当我尝试使用 eureka 服务器 Web 客户端构建器访问微服务时，要求提供微服务名称以及非标准端口号。如果我不使用端口号，则会生成错误。

我想使用尤里卡服务器进行服务发现。我的想法是，当您发现微服务时，您无需提及非标准端口地址和微服务名称。但就我而言，我必须提及端口地址这是我的所有代码详细信息：

尤里卡服务器：

应用程序属性：

    spring.application.name=eureka-server
    server.port=8761

    eureka.client.register-with-eureka=false
    eureka.client.fetch-registry=false

代码春季启动：

    @SpringBootApplication
    @EnableEurekaServer
    public class EurakaServerApplication {

    public static void main(String[] args) {

        SpringApplication.run(EurakaServerApplication.class, args);
    }

    }

消费者服务：

     @Service

public class ConsumerService {

    @LoadBalanced
    private final WebClient webClient;

    public ConsumerService(WebClient.Builder webClientBuilder) {
        this.webClient = webClientBuilder.baseUrl("http://microservice1:8080").build();
    }


    public Mono<String> getProcessedData() {
        return webClient
                .get()
                .uri("/producer/data")
                .retrieve()
                .bodyToMono(String.class)
                .map(data -> data + " - Extra Information Added");
       }
    }

消费者控制器：

    @RestController
    @RequestMapping("/consumer")
    public class ConsumerController {

    private final ConsumerService consumerService;


    public ConsumerController(ConsumerService consumerService) {
        this.consumerService = consumerService;
    }
    //localhost:8081/consumer/processed-data
    @GetMapping("/processed-data")
    public Mono<String> getProcessedData() {
        return consumerService.getProcessedData();
    }
    }

应用程序属性：

    server.port=8081
    spring.application.name=microservice2

生产者应用程序属性：

    server.port=8080
    spring.application.name=microservice1

生产者申请：

    @SpringBootApplication
    @EnableDiscoveryClient
    public class ProducerApplication {

    public static void main(String[] args) {

        SpringApplication.run(ProducerApplication.class, args);
    }}

错误消息（如果我删除端口号 8080）：

Servlet.service() for servlet \[dispatcherServlet\] in context with path \[\] threw exception \[Request processing failed: org.springframework.web.reactive.function.client.WebClientRequestException: finishConnect(..) failed: Connection refused: microservice1/127.0.0.1:80\] with root cause

java.net.ConnectException: finishConnect(..) failed: Connection refused

我不想使用 microservice1:8080（对我来说它有效）。我只想使用“microservice1”。如果我不提及端口 8080，它会自动寻找端口 80。它显示连接拒绝错误。我想使用 http://microservice1 。

谢谢 。

spring-boot

1 个回答

  1. Best Answer

    创建您自己的配置类，并通过提供baseUrl不带端口（仅服务器名称）的服务来为您的服务创建一个构建器，如下所示。

    @Configuration
@AllArgsConstructor
public class UtilConfigWebClient {

    private final EurekaClient eurekaClient;

    /**
     * this is only for microservice1
     *
     * @return {@link WebClient.Builder} with base url as http://microservice1
     */
    @Bean("microservice1WebClientBuilder")
    @LoadBalanced
    public WebClient.Builder paymentWebClientBuilder() {
        return WebClient.builder()
                .baseUrl("http://microservice1");
    }
}

    @Qualifier使用Like this将该 bean（它应该是 WebClient.Builder，而不是 WebClient）注入到 ConsumerService 服务中。

    @Service
public class ConsumerService {
    private final WebClient.Builder microservice1WebClient;

    public ConsumerService(@Qualifier("microservice1WebClientBuilder") WebClient.Builder microservice1WebClient) {
        this.microservice1WebClient = microservice1WebClient;
    }

    public Mono<String> getProcessedData() {
        return microservice1WebClient.build()
                .get()
                .uri("/producer/data")
                .retrieve()
                .bodyToMono(String.class)
                .map(data -> data + " - Extra Information Added");
    }
}
    • 0

相关问题