activemq详细使用教程以及为什么要使用activemq

拼搏现实的明天。 2024-02-17 21:23 84阅读 0赞

mq可以发送多种数据格式，其中就可以发送数据流，那么可以吧文件转换成数据流，发送到mq这种java消息中间件，其他消费者，可以以主题或者点对点的模式来接受消息，接受数据流然后转换成文件，也是可以实现的。  
activemq典型的使用，就是金融软件，我们需要得到实时变化的股价，activemq还有高可用的特性，在网络方面性能也很好  
下面介绍activemq的使用方法  
1.导入jar包

<dependency>
                <groupId>org.apache.activemq</groupId>
                <artifactId>activemq-all</artifactId>
                <version>5.11.0</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-jms</artifactId>
                <version>4.1.4.RELEASE</version>
            </dependency>

2.activemq配置文件，其实就是在spring中来管理activemq

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://www.springframework.org/schema/beans
            http://www.springframework.org/schema/beans/spring-beans.xsd">
    
        
        <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
            <property name="brokerURL" value="failover:(tcp://localhost:61616)" />
        </bean>
    
        
        <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
            
            <constructor-arg>
                <value>queue1</value>
            </constructor-arg>
        </bean>
    
        
        <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
            <property name="connectionFactory" ref="connectionFactory" />
            <property name="defaultDestination" ref="queueDestination" />
            <property name="receiveTimeout" value="10000" />
        </bean>
    
        
        <bean id="activemqImpl" class="study.ActivemqImpl">
        </bean>
        
        <bean id="queueMessageListener" class="study.CustomerMessageListener" />
    
        
        <bean id="jmsContainer"
            class="org.springframework.jms.listener.DefaultMessageListenerContainer">
            <property name="connectionFactory" ref="connectionFactory" />
            <property name="destination" ref="queueDestination" />
            <property name="messageListener" ref="queueMessageListener" />
        </bean>
        
        <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
            <constructor-arg>
                <value>topic_test</value>
            </constructor-arg>
        </bean>
        
        <bean id="topicJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
            <property name="connectionFactory" ref="connectionFactory"></property>
            <property name="defaultDestination" ref="topicDestination" />
            <property name="pubSubDomain" value="true" />
            <property name="receiveTimeout" value="10000" />
        </bean>
        
        <bean id="topicListener" class="study.TopicListener">
        </bean>
        
        <bean id="topicContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
            <property name="connectionFactory" ref="connectionFactory" />
            <property name="destination" ref="topicDestination" />
            <property name="messageListener" ref="topicListener" />
        </bean>
        
        <bean id="topicListener2" class="study.TopicListener2">
        </bean>
        
        <bean id="topicContainer2" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
            <property name="connectionFactory" ref="connectionFactory" />
            <property name="destination" ref="topicDestination" />
            <property name="messageListener" ref="topicListener2" />
        </bean>
    </beans>

3.发送点对点消息（queue）

public void ProviderQueue(Destination destination, final String msg) {
            jmsTemplate.send(destination, new MessageCreator() {
                public Message createMessage(Session session) throws JMSException {
                    return session.createTextMessage(msg);
                }
            });
        }

4.主动接受消息

public void accept(Destination destination) {
            TextMessage textMessage=(TextMessage) jmsTemplate.receive(destination);
            try {
                System.out.println("主动接受消息"+textMessage.getText());
            } catch (JMSException e) {
                e.printStackTrace();
            }
        }

5.监听器监听消息

/**
     * 监听器
     * @author qbm
     *
     */
    public class TopicListener implements MessageListener {
        
    
        public void onMessage(Message arg0) {
            TextMessage textMessage=(TextMessage)arg0;
            try {
                System.out.println("主题消息监听器监听到："+textMessage.getText());
            } catch (JMSException e) {
                e.printStackTrace();
            }
    
        }
    
    }

总结：  
1.发送主题消息和发送点对点消息的不同其实就是目的地不同（destination），jmstemplate不同  
2.监听器接受消息不管是点对点消息和主题消息的写法一直，只是目的地不同  
3.点对点模式一个消息，只能有一个消费者去接受  
4.主题模式一个消息可以有多个消费者去接受  
5每个监听器需要在spring中配置监听容器

demo码云地址：[https://git.oschina.net/hujunna/activemqjinjie.git][https_git.oschina.net_hujunna_activemqjinjie.git]

[https_git.oschina.net_hujunna_activemqjinjie.git]: https://git.oschina.net/hujunna/activemqjinjie.git