1.什麼是MQ，有什麼用?

MQ 是message queue ,訊息佇列，也叫訊息中介軟體，遵守JMS（java message service）規範的一種軟體。(同時還有另一個叫AMQP的應用層協議，語言無關性不受產品 語言等限制，rabbitMQ支援這個 )

是類似於資料庫一樣需要獨立部署在伺服器上的一種應用，提供介面給其他系統呼叫。

主要用於各個系統之間通訊的解耦。

舉例：

比如登陸系統，在登陸之後需要呼叫簡訊系統給使用者發簡訊說已經登陸，同時還需要呼叫日誌系統記錄登陸日誌，需要呼叫積分系統對登陸簽到的積分進行增加 等等等。

這種情況下，登陸系統和日誌系統，簡訊系統，積分系統等等 強耦合，其中存在可能呼叫失敗，資訊丟失等風險，同時會提高系統複雜度。

比如說登陸之後呼叫日誌系統失敗，那麼該次登陸的日誌資訊就會丟失，無法再找回。

而且順序執行，會導致登陸系統執行效率低。

那麼如果使用訊息中介軟體,登陸之後只需要將任務推入到訊息佇列中，就不用去管了。其他系統則從佇列中去獲取任務。

實現解耦和非同步呼叫 （非同步是相對於同步而言，同步是就等待，當系統執行某個任務的時候，一定要等到該任務結束，系統才會繼續往下執行，非同步則不等待。）

同時還有可以實現橫向拓展 安全可靠優點

2.常見MQ的型別

activeMQ 對java支援良好，缺點是對其他語言支援不夠友好，適合中小企業系統

rabbitMQ 對java支援良好，對其他語言也支援良好，跨平臺，語言無關

kaffka 日誌訊息中介軟體 支援大資料場景

3.JMS規範

MQ實現參照了jms規範，（規範就是一種約定）

該規範中包括

提供者：實現jms規範的中介軟體伺服器

客戶端：傳送或者接受訊息的應用程式

生產者/釋出者:建立併發送訊息的客戶端

消費者/訂閱者:接受並處理訊息的客戶端

訊息：應用程式之間傳遞的內容

訊息模式：在客戶端之間傳遞訊息的方式，jms中定義了主題和佇列兩種模式

主題模式：

假如釋出者釋出了100條訊息，那麼如果有n個訂閱者，每個訂閱者都可以獲取到100條訊息。即訂閱者可以獲取到所有的訊息（但如果訂閱是在主題釋出訊息之後，則獲取不到任何訊息，只能獲取到訂閱時間之後主題的釋出的訊息，比如說A訂閱了B, B釋出了訊息，C再訂閱了B,那麼只有a能夠獲取到訊息，C不能，因為它的訂閱行為發生在B釋出訊息之後）

佇列模式:

假如生產者傳送了100條訊息，如果有n個消費者，那麼每個訂閱者加起來獲取到的訊息總數是100。

沒有時間上限制。只要佇列中有訊息，消費者可以任意時間去取訊息，一個訊息只能被一個消費者消費。

4.jms約定的介面

ConnectionFactory 獲取與MQ服務連線的工廠類

Connection 與MQ服務的連線， 由ConnectionFactory 建立

Session 會MQ服務的會話 由Connection 建立

MessageProducer 訊息生產者，由Session 建立

MessageConsumer 訊息消費者 由Session建立

Message 訊息，由Session建立

Desination 訊息的目的地

5.原生實際程式碼例子

一.原生mq用法 佇列， 建立生產者消費者模式

生產者傳送訊息

------------------------

//1.建立connectionFactory 與mq伺服器進行連線

ConnectionFactory connectionFactory=new

XXMQConnectionFactory(url) ; //XX 為該mq的實現 比如activeMQ rabbitMQ等

// url為伺服器地址 tcp格式 比如 tcp://xxxx:xxx

//2.建立Connection

Connection connection=connectionFactory.createConnection();

//3.啟動連線

connection,start();

//4.建立會話

Session session=connection.createSession(XXX); //xx為該session的建立時候的引數 比如設定事務，模式等等，具體依據不同的實現形式

//5.建立一個目標

