【Spring Cloud Alibaba】（四）Dubbo框架介绍及整合Dubbo和OpenAI实战【文末附源码】

天罡gg

发布于 2023-03-01 12:59:31

1.3K0

发布于 2023-03-01 12:59:31

文章被收录于专栏：天罡gg

前言

从本文开始，我们将探讨在Spring Cloud Alibaba微服务组件中的另一个主打高性能RPC调用的微服务调用组件，也就是由阿里巴巴开源的，后捐献给了Apache基金会的Dubbo。在服务调用方面，Dubbo的用户体验无疑是极致的。借助Spring Cloud Alibaba项目，我们只需要几个小小的注解，便能在分分钟内搭建完成服务调用，这是否令你惊讶？简单而爽快！

本文会先从Spring Cloud与Dubbo的关系说起，再讲到Dubbo架构，然后实战落地！最后的常见问题排查绝对是新手必看！我敢说整合Dubbo时有 99% 的人会遇到！文末附源码！！！也有投票期待你的参与！

对于如何在Spring Cloud Alibaba中快速集成Apache Dubbo，我们会搭建一个全新的环境，这样你还可以复习一下Spring Cloud Alibaba环境搭建知识，并能同时在案例中学会如何调用OpenAI API 生成图片！

没有什么比图更直观的了，老哥准备了这张图，相信你能轻松对Dubbo远程调用有个大概的认识！

Spring Cloud与Dubbo的关系

你是否见过下面这两类文章？

Spring Cloud 与 Dubbo的区别、对比、优缺点
Spring Cloud 整合 Dubbo

你心中是否有过 疑问：两个框架能拿来做对比, 说明是同类框架, 为什么又能做整合?

实际上，Apache Dubbo官方定位的是一款微服务框架，如下图，因此它和Spring Cloud都属于微服务框架，也都存在自己独特的生态系统，所以同作为微服务框架，它们经常拿来做对比！

另外，Dubbo最初的核心就是高性能 RPC 通信和自动服务发现，因此它在RPC服务调用方面做的很独立和强大，所以它又可以独立作为微服务调用组件被整合到Spring Cloud中，这就是为什么它们又能做整合!

综上，Dubbo既能与Spring Cloud相提并论，又能与Spring Cloud相辅相成！

Dubbo架构

对于Spring Cloud整合Dubbo，我们不看Dubbo的微服务架构，主要看它 服务发现、服务调用的架构，如下图：

主要是四方的关系：

Registry（注册中心）
Provider（服务提供方：暴露服务）
Consumer（服务消费方，调用Provider服务）
Monitor (监控中心，可以暂不关注)

主要干了这5件事：

0.start ：提供方(Provider)先启动 -初始化
1.register：提供方(Provider)注册 -初始化
2.suscribe：消费方(Consumer)订阅服务提供方 -初始化
3.notify：消费方收到订阅通知 -异步
4.invoke：消费方调用提供方 -同步
5.count, 即监控中心统计调用数据 -异步

然后我们就可以愉快的开始实战了，Let’s Go!

一、项目说明

项目背景

2023-02-16周四晚，在《直达CSDN–当开发者遇到AIGC》的直播中，王总描述自己有一个比较深刻的案例，就是我把百度的文心一格AI生成图片的一些服务给到传统行业的人，他们用完之后非常震撼，因为传统行业他们需要图片的话需要请专业的人来做，可能一张图片需要几天的时间，如果用AI来生成的话，只要你把自己的需求描述清楚，可能几秒就能够生成出来，并且出来的效果非常精美，这是对传统行业的影响

所以，我们就以实现AI作图为例，看看在微服务项目中我是怎么设计的！

项目名： gg

设定需求：用户入驻后，使用OpenAI结合 用户昵称、地域、兴趣爱好 为用户生成个性头像！

仅以此抛砖引玉，你可以设计的更丰满！

服务提供方(Provider)，服务名：gg-chatgpt

提供OpenAI能力的服务！这里用OpenAI生成个性头像！

服务消费方(Consumer)，服务名：gg-entry

