亚洲&

ActiveMQ入門(轉)

1、環境：

Windows XP

apache-activemq-5.2.0-bin.zip

2、安裝

解壓縮到apache-activemq-5.2.0-bin.zip到一個目錄，比如C:\apache-activemq-5.2.0

3、配置

配置就在C:\apache-activemq-5.2.0\conf目錄下三個文件

activemq.xml

credentials.properties

log4j.properties

4、啟動ActiveMQ

運行C:\apache-activemq-5.2.0\bin\activemq.bat

5、測試

ActiveMQ默認使用的TCP連接端口是61616, 通過查看該端口的信息可以測試ActiveMQ是否成功啟動 netstat -an|find "61616"

C:\Documents and Settings\Administrator>netstat -an|find "61616"
TCP 0.0.0.0:61616 0.0.0.0:0 LISTENING

6、監控

ActiveMQ5.0版本默認啟動時，啟動了內置的jetty服務器，提供一個demo應用和用于監控ActiveMQ的admin應用。
admin：http://127.0.0.1:8161/admin/
demo：http://127.0.0.1:8161/demo/

下面是ActiveMQ5.2的一個最簡單例子！

環境還是apache-activemq-5.2.0-bin.zip，需要注意的是，開發時候，要將apache-activemq- 5.2.0-bin.zip解壓縮后里面的activemq-all-5.2.0.jar包加入到classpath下面，這個包包含了所有jms接口 api的實現。

Java代碼

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
* 消息的生產者（發送者）
*
*/
public class JmsSender {
public static void main(String[] args) throws JMSException {
// ConnectionFactory ：連接工廠，JMS 用它創建連接
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://192.168.14.117:61616");
//JMS 客戶端到JMS Provider 的連接
Connection connection = connectionFactory.createConnection();
connection.start();
// Session：一個發送或接收消息的線程
Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
// Destination ：消息的目的地;消息發送給誰.
// 獲取session注意參數值my-queue是Query的名字
Destination destination = session.createQueue("my-queue");
// MessageProducer：消息生產者
MessageProducer producer = session.createProducer(destination);
//設置不持久化
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
//發送一條消息
sendMsg(session, producer);
session.commit();
connection.close();
}
/**
* 在指定的會話上，通過指定的消息生產者發出一條消息
*
* @param session 消息會話
* @param producer 消息生產者
*/
public static void sendMsg(Session session, MessageProducer producer) throws JMSException {
//創建一條文本消息
TextMessage message = session.createTextMessage("Hello ActiveMQ！");
//通過消息生產者發出消息
producer.send(message);
System.out.println("");
}
}

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
* 消息的生產者（發送者）
*
*/
public class JmsSender {
public static void main(String[] args) throws JMSException {
// ConnectionFactory ：連接工廠，JMS 用它創建連接
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://192.168.14.117:61616");
//JMS 客戶端到JMS Provider 的連接
Connection connection = connectionFactory.createConnection();
connection.start();
// Session： 一個發送或接收消息的線程
Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
// Destination ：消息的目的地;消息發送給誰.
// 獲取session注意參數值my-queue是Query的名字
Destination destination = session.createQueue("my-queue");
// MessageProducer：消息生產者
MessageProducer producer = session.createProducer(destination);
//設置不持久化
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
//發送一條消息
sendMsg(session, producer);
session.commit();
connection.close();
}
/**
* 在指定的會話上，通過指定的消息生產者發出一條消息
*
* @param session    消息會話
* @param producer 消息生產者
*/
public static void sendMsg(Session session, MessageProducer producer) throws JMSException {
//創建一條文本消息
TextMessage message = session.createTextMessage("Hello ActiveMQ！");
//通過消息生產者發出消息
producer.send(message);
System.out.println("");
}
}

Java代碼

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
* 消息的消費者（接受者）
*
*/
public class JmsReceiver {
public static void main(String[] args) throws JMSException {
// ConnectionFactory ：連接工廠，JMS 用它創建連接
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://192.168.14.117:61616");
//JMS 客戶端到JMS Provider 的連接
Connection connection = connectionFactory.createConnection();
connection.start();
// Session：一個發送或接收消息的線程
Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
// Destination ：消息的目的地;消息發送給誰.
// 獲取session注意參數值xingbo.xu-queue是一個服務器的queue，須在在ActiveMq的console配置
Destination destination = session.createQueue("my-queue");
// 消費者，消息接收者
MessageConsumer consumer = session.createConsumer(destination);
while (true) {
TextMessage message = (TextMessage) consumer.receive(1000);
if (null != message)
System.out.println("收到消息：" + message.getText());
else
break;
}
session.close();
connection.close();
}
}

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
* 消息的消費者（接受者）
*
*/
public class JmsReceiver {
public static void main(String[] args) throws JMSException {
// ConnectionFactory ：連接工廠，JMS 用它創建連接
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://192.168.14.117:61616");
//JMS 客戶端到JMS Provider 的連接
Connection connection = connectionFactory.createConnection();
connection.start();
// Session： 一個發送或接收消息的線程
Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
// Destination ：消息的目的地;消息發送給誰.
// 獲取session注意參數值xingbo.xu-queue是一個服務器的queue，須在在ActiveMq的console配置
Destination destination = session.createQueue("my-queue");
// 消費者，消息接收者
MessageConsumer consumer = session.createConsumer(destination);
while (true) {
TextMessage message = (TextMessage) consumer.receive(1000);
if (null != message)
System.out.println("收到消息：" + message.getText());
else
break;
}
session.close();
connection.close();
}
}

啟動ActiveMQ，然后開始執行：

先運行發送者，連續運行了三次，最后一次控制臺輸出：

Process finished with exit code 0

后運行接受者，輸出結果：

收到消息Hello ActiveMQ！
收到消息Hello ActiveMQ！
收到消息Hello ActiveMQ！

Process finished with exit code 0

注意：

其中的端口61616是ActiveMQ默認的配置，在activemq.xml中，

Xml代碼

<transportConnectors>
<transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>
<transportConnector name="ssl" uri="ssl://localhost:61617"/>
<transportConnector name="stomp" uri="stomp://localhost:61613"/>
<transportConnector name="xmpp" uri="xmpp://localhost:61222"/>
</transportConnectors>

   <!-- The transport connectors ActiveMQ will listen to -->
<transportConnectors>
<transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>
<transportConnector name="ssl" uri="ssl://localhost:61617"/>
<transportConnector name="stomp" uri="stomp://localhost:61613"/>
<transportConnector name="xmpp" uri="xmpp://localhost:61222"/>
</transportConnectors>

，建議不要改動，都用這個端口多好，就像ftp都用21端口，也沒錯。

這是官方的HelloWorld例子，不過看著不順眼：

http://activemq.apache.org/hello-world.html

posted on 2009-09-16 13:00 大鳥閱讀(1305) 評論(0) 編輯收藏所屬分類: JAVA

常用鏈接

留言簿(1)

隨筆分類

隨筆檔案

文章分類

文章檔案

相冊

我的收藏

搜索

最新評論

閱讀排行榜

評論排行榜


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: （轉）關于Spring中ApplicationContext的說明 JavaGUI應用程序部署優秀程序員的十個習慣 DOM 解析XML jboss 4.2.2 只能localhost訪問不能通過ip訪問解決 ActiveMQ入門(轉) JBoss和JMS(寫的不錯，抄來看看) java concurrent 探秘（2） java concurrent 探秘（1） Java 線程池的原理與實現