俊星的BLOG

導(dǎo)航

<

2011年4月

>

日

一

二

三

四

五

六

27

28

29

30

31

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

1

2

3

4

5

6

7

統(tǒng)計

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

常用鏈接

留言簿(1)

隨筆分類

代碼庫(7) (rss)

隨筆檔案

搜索

閱讀排行榜

評論排行榜

ActiveMQ初探

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

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

3、可通過訪問http://localhost:8161/admin/來查看啟動情況，有可通過netstat -an|find "61616" 來查看端口，因為通過查看activemq.xml中即可發(fā)現(xiàn)傳輸連接器即配置的占用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的控制臺中創(chuàng)建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、編寫消息產(chǎn)生類：

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 {

// 創(chuàng)建一條文本消息

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

producer.send(message);

System.out.println("");

}

6、通過訪問http://localhost:8161/admin/，在queue中創(chuàng)建testqueue，先執(zhí)行消息發(fā)送類，后執(zhí)行消息接收類，借看看到消息接收類的如下執(zhí)行結(jié)果：
收到消息：你好 ActiveMQ！
收到消息：你好 ActiveMQ！

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

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

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