亚洲AV综合色区无码一二三区 ,亚洲国产综合专区电影在线,亚洲日韩中文字幕日韩在线

ActiveMQ初探

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

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

3、可通過訪問http://localhost:8161/admin/來查看啟動(dòng)情況，有可通過netstat -an|find "61616" 來查看端口，因?yàn)橥ㄟ^查看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的控制臺(tái)中創(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ā)送類，則會(huì)接受到多條“你好 ActiveMQ!”消息）

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

評(píng)論

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

測試通過。多謝回復(fù) 更多評(píng)論

新用戶注冊刷新評(píng)論列表


只有注冊用戶登錄后才能發(fā)表評(píng)論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問管理

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

俊星的BLOG

導(dǎo)航

統(tǒng)計(jì)

常用鏈接

留言簿(1)

隨筆分類

隨筆檔案

最新隨筆

搜索

最新評(píng)論

閱讀排行榜

評(píng)論排行榜

ActiveMQ初探

評(píng)論