SpringCloud 整合 Dubbo

Posted 2023-04-02 阿杰的代码空间

目录

1、介绍

2、代码实现

2.1 抽取公共模块

2.2 改造服务提供者

2.3 改造服务消费者

3、启动测试

---

1、介绍

Dubbo有两种使用方式：

1、基于SOA的思想，将一个单体架构拆分为web层和Services层，然后web和services借助Dubbo框架进行数据交互。

2、SpringCloud 整合Dubbo。

这篇博客所要介绍的就是第二种。

首先我们要想，为什么SpringCloud 要整合Dubbo?

在SpringCloud中会有多个微服务，不同的微服务访问一样的数据库，每个微服务都需要进行服务注册和服务发现，这个时候就要用到注册中心Nacos。

在微服务当中，各个服务之间如果要进行通信，要进行调用的话，使用的就是Feign。

那Feign这种协议究竟好不好呢？

Feign其实基于Http协议（应用层），调用的是REST风格的API 来完成数据交互容易成为性能瓶颈。

Dubbo框架的通信协议采用TCP协议（数据传输层）。

看下图：

我们可以看到Http 协议位于七层网络协议的应用层，TCP协议位于数据传输层，可以看到Http协议就是对TCP协议的封装，由于它做了更深层次的封装，所以它的效率可能就会低一些，特别是在高并发场景下性能可能会成为瓶颈。

所以这个时候，有的开发人员就会想了，既然Feign这个协议效率会存在瓶颈，我为什么不把Dubbo拿进来替换Feign呢？

哎，这个就是Dubbo 在SpringCloud 中的意义。

Dubbo框架的通信协议采用RPC协议来进行数据传输的，属于传输层协议，Dubbo默认通过Netty构造TCP长连接的方式进行通信，性能较高，使用SpringCloud整合Dubbo，那就是强强联合。

借助Spring Cloud Alibaba提供了微服务开发的一站式解决方案，我们可以很轻松的完成Dubbo的整合。

在SpringCloud 中加入了 Dubbo,我们的架构整体就会发生了变化，我们的客户端请求网关，网关将请求路由到微服务，微服务呢需要进行注册中心的配置以及配置中心的管理，当然，各个微服务之间进行调用就不再是Feign，而是Dubbo。

2、代码实现

介绍完Dubbo在springcloud 中 的作用，接下来我们就进入代码实战。

这里使用的Demo是以前写过的。具体看这个专栏的文章：SpringCloud_一切总会归于平淡的博客-CSDN博客

以前我们是使用Feign进行服务之间的通信，现在我们将其改造为Dubbo。

2.1 抽取公共模块

抽取公共模块其实是比较简单的，我们来看看实现步骤：

1、创建dubbo-api模块

2、抽取公共模块

这里的实体类其实也可以放到另一个模块里然后进行引入，但是我太懒了，直接拉到dubbo-api模块来了，大家根据自己的习惯来吧。

2.2 改造服务提供者

我们接下来去修改user-service实现dubbo-api中的UserService接口。并使用@DubboService注解替换@Service对外暴露dubbo服务。

1、首先我们要先在user-service 中引入依赖。

<!--nacos注册中心的依赖-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

<!--springcloud alibaba dubbo依赖   -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>

<dependency>
  <groupId>com.jie.demo</groupId>
  <artifactId>dubbo-api</artifactId>
  <version>1.0</version>
</dependency>

2、编写UserService实现类。

这样我们就向外暴露一个Dubbo服务。

3、编写application.yml 文件

dubbo:
  protocol:
    name: dubbo
    port: 20881
  registry:
    address: spring-cloud://localhost   #使用SpringCloud中的注册中心
  scan:
    base-packages: com.jie.user.service  #dubbo中包扫描

2.3 改造服务消费者

1、首先在order-service 中引入依赖。

<!--nacos注册中心的依赖-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

<!--springcloud alibaba dubbo依赖   -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>

<dependency>
  <groupId>com.jie.demo</groupId>
  <artifactId>dubbo-api</artifactId>
  <version>1.0</version>
</dependency>

2、使用@DubboReference引入Dubbo服务，调用远程服务。

3、编写application.yml 文件

