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

chatgpt/2023/12/3 2:17:03

CSDN成就一亿技术人

系列目录

【Spring Cloud Alibaba】（一）微服务介绍 及 Nacos注册中心实战
【Spring Cloud Alibaba】（二）微服务调用组件Feign原理+实战
【Spring Cloud Alibaba】（三）OpenFeign扩展点实战 + 源码详解

本文目录

  • 系列目录
  • 前言
  • Spring Cloud与Dubbo的关系
  • Dubbo架构
  • 一、项目说明
  • 二、新建父工程gg-parent
    • 1. pom.xml 依赖
  • 二、API接口包 gg-api
    • 1. 数据传输对象DTO
    • 2. 接口服务Service
    • 3. pom.xml 依赖
  • 三、服务提供方 gg-chatgpt
    • 1. pom.xml 依赖
    • 2. application.properties
    • 3. 接口实现类ChatGPTServiceImpl
    • 4. 启动类ChatGPTRunner
  • 四、服务消费方 gg-entry
    • 1. pom.xml 依赖
    • 2. application.properties
    • 3. 测试类EntryController
    • 4. 启动类EntryRunner
  • 五、启动验证
    • 1. 先运行Nacos-server
    • 2. 验证调用
  • 六、常见问题
    • 1. 主要排查点
  • 总结

前言

从本文开始，我们将探讨在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远程调用有个大概的认识！
本地调用 VS Dubbo远程调用

Spring Cloud与Dubbo的关系

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

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

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

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

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

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

Dubbo架构

对于Spring Cloud整合Dubbo，我们不看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来生成的话，只要你把自己的需求描述清楚，可能几秒就能够生成出来，并且出来的效果非常精美，这是对传统行业的影响。

引自凉哥(几何心凉)的文章：CSDN城市开发者联盟、C友会期待你的加入 ，推荐阅读！

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

  • 项目名： gg

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

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

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

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

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

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

  • 最终的项目结构如下图（大家可以先尝试自己搭建下）：
    Dubbo实战框架整体预览

提前说明：服务的身份是相对的，服务提供方也可能是服务消费方。主要取决于微服务的拆分！

