一个简单便捷的基于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; } }
以下为测试图例
我刚刚开始使用Spring Boot,我想使用RestTemplate调用一个查询并返回它的结果。 如何使用RESTTemplate调用查询?还是有更好的办法做这件事?
问题内容: 注意:这旨在作为常见问题的规范答案。 我有一个带有字段()的Spring 类(),但是该字段是我尝试使用它时所用的。日志显示同时创建了bean和bean,但是每当尝试在服务bean上调用方法时,我都会得到一个。Spring为什么不自动接线该领域? 控制器类: 服务等级: 应该自动连接的服务bean,但不是: 当我尝试时,出现以下异常: 问题答案: 带注释的字段是因为Spring不知道您
本文向大家介绍SpringBoot开启异步调用方法,包括了SpringBoot开启异步调用方法的使用技巧和注意事项,需要的朋友参考一下 异步调用无需等待,方法相当于子线程,后台执行,主线程执行完成,子线程开始执行。 SpringBoot 开启异步执行仅需两步: 方法上加 @Async main 方法 开启 @EnableAsync controller 执行结果 可以看到 controller 先
我不熟悉这个框架,尝试使用JavaWS调用RESTful API。我一直在努力解决这个问题。这就是我目前的情况: 这段代码基于JavaWS文档(我发现它非常混乱),旨在发出请求。我认为它的工作原理是重复“ok”结果的完成阶段,该结果包含一个字符串,该字符串是将响应转换为文本的结果。 然后从控制器调用此代码: 我目前收到一个错误,上面写着“变量ws可能没有初始化”,这是有意义的,因为我没有初始化ws
本文向大家介绍SpringBoot框架搭建教程分享,包括了SpringBoot框架搭建教程分享的使用技巧和注意事项,需要的朋友参考一下 SpringBoot几乎集成了SpringMVC的所有内容,以及tomcat容器,同时去除了繁复的xml配置文件,开发起来十分方便;页面配合thymeleaf模板渲染也是非常简单,如果是前后端分离的项目,那么SpringBoot就专门负责提供restful风格的a
本文向大家介绍springboot使用校验框架validation校验的示例,包括了springboot使用校验框架validation校验的示例的使用技巧和注意事项,需要的朋友参考一下 b/s系统中对http请求数据的校验多数在客户端进行,这也是出于简单及用户体验性上考虑,但是在一些安全性要求高的系统中服务端校验是不可缺少的。 Spring3支持JSR-303验证框架,JSR-303 是Java
我是Spring世界里的一个新人。我有一个问题,从oracle包调用过程并将游标返回到Spring的更好的方法是什么? 我可以像在经典java中那样使用“可调用语句”,但我认为还有更好、更干净的方法,如何做到这一点? 姓名:尼奥,玛丽姓:安德森,史密斯性别:M,W年龄:20,25卷:测试,测试 b)同时,我们有一个包含过程的包HOME_TEST_PKG 过程show_people_data(VAR
本文向大家介绍Springboot中集成Swagger2框架的方法,包括了Springboot中集成Swagger2框架的方法的使用技巧和注意事项,需要的朋友参考一下 摘要:在项目开发中,往往期望做到前后端分离,也就是后端开发人员往往需要输出大量的服务接口,接口的提供方无论是是Java还是PHP等语言,往往会要花费一定的精力去写接口文档,比如A接口的地址、需要传递参数情况、返回值的JSON数据格式