俊星的BLOG

統計

隨筆 - 50
文章 - 0
評論 - 6
引用 - 0

常用鏈接

留言簿(1)

隨筆分類

代碼庫(7) (rss)

隨筆檔案

搜索

閱讀排行榜

評論排行榜

ActiveMQ初探

Apache ActiveMQ是一個高性能的消息代理，實現了JMS 1.1。
目前的最新版本是5.4.1
1、下載相關包，并將activemq-all-5.4.1.jar加入到工程中。

2、運行bin目錄下的actionmq.bat文件，啟動broker，在conf下是相關的配置文件，例如activemq.xml

3、可通過訪問http://localhost:8161/admin/來查看啟動情況，有可通過netstat -an|find "61616" 來查看端口，因為通過查看activemq.xml中即可發現傳輸連接器即配置的占用61616端口：
<transportConnectors>
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
</transportConnectors>

4、編寫消息接收類：

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.MessageConsumer;

import javax.jms.Session;

import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnection;

import org.apache.activemq.ActiveMQConnectionFactory;

public class JmsReceiver {

public static void main(String[] args) throws JMSException {

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,

ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");

Connection connection = connectionFactory.createConnection();

connection.start();

Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);

// 需要在activemq的控制臺中創建queue：testqueue

Destination destination = session.createQueue("testqueue");

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();

}

5、編寫消息產生類：

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.DeliveryMode;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.MessageProducer;

import javax.jms.Session;

import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnection;

import org.apache.activemq.ActiveMQConnectionFactory;

public class JmsSender {

public static void main(String[] args) throws JMSException {

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,

ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");

Connection connection = connectionFactory.createConnection();

connection.start();

Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);

Destination destination = session.createQueue("testqueue");

MessageProducer producer = session.createProducer(destination);

producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

sendMsg(session, producer);

session.commit();

connection.close();

}

public static void sendMsg(Session session, MessageProducer producer) throws JMSException {

// 創建一條文本消息

TextMessage message = session.createTextMessage("你好 ActiveMQ！");

producer.send(message);

System.out.println("");

}

6、通過訪問http://localhost:8161/admin/，在queue中創建testqueue，先執行消息發送類，后執行消息接收類，借看看到消息接收類的如下執行結果：
收到消息：你好 ActiveMQ！
收到消息：你好 ActiveMQ！

（執行多次消息發送類，則會接受到多條“你好 ActiveMQ!”消息）

posted on 2010-10-28 17:53 俊星閱讀(2910) 評論(1) 編輯收藏

# re: ActiveMQ初探 2011-04-21 16:10 71569973