首页IT科技dubbo微服务架构图(2流高手速成记(之七):基于Dubbo&Nacos的微服务简要实现)

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

时间2025-09-19 14:40:33分类IT科技浏览6686
导读:本节内容会用到之前给大家讲过的这两篇:...

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

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.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<Person> select(); }

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

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

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

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

<!-- 引入mybatis                        、mybatis-plus                、mysql等依赖 --> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>2.2.2</version> </dependency> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> <version>3.5.2</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <dependency> <groupId>com.example</groupId> <artifactId>dubbo-nacos-api</artifactId> <version>0.0.1-SNAPSHOT</version> </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<Person> { }
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<Person> select() { return mapper.selectList(null); } }

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

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

3. Controller迁移到dubbo-nacos-consumer

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>com.example</groupId> <artifactId>dubbo-nacos-api</artifactId> <version>0.0.1-SNAPSHOT</version> </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<Person> 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

声明:本站所有文章        ,如无特殊说明或标注                 ,均为本站原创发布        。任何个人或组织                        ,在未征得本站同意时        ,禁止复制                 、盗用                        、采集        、发布本站内容到任何网站                 、书籍等各类媒体平台                。如若本站内容侵犯了原著者的合法权益         ,可联系我们进行处理                         。

创心域SEO版权声明:以上内容作者已申请原创保护,未经允许不得转载,侵权必究!授权事宜、对本内容有异议或投诉,敬请联系网站管理员,我们将尽快回复您,谢谢合作!

展开全文READ MORE
python中包的导入(Python导入包的注意事项)