• 2流高手速成记(之七):基于Dubbo&Nacos的微服务简要实现


    本节内容会用到之前给大家讲过的这两篇:

    2流高手速成记(之六):从SpringBoot到SpringCloudAlibaba

    2流高手速成记(之三):SpringBoot整合mybatis/mybatis-plus实现数据持久化

    链接挂出来,方便咱们中途对比着看

    老规矩,先放出本节的项目结构:

     

     

    我们参考上一节中讲到的创建SpringCloudAlibaba工程模板的步骤,在工程下在创建三个子模块,创建过程中勾选相同的依赖项

     

     

    这三个子模块也是三个独立的可执行的工程,他们的用途分别为:

    dubbo-nacos-provider:服务(Service)提供方

    dubbo-nacos-consumer:消费方,服务的调用者

    dubbo-nacos-api:接口及模型类定义,同时作为前边二者的依赖方

    接下来,我们共同见证神奇的一幕:

    大家都知道,我们在第三节中实现的工程是一个结构相对完备(包含Service、Controller,View由Postman替代)且可以直接执行的独立进程

    本节我们依靠上一节讲到的微服务技术,以几乎不改变原有代码为前提,将其一分为三:

    provider和consumer分别独立执行

    consumer借助微服务技术完成对provider的调用

    api模块是二者的依赖项,并非可执行的进程

    1. Service接口、Model声明迁移到dubbo-nacos-api

     

     

    复制代码
    package com.example.dubbonacosapi.model;
    
    import java.io.Serializable;
    
    public class Person implements Serializable {
        private Integer id = 0;
    
        private String name = "";
    
        public Integer getId() {
            return id;
        }
    
        public void setId(Integer id) {
            this.id = id;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    }
    复制代码
    复制代码
    package com.example.dubbonacosapi.service;
    
    import com.example.dubbonacosapi.model.Person;
    
    import java.util.List;
    
    public interface PersonService {
        Integer insert(Person person);
    
        Integer update(Person person);
    
        Integer delete(int id);
    
        List select();
    }
    复制代码

    因为api的作用仅是构成provider、consumer的二者依赖,所以其仅是持有相关声明即可

    Person类及PersonService在原有代码基础上保持不变!

    2. Service接口实现类、Mapper声明(mybatis-plus)迁移到dubbo-nacos-provider

     

     

    既然provider保有mybatis-plus访问mysql的能力,所以相关的依赖必定不可或缺

    复制代码
            
            <dependency>
                <groupId>org.mybatis.spring.bootgroupId>
                <artifactId>mybatis-spring-boot-starterartifactId>
                <version>2.2.2version>
            dependency>
            <dependency>
                <groupId>com.baomidougroupId>
                <artifactId>mybatis-plus-boot-starterartifactId>
                <version>3.5.2version>
            dependency>
            <dependency>
                <groupId>mysqlgroupId>
                <artifactId>mysql-connector-javaartifactId>
            dependency>
    
            <dependency>
                <groupId>com.examplegroupId>
                <artifactId>dubbo-nacos-apiartifactId>
                <version>0.0.1-SNAPSHOTversion>
            dependency>
    复制代码

    引入的方式和第三节讲到的方式一样

    此外还包含了对于刚才我们创建的dubbo-nacos-api的依赖,引入非常的方便

    复制代码
    package com.example.dubbonacosprovider.mapper;
    
    import com.baomidou.mybatisplus.core.mapper.BaseMapper;
    import com.example.dubbonacosapi.model.Person;
    import org.apache.ibatis.annotations.Mapper;
    import org.springframework.stereotype.Repository;
    
    @Mapper
    @Repository
    public interface PersonMapper extends BaseMapper {
    }
    复制代码
    复制代码
    package com.example.dubbonacosprovider.service.impl;
    
    import com.example.dubbonacosapi.model.Person;
    import com.example.dubbonacosapi.service.PersonService;
    import com.example.dubbonacosprovider.mapper.PersonMapper;
    import org.apache.dubbo.config.annotation.DubboService;
    import org.springframework.beans.factory.annotation.Autowired;
    
    import java.util.List;
    
    @DubboService
    public class PersonServiceImpl implements PersonService {
    
        @Autowired
        PersonMapper mapper;
    
        public Integer insert(Person person) {
            return mapper.insert(person);
        }
    
        public Integer update(Person person) {
            return mapper.updateById(person);
        }
    
        public Integer delete(int id) {
            return mapper.deleteById(id);
        }
    
        public List select() {
            return mapper.selectList(null);
        }
    }
    复制代码

    Mapper的声明没有任何变化,而PersonServiceImpl依然保有对接口PersonService的实现,区别在于后者来自api模块

    唯一的区别在于PesonServiceImpl类的注解,由原有的@Service变更为@DubboService —— 这是唯一的区别!

    3. Controller迁移到dubbo-nacos-consumer

    复制代码
            <dependency>
                <groupId>org.springframework.bootgroupId>
                <artifactId>spring-boot-starter-webartifactId>
            dependency>
    
            <dependency>
                <groupId>com.examplegroupId>
                <artifactId>dubbo-nacos-apiartifactId>
                <version>0.0.1-SNAPSHOTversion>
            dependency>
    复制代码

    consumer作为外部可访问的web服务,自然需要持有web相关依赖项

    同时,与provicer相同,其与api模块保持依赖关系

     

     

    复制代码
    package com.example.dubbonacosconsumer.controller;
    
    import com.example.dubbonacosapi.model.Person;
    import com.example.dubbonacosapi.service.PersonService;
    import org.apache.dubbo.config.annotation.DubboReference;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.List;
    
    @RestController
    @RequestMapping("/person")
    public class PersonController {
        @DubboReference
        PersonService service;
    
        @PostMapping("/insert")
        public Integer insert(Person person) {
            return service.insert(person);
        }
    
        @PostMapping("/update")
        public Integer update(Person person) {
            return service.update(person);
        }
    
        @PostMapping("/delete")
        public Integer delete(int id) {
            return service.delete(id);
        }
    
        @GetMapping("/select")
        public List select() {
            return service.select();
        }
    }
    复制代码

    留意PersonService的引入方式:不再是@Autowired,而是变更为@DubboReference —— 这是唯一的区别!

    4. Consumer和Provider的配置项

    这里我们依然沿用上一节讲到的知识——以nacos作为配置中心

    二者同时仅在本地保留一个bootstrap.properties配置文件,application.properties托管给nacos

     

     

    复制代码
    # Nacos帮助文档: https://nacos.io/zh-cn/docs/concepts.html
    # Nacos认证信息
    spring.cloud.nacos.config.username=nacos
    spring.cloud.nacos.config.password=nacos
    spring.cloud.nacos.config.contextPath=/nacos
    # 设置配置中心服务端地址
    spring.cloud.nacos.config.server-addr=127.0.0.1:8848
    # Nacos 配置中心的namespace。需要注意,如果使用 public 的 namcespace ,请不要填写这个值,直接留空即可
    # spring.cloud.nacos.config.namespace=
    
    # 应用名称
    spring.application.name=dubbo-nacos-consumer
    复制代码
    复制代码
    # Nacos帮助文档: https://nacos.io/zh-cn/docs/concepts.html
    # Nacos认证信息
    spring.cloud.nacos.config.username=nacos
    spring.cloud.nacos.config.password=nacos
    spring.cloud.nacos.config.contextPath=/nacos
    # 设置配置中心服务端地址
    spring.cloud.nacos.config.server-addr=127.0.0.1:8848
    # Nacos 配置中心的namespace。需要注意,如果使用 public 的 namcespace ,请不要填写这个值,直接留空即可
    # spring.cloud.nacos.config.namespace=
    
    # 应用名称
    spring.application.name=dubbo-nacos-provider
    复制代码

    内容均为nacos相关配置,以及各自声明了自己的应用名称(spring.application.name)

    然后是他们在nacos上托管的配置数据:

     

     

     注意,新创建配置的Data Id需要与他们的应用名称同名

     

     

     provider需要持有mysql相关配置

     

    consumer作为controller的持有者,需要声明外部的可访问端口

    全部的移植工作到这里就完毕了!

    我们分别执行provider、consumer两个独立进程

    此时我们打开nacos服务列表,会看到dubbo-nacos-consumer、dubbo-nacos-provider两个执行中的服务

     

     执行结果如下:

     

    怎么样?是不是非常神奇?我们只改动了两个注解,原本还是一个整体的工程就被一分为二了,并且是两个可以彼此独立运转在两台独立机器上的服务

    —— 这就是微服务的神奇之处!

    借助于强大的SpringCloudAlibaba,我们不仅可以对所有的业务实现统合拆分,充分调动团队人员配置各司其职各自编写自己的服务模块,

    更大的意义在于我们可以充分调动多台独立设备的技能,使之串联为一个庞大服务集群,较之于单台机器实现整个架构性能成千上万倍的飞跃!

    但是,微服务带来研发、管理、性能便捷的同时,整个集群也在运维层面面对了前所未有的挑战,最明显的:

    consumer在业务上依赖于后端的provider,如果provider运转不正常,前方的consumer又该如何自处?!

    围绕这个问题,又有新的概念诞生了——【限流、熔断、容错、服务降级】

    Sentinel要来咯~ 敬请期待!
    properties
  • 相关阅读:
    781. 森林中的兔子
    [经验] 天猫盒子怎么投屏手机照片 #经验分享#其他#经验分享
    ISP-SO安全运维工程师入门系统操作需要理解什么
    图与图的深度优先遍历、广度优先遍历
    关于英文BALL的一些地道说法和用法,你知多少?
    分布式服务的链路跟踪 Sleuth Micrometer zipkin OpenTelemetry
    实验四:图像的锐化处理
    嵌入式系统设计与应用---ARM处理器体系结构(学习笔记)
    SD卡报错“error -110 whilst initialising SD card
    使用html+css+js实现一个静态页面(含源码)
  • 原文地址:https://www.cnblogs.com/itfantasy/p/16855963.html