柠檬框架之rabbitMQ的反射实现解耦方式

柠檬框架 -- 基于去涩留精的架构理念实现代码的最优化。

实现方案:springboot + amqp (rabbitmq) + maven + jdk1.7

lemon-rabbitmq 消息生产端

lemon-rabbitmq-protocol 消息协议层

lemon-rabbitmq-consumer 消息消费端

消息协议层

通过Jackson2序列化/反序列化,实现消息传递和对象接收

协议层对象

消息生产端

1、通过发送带有消费端服务类名称和方法请求头,控制消费端调用执行消费发送的信息

2、利用消息回调接口ConfirmCallback确保消息安全发送至broker服务器,处理效率比事物方式更高

生产端发送消息

消息消费端

1、监听MQ消息,利用method.invoke调用指定的服务类名称和方法,消费接收到的消息

2、使用Ack/Nack手动确认消息处理状态,保证broker消息被正确消费

消费端监听

项目开源地址:https://github.com/lonyee1989/lemon-rabbitmq

github发布的完整项目

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,886评论 18 139
  • 来源 RabbitMQ是用Erlang实现的一个高并发高可靠AMQP消息队列服务器。支持消息的持久化、事务、拥塞控...
    jiangmo阅读 10,399评论 2 34
  • 关于消息队列,从前年开始断断续续看了些资料,想写很久了,但一直没腾出空,近来分别碰到几个朋友聊这块的技术选型,是时...
    预流阅读 585,400评论 51 786
  • kafka的定义:是一个分布式消息系统,由LinkedIn使用Scala编写,用作LinkedIn的活动流(Act...
    时待吾阅读 5,356评论 1 15
  • RabbitMQ详解 本文地址:http://www.host900.com/index.php/articles...
    嘉加家佳七阅读 2,532评论 0 9