所以项目命名一般不会出现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;@Autowiredprivate RestTemplate restTemplate;@Overridepublic 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);}@Configurationpublic class Config {@Beanpublic RestTemplate restTemplate(ClientHttpRequestFactory factory) {return new RestTemplate(factory);}@Beanpublic 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

cmd启动nacos

2. 验证调用

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

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

使用postman测试一下，达到预期~ 💪💪💪
在这里插入图片描述

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

六、常见问题

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

No provider available from registry localhost:9090 for service xxx

1. 主要排查点

  1. 服务消费方（Consumer）是否正确订阅

    本例中就是：dubbo.cloud.subscribed-services=gg-chatgpt

    检查application.properties，有没有配置该项，或者配的对不对！

  2. 服务提供方（Provider）是否正确启用Dubbo

    本例中就是：@EnableDubbo(scanBasePackages = {"com.tiangang.gg.chatgpt.facade"})

    检查启动类上是否有@EnableDubbo注解，或者scanBasePackages的包路径(@DubboService所在包)配的对不对！

  3. 服务提供方（Provider）有没有启动！

    这也是为什么让你注意启动顺序的原因。

总结

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

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

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

img
源码下载地址：https://download.csdn.net/download/scm_2008/87472654
对于Dubbo，你知道他有哪些坑吗？这也是我计划将在下文分享的内容，如果感觉不错，欢迎订阅本专栏，后面还有更多的【Spring Cloud Alibaba】实战知识陆续放出。

关注我 天罡gg 分享更多干货： https://blog.csdn.net/scm_2008
大家的「关注❤️ + 点赞👍 + 收藏⭐」就是我创作的最大动力！谢谢大家的支持，我们下文见！


http://www.ngui.cc/chatgpt/12.html

相关文章

ChatGPT没有API？OpenAI官方API带你起飞

ChatGPT没有API？OpenAI官方API带你起飞

目录ChatGPT没有API&#xff1f;OpenAI官方API带你起飞安装 OpenAI 的 API 库包装个函数包装个UIAPI 调不通怎么办&#xff1f;ChatGPT没有API&#xff1f;OpenAI官方API带你起飞 前段时间ChatGPT爆火&#xff0c;OpenAI 的 GPT API也被大家疯狂调用&#xff0c; 但其实这个AP…
阅读更多...
【国内chatgpt最全使用方法合集】（总有一个适合你）

【国内chatgpt最全使用方法合集】（总有一个适合你）

写在前面 Hello大家好&#xff0c; 我是【麟-小白】&#xff0c;一位软件工程专业的学生&#xff0c;喜好计算机知识。希望大家能够一起学习进步呀&#xff01;本人是一名在读大学生&#xff0c;专业水平有限&#xff0c;如发现错误或不足之处&#xff0c;请多多指正&#xff0…
阅读更多...
如何使用New Bing的ChatGPT聊天机器人

如何使用New Bing的ChatGPT聊天机器人

New Bing是微软推出的一款基于GPT4模型的智能搜索引擎&#xff0c;可以提供更加人性化、交互式和多样化的搜索体验。在中国使用New Bing的ChatGPT聊天机器人需要以下几个步骤&#xff1a; 一、准备工作 1.1 申请微软邮箱 用来登录Edge浏览器和接收来自微软New Bing使用邀请的…
阅读更多...
ChatGPT 本地部署及搭建

ChatGPT 本地部署及搭建

这篇简要说下清华开源项目 ChatGLM 本地部署的详细教程。清华开源项目 ChatGLM-6B 已发布开源版本&#xff0c;这一项目可以直接部署在本地计算机上做测试&#xff0c;无需联网即可体验与 AI 聊天的乐趣。 项目地址&#xff1a;GitHub - THUDM/ChatGLM-6B: ChatGLM-6B&#xf…
阅读更多...
ChatGPT“铸魂”：人形机器人“进化论”

ChatGPT“铸魂”：人形机器人“进化论”

熊猫机器人优悠在迪拜世博会中国馆教游客打太极 近日&#xff0c;伴随微软ChatGPT、谷歌Bard、百度“文心一言”等AI大模型之争愈演愈烈&#xff0c;生成式AI在全球范围内掀起轩然大波。与此同时&#xff0c;人形机器人赛道也悄悄升温了。ChatGPT背后的造物主OpenAI领投人形机器…
阅读更多...
作为大学生，你还不会搭建chatGPT微应用吗？

作为大学生，你还不会搭建chatGPT微应用吗？

目录 引言ChatGPT是什么&#xff1f;背景&#xff1a;ChatGPT敢为人先&#xff0c;打破全球僵局示例演示&#xff1a;基于ChatGPT微应用实现的条件及步骤&#xff08;1&#xff09;整体框架&#xff08;2&#xff09;搭建前的准备工作&#xff08;3&#xff09;实际搭建步骤&a…
阅读更多...

如何看待ChatGPT

如何看待ChatGPT 如何看待ChatGPT&#xff0c;语言学家乔姆斯基说&#xff0c;这是一个抄袭的机器。 欺骗性机器 ChatGPT使用大量文本数据进行训练&#xff0c;然后以一种令人信服的修饰语句展现&#xff0c;这使得它和人的互动能力更加契合&#xff0c;但是仍然不是一个充满…
阅读更多...

ChatGPT预语言训练模型

我今天想要给大家分享的是现在比较热门的一个美国OpenAI研发的聊天机器人程序 它的英文名字叫ChatGPT 1 英文ChatGPT是什么意思&#xff1f; Chat表示聊天。 GPT是一种预训练语言模型的缩写 通俗来讲 它是个“会说话”的人工智能。 2 他厉害在哪&#xff1f; 不仅会回答 而且可…
阅读更多...
ChatGPT怎么下载？ChatGPT国内怎么使用

ChatGPT怎么下载？ChatGPT国内怎么使用

为什ChatGPT这么火&#xff0c;他的优势是什么&#xff1f;ChatGPT 也是创业公司和企业家应该已经知道的事情的最佳表达&#xff1a;生成人工智能的淘金热将由开发新颖的、防御性的业务驱动&#xff0c;围绕它的出现方式&#xff0c;而不是引擎盖下的内容。 对于那些在该领域从…
阅读更多...
上海亚商投顾：创业板指高开高走 ChatGPT概念卷土重来

上海亚商投顾：创业板指高开高走 ChatGPT概念卷土重来

上海亚商投顾前言&#xff1a;无惧大盘涨跌&#xff0c;解密龙虎榜资金&#xff0c;跟踪一线游资和机构资金动向&#xff0c;识别短期热点和强势个股。 市场情绪沪指今日红盘震荡&#xff0c;深成指、创业板指小幅走高&#xff0c;科创50指数涨近1.5%。ChatGPT概念股再度爆发&a…
阅读更多...
最新文章

Copyright @ 2022~2023