ActiveMQ在SpringMVC下配置和应用

ActiveMQ下载地址

http://activemq.apache.org/download-archives.html

解压，启动
./bin/activemq start

访问Web控制台

默认用户名和密码：admin:admin
http://192.168.9.10:8161/

设置Web控制台用户名和密码
vim ./conf/users.properties

设置访问端口

默认是61616
vim ./conf/activemq.xml

加入Maven

<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-all</artifactId>
<version>5.9.1</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.26</version>
</dependency>

在Web控制台创建一个队列(Queue)，如myFirstQueue

测试代码：

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.9.10:61616");

try {

Connection conn = connectionFactory.createConnection();
conn.start();

Session session = conn.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
Destination dest = session.createQueue("myFirstQueue");

MessageProducer producer = session.createProducer(dest);

JSONObject json = new JSONObject();
json.put("id", "101");
json.put("name","book");

TextMessage msg = session.createTextMessage(json.toJSONString());
producer.send(msg);

session.commit();
session.close();
conn.close();

}catch(JMSException e) {
e.printStackTrace();
}