整合SpringCloud Alibaba nacos 2.2.1

快来打我* 2022-11-26 01:52 62阅读 0赞

# 一、Nacos安装与启停 #

这个网上一大堆，建议自行参考。

# 二、将应用注册到Nacos上 #

首先贴一下应用所需要的依赖，不一定非用这些，仅作参考。

<properties>
            <java.version>1.8</java.version>
            <sentinel-core.version>1.7.1</sentinel-core.version>
            <spring-orm.version>4.3.25.RELEASE</spring-orm.version>
            <spring-boot.version>2.2.4.RELEASE</spring-boot.version>
            <spring-cloud.version>Hoxton.SR3</spring-cloud.version>
            <spring-context-support.version>1.0.6</spring-context-support.version>
            <spring-cloud-alibaba.version>2.2.1.RELEASE</spring-cloud-alibaba.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>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>com.alibaba.csp</groupId>
                <artifactId>sentinel-core</artifactId>
                <version>${sentinel-core.version}</version>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba.spring</groupId>
                <artifactId>spring-context-support</artifactId>
                <version>${spring-context-support.version}</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
            </dependency>
    
            <dependency>
                <groupId>com.alibaba.csp</groupId>
                <artifactId>sentinel-transport-simple-http</artifactId>
                <version>1.6.3</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-dependencies</artifactId>
                    <version>${spring-boot.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
    
                
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
    
                <dependency>
                    <groupId>com.alibaba.cloud</groupId>
                    <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                    <version>${spring-cloud-alibaba.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>

现在开始整合应用

## 1. 数据服务提供者 ##

配置文件  bootstrap.yml：这里提供者与消费者配置文件都一样，唯一的区别就是端口与 应用名称 不同

server:
      port: 8000    #端口
    
    spring:
      application:
        name: service     #注册到naocos时的应用名
      main:
        allow-bean-definition-overriding: true
      cloud:
        nacos:
          config:
            #nacos配置中心地址
            server-addr: 192.168.2.139:8848
            #配置中心创建的配置文件，这里指定引用，多个配置文件用 , 分割
            shared-dataids: public-cinfig-dev.properties,application-db.yml
            refreshable-dataids: public-cinfig-dev.properties,application-db.yml
          discovery:
            #nacos注册中心地址
            server-addr: 192.168.2.139:8848

新建Controller :

@RestController
    @RequestMapping(value = "/data", produces = "application/json;charset=UTF-8")
    public class TestController {
        @Value("${server.port}")
        private int port;
        @Value("${spring.application.name}")
        private String name;
    
        @ResponseBody
        @RequestMapping("/test")
        @SentinelResource(value = "collect-extract", blockHandler = "blockHandler")
        public String test() {
            return name + "  " + port;
        }
    }

这里只为测试，返回的内容为服务的 端口 以作区别。

Application启动类上添加开启服务注册 的注解：@EnableDiscoveryClient

@EnableDiscoveryClient
    @SpringBootApplication
    public class TestApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(TestApplication.class, args);
        }
    
    }

## 2. 消费者 ##

配置文件同提供者一样，只需要修改端口和服务名称即可，这里我们命名为consumer，端口8005

新建测试的Controller以供测试：

@RestController
    public class TestController {
        @Resource
        private RemoteDataFeginService feginService;
    
        @ResponseBody
        @RequestMapping(value = "/test", produces = "application/json;charset=UTF-8")
        @SentinelResource(value = "collect-notice", blockHandler = "blockHandler")
        public String extract() {
            return feginService.test("");
        }
    }

新建Fegin：

//这里的name和contextId为服务提供者的服务名称
    @FeignClient(name = "service", contextId = "service", fallbackFactory = DataServiceFallbackFactory.class)
    public interface RemoteDataFeginService {
    
        @PostMapping(value = "/data/test")
        String test(@SpringQueryMap String param);
    }

新建FallbackFactory

@Component
    public class DataServiceFallbackFactory implements FallbackFactory {
        @Override
        public Object create(Throwable throwable) {
            return new RemoteDataFeginService() {
    
                @Override
                public String test(String param) {
                    // TODO Auto-generated method stub
                    return throwable.getMessage();
                }
            };
        }
    }

启动类上添加注解：

//开启服务注册  
@EnableDiscoveryClient  
//指定RemoteDataFeginService 包的地址  
@EnableFeignClients(basePackages = \{"com"\})

@EnableDiscoveryClient
    @SpringBootApplication
    @EnableFeignClients(basePackages = {"com"})
    public class TestApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(TestApplication.class, args);
        }
    }

接下来依次启动服务提供者和消费者就可以了，为方便测试，我以不同端口启动了三个 服务提供者，和一个消费者。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzA2MDM4_size_16_color_FFFFFF_t_70][]

到这里所有服务都已经注册到Nacos中了，Nacos中配置文件能正常读取并使用。  
 访问测试：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzA2MDM4_size_16_color_FFFFFF_t_70 1][]![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzA2MDM4_size_16_color_FFFFFF_t_70 2][]![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzA2MDM4_size_16_color_FFFFFF_t_70 3][]

每刷新一次都可见返回的数据不同，拿到了三个服务提供者的端口，到这里就基本完成了。

码云项目地址：  
[https://gitee.com/SGHDXX/springcloud-nacos-test.git][https_gitee.com_SGHDXX_springcloud-nacos-test.git]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzA2MDM4_size_16_color_FFFFFF_t_70]: /images/20221124/68153459842f4a1a98d49ce47550ac6c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzA2MDM4_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20201026110113291.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzA2MDM4,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzA2MDM4_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20201026110135702.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzA2MDM4,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzA2MDM4_size_16_color_FFFFFF_t_70 3]: /images/20221124/d211273357cd4e4e8ccf84f815db158e.png
[https_gitee.com_SGHDXX_springcloud-nacos-test.git]: https://gitee.com/SGHDXX/springcloud-nacos-test.git