快捷導(dǎo)航

Spring Gateway集成 Nacos注冊(cè)中心不能夠發(fā)現(xiàn)服務(wù)的解決方案

更新時(shí)間：2026年01月09日 10:13:48 作者：馮立彬

文章描述了在將Eureka替換為Nacos后,Spring Cloud Gateway在調(diào)用Nacos注冊(cè)的服務(wù)時(shí)出現(xiàn)問(wèn)題,通過(guò)調(diào)試和分析,發(fā)現(xiàn)Spring Cloud Gateway在初始化時(shí)沒(méi)有正確加載Nacos的ReactiveDiscoveryClient,導(dǎo)致服務(wù)調(diào)用失敗,感興趣的朋友跟隨小編一起看看吧

一、問(wèn)題描述

我們現(xiàn)在是在用Nacos替換Eureka，原來(lái)Eureka和Spring gateway運(yùn)行正常，可以通過(guò)Spring gateway調(diào)用注冊(cè)到Eureka中的服務(wù)。

當(dāng)前Spring cloud的版本是Hoxton.SR8，Nacos discovery的版本為0.9.0.RELEASE，使用的Nacos版本為2.0.3。

Nacos替換Eureka改動(dòng)的地方如下：

１、去掉POM中Eureka的引入；

２、去掉主類(lèi)中引入的@EnableEurekaClient注解；

３、引入Nacos依賴(lài)：

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  <version>0.9.0.RELEASE</version>
  <exclusions>
    <exclusion>
        <groupId>com.alibaba.nacos</groupId>
        <artifactId>nacos-client</artifactId>
    </exclusion>
    <exclusion>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
    </exclusion>
  </exclusions>
</dependency>
<dependency>
  <groupId>com.alibaba.nacos</groupId>
  <artifactId>nacos-client</artifactId>
  <version>2.0.3</version>
</dependency>

４、引入spring-cloud-loadbalancer：

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

５、spring-cloud-starter-openfeign中exclude掉ribbon的依賴(lài)：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
    <exclusions>
        <exclusion>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-netflix-ribbon</artifactId>
        </exclusion>
    </exclusions>
</dependency>

６、application.yml中禁用nacos的ribbon：

ribbon:
  nacos:
    enabled: false

現(xiàn)在的現(xiàn)象：

Spring gateway啟動(dòng)不報(bào)錯(cuò)；
gateway也可以正常注冊(cè)到Nacos；
通過(guò)打斷點(diǎn)到NacosDiscoveryClientAutoConfiguration，NacosDiscoveryClient會(huì)被初使化，但是調(diào)用時(shí)不會(huì)調(diào)用NacosDiscoveryClient.getInstances(String)獲取被調(diào)用應(yīng)用的Provider，會(huì)報(bào)類(lèi)似下面的接口404錯(cuò)誤：

{"msg":"/user-service/user/getByToken","result":404,"data":null}

其中user-service為注冊(cè)到Nacos上面的服務(wù)名稱(chēng)，但是就是不能夠被調(diào)用到。

Spring gateway的注冊(cè)中心切換為Eureka，再次調(diào)用服務(wù)時(shí)，Eureka的CompositeDiscoveryClient.getInstances(String)方法就會(huì)被調(diào)用。

二、問(wèn)題分析

前面走了一些彎路，也花了一些時(shí)間，最后想到的是與Eureka注冊(cè)中心進(jìn)行對(duì)比調(diào)試分析，下面例出關(guān)鍵的分析步驟。

Debug斷點(diǎn)打到DiscoveryClientRouteDefinitionLocator兩個(gè)構(gòu)造函數(shù)上，只有參數(shù)是ReactiveDiscoveryClient的構(gòu)造函數(shù)被加載：

繼續(xù)跟蹤到ReactiveCompositeDiscoveryClient.getServices()方法：

發(fā)現(xiàn)數(shù)組變量discoveryClients包含了兩個(gè)實(shí)現(xiàn)，如下圖所示：

其中有一個(gè)是EurekaReactiveDiscoveryClient，那在使用Nacos時(shí)就應(yīng)該包含一個(gè)針對(duì)Nacos實(shí)現(xiàn)的ReactiveDiscoveryClient，于是切換為Nacos分支調(diào)試。

