1. 消費者組到底是個什么概念
消費者組的意思就是讓你給一組消費者起一個名字,比如有一個Topic叫“TopicOrderPaySuccess”,然后假設有庫存系統、積分系統、營銷系統、倉儲系統他們都要去消費這個Topic中的數據。
此時我們應該給這四個系統分別起一個消費組的名字,比如stock_consumer_group、marketing_consumer_group、credie_consumer_group、wms_consumer_group。
設置消費者組的方式是在代碼里面進行設置的,類似下面:
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("stock_consumer_group");
然后比如庫存系統部署了4臺機器,每臺機器上的消費者組的名字都是stock_consumer_group,那么這4臺機器就同屬于一個消費者組,以此類推,每個系統的幾臺機器都是屬于各自的消費者組的。
假設庫存系統和營銷系統做為兩個消費者組,都訂閱了TopicOrderPaySuccess這個訂單支付成功消息的Topic