Sping整合ActiveMQ（一.ActiveMQ使用javax.jms通信）

Sping整合ActiveMQ（一.ActiveMQ使用javax.jms通信）

1.Pom文件：

 

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>ActiveMQ</groupId>
    <artifactId>ActiveMQ</artifactId>
    <version>1.0-SNAPSHOT</version>

    <name>ActiveMQ</name>
    <description>ActiveMQ AMQP Java Examples</description>

    <repositories>
        <repository>
            <id>Fusesource Snapshots</id>
            <url>http://repo.fusesource.com/nexus/content/repositories/snapshots</url>
        </repository>
    </repositories>

    <dependencies>

        <dependency>
            <groupId>org.apache.geronimo.specs</groupId>
            <artifactId>geronimo-jms_1.1_spec</artifactId>
            <version>1.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.qpid</groupId>
            <artifactId>qpid-amqp-1-0-client-jms</artifactId>
            <version>0.24</version>
        </dependency>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-core</artifactId>
            <version>5.7.0</version>
        </dependency>

    </dependencies>

    <!--<build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>2.1</version>
                <configuration>
                    <source>1.6</source>
                    <target>1.6</target>
                </configuration>
            </plugin>

            &lt;!&ndash; include all the dependencies into the jar so it's easier to execute the example &ndash;&gt;
            <plugin>
                <groupId>org.fusesource.mvnplugins</groupId>
                <artifactId>maven-uberize-plugin</artifactId>
                <version>1.14</version>
                <executions>
                    <execution>
                        <phase>package</phase>
                        <goals><goal>uberize</goal></goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>-->

</project>

 2.发送消息测试类Sender:

 

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

import javax.jms.*;

public class SenderTest {
    public static void main(String[] args) {
        //1.创建连接工厂
        ConnectionFactory factory = new ActiveMQConnectionFactory(
                ActiveMQConnection.DEFAULT_USER,
                ActiveMQConnection.DEFAULT_PASSWORD,
                "tcp://localhost:61616");
        Connection connection = null;
        try {
            //2.通过工厂创建连接
            connection = factory.createConnection();
            /*启动连接*/
            connection.start();
            //3.通过连接创建发送或接收消息的会话Session
            Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
            //4.通过session创建目的地，即消息发送给谁
            Destination destination = session.createQueue("SecondQueue");
            //5.通过session创建生产者Product,用于生成消息
            MessageProducer producer = session.createProducer(destination);
            //6.设置不持久化
            producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
            //7.开始发送消息
            sendMessage(session, producer);
            session.commit();
        } catch (JMSException e) {
            e.printStackTrace();
        } finally {
            try {
                /*关闭连接*/
                if (null != connection)
                    connection.close();
            } catch (JMSException e) {
                e.printStackTrace();
            }
        }
    }


    public static void sendMessage(Session session, MessageProducer producer) throws JMSException {
        for(int i = 0; i < 10; i++) {
            /*创建消息*/
            TextMessage message = session.createTextMessage("发送的消息为：" + i);
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("发送的消息为：" + i);
            /*开始发送*/
            producer.send(message);
        }
    }
}

 3.接收消息测试类Receiver:

 

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

import javax.jms.*;

public class ReceiverTest {
    public static void main(String[] args) {
        //1.创建连接工厂
        ConnectionFactory factory = new ActiveMQConnectionFactory(
                ActiveMQConnection.DEFAULT_USER,
                ActiveMQConnection.DEFAULT_PASSWORD,
                "tcp://localhost:61616");
        //2.创建连接
        Connection connection = null;
        try {
            connection = factory.createConnection();
            /*开启连接*/
            connection.start();
            //3.通过连接创建发送和接收消息的会话Session(支持事务，自动通知)
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            //4.通过Session创建消息的目的地
            Destination destination = session.createQueue("SecondQueue");
            //5.通过Session创建消费者Consumer
            MessageConsumer consumer = session.createConsumer(destination);
            //6.开始接收消息
            while (true) {
                /*创建消息对象 用来接收消息*/
                TextMessage message = (TextMessage) consumer.receive();
                System.out.println(message.getText());
            }
        } catch (JMSException e) {
            e.printStackTrace();
        } finally {
            /*关闭连接*/
            try {
                if (null != connection)
                    connection.close();
            } catch (JMSException e) {
                e.printStackTrace();
            }
        }
    }
}