首页 > 其他分享 >2流高手速成记(之七):基于Dubbo&Nacos的微服务简要实现

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

时间:2022-11-03 22:00:19浏览次数:74  
标签:之七 Dubbo dubbo spring Nacos nacos import com public

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

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<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

标签:之七,Dubbo,dubbo,spring,Nacos,nacos,import,com,public
From: https://www.cnblogs.com/itfantasy/p/16855963.html

相关文章

  • Dubbo 可观测性实践之 Metrics 功能解析
    作者:姚辉在2018年,Observability(即可观测性)首次被引入IT领域,并逐渐取代只关注系统整体可用性的传统监控。随着云原生技术的不断发展,企业从单体架构发展到分布式架构,使......
  • CentOS 7安装Nacos
    1.下载编译后压缩包您可以从 最新稳定版本 下载包。 2.上传到对应的目录可以通过rz命令上传文件,上传路径:/opt/install_package 3.将安装包解压缩tar-zxvfnaco......
  • nacos 在linux上常用指令
    /usr/local/nacos/nacos/bin这只是我自己服务器的nacos的bin路基1.启动到nacos/bin目录下执行一下命令:shstartup.sh#集群启动shstartup.......
  • Dubbo
    Dubbo是一款高性能、轻量级的开源JavaRPC框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。Dubbo是一个分布式服务框架,......
  • Nacos2.1配置发布失败,请检查参数是否正确
    问题说明:chrome上配置新增配置文件,点击发布,报错“新增配置发布失败。请检查参数是否正确”解决方法:在nacosmysql数据库中分别在config_info、his_config_info表中新增......
  • dubbo java.nio.channels.ClosedChannelException、com.alibaba.dubbo.remoting.Remot
    客户端错误:com.alibaba.dubbo.rpc.RpcException:Invokeremotemethodtimeout.method:searchUser,provider:...cause:Waitingserver-sideresponsetimeoutbyscan......
  • SpringCloudAlibaba 主要组件与nacos 填坑记录
    SpringCloudAlibaba主要功能与实现组件(1)SpringCloudAlibaba主要功能与实现组件【功能与实现组件:】服务限流降级:基本说明:默认支持WebServlet、WebF......
  • Dubbo的多协议、多Registry、服务分组、多版本、分组聚合
    转自:https://blog.csdn.net/dkfajsldfsdfsd/article/details/907212301、参考多协议:http://dubbo.apache.org/en-us/docs/user/demos/multi-protocols.html多Registry:ht......
  • Dubbo笔记衍生篇:MergeableClusterInvoker
    转自:https://blog.csdn.net/qq_36882793/article/details/117366243一、前言本系列为个人Dubbo学习笔记衍生篇,是正文篇之外的衍生内容,内容来源于《深度剖析ApacheDubbo......
  • springcloud Alibaba-nacos[作为配置中心]
    1、在pom文件中引入nacos-config-starter依赖    <!--nacos配置中心的依赖--><dependency><groupId>com.alibaba.cloud</groupId>......