nacos-eureka如何平滑迁移到nacos（四）

上一篇文章nacos-作为注册中心与springcloud整合（三），我们已经用nacos代替eureka作为springcloud的注册中心了，但是实际生产环境要比练习环境复杂得多。

1. 每换一个组件或者中间件都有可能存在的风险，有可能会出现测试环境没问题，但是正式环境有问题的情况

2. 更换中间更换组件都需要有一个中间过渡期，一般的过渡期方案，部分不重要的业务尝试用新组件，观察一段时间，然后逐步把一些重要业务切换到新的组件。

这里介绍如何通过nacos-sync工程将eureka平滑过渡到nacos。

一、整体架构设计方案

  1. app1应用注册到eureka，app2应用注册nacos。
  2. nacos-sync应用把eureka的数据同步到nacos，同时把nacos的数据同步到eureka，让eureka和nacos都保存最全的注册信息。
  3. app1通过eureka获取app2的注册信息，然后通过feign远程调用app2的接口。
  4. app2通过nacos获取app1的注册信息，然后通过feign远程调用app1的接口。

二、项目搭建

1、新建并部署nacos工程，参考文章nacos-简介和初体验（一）

2、新建并部署eureka工程。

  1. 新建boot工程，pom文件
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.4.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.eujian</groupId>
    <artifactId>eureka</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>eureka</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.SR8</spring-cloud.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>
  1. application.properties文件配置如下：
server.port=8761
eureka.instance.hostname=eureka
eureka.client.fetch-registry=false
eureka.client.register-with-eureka=false
eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/
eureka.server.enable-self-preservation=false
eureka.server.eviction-interval-timer-in-ms= 5000

  1. 启动类增加注解@EnableEurekaServer并启动应用。

  2. 登录ip:8761查看eureka管理台


3、新建并部署nacos-sync工程。

  1. 执行命令打包
git clone https://github.com/nacos-group/nacos-sync.git
cd nacosSync/
mvn clean package -U

如果打包过程出现如下报错

则可以修改nacossync-distribution目录下面的pom文件
在plugin标签的configuration内加上<tarLongFileMode>posix</tarLongFileMode>


cd nacos-sync/nacossync-distribution/target
tar -zxvf nacosSync.0.4.1.tar.gz
cd /nacosSync.0.4.1/nacosSyn
  1. 初始化mysql数据库
    系统默认配置的数据库是Mysql，也能支持其他的关系型数据库。 1.建库，缺省的数据库名字为“nacos_sync”。 2.数据库表不需要单独创建，默认使用了hibernate的自动建表功能。 3.如果你的环境不支持自动建表，可以使用系统自带的sql脚本建表，脚本放在bin目录下。

数据库的配置文件放在conf/application.properties中：

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/nacos_sync?characterEncoding=utf8
spring.datasource.username=root
spring.datasource.password=root
  1. 启动服务器，启动脚本在bin目录下面
    sh startup.sh start

  2. 登录host:8081地址查看


4、新建eureka-provider和eureka-nacos-provider工程，并配置eureka为注册中心。

  1. pom文件
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.4.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.eujian</groupId>
    <artifactId>eureka-provider</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>eureka-provider</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.SR8</spring-cloud.version>
    </properties>
    <dependencies>
        <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>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>
  1. eureka-provider新建controller和feign类,并在启动类增加注解@EnableFeignClients @EnableDiscoveryClient 
@RestController
@RequestMapping
public class EurekaController {
    @Autowired
    private ProviderFeign providerFeign;

    @GetMapping("/action")
    public String demo(@RequestParam("action")String act){
        return "eureka-provider:"+providerFeign.microFeign(act);
    }

    @GetMapping("/micro/feign")
    public String microFeign(@RequestParam("act")String act){
        return "eureka-provide-microFeign:"+act;
    }
}

@FeignClient(name = "eureka-nacos-provider")
public interface ProviderFeign {
    @GetMapping("/micro/feign")
    String microFeign(@RequestParam("act")String act);
}
  1. 增加application.properties配置
