上一篇文章nacos-作为注册中心与springcloud整合(三),我们已经用nacos代替eureka作为springcloud的注册中心了,但是实际生产环境要比练习环境复杂得多。
1. 每换一个组件或者中间件都有可能存在的风险,有可能会出现测试环境没问题,但是正式环境有问题的情况
2. 更换中间更换组件都需要有一个中间过渡期,一般的过渡期方案,部分不重要的业务尝试用新组件,观察一段时间,然后逐步把一些重要业务切换到新的组件。
这里介绍如何通过nacos-sync工程将eureka平滑过渡到nacos。
一、整体架构设计方案
- app1应用注册到eureka,app2应用注册nacos。
- nacos-sync应用把eureka的数据同步到nacos,同时把nacos的数据同步到eureka,让eureka和nacos都保存最全的注册信息。
- app1通过eureka获取app2的注册信息,然后通过feign远程调用app2的接口。
- app2通过nacos获取app1的注册信息,然后通过feign远程调用app1的接口。
二、项目搭建
1、新建并部署nacos工程,参考文章nacos-简介和初体验(一)
2、新建并部署eureka工程。
- 新建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>
-
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
启动类增加注解
@EnableEurekaServer
并启动应用。-
登录ip:8761查看eureka管理台
3、新建并部署nacos-sync工程。
- 执行命令打包
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
- 初始化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
- 启动服务器,启动脚本在bin目录下面
sh startup.sh start
-
登录host:8081地址查看
4、新建eureka-provider和eureka-nacos-provider工程,并配置eureka为注册中心。
- 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>
- 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);
}
- 增加
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
- 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);
}
- 增加
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的数据同步规则,验证数据同步功能。
-
在IP:8081页面新建集群
对于类型为nacos的集群填写ip集群为
ip1:8848
ip2:8848
对于类型为eureka的集群填写ip集群为
http://ip1:8761/eureka
http://ip2:8761/eureka
-
配置数据同步规则
服务名是提供者的服务名,这里以eureka-provider为例子。
分组名不填 -
查看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。
- 把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>-->
- 配置文件修改为
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
-
重启eureka-nacos-provider,并在nacos-sync配置同步规则
测试两个应用之间的调用联通性。
执行命令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(四)