Destination destination=session.createQueue(queueName);

//6.建立一個生產者

MessageProducer producer=session.createProducer(destination);

//7.建立訊息

TextMessage textMessage=session.createTextMessage("text");

//8.傳送訊息

producer.send(textMessage);

//9.關閉連線

connection.close();

----------------

消費者獲取訊息

//1.建立connectionFactory 與mq伺服器進行連線

ConnectionFactory connectionFactory=new

XXMQConnectionFactory(url) ; //XX 為該mq的實現 比如activeMQ rabbitMQ等

// url為伺服器地址 tcp格式 比如 tcp://xxxx:xxx

//2.建立Connection

Connection connection=connectionFactory.createConnection();

//3.啟動連線

connection,start();

//4.建立會話

Session session=connection.createSession(XXX); //xx為該session的建立時候的引數 比如設定事務，模式等等，具體依據不同的實現形式

//5.建立一個目標

Destination destination=session.createQueue(queueName);

//6.建立一個消費者

MessageConsumer consumer=session.createConsumer(destination);

//7.建立一個監聽器

consumer.setMessageListener(

new MessageListener(){

public void onMessage(Message message){

TextMessage textMessage=(TextMessage)message;

//8.獲取訊息

textMessage.getText();

}});

//9.關閉連線

connection.close();

二.原生mq用法 主題， 建立釋出者 訂閱者模式

釋出者----

//1.建立connectionFactory 與mq伺服器進行連線

ConnectionFactory connectionFactory=new

XXMQConnectionFactory(url) ; //XX 為該mq的實現 比如activeMQ rabbitMQ等

// url為伺服器地址 tcp格式 比如 tcp://xxxx:xxx

//2.建立Connection

Connection connection=connectionFactory.createConnection();

//3.啟動連線

connection,start();

//4.建立會話

Session session=connection.createSession(XXX); //xx為該session的建立時候的引數 比如設定事務，模式等等，具體依據不同的實現形式

//5.建立一個目標

Destination destination=session.createTopic(topicName);

//6.建立一個生產者

MessageProducer producer=session.createProducer(destination);

//7.建立訊息

TextMessage textMessage=session.createTextMessage("text");

//8.傳送訊息

producer.send(textMessage);

//9.關閉連線

connection.close();

---訂閱者

//1.建立connectionFactory 與mq伺服器進行連線

ConnectionFactory connectionFactory=new

XXMQConnectionFactory(url) ; //XX 為該mq的實現 比如activeMQ rabbitMQ等

// url為伺服器地址 tcp格式 比如 tcp://xxxx:xxx

//2.建立Connection

Connection connection=connectionFactory.createConnection();

//3.啟動連線

connection,start();

//4.建立會話

Session session=connection.createSession(XXX); //xx為該session的建立時候的引數 比如設定事務，模式等等，具體依據不同的實現形式

//5.建立一個目標

Destination destination=session.createTopic(topicName);

//6.建立一個消費者

MessageConsumer consumer=session.createConsumer(destination);

//7.建立一個監聽器

consumer.setMessageListener(

new MessageListener(){

public void onMessage(Message message){

TextMessage textMessage=(TextMessage)message;

//8.獲取訊息

textMessage.getText();

}});

//9.關閉連線

connection.close();

6.spring整合下的程式碼例子

ConnectionFactory用於管理連線的連線工廠 這個是

spring提供地連線池，spring提供了SingleConnectionFactory和

CachingConnectionFactory

JmsTemplate用於傳送和接受訊息的模板類，spring提供的 只要注入這個bean，既可以

用jmsTempalate方便的操作jms 不需要像之前那樣寫一堆重複程式碼

這個是執行緒安全的

MessageListerner 訊息監聽器，實現了一個onMessage方法，該方法只接收一個Message引數

傳送訊息的方法

@Autowired

JmsTemplate jmsTemplate;

@Autowired

Destination destination;

jmsTemplate.send(destination,new MessgaeCreator(){

public Message createMessage(Session session) {

TextMessage textMessage=session.createTextMessage("message");

return textMessage;

}});

JmsTemplate實際上就是做了一層封裝而已 簡化了用法 ，可以參考裡面的原始碼