#dubbo配置
dubbo:
  registry:
    address: spring-cloud://localhost  #使用cloud的注册中心
  consumer:
    check: false   #dubbo默认有启动检查
    retries: 0     #dubbo内置的重试机制

3、启动测试

重启提供者和消费者的服务，然后发送一个请求测试。

注意：

实体类一定要实现序列化接口！！！

Dubbo整合SpringCloud图片显示问题

Dubbo整合SpringCloud图片显示问题

Tips：公司项目，记录一点经验吧，理解的不对的地方欢迎大神指点

问题：商品图片上传功能(公司没有专门文件服务器)写的保存目录直接是保存在docker容器内部目录下，做的docker外部存储映射到服务器某个文件夹下面(因为怕镜像升级啊什么的 导致图片丢失)。下面粘贴一下

Jenkins配置(外部存储设置 Jenkins构建自动设置)

SpringBoot设置docker容器新增文件夹配置

<plugin>
                <groupId>com.spotify</groupId>
                <artifactId>docker-maven-plugin</artifactId>
                <version>0.4.13</version>
                <configuration>
                    <dockerHost>http://0.0.0.0:2375</dockerHost>
                    <imageName>${docker.image.prefix}/${project.artifactId}</imageName>
                    <imageTags>
                        <imageTag>${project.version}</imageTag>
                        <imageTag>latest</imageTag>
                    </imageTags>
                    <baseImage>frolvlad/alpine-oraclejdk8:slim</baseImage>
                    <volumes>/product-images</volumes>
                    <entryPoint>["java", "-jar", "/${project.build.finalName}.jar"]</entryPoint>
                    <resources>
                        <resource>
                            <targetPath>/</targetPath>
                            <directory>${project.build.directory}</directory>
                            <include>${project.build.finalName}.jar</include>
                        </resource>
                    </resources>
                </configuration>
            </plugin>

这样实际图片上传路径指定/product-images图片上传问题就解决了

问题2：因为图片直接存储在数据库的是相对路径就是比如（/20180909/image.png）实际项目是在docker容器中，图片也是在/product-images 。我返回给前端的文件路径就是这样的 www.域名/Zool/product-images/20180909/image.png 导致找不到图片，在测试服务器上还没发现问题因为测试机有缓存所以导致了这个问题的一个隐藏，今天打正式版导致图片不显示。

思路：项目是SpringBoot 目前我知道的 放到resource目录下 文件直接项目 然后相对路径是能读取到图片的 但是放到docker下，而且也没在resource下，(跟docker没关系)就相当于读机器上某个文件导致的不让读取。

解决办法：

https://域名/Zool/seeImage?imgPath=/product-images" + catalogProductDto.getImages()

@RequestMapping(value = "/seeImage",method = RequestMethod.GET)
public String seeImage(HttpServletRequest request, HttpServletResponse response,
                       @RequestParam(value = "imgPath") String imgPath ) {
    try {
        FileInputStream hFile = new FileInputStream(imgPath);
        //得到文件大小
        int i = hFile.available();
        byte data[] = new byte[i];
        //读数据
        hFile.read(data);
        response.addHeader("Content-Type",getContentType(imgPath));
        response.addHeader("Accept-Ranges","bytes");
        //得到向客户端输出二进制数据的对象
        OutputStream toClient = response.getOutputStreStream();
        //输出数据
        toClient.write(data);
        toClient.flush();
        toClient.close();
        hFile.close();
        return "";
    }
    catch (Exception ex)
    {
        ex.printStackTrakTrace();
        return "处理失败"+ex.getMessage();
    }
}
/**
 * 获取后缀
 * @return
 */
private String getContentType(String imgPath) {
    String resultSuffix = "";
    try{
        String suffix = imgPath.substring(imgPath.lastIndexOf(\'.\'));
        System.out.println("url中的文件扩展名："+ suffix);
        if(".jpg".equals(suffix)){
            resultSuffix = "image/jpeg";
        }
        if(".png".equals(suffix)){
            resultSuffix = "image/png";
        }
    }catch (Exception e){
        e.printStackTrakTrace();
        return "处理失败" + e.getMessage();;
    }
    return resultSuffix;
}

逻辑：后台传给前台一个请求路径，前台请求调用后台的加载图片方法，图片加载以流的方式返回给前台展示 这个问题解决