×

RabbitRpc基于spring cloud的微服务rpc调用

消耗积分:2 | 格式:zip | 大小:0.12 MB | 2022-06-14

李林

分享资料个

授权协议 Apache
开发语言 Java
操作系统 跨平台
软件类型 开源软件
所属分类 程序开发微服务框架

软件简介

Spring Cloud RabbitRpc 是基于 spring cloud 的微服务 rpc 调用。

组件介绍

目前微服务应用和开发已经成为主流,远程调用,服务治理方面我们通常有两个选择,spring cloud 和 ali 的dubbo,spring cloud 提供了非常容易上手的全家桶模式,也是目前很多公司的选择,在远程调用方面基于openfeign实现,底层逻辑是 http 协议,所以被一些人称为伪 rpc,而选用 dubbo吧,生态不是很完整,ali 内部更多却在使用HSF 和 dubbo从远程调用方面和服务治理方面 HSF的用户多一些,但是HSF没有开源,ali 也出了 spring cloud alibaba 版本。但是在一些需求上面趋向于商业化,很多公司不想上船,在并发要求不是很高的环境下,基于 http 协议的远程调用无可厚非,但是如果要构建高并发应用,http 协议的解析效率低,同步等待问题就成了远程调用的性能瓶颈。很多公司为了满足需求,也有spring cloud 和 dubbo并存的奇葩方案。

rabbitrpc 为解决这一需求而设计,既有dubbo的性能又能满足在 spring cloud生态里轻松集成使用。

v1.0.0 版本 的 features

1 支持与spring cloud 集成。

2 支持异步请求。

3 支持 eureka 注册中心。

4 自定义 rabbit 协议,请求头只有15个字节。

5 序列化 支持 hessian,后续会加入protolbuf实现

6 支持SPI 动态加载机制。

7 支持一个应用双端口,支持rabbit,http双协议,根据需要来选择。

quick start

maven 引入 rabbitrpc-spring-boot-starte

        
            com.yixiu.rabbitrpc
            rabbitrpc-spring-boot-starter
            1.0.0-SNAPSHOT
        

如果是服务端 1 需要提供api,需要定义如下,在提供的接口上添加注解配置。

@RabbitRpcClient(facadeId = "userService",facadeType = "com.yixiu.server.api.facade.UserFacade",name = "rabbitrpc-user-server",group = "rabbit")
public interface UserFacade {
    /**
     * 根据id 获取一个用户
     * @param id
     * @return
     */
    User getUser(Long id);
}

一般常用配置解释 facadeId:接口id facadeType:接口类型 name:服务名称 group:分组名称

2 在properties 文件添加如下配置

protocol.name=rabbit
protocol.port=20918

protocol.name 定义 rabbitrpc 要使用的协议,protocol.por 服务端开放监听的端口号。

3 在spring boot 启动入口,添加如下注解配置 @EnableRabbitRpcServices

@EnableEurekaClient
@EnableDiscoveryClient
@SpringBootApplication
@EnableRabbitRpcServices(basePackages = "com.yixiu.server.api")
public class RabbitRpcServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(RabbitRpcServerApplication.class);
    }
}

basePackages:接口定义包路径

如果是客户端

1 只需要将服务端提供的 api 引入,例如。

        
            org.example
            rabbitrpc-server-api
            1.0-SNAPSHOT
        

2 在spring boot 启动入口添加如下注解配置 @EnableRabbitRpcClients

@EnableEurekaClient
@EnableDiscoveryClient
@SpringBootApplication
@EnableRabbitRpcClients(basePackages = "com.yixiu.server")
public class RabbitClientApplication {
    public static void main(String[] args) {
        SpringApplication.run(RabbitClientApplication.class);
    }
}

basePackages: 即api jar包的根路径。

如上配置完成就可以像本地方法一样使用远程服务了。

 

声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉

评论(0)
发评论

下载排行榜

全部0条评论

快来发表一下你的评论吧 !