springboot-MQRPC 正在参加 2021 年度 OSC 中国开源项目评选,请投票支持!
springboot-MQRPC 在 2021 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
2021 年度 OSC 中国开源项目评选 正在火热进行中,快来投票支持你喜欢的开源项目!
2021 年度 OSC 中国开源项目评选 >>> 中场回顾
springboot-MQRPC 获得 2021 年度 OSC 中国开源项目评选「最佳人气项目」 !

软件简介

一个简单便捷的基于springboot+RabbitMQ中间件实现的RPC调用框架

远程调用过程如下

首先:消费者和生产者spring容器初始化的时候,会根据配置的的api在RabbitMQ上建立相应的队列,消费者会监听相关队列

1)生产者(client)调用以本地调用方式调用服务;

2)client 接收到调用后通过Hessian将方法、参数等组装成能够进行网络传输的消息体;

3)client 通过代理类,执行invoke方法,统一将消息发送到MQ监听的服务端;

4)server 收到消息后通过Hessian进行解码;

5)server 根据解码结果调用本地的服务;

6)本地服务执行并将结果返回给server ;

7)server 将返回结果通过Hessian打包发送至消费方;

8)client 接收到消息,并进行解码;

9)生产者得到最终结果。

客户端配置:


    <!-- RabbitMQ连接池 -->
    <task:executor id="amqpConnectionTaskExecutor" pool-size="5"/>

    <!-- RabbitMQ连接器 -->
    <rabbit:connection-factory id="connectionFactory" executor="amqpConnectionTaskExecutor" host="127.0.0.1" port="5672" username="admin" password="admin"
                               virtual-host="/kl"/>

    <bean id="myService" class="com.kl.client.MQClientProxyFactoryBean">
        <property name="connectionFactory" ref="connectionFactory"/>
        <property name="serviceInterface" value="com.kl.api.Service"/>
    </bean>
服务端配置:



   <!-- RabbitMQ连接池 -->
    <task:executor id="amqpConnectionTaskExecutor" pool-size="5"/>

    <!-- RabbitMQ连接器 -->
    <rabbit:connection-factory id="connectionFactory" executor="amqpConnectionTaskExecutor" host="127.0.0.1" port="5672" username="admin" password="admin"
                               virtual-host="/kl"/>
    <bean id="ServiceImpl" class="com.kl.apiImpl.ServiceImpl"/>

    <bean id="MyServiceEndpoint" class="com.kl.server.MQServerEndpoint">
        <constructor-arg index="0" ref="ServiceImpl"/>
        <property name="connectionFactory" ref="connectionFactory"/>
    </bean>


测试代码及图例

    /**
     * 暴力测试
     * @param args
     */
    public static void main(String[] args) {
        GenericXmlApplicationContext context = new GenericXmlApplicationContext(
                "classpath:/applicationContext-client.xml");
        Service service = (Service) context.getBean("myService");
        new ClientTest().exec(service);
    }
    public void exec(Service service){
        ExecutorService executorService= Executors.newFixedThreadPool(30);
        for(int i=0;i<=30;i++){
            executorService.submit(new Task(service));
        }
    }
    private class Task implements Callable {
        private Service service;
        public Task(Service service){
            this.service=service;
        }
        @Override
        public Object call() throws Exception {
            for(int i=0;i<=100000;i++){
                System.out.println("servicEcho当前线程:"+Thread.currentThread().getName()+"| 线程任务数"+i+"| 输出:"+service.echo("Hello AMQP!"));
                System.out.println("serviceStudent当前线程:"+Thread.currentThread().getName()+"| 线程任务数"+i+"| 输出:"+service.getStudent(null).getName());

            }
            return null;
        }
    }



以下为测试图例
输入图片说明
输入图片说明
输入图片说明



展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (6)

加载中
厉害
2017/11/23 09:14
回复
举报
打分: 还行
这个好用吗?
2017/02/21 14:09
回复
举报
打分: 推荐
down来看看
2017/02/21 13:58
回复
举报
打分: 力荐
各种分布式架构太多了,不知道用哪个好?
2017/02/21 12:43
回复
举报
KL博主软件作者
打分: 力荐
基于RabbitMQ,抗高并发,大流量。简便实用
2017/03/10 14:09
回复
举报
2016/12/07 11:23
回复
举报
更多评论
暂无内容
发表了博客
2019/10/24 15:45

【SpringBoot】SpringBoot实战,手写自己的SpringBoot Strater

对SpringBoot印象一直是:配置简单、快速开发、轻量.....通俗点讲就是:简单、高级、主流。现在出去面试,如果没有用过SpringBoot,甚至不甚了解,先天在底气上就矮一头。前段时间学习使用并了解了SpringBoot的一些原理,参考了Mybatis、jdbc等插件的源码,从实际意义上出发,手写了一套自己的插件以及开箱即用的Strater,在此记录,希望对正在读这篇文章的你有一些帮助。 本篇将会以三段式的方式进行: 一、概念储备 二、关键技...

