一、ActiveMQ安装与配置
1、安装文件:apache-activemq-5.2.0-bin.zip
2、安装过程:解压缩到apache-activemq-5.2.0-bin.zip到一个目录,比如C:\apache-activemq-5.2.0
3、ActiveMQ配置文件在C:\apache-activemq-5.2.0\conf\activemq.xml,采用默认的配置就可以运行了,多台做集群时可以修改该文件。
4、启动ActiveMQ:运行C:\apache-activemq-5.2.0\bin\activemq.bat
5、测试
ActiveMQ默认使用的TCP连接端口是61616, 通过查看该端口的信息可以测试ActiveMQ是否进入DOS: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/
二、测试ActiveMQ的一个简单例子
1.新建一个工程,将apache-activemq-5.2.0-bin.zip解压缩后里面的activemq-all-5.2.0.jar包加入到classpath下面,这个包包含了所有jms接口api的实现。
JMS消息的发送类JmsSender.java,代码如下:
package com.jms;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
*
* @author Wind
*
*/
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.1.27: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("");
}
}
JMS的消息接收类JmsReceiver.java
package com.jms;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
*
* @author Wind
*
*/
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.1.27: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();
}
}
3.启动ActiveMQ,先运行发送者JmsSender,然后运行JmsReceiver,控制台输出如下:
收到消息Hello ActiveMQ!
4.成功了,没什么问题,晚上再去整合下Spring+JMS的例子。
附:
1.activemq官方也有个HelloWorld例子,http://activemq.apache.org/hello-world.html
2.附件导入activemq-all-5.2.0.jar后才可以直接运行。
分享到:
相关推荐
消息中间件和JMS消息服务.pdf消息中间件和JMS消息服务.pdf消息中间件和JMS消息服务.pdf消息中间件和JMS消息服务.pdf消息中间件和JMS消息服务.pdf消息中间件和JMS消息服务.pdf消息中间件和JMS消息服务.pdf
本例详细介绍了如何配置JMS服务以及weblogic的安装及在weblogic中配置JMS服务,例子简单易懂,文档含代码,适合初学者学习使用
利用soapUI3.5测试JMS消息 利用soapUI3.5测试JMS消息
消息中间件和JMS消息服务.rar 消息中间件和JMS消息服务.rar
was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置was jms配置...
Spring发送接收JMS消息 文档+例子
本教程描述了消息服务的概念和一些应用事例,说明了 JMS 的基本概念和结构,并就消息服务的发布/订阅、点对点模式编写了简单代码,最后讨论的JMS的一些高级问题,如食物、可靠性、可恢复性等。
关于JMS的消息服务的代码,包括PTP和Pub/Sub,简单通俗 易懂。
描述了weblogic jms服务器的配置
JMS 简介以及Weblogic配置JMS图解
weblogic中使用JMS发送和接受消息(Queue and TOPIC)
关于java的jms的一个小例子,对jms使用的应用。。。
JMS简明教程+JMS规范教程+activemq以及activemq和tomcat的整合+整合实例代码+持久化消息配置以及工程+tomcat服务器的配置+整合需要的lib文件+部署多个tomcat服务器方案等
NULL 博文链接:https://1028826685.iteye.com/blog/1504038
JMS消息模型…………………………………………………………………………………..7 JMS消息工具…………………………………………………………………………………..10 JMS Point-To-Point模式…………………………...
什么是消息服务 为什么使用消息服务 什么是JMS(Java Message Service) JMS的通信方式 JMS应用程序开发步骤 JMS应用程序开发实践 其他的JMS特性
复件 weblogic中配置JMS及其测试程序
JMS消息队列机制及众多各种各样的案例,可供学习与参考。