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

联合创作 · 2023-09-28 04:47

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

        <dependency>
            <groupId>com.yixiu.rabbitrpc</groupId>
            <artifactId>rabbitrpc-spring-boot-starter</artifactId>
            <version>1.0.0-SNAPSHOT</version>
        </dependency>

如果是服务端 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 引入,例如。

        <dependency>
            <groupId>org.example</groupId>
            <artifactId>rabbitrpc-server-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

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包的根路径。

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

浏览 5
点赞
评论
收藏
分享

手机扫一扫分享

编辑 分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

编辑 分享
举报