題目

題目內(nèi)容

實現(xiàn)一個基于發(fā)布/訂閱模型的消息中間件，功能要求如下：

1. broker保證消息落盤后才向producer返回發(fā)送成功的ack，并把消息推送給consumer；
2. consumer消費成功或失敗都返回ack給broker；
3. consumer消費失敗、消費超時、不在線時，消息不能丟失，需要盡快重新推送，且consumer正常后可以及時消費完堆積的消息；
4. 采用push模式把消息推送給consumer；
5. 支持簡單過濾功能，即broker只推送符合訂閱條件的消息給consumer；
6. broker宕機重啟后，保證消息不能丟失；
7. 支持consumer group，即consumer群組訂閱了某topic，該topic的消息發(fā)送給其中任意一臺機器都可以；

考核方式

性能指標：
每秒消息接收量，每秒消息投遞量，消息投遞延遲；
測試場景：

• 4k消息，一個producer發(fā)布topicA，一個consumer訂閱topicA，consumer能正常消費所有消息，且無堆積；
• 4k消息，一個producer發(fā)布topicA，二十個consumer訂閱topicA，consumer能正常消費所有消息，且無堆積；
• 4k消息，一個producer發(fā)布topicA，一個consumer訂閱topicA，consumer消費超時，有大量堆積；
• 4k消息，一個producer發(fā)布topicA，二十個consumer訂閱topicA，只有一個consumer能正常消費，其它消費者消費超時、失敗、不在線，有大量堆積；
• 4k消息，二十個producer發(fā)布20個不同的topic，每個topic有二十個consumer，且每個consumer訂閱不同屬性值的消息，都正常消費，且無堆積；
• 4k消息，二十個producer發(fā)布20個不同的topic，每個topic有二十個consumer，且每個consumer訂閱不同屬性值的消息，所有消費均超時，有大量堆積。堆積一段時間后，減少90%的發(fā)送量，且消費者恢復正常，broker盡可能把堆積的消息推送出去；