背景:
因为项目是分布式项目,已经集成过rocketmq.但是没有单独将消息服务提取出来.而是每个model之间相互进行消息发布与消费.
这样解耦性比较差.且仍需要model与model之间进行服务的调用..还是多多少少会影响服务器的性能.
所以考虑将消息服务提取出来.单独建一个model.进行专门的管理rocketmq的消费.这样虽然也需要其他model进行调用rocketmq.但是与原有model项目进行了隔离…只需要利用rocketmq的异步消息在消息服务中进行各个model的调用….做到