0
2
发表了博客
2019/03/11 20:49

SpringBoot之快速入门SpringBoot

前言 在没有SpringBoot之前,我们搭建的是SSM(SpingMVC+Spring+Mybatis)项目,搭建SSM项目的时候,我们要经过一系列的繁琐配置,例如:application,web.xml,spring-servlet等等的配置信息。如果我们这些配置出现一点点的错误。那么面临的就是寻找一大堆的Bug,而且还出现一些我们看难以看懂的异常,对于English不好的同志来说,这是内伤。那么SpringBoot到底解决了什么问题呢?简单来说,SpringBoot主要简化了我们的配置操作,将...

0
5
发表了博客
2020/06/16 17:31

SpringBoot之快速入门SpringBoot

前言 在没有SpringBoot之前,我们搭建的是SSM(SpingMVC+Spring+Mybatis)项目,搭建SSM项目的时候,我们要经过一系列的繁琐配置,例如:application,web.xml,spring-servlet等等的配置信息。如果我们这些配置出现一点点的错误。那么面临的就是寻找一大堆的Bug,而且还出现一些我们看难以看懂的异常,对于English不好的同志来说,这是内伤。那么SpringBoot到底解决了什么问题呢?简单来说,SpringBoot主要简化了我们的配置操作,将...

0
0
发表了博客
2019/03/12 10:44

SpringBoot之SpringBoot整合MyBatis

前言 通过上一章的学习,我们已经对SpringBoot有简单的入门,接下来我们深入学习一下SpringBoot,我们知道任何一个网站的数据大多数都是动态的,也就是说数据是从数据库提取出来的,而非静态数据,那么我们接下来就是要连接数据库,现在我们经常使用的数据库的种类可以大致分为两种,关系型数据库和非关系型数据库,而MySQL数据库,Oracle数据库SQL Server数据库等都是关系型数据库,而Redis,Mongodb等都是非关系型数据库。 本章...

1
6
2020/02/24 21:21

SpringBoot实战:SpringBoot简介

SpringBoot介绍 SpringBoot是由Pivotal团队在2013年开始研发、2014年4月发布第一个版本的全新开源的轻量级框架。它基于Spring4.0设计,不仅继承了Spring框架原有的优秀特性,而且还通过简化配置来进一步简化了Spring应用的整个搭建和开发过程。另外SpringBoot通过集成大量的框架使得依赖包的版本冲突,以及引用的不稳定性等问题得到了很好的解决。 SpringBoot所具备的特征 可以创建独立的Spring应用程序,并且基于其Maven或Gra...

0
0
2020/06/13 09:12

SpringBoot 精髓之 SpringBoot-starter

背景 在互联网发达的今天,容器化和微服务化是一种潮流,已经不是趋势了,而是潮流。不管是出去面试还是自己日常项目开发,容器化可能还没普及,但是微服务化是不能缺少的。在微服务如此盛行的天下,Spring Clound 已经很流行了,作为 SpringCloud 的基石 SpringBoot 自然也是不容忽视。关于 SpringBoot 我们 Java 极客技术团队专门为知识星球的用户制作了一套视频教程,视频已经发布了几章了,还在持续更新中,欢迎大家到知识星...

0
1
发表了博客
2019/03/12 14:34

SpringBoot

什么是 Spring Boot? Spring Boot 是 Spring 开源组织下的子项目,是 Spring 组件一站式解决方案,主要是简化了使用 Spring 的难度,简省了繁重的配置,提供了各种启动器,开发者能快速上手。 Spring Boot特点有什么? 独立运行 简化配置 自动配置 无代码生成和XML配置 应用监控 上手容易 springBoot中有哪些重要的注解呢? @Configuration 在spring3.0添加的注解,用来替代applicationContext.xml配置 @Bean 用来...

0
0
发表了博客
2018/08/09 13:34

SpringBoot

一、SpringBoot简介 简化Spring应用开发的一个框架; 整个Spring技术栈的一个大整合; J2EE开发的一站式解决方案; 它还是一个微服务框架 环境约束 –jdk1.8:Spring Boot 推荐jdk1.7及以上;java version "1.8.0_112" –maven3.x:maven 3.3以上版本;Apache Maven 3.3.9 –IntelliJIDEA2017:IntelliJ IDEA 2017.2.2 x64、STS –SpringBoot 1.5.9.RELEASE:1.5.9; 二、项目搭建 1、创建普通maven项目 2、导入spring boot相关...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
暂无内容
6 评论
192 收藏
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部