ActiveMQ訊息中介軟體入門學習
同步通訊：客戶端向伺服器端發出請求，並一直等待伺服器端的響應。直到獲取到伺服器端返回的響應資訊，客戶端才能繼續執行。
MQ全稱為Message Queue, 訊息佇列（MQ）是一種應用程式對應用程式的通訊方法。應用程式通過讀寫出入佇列的訊息（針對應用程式的資料）來通訊，而無需專用連線來連結它們。訊息傳遞指的是程式之間通過在訊息中傳送資料進行通訊，而不是通過直接呼叫彼此來通訊，直接呼叫通常是用於諸如遠端過程呼叫的技術。
MOM訊息中介軟體：訊息傳送端將訊息傳送給訊息伺服器，訊息伺服器將訊息存放在若干個佇列中，在合適的時候再將訊息轉發給訊息接收端。在這種模式下，傳送訊息和接收訊息是一個非同步的過程，訊息傳送端和訊息接收端不一定同時執行，訊息傳送端在傳送完訊息後也無需繼續等待訊息接收端的響應資訊，而可以繼續做其它事情。
Java提供JMS規範，即定義了Java訪問訊息中介軟體的介面，它並沒有提供介面的實現。目前，有很多的JMS Provider提供了這些介面的實現，包括Apache的ActiveMQ、阿里巴巴的RocketMQ、Pivotal的RabbitMQ。
JMS中相關術語：
Provider:訊息生產者
Customer：訊息消費者
Publish/Subscribe:訊息的釋出訂閱模式
Queue：訊息對列
Topic：訊息主題
ConnectionFactory：連線工廠，用於建立連線
Connection：訊息生產者或消費者到JMS Provider的連線
Destination：訊息的目的地
Session：會話，一個傳送或接收訊息的執行緒
訊息格式定義：
StreamMessage：資料流
MapMessage：名稱-值對
TextMessage：字串物件
ObjectMessage：序列化的Java物件
BytesMessage：位元組資料流
在ActiveMQ的官網下載最新版本的軟體包
ActiveMQ的配置檔案、jetty容器的配置檔案
ActiveMQ軟體包中一個比較全的jar包
webapps包含可以部署到jetty中的admin管控臺程式
在bin目錄下通過bat檔案啟動ActiveMQ
檢視jetty.xml中的埠號
啟動完成後，使用瀏覽器訪問
訊息生產者Producer
-
package com.cb;
-
-
import javax.jms.Connection;
-
import javax.jms.ConnectionFactory;
-
import javax.jms.DeliveryMode;
-
import javax.jms.Destination;
-
import javax.jms.MessageProducer;
-
import javax.jms.Session;
-
import javax.jms.TextMessage;
-
import org.apache.activemq.ActiveMQConnectionFactory;
-
-
public
class Producer {
-
public static void main(String[] args) throws Exception{
-
//1.建立ConnectionFactory物件
-
ConnectionFactory connectionFactory=
new ActiveMQConnectionFactory(
-
ActiveMQConnectionFactory.DEFAULT_USER,
-
ActiveMQConnectionFactory.DEFAULT_PASSWORD,
-
"tcp://localhost:61616");
-
//2.建立一個Connection並開啟
-
Connection connection=connectionFactory.createConnection();
-
connection.start();
-
//3.建立Session會話，用來接收訊息，通過引數可以設定：是否啟用事務、訊息簽收模式
-
Session session=connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
-
//4.建立Destination物件。在點對點模式中，該物件被稱為Queue；在釋出訂閱模式中，該物件被稱為Topic
-
Destination destination=session.createQueue(
"queue1");
-
//5.建立訊息的生產者
-
MessageProducer messageProducer=session.createProducer(destination);
-
//6.設定生產者的訊息持久化與非持久化特性
-
messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
-
//7.選擇需要的JMS訊息格式，建立併發送訊息，此處選擇的是TextMessage字串物件
-
TextMessage textMessage=session.createTextMessage();
-
textMessage.setText(
"生產者"+
"activemq訊息測試");
-
messageProducer.send(textMessage);
-
//8.釋放Connection
-
if(
null!=connection){
-
connection.close();
-
}
-
-
}
-
}
執行上述程式碼，檢視控制檯
點選佇列名稱，檢視詳情
此時，生產者傳送訊息到訊息中介軟體ActiveMQ中了。
訊息消費者Consumer
-
package com.cb;
-
-
import javax.jms.Connection;
-
import javax.jms.ConnectionFactory;
-
import javax.jms.Destination;
-
import javax.jms.MessageConsumer;
-
import javax.jms.Session;
-
import javax.jms.TextMessage;
-
import org.apache.activemq.ActiveMQConnectionFactory;
-
-
public
class Consumer {
-
public static void main(String[] args) throws Exception{
-
//1.建立ConnectionFactory物件
-
ConnectionFactory connectionFactory=
new ActiveMQConnectionFactory(
-
ActiveMQConnectionFactory.DEFAULT_USER,
-
ActiveMQConnectionFactory.DEFAULT_PASSWORD,
-
"tcp://localhost:61616");
-
//2.建立一個Connection並開啟
-
Connection connection=connectionFactory.createConnection();
-
connection.start();
-
//3.建立Session會話，用來接收訊息，通過引數可以設定：是否啟用事務、訊息簽收模式
-
Session session=connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
-
//4.建立Destination物件。在點對點模式中，該物件被稱為Queue；在釋出訂閱模式中，該物件被稱為Topic
-
Destination destination=session.createQueue(
"queue1");
-
//5.建立訊息的消費者
-
MessageConsumer messageConsumer=session.createConsumer(destination);
-
//6.消費者從訊息中介軟體的Queue獲取訊息
-
while(
true){
-
TextMessage textMessage=(TextMessage) messageConsumer.receive();
-
if(
null==textMessage){
-
break;
-
}
-
System.out.println(
"消費者接收到的內容："+textMessage.getText());
-
}
-
//7.釋放Connection
-
if(
null!=connection){
-
connection.close();
-
}
-
-
}
-
}
執行上面消費訊息的程式碼，並檢視控制檯
此時，點選queue1檢視佇列中訊息，發現為空，因為訊息已經被消費了
在Eclipse的Console中結果如下圖：
在activemq.xml中可以設定安全驗證，只有驗證通過的使用者才可以向ActiveMQ訊息中介軟體中傳送、獲取訊息。
-
<plugins>
-
<simpleAuthenticationPlugin>
-
<users>
-
<authenticationUser username="cb" password="123456" groups="users,admins"/>
-
</users>
-
</simpleAuthenticationPlugin>
-
</plugins>
同時修改Producer、Customer第1步中的使用者名稱和密碼
