java - 多客户端如何操作MQ比较合适
本文介绍了java - 多客户端如何操作MQ比较合适的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
问 题
我有500个子应用分别部署在500台不同的服务器上,还有一个主应用,现在有一个MQ。 我主应用会给子应用发消息。 子应用上有很多功能,都需要用到不同的消息。
我是在子应用开一个consumer好,还是为子应用的每一个功能都开一个consumer好。
我目前打算是这样,每个子应用,只开一个consumer,然后在发送的消息里面定义,具体要操作的方法。格式如下:
{
"header": {
"action": "scan_address"
},
"body": {
"id": 1234,
"name": "xxxxxx"
}
}
当子应用拿到消息后,根据action来决定调用哪个方法。 然后body就是需要处理的业务数据。
解决方案
你这种情况属于用MQ做松耦合的RPC调用。 我不知道你的mq选型是什么。就按照我熟悉的kafka来说吧,可以使用一个topic,然后单台机器配置单个消费组,然后消息就按照RPC的那种去写,基本可以做到不重不丢,且服务上下游解耦
这篇关于java - 多客户端如何操作MQ比较合适的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文