問(wèn)題描述

我有500個(gè)子應(yīng)用分別部署在500臺(tái)不同的服務(wù)器上，還有一個(gè)主應(yīng)用，現(xiàn)在有一個(gè)MQ。 我主應(yīng)用會(huì)給子應(yīng)用發(fā)消息。 子應(yīng)用上有很多功能，都需要用到不同的消息。

我是在子應(yīng)用開一個(gè)consumer好，還是為子應(yīng)用的每一個(gè)功能都開一個(gè)consumer好。

我目前打算是這樣，每個(gè)子應(yīng)用，只開一個(gè)consumer，然后在發(fā)送的消息里面定義，具體要操作的方法。格式如下：

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

當(dāng)子應(yīng)用拿到消息后，根據(jù)action來(lái)決定調(diào)用哪個(gè)方法。 然后body就是需要處理的業(yè)務(wù)數(shù)據(jù)。

問(wèn)題解答

你這種情況屬于用MQ做松耦合的RPC調(diào)用。 我不知道你的mq選型是什么。就按照我熟悉的kafka來(lái)說(shuō)吧，可以使用一個(gè)topic，然后單臺(tái)機(jī)器配置單個(gè)消費(fèi)組，然后消息就按照RPC的那種去寫，基本可以做到不重不丟，且服務(wù)上下游解耦