Comment résoudre le problème lorsque SpringBoot est déployé sur Tomcat externe et ne peut pas être enregistré sur le serveur Nacos

Que s'est-il passé

J'ai récemment effectué un support d'environnement de démonstration d'appel d'offres de projet (POC) et j'avais besoin d'intégrer le serveur Nacos. Considérant que les projets existants ont déjà des dépendances liées à Nacos, n'est-ce pas simple ? Créez un nouveau serveur, configurez-le et redémarrez-le plusieurs fois, n'est-ce pas ? Cependant, les choses sont loin d’être aussi simples qu’on le pense. Le même code peut être enregistré avec succès lorsqu'il est exécuté dans mon IDE local, mais ne peut pas être déployé dans l'environnement de démonstration Tomcat+War.

Après avoir débogué le code à distance, il a été constaté que les threads du client Nacos avaient été démarrés, mais l'enregistrement n'a pas réussi.

En réflexion

Je pensais que cela pourrait être lié au mode de déploiement de Tomcat, j'ai donc vérifié le problème officiel et StackOverFlow

L'événement est publié dans le cadre du démarrage de Spring Boot de l'instance Tomcat intégrée si vous déployez sur une instance externe. conteneur, il n'y a pas de conteneur intégré à démarrer et, par conséquent, aucun événement n'est publié - Andy Wilkinson

En gros, l'événement WebServerInitializedEvent ne sera publié qu'après que Spring Boot ait démarré avec succès le Tomcat intégré. Le client Nacos attendra que cet événement se produise avant de s'enregistrer auprès du serveur. Et comme il est déployé dans un Tomcat externe, le Tomcat intégré ne sera pas initialisé, donc cet événement ne sera pas déclenché. WebServerInitializedEvent 事件。而Nacos客户端在等这个事件出现才会向服务端注册自己。又因部署在外部Tomcat中就不会初始化内嵌Tomcat，也就没触发这个事件。

所以解决方法就是将Nacos等事件的部分代码调用下，让他们启动注册。

Nacos的自动注册类是 NacosAutoServiceRegistration，它继承Spring Cloud的AbstractAutoServiceRegistration，在AbstractAutoServiceRegistration等的 bind(WebServerInitializedEvent)方法监听事件，设置端口号并启动注册。这里边 this.port 是从事件中获取的，需要我们自行获取。

设置port的位置可见，是从org.springframework.cloud.client.serviceregistry.Registration

La solution est donc d'appeler certains codes d'événements comme Nacos et de les laisser commencer les inscriptions.

La classe d'enregistrement automatique de Nacos est NacosAutoServiceRegistration, qui hérite de AbstractAutoServiceRegistration de Spring Cloud, et bind(WebServerInitializedEvent)AbstractAutoServiceRegistration et ainsi on La méthode /code> écoute les événements, définit le numéro de port et démarre l'enregistrement. Ici, this.port est obtenu à partir de l'événement et doit être obtenu par nous-mêmes.

L'emplacement où le port est défini est visible. Il est extrait de org.springframework.cloud.client.serviceregistry.Registration. Définissez-le simplement.

🎜🎜🎜🎜Solution🎜🎜J'ai écrit une classe de configuration complète et je l'ai placée sous le ISSUE, qui est publié directement ci-dessous. 🎜

import java.lang.management.ManagementFactory;
import java.util.Set;
 
import javax.annotation.PostConstruct;
import javax.management.MBeanServer;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectName;
import javax.management.Query;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
 
import com.alibaba.cloud.nacos.registry.NacosAutoServiceRegistration;
import com.alibaba.cloud.nacos.registry.NacosRegistration;
 
@Configuration
public class NacosWarDeployConfig {
    private static final Logger logger = LoggerFactory.getLogger(NacosWarDeployConfig.class);
 
    @Autowired
    private Environment env;
    @Autowired
    private NacosRegistration registration;
    @Autowired
    private NacosAutoServiceRegistration nacosAutoServiceRegistration;
 
    @PostConstruct
    public void nacosServerRegister() {
        if (registration != null) {
            registration.setPort(getTomcatPort());
            nacosAutoServiceRegistration.start();
        }
    }
 
    public int getTomcatPort() {
        try {
            return getProvideTomcatPort();
        } catch (Exception e) {
            logger.warn("obtain provide tomcat port failed, fallback to embeded tomcat port.");
        }
        return getEmbeddedTomcatPort();
    }
 
    private int getProvideTomcatPort() throws MalformedObjectNameException, NullPointerException {
        MBeanServer beanServer = ManagementFactory.getPlatformMBeanServer();
        Set<ObjectName> objectNames = beanServer.queryNames(new ObjectName("*:type=Connector,*"),
                Query.match(Query.attr("protocol"), Query.value("HTTP/1.1")));
        String port = objectNames.iterator().next().getKeyProperty("port");
        return Integer.valueOf(port);
    }
 
    private int getEmbeddedTomcatPort() {
        return env.getProperty("server.port", Integer.class, 8080);
    }
 
}

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!