activemq安装与简单消息发送接收实例

[root@localhost software]# pwd
/export/software
[root@localhost software]# tar -zxvf apache-activemq-5.11.1-bin.tar.gz
[root@localhost software]# mv apache-activemq-5.11.1 /usr/local

upstream tomcat_tools.activemq.local {
        server 127.0.0.1:8161  weight=10 max_fails=2 fail_timeout=300s;
}
server {
        listen                   80;
        server_name              tools.activemq.local.com;
        root                     /usr/local/apache-activemq-5.11.1/webapps/;
        access_log               /usr/local/apache-activemq-5.11.1/logs/tools.activemq.local.com_access.log main;
        error_log                /usr/local/apache-activemq-5.11.1/logs/tools.activemq.local.com_error.log warn;
        error_page               403 404 /40x.html;

        location / {
            index index.html index.htm;
            proxy_next_upstream     http_500 http_502 http_503 http_504 error timeout invalid_header;
            proxy_set_header        Host  $host;
            proxy_set_header       X-Real-IP        $remote_addr;
            proxy_set_header        X-Forwarded-For $proxy_add_x_forwarded_for;
            proxy_pass              http://tomcat_tools.activemq.local;
        }

        #静态文件，nginx自己处理
            location ~ ^/(images|javascript|js|css|flash|media|static)/ {

                    #过期30天，静态文件不怎么更新，过期可以设大一点，
                    #如果频繁更新，则可以设置得小一点。
                    expires 30d;
            }
}

[root@localhost linux-x86-64]# pwd
/usr/local/apache-activemq-5.11.1/bin/linux-x86-64
[root@localhost linux-x86-64]# ./activemq start

 <dependency>
     <groupId>org.apache.activemq</groupId>
     <artifactId>activemq-all</artifactId>
     <version>5.11.1</version>
 </dependency>

public class Constant {

    public static final String brokerURL = "tcp://192.168.147.131:61616";

    public static final String queueDestination = "testQueue";
}

import javax.jms.*;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

/**
 * created on 2015/6/4
 * @author dennisit@163.com
 * @version 1.0
 */
public class MqSender {

    public static void main(String[] args) throws JMSException {
        ConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
                ActiveMQConnection.DEFAULT_PASSWORD, Constant.brokerURL);
        Connection connection = factory.createConnection();
        connection.start();
        Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue(Constant.queueDestination);
        MessageProducer producer = session.createProducer(destination);
        producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
        ObjectMessage message = session.createObjectMessage("hello world...");
        producer.send(message);
        session.commit();
        System.out.println("send...");
    }

}

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.ObjectMessage;
import javax.jms.Session;

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

/**
 * created on 2015/6/4
 * @author dennisit@163.com
 * @version 1.0
 */
public class MqReceiver {

    public static void main(String[] args) throws JMSException {
        ConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD,
                Constant.brokerURL);
        Connection connection = factory.createConnection();
        connection.start();
        Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue(Constant.queueDestination);

        MessageConsumer consumer = session.createConsumer(destination);
        ObjectMessage message = (ObjectMessage)consumer.receive();
        if (message != null) {
            String messageString = (String)message.getObject();
            System.out.println("Receive : " + messageString);
        }
    }
}