• SpringCloud Alibaba&注册中心(nacos)&远程调用(OpenFeign)使用


    声明式远程调用(OpenFeign)

    feign是一个声明式的HTTP客户端,他的目的就是让远程调用更加简单。给远程服务发的是HTTP请求。

    会员服务想要远程调用优惠券服务,只需要给会员服务里引入openfeign依赖,他就有了远程调用其他服务的能力。

    pom.xml

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>
    
    • 1
    • 2
    • 3
    • 4

    我们之前在member(会员服务)的pom.xml已经引用过了(微服务)。

    在coupon(优惠券服务)中修改如下的内容

    1.创建远程调用接口
    @RequestMapping("coupon/coupon")
    public class CouponController {
        @Autowired
        private CouponService couponService;
    
        @RequestMapping("/member/list")
        public R membercoupons(){    //全系统的所有返回都返回R
            // 应该去数据库查用户对于的优惠券,但这个我们简化了,不去数据库查了,构造了一个优惠券给他返回
            CouponEntity couponEntity = new CouponEntity();
            couponEntity.setCouponName("满100-10");//优惠券的名字
            return R.ok().put("coupons",Arrays.asList(couponEntity));
        }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12

    这样我们准备好了优惠券的调用内容

    在member的配置类上加注解@EnableDiscoveryClient,告诉member是一个远程调用客户端,member要调用东西的.

    2.想要远程调用的步骤
    /*
    * 想要远程调用的步骤:
    * 1 引入openfeign
    * 2 编写一个接口,接口告诉springcloud这个接口需要调用远程服务
    * 	2.1 在接口里声明@FeignClient("gulimall-coupon")他是一个远程调用客户端且要调用coupon服务
    * 	2.2 要调用coupon服务的/coupon/coupon/member/list方法
    * 3 开启远程调用功能 @EnableFeignClients,要指定远程调用功能放的基础包
    * */
    @EnableFeignClients(basePackages="com.atguigu.gulimall.member.feign")//扫描接口方法注解
    @EnableDiscoveryClient// 注册到nacos
    @SpringBootApplication
    public class gulimallMemberApplication {
    
     public static void main(String[] args) {
      SpringApplication.run(gulimallMemberApplication.class, args);
     }
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17

    那么要调用什么东西呢?就是我们刚才写的优惠券的功能,
    复制函数部分,在member的com.atguigu.gulimall.member.feign包下新建类:

    @FeignClient("gulimall-coupon") //告诉spring cloud这个接口是一个远程客户端,要调用coupon服务(nacos中找到),具体是调用coupon服务的/coupon/coupon/member/list对应的方法
    public interface CouponFeignService {
        // 远程服务的url
        @RequestMapping("/coupon/coupon/member/list")//注意写全优惠券类上还有映射//注意我们这个地方不是控制层,所以这个请求映射请求的不是我们服务器上的东西,而是nacos注册中心的
        public R membercoupons();//得到一个R对象
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    3.@FeignClient+@RequestMapping构成远程调用的坐标

    其他类中看似只是调用了CouponFeignService.membercoupons(),而实际上该方法跑去nacos里和rpc里调用了才拿到东西返回

    然后我们在member的控制层写一个测试请求

    @RestController
    @RequestMapping("member/member")
    public class MemberController {
        @Autowired
        private MemberService memberService;
    
        @Autowired
        CouponFeignService couponFeignService;
    
        @RequestMapping("/coupons")
        public R test(){
            MemberEntity memberEntity = new MemberEntity();
            memberEntity.setNickname("会员昵称张三");
            R membercoupons = couponFeignService.membercoupons();//假设张三去数据库查了后返回了张三的优惠券信息
    
            //打印会员和优惠券信息
            return R.ok().put("member",memberEntity).put("coupons",membercoupons.get("coupons"));
        }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18

    重新启动服务刷新容器

    测试:http://localhost:8000/member/member/coupons
    TIPS:版本和视频不一致

    is java.lang.IllegalStateException: No Feign Client for loadBalancing defined. Did you forget to include spring-cloud-starter-loadbalancer
    
    • 1

    返回结果

    {
        "msg":"success",
        "code":0,
        "coupons":[
            {"id":null,"couponType":null,"couponImg":null,
             "couponName":"满100-10","num":null,"amount":null,"perLimit":null,
             "minPoint":null,"startTime":null,"endTime":null,"useType":null,
             "note":null,"publishCount":null,"useCount":null,"receiveCount":null,
             "enableStartTime":null,"enableEndTime":null,"code":null,
             "memberLevel":null,"publish":null}
        ],
        "member":{"id":null,"levelId":null,"username":null,"password":null,
                  "nickname":"会员昵称张三","mobile":null,"email":null,
                  "header":null,"gender":null,"birth":null,
                  "city":null,"job":null,"sign":null,"sourceType":null,
                  "integration":null,"growth":null,"status":null,"createTime":null}
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17

    上面讲的内容很重要,我们停留5分钟体会一下调用逻辑。

    coupon里的R.ok()是什么,就是设置了个msg

    public class R extends HashMap<String, Object> {//R继承了HashMap
        // ok是个静态方法,new了一个R对象,并且
        public static R ok(String msg) {
            R r = new R();
            r.put("msg", msg);//调用了super.put(key, value);,即hashmap的put
            return r;
        }
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8

    nacos作为配置中心

    我们还可以用nacos作为配置中心。配置中心的意思是不在application.properties等文件中配置了,而是放到nacos配置中心公用,这样无需每台机器都改。

    官方教程:https://github.com/alibaba/spring-cloud-alibaba/blob/master/spring-cloud-alibaba-examples/nacos-example/nacos-config-example/readme-zh.md

    1.common中添加依赖 nacos配置中心
    <dependency>
         <groupId>com.alibaba.cloud</groupId>
         <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
     </dependency>
    
    • 1
    • 2
    • 3
    • 4

    在coupons项目中创建/src/main/resources/bootstrap.properties ,这个文件是springboot里规定的,他优先级别application.properties高

    2. 改名字,对应nacos里的配置文件名
    spring.application.name=gulimall-coupon
    spring.cloud.nacos.config.server-addr=127.0.0.1:8848
    
    • 1
    • 2

    还是原来我们使用配置的方式,只不过优先级变了,所以匹配到了nacos的配置

    还是配合@Value注解使用

    @RestController
    @RequestMapping("coupon/coupon")
    public class CouponController {
        @Autowired
        private CouponService couponService;
    
        @Value("${coupon.user.name}")//从application.properties中获取//不要写user.name,他是环境里的变量
        private String name;
        @Value("${coupon.user.age}")
        private Integer age;
        @RequestMapping("/test")
        public R test(){
    
            return R.ok().put("name",name).put("age",age);
        }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15

    在这里插入图片描述

    3.浏览器去nacos里的配置列表,点击+号,data ID:gulimall-coupon.properties,配置
    #gulimall-coupon.properties
    coupon.user.name="配置中心"      
    coupon.user.age=12
    
    • 1
    • 2
    • 3

    在这里插入图片描述

    5.然后点击发布。重启coupon(生产中加入@RefreshScope即可)

    http://localhost:7000/coupon/coupon/test

    {"msg":"success","code":0,"name":"配置中心","age":12}
    
    • 1

    但是修改肿么办?实际生产中不能重启应用。在coupon的控制层上加@RefreshScope

    @RefreshScope
    @RestController
    @RequestMapping("coupon/coupon")
    public class CouponController {
        @Autowired
        private CouponService couponService;
    
        @Value("${coupon.user.name}")//从application.properties中获取//不要写user.name,他是环境里的变量
        private String name;
        @Value("${coupon.user.age}")
        private Integer age;
        
        @RequestMapping("/test")
        public R test(){
            return R.ok().put("name",name).put("age",age);
        }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16

    重启后(让注解生效),在nacos浏览器里修改配置,修改就可以观察到能动态修改

    nacos的配置内容优先于项目本地的配置内容。

    3.配置中心总结

    /**
     * 1、如何使用Nacos作为配置中心统一管理配置
     *
     * 1)、引入依赖,
     *         <dependency>
     *             <groupId>com.alibaba.cloud</groupId>
     *             <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
     *         </dependency>
     * 2)、创建一个bootstrap.properties。
     *      spring.application.name=gulimall-coupon
     *      spring.cloud.nacos.config.server-addr=127.0.0.1:8848
     * 3)、需要给配置中心默认添加一个叫 数据集(Data Id)gulimall-coupon.properties。默认规则,应用名.properties
     * 4)、给 应用名.properties 添加任何配置
     * 5)、动态获取配置。
     *      @RefreshScope:动态获取并刷新配置
     *      @Value("${配置项的名}"):获取到配置。
     *      如果配置中心和当前应用的配置文件中都配置了相同的项,优先使用配置中心的配置。
     *
     * 2、细节
     *  1)、命名空间:配置隔离;
     *      默认:public(保留空间);默认新增的所有配置都在public空间。
     *      1、开发,测试,生产:利用命名空间来做环境隔离。
     *         注意:在bootstrap.properties;配置上,需要使用哪个命名空间下的配置,
     *         spring.cloud.nacos.config.namespace=9de62e44-cd2a-4a82-bf5c-95878bd5e871
     *      2、每一个微服务之间互相隔离配置,每一个微服务都创建自己的命名空间,只加载自己命名空间下的所有配置
     *
     *  2)、配置集:所有的配置的集合
     *
     *  3)、配置集ID:类似文件名。
     *      Data ID:类似文件名
     *
     *  4)、配置分组:
     *      默认所有的配置集都属于:DEFAULT_GROUP;
     *      1111,618,1212
     *
     * 项目中的使用:每个微服务创建自己的命名空间,使用配置分组区分环境,dev,test,prod
     *
     * 3、同时加载多个配置集
     * 1)、微服务任何配置信息,任何配置文件都可以放在配置中心中
     * 2)、只需要在bootstrap.properties说明加载配置中心中哪些配置文件即可
     * 3)、@Value,@ConfigurationProperties。。。
     * 以前SpringBoot任何方法从配置文件中获取值,都能使用。
     * 配置中心有的优先使用配置中心中的,
     *
     *
     */
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46

    4.配置中心进阶

    在nacos浏览器中还可以配置:

    • 命名空间:用作配置隔离。(一般每个微服务一个命名空间)

    • 默认public。默认新增的配置都在public空间下

    • 开发、测试、开发可以用命名空间分割。properties每个空间有一份。也可以为每个微服务配置一个命名空间,微服务互相隔离

    • 在bootstrap.properties里配置(测试完去掉,学习不需要)

    #可以选择对应的命名空间 # 写上对应环境的命名空间ID
    spring.cloud.nacos.config.namespace=b176a68a-6800-4648-833b-be10be8bab00
    
    • 1
    • 2
    • 配置集:一组相关或不相关配置项的集合。

    • 配置集ID:类似于配置文件名,即Data ID

    • 配置分组:默认所有的配置集都属于DEFAULT_GROUP。双十一,618的优惠策略改分组即可

    #更改配置分组
    spring.cloud.nacos.config.group=DEFAULT_GROUP
    
    • 1
    • 2

    其他划分方案:

    • NameSpace:命名空间 默认为public,其作用可以用来实现环境隔离作用,比如我们的开发环境、测试环境、生产环境。
    • Group:默认分组为DEFAULT_GROUP,Group 可以将不同的微服务进行分组划分。
    • Service/DataId: 也就是微服务工程,一个微服务工程可以有多个集群中心,比如一个消费者工程可以使用两个中心,每个中心读取不同的配置文件,每个中心内可以有多个实例实现集群。。
    • 最终方案:每个微服务创建自己的命名空间,然后使用配置分组区分环境(dev/test/prod)

    两种隔离方案:1.基于环境进行隔离。2.基于微服务之间进行隔离
    在这里插入图片描述
    通过分组获取配置
    在这里插入图片描述

    4.加载多配置集

    在微服务中配置众多,又多又乱不好维护,将配置拆分,例如和数据源有关的,放在datasource.properties,和框架有关的放在mybatis.properties中,Nacos配置中心也支持这种操作

    在这里插入图片描述
    在这里插入图片描述

    我们要把原来application.yml里的内容都分文件抽离出去。我们在nacos里创建好后,在coupons里指定要导入的配置即可。

    bootstrap.properties

    在其中用数组spring.cloud.nacos.config.extension-configs[]写明每个配置集

    spring.application.name=gulimall-coupon
    
    spring.cloud.nacos.config.server-addr=127.0.0.1:8848
    # 可以选择对应的命名空间 # 写上对应环境的命名空间ID
    spring.cloud.nacos.config.namespace=b176a68a-6800-4648-833b-be10be8bab00
    # 更改配置分组
    spring.cloud.nacos.config.group=dev
    
    #新版本不建议用下面的了
    #spring.cloud.nacos.config.ext-config[0].data-id=datasource.yml
    #spring.cloud.nacos.config.ext-config[0].group=dev
    #spring.cloud.nacos.config.ext-config[0].refresh=true
    #spring.cloud.nacos.config.ext-config[1].data-id=mybatis.yml
    #spring.cloud.nacos.config.ext-config[1].group=dev
    #spring.cloud.nacos.config.ext-config[1].refresh=true
    #spring.cloud.nacos.config.ext-config[2].data-id=other.yml
    #spring.cloud.nacos.config.ext-config[2].group=dev
    #spring.cloud.nacos.config.ext-config[2].refresh=true
    
    spring.cloud.nacos.config.extension-configs[0].data-id=datasource.yml
    spring.cloud.nacos.config.extension-configs[0].group=dev
    spring.cloud.nacos.config.extension-configs[0].refresh=true
    
    spring.cloud.nacos.config.extension-configs[1].data-id=mybatis.yml
    spring.cloud.nacos.config.extension-configs[1].group=dev
    spring.cloud.nacos.config.extension-configs[1].refresh=true
    
    spring.cloud.nacos.config.extension-configs[2].data-id=other.yml
    spring.cloud.nacos.config.extension-configs[2].group=dev
    spring.cloud.nacos.config.extension-configs[2].refresh=true
    
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31

    输出内容有

    2020-06-25 00:04:13.677  WARN 17936 --- [           main] c.a.c.n.c.NacosPropertySourceBuilder     : Ignore the empty nacos configuration and get it based on dataId[gulimall-coupon] & group[dev]
    
    2020-06-25 00:04:13.681  INFO 17936 --- [           main] b.c.PropertySourceBootstrapConfiguration :
    Located property source: [
    BootstrapPropertySource {name='bootstrapProperties-gulimall-coupon.properties,dev'}, 
    BootstrapPropertySource {name='bootstrapProperties-gulimall-coupon,dev'}, 
    BootstrapPropertySource {name='bootstrapProperties-other.yml,dev'}, 
    BootstrapPropertySource {name='bootstrapProperties-mybatis.yml,dev'}, 
    BootstrapPropertySource {name='bootstrapProperties-datasource.yml,dev'}]
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
  • 相关阅读:
    编程参考 - C/C++中的方便调试使用的内置宏
    TypeScript中的Symbol,确实唯一。。。
    人工智能迷惑行为大赏
    4.2 Windows驱动开发:内核中进程线程与模块
    Redis中的Zset类型
    [Android][DevTips]chrt命令修改线程优先级与调度策略
    JavaScript 从入门到熟悉
    (01)ORB-SLAM2源码无死角解析-(45) 跟踪线程→局部地图跟踪TrackLocalMap():主体流程
    淘宝/天猫api数据接口,获得淘宝商品详情 API 返回值说明
    在云服务器上打开ftp服务-踩坑及心得
  • 原文地址:https://blog.csdn.net/shujuku____/article/details/125434758