RabbitMQ Bridge后台系统开发

网站建设4年前发布
10 0 0

20230306012932f799567309261912b5c348134d25c55745e916177,​​想了解更多关于开源的内容,请访问:​​,​​51CTO 开源基础软件社区​​,​​https://ost.51cto.com​​,前面几篇文章已经简单写了关于RabbitMQ安装,使用,结合SpringBoot使用流程,有了前面的基础知识了,我们现在开始开发一个完整,可以直接使用到生产上的MQBridge后台系统,创建SpringBoot项目,这里就不详细说了,主要讲解MQBridge项目的开发过程,我画了一个流程图,整体说明MQBridge的功能和流程。,202303060129494783b0a40874b0a101914277dd59df66b6bff7362,项目依赖哪些第三方包,项目结构说明:,2023030601313162949ac21ce91f4bc11718b99a8efcfa5bf395301,参数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调用。,202303060129357743c5d2135ad6b84b0216ccc6b163e61556bc604,2023030601293569f94fa991b5dae4e69674b98818a9aab397ee167,2.  Source为MQBridge.Sample调用 。,2023030601293519ad2ed34ec454ef0f95834a4b0ec9dc87c05c343,2023030601293512ce5418701ad2cfaae212965ccf9294afe44c323,3.  Source为MQBridge.Logistics调用 。,​20230306012935d34e25b740278d9efaf494ce69e98016b86bd7789,20230306012950b1a0dfb77fdaaf85a8b96710a34789a28e2e25931,从调试和打印日志可以看出MQBridge项目,可以很方便添加新功能,下图是调试的三次日志。,20230306012951e78d8fd947fad7a4897643614df9b7e24382bb228,​​想了解更多关于开源的内容,请访问:​​,​​51CTO 开源基础软件社区​​,​​https://ost.51cto.com​​。

© 版权声明

相关文章