摘要：消息隊(duì)列帶來的問題系統(tǒng)可用性降低系統(tǒng)引入的外部依賴越多，系統(tǒng)越容易出問題。系統(tǒng)復(fù)雜性提高加入消息隊(duì)列后，需要保證消息沒有被重復(fù)消費(fèi)，保證消息傳遞的順序性等等。

消費(fèi)者執(zhí)行過程比較長且生產(chǎn)者不需要消費(fèi)者返回結(jié)果。用于更新索引庫，生成商品詳情頁，發(fā)短信。

通過異步處理提高系統(tǒng)性能（削峰、減少響應(yīng)所需時(shí)間）;

降低系統(tǒng)耦合性。

削鋒作用：通過異步處理，將短時(shí)間高并發(fā)產(chǎn)生的事務(wù)消息存儲(chǔ)在消息隊(duì)列中，從而削平高峰期的并發(fā)事務(wù)。

系統(tǒng)可用性降低：系統(tǒng)引入的外部依賴越多，系統(tǒng)越容易出問題。如果MQ出問題，整套系統(tǒng)更容易崩潰。

系統(tǒng)復(fù)雜性提高：加入消息隊(duì)列后，需要保證消息沒有被重復(fù)消費(fèi)，保證消息傳遞的順序性等等。

一致性問題：消息沒有被真正消費(fèi)者正確消費(fèi)，會(huì)導(dǎo)致數(shù)據(jù)不一致的情況。

JMS：Java Message Service，是一個(gè)消息服務(wù)的標(biāo)準(zhǔn)和規(guī)范，允許應(yīng)用程序組件基于JaveEE平臺(tái)創(chuàng)建、發(fā)送、接收和讀取消息。

點(diǎn)到點(diǎn)模型（P2P）：

使用隊(duì)列作為消息通信載體，一條消息只能被一個(gè)消費(fèi)者使用，未消費(fèi)的消息在隊(duì)列中保留直到被消費(fèi)或者超時(shí)。

發(fā)布/訂閱模型（Pub/Sub）：

發(fā)布者發(fā)布一條信息，通過主題傳遞給所有的訂閱者，在一條消息廣播后才訂閱的用戶收不到該條消息。

StreamMessage——Java原始值的數(shù)據(jù)流

MapMessage——一套鍵值對(duì)

TextMessage——一個(gè)字符串對(duì)象

ObjectMessage——一個(gè)序列化的Java對(duì)象

BytesMessage——一個(gè)字節(jié)的數(shù)據(jù)流

AMQP：Advanced Message Queuing Protocol，一個(gè)提供統(tǒng)一消息服務(wù)的應(yīng)用層標(biāo)準(zhǔn)高級(jí)消息隊(duì)列協(xié)議（二進(jìn)制應(yīng)用層協(xié)議）。

以 RabbitMQ 為例子講解第一種 MQ 的高可用性怎么實(shí)現(xiàn)。

RabbitMQ 有三種模式：單機(jī)模式、普通集群模式、鏡像集群模式。

單機(jī)模式，就是 Demo 級(jí)別的，一般就是你本地啟動(dòng)了玩玩兒的，沒人生產(chǎn)用單機(jī)模式。

普通集群模式，無高可用性，在多臺(tái)機(jī)器上啟動(dòng)多個(gè) RabbitMQ 實(shí)例，每個(gè)機(jī)器啟動(dòng)一個(gè)。你創(chuàng)建的 queue，只會(huì)放在一個(gè) RabbitMQ 實(shí)例上，沒做到所謂的分布式，就是個(gè)普通集群。因?yàn)檫@導(dǎo)致你要么消費(fèi)者每次隨機(jī)連接一個(gè)實(shí)例然后拉取數(shù)據(jù)，要么固定連接那個(gè) queue 所在實(shí)例消費(fèi)數(shù)據(jù)，前者有數(shù)據(jù)拉取的開銷，后者導(dǎo)致單實(shí)例性能瓶頸。這個(gè)方案提高了吞吐量，但沒有高可用性。

鏡像集群模式，有高可用性，queue里的消息會(huì)存在于多個(gè)實(shí)例上，每個(gè)RabbitMQ節(jié)點(diǎn)都有這個(gè)queue的一個(gè)完整鏡像，包含queue的全部數(shù)據(jù)。該模式的缺點(diǎn)：性能開銷過大，帶寬壓力和消耗很重；不是分布式的，沒有擴(kuò)展性。

Kafka的高可用性：由多個(gè)broker組成，每個(gè)broker是一個(gè)節(jié)點(diǎn)；你創(chuàng)建的一個(gè)topic會(huì)被劃分為多個(gè)partition，每個(gè)partition存儲(chǔ)于不同的broker上，每個(gè)partition包含部分topic的數(shù)據(jù)，是一個(gè)天然的分布式消息隊(duì)列。

Kafka 0.8 以后，提供了 HA 機(jī)制，就是 replica（復(fù)制品） 副本機(jī)制。

每個(gè) partition 的數(shù)據(jù)都會(huì)同步到其它機(jī)器上，形成自己的多個(gè) replica 副本。

所有 replica 會(huì)選舉一個(gè) leader 出來，那么生產(chǎn)和消費(fèi)都跟這個(gè) leader 打交道，然后其他 replica 就是 follower。

這么搞，就有所謂的高可用性了，因?yàn)槿绻硞€(gè) broker 宕機(jī)了，沒事兒，那個(gè) broker上面的 partition 在其他機(jī)器上都有副本的，如果這上面有某個(gè) partition 的 leader，那么此時(shí)會(huì)從 follower 中重新選舉一個(gè)新的 leader 出來，大家繼續(xù)讀寫那個(gè)新的 leader 即可。

ack消息延遲：

如果寫入了 RabbitMQ 中，RabbitMQ 會(huì)給你回傳一個(gè) ack 消息，告訴你說這個(gè)消息 ok 了。→

持久化可以跟生產(chǎn)者那邊的 confirm 機(jī)制配合起來，只有消息被持久化到磁盤之后，才會(huì)通知生產(chǎn)者 ack 了。→

關(guān)閉 RabbitMQ 的自動(dòng) ack，可以通過一個(gè) api 來調(diào)用就行，然后每次確保消費(fèi)端處理完數(shù)據(jù)的時(shí)候，再在程序里 ack 一把。

各類MQ對(duì)比

代碼

    org.springframework
    spring-jms

//生產(chǎn)者
@Autowired
private JmsTemplate jmsTemplate;
@Autowired
private Destination queueSolrDestination;
@Autowired
private Destination topicPageDestination;
//更新索引庫
jmsTemplate.send(queueSolrDestination, new MessageCreator() {
    @Override
    public Message createMessage(Session session) throws JMSException {
        return session.createTextMessage(jsonString);
    }
});
//生成商品詳情頁
jmsTemplate.send(topicPageDestination, new MessageCreator() {
    @Override
    public Message createMessage(Session session) throws JMSException {
        return session.createTextMessage(id + "");
    }
});

//消費(fèi)者（監(jiān)聽）
@Component
public class PageListener implements MessageListener{
    @Autowired
    private ItemPageService itemPageService;
    @Override
    public void onMessage(Message message) {
        TextMessage textMessage = (TextMessage) message;
        try {
            String text = textMessage.getText();
            System.out.println("接收到消息：" + text);
            boolean b = itemPageService.genItemHtml(Long.parseLong(text));
            System.out.println("網(wǎng)頁生成結(jié)果：" + b);
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

?