Spring Cloud AlibabaDubbo框架介绍 及 整合Dubbo和OpenAI实战文末附源码
Posted 天罡gg
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Spring Cloud AlibabaDubbo框架介绍 及 整合Dubbo和OpenAI实战文末附源码相关的知识,希望对你有一定的参考价值。
系列目录
【Spring Cloud Alibaba】(一)微服务介绍 及 Nacos注册中心实战
【Spring Cloud Alibaba】(二)微服务调用组件Feign原理+实战
【Spring Cloud Alibaba】(三)OpenFeign扩展点实战 + 源码详解
本文目录
- 系列目录
- 前言
- Spring Cloud与Dubbo的关系
- Dubbo架构
- 一、项目说明
- 二、新建父工程gg-parent
- 二、API接口包 gg-api
- 三、服务提供方 gg-chatgpt
- 四、服务消费方 gg-entry
- 五、启动验证
- 六、常见问题
- 总结
前言
从本文开始,我们将探讨在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来生成的话,只要你把自己的需求描述清楚,可能几秒就能够生成出来,并且出来的效果非常精美,这是对传统行业的影响。
引自凉哥(几何心凉)的文章:CSDN城市开发者联盟、C友会期待你的加入 ,推荐阅读!
所以,我们就以实现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
:用于支持Nacosspring-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以上是关于Spring Cloud AlibabaDubbo框架介绍 及 整合Dubbo和OpenAI实战文末附源码的主要内容,如果未能解决你的问题,请参考以下文章
Spring Cloud AlibabaDubbo启动报错?一直重连报错?你值得学习的是排查问题的方法
基于Spring的可扩展Schema进行开发自定义配置标签支持