問題描述

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

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

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

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

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

問題解答

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