java消息中间件：ActiveMQ

From：http://baike.baidu.com/view/433374.htm

ActiveMQ

ActiveMQ 是Apache出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。

 

ActiveMQ特性列表

1. 多种语言和协议编写客户端。语言: Java, C, C++, C#, Ruby, Perl, Python, PHP。应用协议: OpenWire,Stomp REST,WS Notification,XMPP,AMQP
　　2. 完全支持JMS1.1和J2EE 1.4规范 (持久化,XA消息,事务)
　　3. 对Spring的支持,ActiveMQ可以很容易内嵌到使用Spring的系统里面去,而且也支持Spring2.0的特性
　　4. 通过了常见J2EE服务器(如 Geronimo,JBoss 4, GlassFish,WebLogic)的测试,其中通过JCA 1.5 resource adaptors的配置,可以让ActiveMQ可以自动的部署到任何兼容J2EE 1.4 商业服务器上
　　5. 支持多种传送协议:in-VM,TCP,SSL,NIO,UDP,JGroups,JXTA
　　6. 支持通过JDBC和journal提供高速的消息持久化
　　7. 从设计上保证了高性能的集群,客户端-服务器,点对点
　　8. 支持Ajax
　　9. 支持与Axis的整合
　　10. 可以很容易得调用内嵌JMS provider,进行测试

评论

4 楼 zhongaili520 2011-05-14  

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Exception in thread "main" java.lang.NoClassDefFoundError: org/slf4j/impl/StaticLoggerBinder
at org.slf4j.LoggerFactory.getSingleton(LoggerFactory.java:230)
at org.slf4j.LoggerFactory.bind(LoggerFactory.java:121)
at org.slf4j.LoggerFactory.performInitialization(LoggerFactory.java:112)
at org.slf4j.LoggerFactory.getILoggerFactory(LoggerFactory.java:275)
at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:248)
at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:261)
at org.apache.activemq.ActiveMQConnection.<clinit>(ActiveMQConnection.java:109)
at JmsSender.main(JmsSender.java:14)
Caused by: java.lang.ClassNotFoundException: org.slf4j.impl.StaticLoggerBinder
at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:248)
... 8 more


运行报错啊

3 楼 liudaoru 2010-02-24  

Hello ActiveMQ！

From：http://lavasoft.blog.51cto.com/62575/190815

下面是ActiveMQ5.2的一个最简单例子！
环境还是apache-activemq-5.2.0-bin.zip，需要注意的是，开发时候，要将apache-activemq-5.2.0-bin.zip解压缩后里面的activemq-all-5.2.0.jar包加入到classpath下面，这个包包含了所有jms接口api的实现。


import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
* 消息的生产者（发送者）
*
* @author leizhimin 2009-8-12 11:41:20
*/
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.14.117: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("");
        }
}

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
* 消息的消费者（接受者）
*
* @author leizhimin 2009-8-12 11:41:33
*/
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.14.117: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();
        }
}


启动ActiveMQ，然后开始执行：
先运行发送者，连续运行了三次，最后一次控制台输出：


Process finished with exit code 0

后运行接受者，输出结果：
收到消息Hello ActiveMQ！
收到消息Hello ActiveMQ！
收到消息Hello ActiveMQ！

Process finished with exit code 0

注意：
其中的端口61616是ActiveMQ默认的配置，在activemq.xml中，
                <!-- The transport connectors ActiveMQ will listen to -->
                <transportConnectors>
                        <transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>
                        <transportConnector name="ssl" uri="ssl://localhost:61617"/>
                        <transportConnector name="stomp" uri="stomp://localhost:61613"/>
                        <transportConnector name="xmpp" uri="xmpp://localhost:61222"/>
                </transportConnectors>
，建议不要改动，都用这个端口多好，就像ftp都用21端口，也没错。


这是官方的HelloWorld例子，不过看着不顺眼：
http://activemq.apache.org/hello-world.html

----------------------

2 楼 liudaoru 2010-02-24  

面向消息的中间件和ActiveMQ的介绍
From: http://marshal.iteye.com/blog/139636

什么是消息中间件


面向消息的中间件：Message-oriented Middleware, MOM

基本功能：将信息以消息的形式，从一个应用程序传送到另一个或多个应用程序。

主要特点：
消息异步接受，类似手机短信的行为，消息发送者不需要等待消息接受者的响应，减少软件多系统集成的耦合度；
消息可靠接收，确保消息在中间件可靠保存，只有接收方收到后才删除消息，多个消息也可以组成原子事务。
消息中间件的主要应用场景：

公司在发展过程中，开发（或者购买了）多套企业信息系统，比如财务系统，人事系统，在线销售系统，运营系统等。

这些系统生产/消费公司的各种业务数据。

公司需要将这些系统集成（整合），比如让在线销售系统的订单数据输入到财务系统中。

类似应用的一般系统需求是：
可靠传输，数据不能丢失，有的时候，也会要求不能重复传输；
异步传输，否则各个系统同步发送接受数据，互相等待，造成系统瓶颈。

公司可以为此开发自己的软件服务，代价会比较大，现在一般使用已经成型的消息中间件。

目前比较知名的消息中间件：
IBM MQSeries
BEA WebLogic JMS Server
Oracle AQ
Tibco
SwiftMQ
AcitveMQ：是免费的java实现的消息中间件

什么是JMS


JMS Java Message Service，Java消息服务。

和消息中间件的关系，类似于DBMS和JDBC的关系。

JMS是个标准，见：java.sun.com/products/jms/

目前版本是1.1。

JMS是J2EE（JavaEE）标准的一部分。


ActiveMQ的简单使用


简介


ActiveMQ，网址：activemq.apache.org/

目前是Apache下的一级项目。

免费开源由java编写符合JMS1.1标准的消息中间件。

另外，它也支持通过除java语言外的语言的使用：

PHP
C/C++
C#
Ruby
Perl
Python

简单使用


本文操作系统Windows XP。

SUN JDK 1.6.0_03。
启动：

进入${active-mq}\bin目录。

运行activemq.bat

检查安装是否成功：

命令行执行如下命令


netstat -an|find "61616" 

显示如下内容表示启动成功：


TCP    0.0.0.0:61616          0.0.0.0:0              LISTENING 

1 楼 liudaoru 2009-09-02  

javaeye ActiveMQ专题：http://www.iteye.com/wiki/ActiveMQ