多客户端如何操作MQ比较合适

Question

我有500个子应用分别部署在500台不同的服务器上，还有一个主应用，现在有一个MQ。 我主应用会给子应用发消息。 子应用上有很多功能，都需要用到不同的消息。

我是在子应用开一个consumer好，还是为子应用的每一个功能都开一个consumer好。

我目前打算是这样，每个子应用，只开一个consumer，然后在发送的消息里面定义，具体要操作的方法。格式如下：

{
    "header": {
        "action": "scan_address"
    },
    "body": {
            "id": 1234,
            "name": "xxxxxx"
    }
}

当子应用拿到消息后，根据action来决定调用哪个方法。 然后body就是需要处理的业务数据。

Answer 1

你这种情况属于用MQ做松耦合的RPC调用。 我不知道你的mq选型是什么。就按照我熟悉的kafka来说吧，可以使用一个topic，然后单台机器配置单个消费组，然后消息就按照RPC的那种去写，基本可以做到不重不丢，且服务上下游解耦

Answer 2

要深入学习Kafka的话，推荐《Apache Kafka源码剖析》这本书