,想了解更多关于开源的内容,请访问:,51CTO 开源基础软件社区,https://ost.51cto.com,前面几篇文章已经简单写了关于RabbitMQ安装,使用,结合SpringBoot使用流程,有了前面的基础知识了,我们现在开始开发一个完整,可以直接使用到生产上的MQBridge后台系统,创建SpringBoot项目,这里就不详细说了,主要讲解MQBridge项目的开发过程,我画了一个流程图,整体说明MQBridge的功能和流程。,
,项目依赖哪些第三方包,项目结构说明:,
,参数DefaultMessage说明:,返回类StandardResponse说明:,2. MQBridge服务接口与实现类:,消息消费者接口:,订单交换机、队列、路由主键之间关系使用:,1. 创建一个订单交换机。,2. 订单消息生产者类,实例消息生产者类(测试使用)。,3. 订单Email消费者,订单公共消费者(此消费在这里说明通配符交换机其中一使用)。,物流交换机、队列、路由主键之间关系使用:,1. 创建一个物流交换机。,2. 物流消息生产者:,3. 物流消息消费者:,从项目结构和代码可以看出,第五步和第六步是不同的业务功能,我们通过传递参数Source不同,调用不同的业务逻辑功能,之后如果添加新的模块,就可以参考第五步或第六步就可以实现,然后调用时,参数Source指定为新值就可以;这里再说一下Source参数值与Service是怎么对应的,在LogisticsSender类,OrderSender类,SampleSender类上都有一个注解@Service(“MQBridge.Order”), 括号里的字符串就是对应参数的Source值了。,1. Source为MQBridge.Order调用。,
,
,2. Source为MQBridge.Sample调用 。,
,
,3. Source为MQBridge.Logistics调用 。,
,
,从调试和打印日志可以看出MQBridge项目,可以很方便添加新功能,下图是调试的三次日志。,
,想了解更多关于开源的内容,请访问:,51CTO 开源基础软件社区,https://ost.51cto.com。
© 版权声明
文章版权归作者所有,未经允许请勿转载。