Spring Cloud Alibaba+Nacos+Dubbo如何进行零成本实现RPC调用,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
dubbo的rpc框架学习成本较高,代码入侵性强,本身生态不完整,需要整合多个外部组件,故选择了相对性能弱一点的Spring Cloud全家桶。
直到Spring Cloud Alibaba的出现,使用Nacos作为服务发现与注册,同时兼容使用Feign的http
方式和使用dubbo的rpc
方式调用。
Spring Cloud 为什么需要RPC
在Spring Cloud构建的微服务系统中,大多数的开发者使用都是官方提供的Feign组件来进行内部服务通信,这种声明式的HTTP客户端使用起来非常的简洁、方便、优雅,并且和开发平台、语言无关,但是通常情况下,HTTP并不会开启KeepAlive功能,即当前连接为短连接,短连接的缺点是每次请求都需要建立TCP连接,这使得其效率变的相当低下。
对外部提供REST API服务是一件非常好的事情,但是如果内部调用也是使用HTTP调用方式,就会显得显得性能低下,Spring Cloud默认使用的Feign组件进行内部服务调用就是使用的HTTP协议进行调用,这时,我们如果内部服务使用RPC调用,对外使用REST API,将会是一个非常不错的选择。
引用至:Dubbo 与 Spring Cloud 完美结合
使用Dubbo Spring Cloud使用内部的RPC协议调用几乎是零成本的改造。
cloud-gateway
作为cloud集群的网关,外部的路由转发使用http协议,内部的服务调用使用dubbo协议
cloud-user
和cloud-mq
之间的远程调用使用dubbo协议
使用Nacos
作为服务注册与发现和配置中心的服务
使用Sentinel
作为服务间http和dubbo调用的流量控制服务
目录结构
├── cloud-admin # 服务监控
├── cloud-gateway # 服务网关
├── cloud-mq # mq服务
├── cloud-provider # 服务接口
└── cloud-user # user服务
public interface UserProvider {
UserDTO checkUser(String userName, String password);
UserDTO findByUserName(String userName);
}
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class UserDTO implements Serializable {
String userName;
String realName;
String password;
}
服务接口是服务提供方和消费方的契约,包含服务的方法传输对象DTO。由于涉及多个应用服务的引入,最好是将其独立成Module
DTO对象必须实现Serializable
接口
POM
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
spring-boot-starter-actuator
也是必须的
import org.apache.dubbo.config.annotation.Service;
@Service
public class UserProviderImpl implements UserProvider {
@Autowired
private UserService userService;
@Override
public UserDTO checkUser(String userName, String password) {
User user = userService.checkUser(userName, password);
return UserConvertor.toDTO(user);
}
}
@Service
必须是org.apache.dubbo.config.annotation.Service
spring:
main:
allow-bean-definition-overriding: true
dubbo:
scan:
base-packages: fun.barryhome.cloud.provider #指定 Dubbo 服务实现类的扫描基准包
protocols:
dubbo:
name: dubbo # Dubbo 的协议名称
port: -1 # port 为协议端口( -1 表示自增端口,从 20880 开始)
registry:
address: spring-cloud://localhost # 挂载到 Spring Cloud 注册中心
启动后有可能出现连接失败,不影响使用
java.net.ConnectException: Connection refused (Connection refused)
at java.net.PlainSocketImpl.socketConnect(Native Method) ~[na:1.8.0_111]
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) ~[na:1.8.0_111]
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[na:1.8.0_111]
<!--服务接口-->
<dependency>
<groupId>fun.barryhome</groupId>
<artifactId>cloud-provider</artifactId>
<version>0.0.1-SNAPSHOT</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
import org.apache.dubbo.config.annotation.Reference;
public class UserController {
@Reference
private UserProvider userProvider;
@GetMapping(value = "/sessionUser")
public UserDTO sessionUser(HttpServletRequest request) {
String userName = request.getHeader("X-User-Name");
if (Strings.isEmpty(userName)) {
throw new RuntimeException("没有找到用户");
}
return userProvider.findByUserName(userName);
}
}
dubbo:
cloud:
subscribed-services: cloud-user # 服务提供方的服务名
consumer:
check: false
loadbalance: "leastactive" # 最小活跃数负载均衡
registry:
# 挂载到 Spring Cloud 注册中心
address: spring-cloud://localhost
dubbo.consumer.check
:用于启动时是否检查服务提供方是否运行正常,如果不正常将不能启动调用方
dubbo.consumer.loadbalance
:负载均衡策略
RandomLoadBalance:随机,按权重设置随机概率
ConsistentHashLoadBalance:一致性哈希算法
LeastActiveLoadBalance:最小活跃数负载均衡
RoundRobinLoadBalance:根据权重进轮训
服务间使用了长连接,在正常运行时,提供方某个节点断掉后会需要一段时间来切换,可使用sentinel
来控制快速切换可用节点
使用dubbo进行远程调用,内部调用性能上有所提供,调用方式上也相对简单
与sentinel
配合,合理使用负载策略,可实现更多功能,如灰度发布,版本控制等
性能的提升让调用链增加成为可能性,可实现更小粒度的微服务拆分与组合
看完上述内容,你们掌握Spring Cloud Alibaba+Nacos+Dubbo如何进行零成本实现RPC调用的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注亿速云行业资讯频道,感谢各位的阅读!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:https://my.oschina.net/barryhome/blog/4551068