server.port=8091
spring.application.name=eureka-provider
eureka.instance.prefer-ip-address=true
eureka.instance.lease-renewal-interval-in-seconds= 5
eureka.instance.lease-expiration-duration-in-seconds= 20
eureka.client.serviceUrl.defaultZone= http://nacoshost:8761/eureka
eureka.client.serviceUrl.registry-fetch-interval-seconds= 10
  1. eureka-nacos-provider新建controller和feign类,并在启动类增加注解@EnableFeignClients @EnableDiscoveryClient 
@RestController
@RequestMapping
public class EurekaNacosController {
    @Autowired
    private ProviderFeign providerFeign;
    @GetMapping("/action")
    public String demo(@RequestParam("action")String act){
        return "eureka-nacos-provider:"+providerFeign.microFeign(act);
    }

    @GetMapping("/micro/feign")
    public String microFeign(@RequestParam("act")String act){
        return "eureka-nacos-provide-microFeign:"+act;
    }
}

@FeignClient(name = "eureka-provider")
public interface ProviderFeign {
    @GetMapping("/micro/feign")
    String microFeign(@RequestParam("act") String act);
}
  1. 增加application.properties配置
server.port=8093
spring.application.name=eureka-nacos-provider
eureka.instance.prefer-ip-address=true
eureka.instance.lease-renewal-interval-in-seconds= 5
eureka.instance.lease-expiration-duration-in-seconds= 20
eureka.client.serviceUrl.defaultZone= http://nacoshost:8761/eureka
eureka.client.serviceUrl.registry-fetch-interval-seconds= 10

5、配置nacos-sync的数据同步规则，验证数据同步功能。

  1. 在IP:8081页面新建集群


对于类型为nacos的集群填写ip集群为

ip1:8848
ip2:8848

对于类型为eureka的集群填写ip集群为

http://ip1:8761/eureka
http://ip2:8761/eureka

  1. 配置数据同步规则



    服务名是提供者的服务名，这里以eureka-provider为例子。
    分组名不填

  2. 查看nacos页面


三、测试模拟迁移过程

1、eureka-provider和eureka-nacos-provider都注册到eureka，测试两个应用之间的调用联通性。

执行命令http://localhost:8091/action?action=调用的是eureka-provider
执行命令http://localhost:8093/action?action=调用的是eureka-nacos-provider


2、配置eureka-nacos-provider注册到nacos，同时配置nacos同步数据到eureka。

  1. 把eureka-nacos-provider的工程pom依赖修改，把netflix修改为nacos的服务发现
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            <version>2.2.5.RELEASE</version>
        </dependency>
<!--        <dependency>-->
<!--            <groupId>org.springframework.cloud</groupId>-->
<!--            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>-->
<!--        </dependency>-->
  1. 配置文件修改为
server.port=8093
spring.application.name=eureka-nacos-provider
#eureka.instance.prefer-ip-address=true
#eureka.instance.lease-renewal-interval-in-seconds= 5
#eureka.instance.lease-expiration-duration-in-seconds= 20
#eureka.client.serviceUrl.defaultZone= http://nacoshost:8761/eureka
#eureka.client.serviceUrl.registry-fetch-interval-seconds= 10
spring.cloud.nacos.discovery.server-addr=nacoshost:8848

  1. 重启eureka-nacos-provider，并在nacos-sync配置同步规则



    eureka的数据

  2. 测试两个应用之间的调用联通性。
    执行命令http://localhost:8091/action?action=调用的是eureka-provider
    执行命令http://localhost:8093/action?action=调用的是eureka-nacos-provider

3、eureka-provider和eureka-nacos-provider都注册到nacos。

同样的操作在eureka-provider操作一次

执行命令http://localhost:8091/action?action=调用的是eureka-provider
执行命令http://localhost:8093/action?action=调用的是eureka-nacos-provider

码云地址：https://gitee.com/guoeryyj/nacos-demo.git

系列文章：
nacos - 简介和初体验（一）
nacos - 作为配置中心与springcloud整合（二)
nacos - 作为注册中心与springcloud整合（三）
nacos - eureka如何平滑迁移到nacos（四）

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容