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

chatgpt/2024/6/24 17:33:22

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.xmldependencyManagement配置如下(内有详细注释):

<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&#xff1f;OpenAI官方API带你起飞安装 OpenAI 的 API 库包装个函数包装个UIAPI 调不通怎么办&#xff1f;ChatGPT没有API&#xff1f;OpenAI官方API带你起飞 前段时间ChatGPT爆火&#xff0c;OpenAI 的 GPT API也被大家疯狂调用&#xff0c; 但其实这个AP…

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

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

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

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

ChatGPT 本地部署及搭建

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

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

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

作为大学生,你还不会搭建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这么火&#xff0c;他的优势是什么&#xff1f;ChatGPT 也是创业公司和企业家应该已经知道的事情的最佳表达&#xff1a;生成人工智能的淘金热将由开发新颖的、防御性的业务驱动&#xff0c;围绕它的出现方式&#xff0c;而不是引擎盖下的内容。 对于那些在该领域从…

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

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