提供入驻能力的服务，会调用gg-chatgpt服务 ！

最终的项目结构如下图（大家可以先尝试自己搭建下）：

提前说明：服务的身份是相对的，服务提供方也可能是服务消费方。主要取决于微服务的拆分！所以项目命名一般不会出现provider或consumer的关键词！

二、新建父工程gg-parent

对于Spring Cloud Alibaba的版本选择，第一篇已经有详细的说明，所以本篇对版本选择不变！

注册中心依然是使用标配的Nacos，对于Nacos-server的安装请参见第一篇：【Spring Cloud Alibaba】（一）微服务介绍及 Nacos注册中心实战

对于dubbo的版本，spring-cloud-alibaba 2.2.7默认集成的是2.7.13，这里升级到2.7.18，主要是做了安全升级！

1. pom.xml 依赖

父工程只有一个pom.xml文件，主要目的是引入BOM，定义好版本，服务不必关心版本号，pom.xml的dependencyManagement配置如下（内有详细注释）：

<properties>
    <maven.compiler.source>8</maven.compiler.source>
    <maven.compiler.target>8</maven.compiler.target>
    <spring-boot.version>2.3.12.RELEASE</spring-boot.version>
    <spring-cloud.version>Hoxton.SR12</spring-cloud.version>
    <spring-cloud-alibaba.version>2.2.7.RELEASE</spring-cloud-alibaba.version>
    <spring.version>5.2.21.RELEASE</spring.version>
    <dubbo.version>2.7.18</dubbo.version>
</properties>