但是調(diào)試發(fā)現(xiàn)數(shù)組變量discoveryClients并沒(méi)有包含針對(duì)Nacos實(shí)現(xiàn)的ReactiveDiscoveryClient：

于是參考EurekaReactiveDiscoveryClient以及NacosDiscoveryClient，立即就寫(xiě)了NacosReactiveDiscoveryClient：

import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.springframework.cloud.alibaba.nacos.NacosDiscoveryProperties;
import org.springframework.cloud.alibaba.nacos.NacosServiceInstance;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.ReactiveDiscoveryClient;
import com.alibaba.nacos.api.naming.pojo.Instance;
import com.alibaba.nacos.api.naming.pojo.ListView;
import lombok.extern.slf4j.Slf4j;
import reactor.core.publisher.Flux;
/**
 * 
 * @author fenglibin
 *
 */
@Slf4j
public class NacosReactiveDiscoveryClient implements ReactiveDiscoveryClient {
	public static final String DESCRIPTION = "Spring Cloud Nacos Reactive Discovery Client";
	private NacosDiscoveryProperties discoveryProperties;
	public NacosReactiveDiscoveryClient(NacosDiscoveryProperties discoveryProperties) {
		this.discoveryProperties = discoveryProperties;
	}
	@Override
	public String description() {
		return DESCRIPTION;
	}
	@Override
	public Flux<ServiceInstance> getInstances(String serviceId) {
		try {
			List<Instance> instances = discoveryProperties.namingServiceInstance().selectInstances(serviceId, true);
			return Flux.fromStream(hostToServiceInstanceList(instances, serviceId).stream());
		} catch (Exception e) {
			throw new RuntimeException("Can not get hosts from nacos server. serviceId: " + serviceId, e);
		}
	}
	@Override
	public Flux<String> getServices() {
		try {
			ListView<String> services = discoveryProperties.namingServiceInstance().getServicesOfServer(1,
					Integer.MAX_VALUE);
			return Flux.fromStream(services.getData().parallelStream());
		} catch (Exception e) {
			log.error("get service name from nacos server fail,", e);
			return Flux.fromStream(Collections.<String>emptyList().stream());
		}
	}
	private static ServiceInstance hostToServiceInstance(Instance instance, String serviceId) {
		NacosServiceInstance nacosServiceInstance = new NacosServiceInstance();
		nacosServiceInstance.setHost(instance.getIp());
		nacosServiceInstance.setPort(instance.getPort());
		nacosServiceInstance.setServiceId(serviceId);
		Map<String, String> metadata = new HashMap<>();
		metadata.put("nacos.instanceId", instance.getInstanceId());
		metadata.put("nacos.weight", instance.getWeight() + "");
		metadata.put("nacos.healthy", instance.isHealthy() + "");
		metadata.put("nacos.cluster", instance.getClusterName() + "");
		metadata.putAll(instance.getMetadata());
		nacosServiceInstance.setMetadata(metadata);
		if (metadata.containsKey("secure")) {
			boolean secure = Boolean.parseBoolean(metadata.get("secure"));
			nacosServiceInstance.setSecure(secure);
		}
		return nacosServiceInstance;
	}
	private static List<ServiceInstance> hostToServiceInstanceList(List<Instance> instances, String serviceId) {
		List<ServiceInstance> result = new ArrayList<>(instances.size());
		for (Instance instance : instances) {
			result.add(hostToServiceInstance(instance, serviceId));
		}
		return result;
	}
}

或者集成如下starter：

    <dependency>
        <groupId>com.eeeffff</groupId>
        <artifactId>nacos-reactive-discovery-client</artifactId>
        <version>1.0.0</version>
    </dependency>

并在啟動(dòng)時(shí)創(chuàng)建Bean：

再次啟動(dòng)調(diào)試就可以看到數(shù)組變量discoveryClients中有NacosReactiveDiscoveryClient了：

再次通過(guò)網(wǎng)關(guān)請(qǐng)求服務(wù)，就可以正常調(diào)用成功了。

感覺(jué)Nacos的怪問(wèn)題都讓我給碰上了！

到此這篇關(guān)于Spring Gateway集成 Nacos注冊(cè)中心不能夠發(fā)現(xiàn)服務(wù)的解決方案的文章就介紹到這了,更多相關(guān)Spring Gateway集成 Nacos內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: