springboot-MQRPC 介绍
一个简单便捷的基于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;
}
}
以下为测试图例
springboot-MQRPC 官网
https://git.oschina.net/kailing/springboot-mqrpc
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。