<dependencyManagement>
    <dependencies>
        <!-- bom start -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-framework-bom</artifactId>
            <version>${spring.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <!-- duboo-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-bom</artifactId>
            <version>${dubbo.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <!-- spring cloud alibab-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-dependencies</artifactId>
            <version>${spring-cloud-alibaba.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <!-- spring boot-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-dependencies</artifactId>
            <version>${spring-boot.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <!-- spring cloud-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <!-- bom end -->
        
        <!-- dubbo start -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>${dubbo.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>${dubbo.version}</version>
        </dependency>
        <!-- dubbo end -->
        
        <!-- API start-->
        <dependency>
            <groupId>com.tiangang</groupId>
            <artifactId>gg-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <!-- API end -->
    </dependencies>
</dependencyManagement>

二、API接口包 gg-api

API接口包，是实现RPC通信的接口定义，可以使API接口更加清晰，便于维护与管理，在OpenFeign实战中我也同样推荐过：API接口单独放在一个包里。

1. 数据传输对象DTO

接口参数DTO，这里为了方便直接用了lombok

@Data
public class ChatGPTParamDTO implements Serializable {
    private String name;
    private String area;
    private String hobby;
}

接口返回结果DTO

@Data
public class ChatGPTResultDTO implements Serializable {
    private String imageUrl;
}

2. 接口服务Service

public interface ChatGPTService {
	/**
     * 生成头像
     */
    ChatGPTResultDTO generateAvatar(ChatGPTParamDTO paramDTO);
}

3. pom.xml 依赖

lombok依赖是可选的，如果你不用，就没有依赖了！

<dependencies>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>
</dependencies>

三、服务提供方 gg-chatgpt

首先，新建一个SpringBoot程序，命名：gg-chatgpt。

然后，在此基础上，主要实现：

注册到Nacos
调用gg-chatgpt的Dubbo服务

1. pom.xml 依赖

spring-cloud-starter-alibaba-nacos-discovery：用于支持Nacos
spring-cloud-starter-dubbo：用于支持dubbo

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!-- Dubbo Spring Cloud Starter -->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-dubbo</artifactId>
    </dependency>
    <!-- Spring Cloud Nacos Service Discovery -->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <!-- API接口包 -->
    <dependency>
        <groupId>com.tiangang</groupId>
        <artifactId>gg-api</artifactId>
    </dependency>
</dependencies>

2. application.properties

# 服务端口
server.port=8081
# 注册中心的服务名
spring.application.name=gg-chatgpt
# 注册中心地址
spring.cloud.nacos.discovery.server-addr=localhost:8848

# dubbo协议
dubbo.protocols.dubbo.name = dubbo
# dubbo协议端口（ ‐1 表示自增端口，从 20880 开始）
dubbo.protocols.dubbo.port = -1
# 其它dubbo配置先不关心

# openAI配置
chatgpt.image.generation.url=https://api.openai.com/v1/images/generations
chatgpt.secret=YOUR_KEY_SECRET

3. 接口实现类ChatGPTServiceImpl

这里主要是实现gg-api接口包的ChatGPTService，增加@DubboService注解，用于暴露Dubbo服务.

内部使用RestTemplate以HTTP方式调用OpenAI API生成图片.

对于RestTemplate的用法，建议看我的博文：RestTemplate.exchange各种用法（包括泛型等 --全）

当然，也可以使用OpenFeign以RPC方式调用OpenAI API生成图片.

对于OpenFeign实战案例，建议看我的博文：【Spring Cloud Alibaba】（二）微服务调用组件Feign原理+实战

@DubboService
public class ChatGPTServiceImpl implements ChatGPTService {

    @Value("${chatgpt.image.generation.url}")
    private String imageGenerationUrl;
    @Value("${chatgpt.secret}")
    private String secret;

    @Autowired
    private RestTemplate restTemplate;

    @Override
    public ChatGPTResultDTO generateAvatar(ChatGPTParamDTO paramDTO) {
        ChatGPTResultDTO resultDTO = new ChatGPTResultDTO();
        resultDTO.setImageUrl(createImage(paramDTO));
        return resultDTO;
    }

    private String createImage(ChatGPTParamDTO paramDTO) {
        String prompt = String.format("生成一张个性头像: 昵称:%s, 地区:%s, 爱好:%s"
                , paramDTO.getName(), paramDTO.getArea(), paramDTO.getHobby());
        return invokeChatgptCreateImage(prompt);
    }

    private String invokeChatgptCreateImage(String prompt) {
        Map<String, Object> body = new HashMap<>();
        body.put("prompt", prompt);
        body.put("n", 1);
        body.put("size", "256x256");

        HttpHeaders headers = new HttpHeaders();
        headers.add("Content-Type", "application/json");
        headers.add("Authorization", "Bearer " + secret);

        HttpEntity<?> httpEntity = new HttpEntity<>(body, headers);
        try {
            JSONObject responseBody = restTemplate.exchange(imageGenerationUrl, HttpMethod.POST, httpEntity, JSONObject.class).getBody();
            System.out.println(responseBody);
            if (responseBody != null && responseBody.get("data") != null) {
                return responseBody.getJSONArray("data").getJSONObject(0).get("url").toString();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "https://blog.csdn.net/scm_2008/article/details/128931945";
    }
}

4. 启动类ChatGPTRunner

额外增加注解：

@EnableDiscoveryClient 用于服务注册和发现
@EnableDubbo 用于扫描上面配置的@DubboService注解，scanBasePackages指定扫描的路径

@SpringBootApplication
@EnableDiscoveryClient
@EnableDubbo(scanBasePackages = {"com.tiangang.gg.chatgpt.facade"})
public class ChatGPTRunner {
    public static void main(String[] args) {
        SpringApplication.run(ChatGPTRunner.class, args);
    }
    
    @Configuration
    public class Config {
        @Bean
        public RestTemplate restTemplate(ClientHttpRequestFactory factory) {
            return new RestTemplate(factory);
        }

        @Bean
        public ClientHttpRequestFactory simpleClientHttpRequestFactory(){
            SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
            factory.setConnectTimeout(15000);
            factory.setReadTimeout(30000);
            return factory;
        }
    }
}

四、服务消费方 gg-entry

首先，新建一个SpringBoot程序，命名：gg-entry。

然后，在此基础上，主要实现：

注册到Nacos
调用gg-chatgpt的Dubbo服务

1. pom.xml 依赖

spring-cloud-starter-alibaba-nacos-discovery：用于支持Nacos
spring-cloud-starter-dubbo：用于支持dubbo

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!-- Dubbo Spring Cloud Starter -->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-dubbo</artifactId>
    </dependency>
    <!-- Spring Cloud Nacos Service Discovery -->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <!-- API接口包 -->
    <dependency>
        <groupId>com.tiangang</groupId>
        <artifactId>gg-api</artifactId>
    </dependency>
</dependencies>

2. application.properties

额外增加dubbo.cloud.subscribed-services = gg-chatgpt ，可以订阅多个提供方服务，以逗号分隔

# 服务端口
server.port=8082
# 注册中心的服务名
spring.application.name=gg-entry
# 注册中心地址
spring.cloud.nacos.discovery.server-addr=localhost:8848
# 订阅服务提供方
dubbo.cloud.subscribed-services = gg-chatgpt
# dubbo协议
dubbo.protocols.dubbo.name = dubbo
# dubbo协议端口（ ‐1 表示自增端口，从 20880 开始）
dubbo.protocols.dubbo.port = -1
# 其它dubbo配置先不关心

3. 测试类EntryController

对于服务调用，通常都会在Service层调Dubbo服务，我这里简化只创建Controller，直接在Controller里调用Dubbo服务，目的就是为了测试验证，主要通过@DubboReference 引入dubbo服务

注意这里不能用@Autowired
retries：防止幂等问题设置为0：不重试
timeout: 防止调用服务超时，默认1秒，单位ms

@RestController
@RequestMapping("/entry")
public class EntryController {

    @DubboReference(retries = 0, timeout = 10000)
    private ChatGPTService chatGPTService;

    // 定义一个测试用的接口
    @PostMapping("/chatgpt")
    public ChatGPTResultDTO generateAvatar(@RequestBody ChatGPTParamDTO paramDTO) {
        return chatGPTService.generateAvatar(paramDTO);
    }
}

4. 启动类EntryRunner

额外增加注解：

@EnableDiscoveryClient 用于服务注册和发现

@SpringBootApplication
@EnableDiscoveryClient
public class EntryRunner {
    public static void main(String[] args) {
        SpringApplication.run(EntryRunner.class, args);
    }
}

五、启动验证

1. 先运行Nacos-server

2. 验证调用

注意启动顺序：先启动服务提供者gg-chatgpt，再启动服务消费者gg-entry。

启动后，到Nacos的服务列表，可以看到：

使用postman测试一下，达到预期~ 💪💪💪

看看结果哈，这是画吗？也太真了，反正我是看不出来这是真人照片还是AI的画了…

六、常见问题

初学者最常见的问题，也是最让人懵圈的报错：

No provider available from registry localhost:9090 for service xxx

1. 主要排查点

服务消费方（Consumer）是否正确订阅本例中就是：dubbo.cloud.subscribed-services=gg-chatgpt 检查application.properties，有没有配置该项，或者配的对不对！
服务提供方（Provider）是否正确启用Dubbo 本例中就是：@EnableDubbo(scanBasePackages = {"com.tiangang.gg.chatgpt.facade"}) 检查启动类上是否有@EnableDubbo注解，或者scanBasePackages的包路径(@DubboService所在包)配的对不对！
服务提供方（Provider）有没有启动！这也是为什么让你注意启动顺序的原因。

总结

最后，我再总结一下主要步骤，其实和本地调用相比，无外乎就是几个注解和配置的区别！

提供方
用@DubboService声明提供方的服务，与本地服务声明用@Service对应
提供方在启动类上加@@EnableDubbo注解，提供DubboService
消费方
用@DubboReference引入提供方的服务，与本地服务引入用@Autowired对应
消费方用dubbo.cloud.subscribed-services配置，订阅DubboService

如果你能看懂我总结的这几点，那么恭喜你，说明你对Dubbo基础应用入门了！

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2023-02-20，如有侵权请联系 cloudcommunity@tencent.com 删除

微服务

xml

maven

dubbo

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

登录后参与评论

0 条评论

热度