ActiveMQ Artemis 的安装和使用

export ARTEMIS_HOME=${HOME}/apache-artemis-2.9.0
${ARTEMIS_HOME}/bin/artemis create eventbroker --http-host 10.80.28.27

[demo@localhost ~]$ ${ARTEMIS_HOME}/bin/artemis create eventbroker --http-host 10.80.28.27
Creating ActiveMQ Artemis instance at: /home/demo/eventbroker

--user: is a mandatory property!
Please provide the default username:
admin

--password: is mandatory with this configuration:
Please provide the default password:


--allow-anonymous | --require-login: is a mandatory property!
Allow anonymous access?, valid values are Y,N,True,False
Y

Auto tuning journal ...
done! Your system can make 7.58 writes per millisecond, your journal-buffer-timeout will be 132000

You can now start the broker by executing:  

   "/home/demo/eventbroker/bin/artemis" run

Or you can run the broker in the background using:

   "/home/demo/eventbroker/bin/artemis-service" start

# service
"/home/demo/eventbroker/bin/artemis-service" start
"/home/demo/eventbroker/bin/artemis-service" stop

# run in shell
"/home/demo/eventbroker/bin/artemis" run

    -Xms2048M \
    -Xmx2048M \
    -XX:MaxMetaspaceSize=512M \
    -XX:MetaspaceSize=512M \

            <!-- 在 address-setting 部分 -->
            <auto-create-queues>false</auto-create-queues>
            <auto-create-addresses>true</auto-create-addresses>
            <!-- <auto-create-jms-queues>true</auto-create-jms-queues> -->
            <!-- <auto-create-jms-topics>true</auto-create-jms-topics> -->

<addresses>
   <address name="pubsub.foo">
      <multicast>
      </multicast>
   </address>
</addresses>

    <bean id="connectionFactory" class="org.apache.activemq.artemis.jms.client.ActiveMQJMSConnectionFactory">
        <constructor-arg value="tcp://10.80.28.27:61616"/>
    </bean>

    <bean id="exampleQueue" class="org.apache.activemq.artemis.jms.client.ActiveMQQueue">
        <constructor-arg index="0" value="exampleQueue"/>
    </bean>

    <bean id="exampleTopic" class="org.apache.activemq.artemis.jms.client.ActiveMQTopic">
        <constructor-arg index="0" value="exampleTopic"/>
    </bean>

    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="connectionFactory" />
    </bean>

    <bean id="sampleJmsMessageSender" class="com.example.SampleJmsMessageSender">
        <property name="jmsTemplate" ref="jmsTemplate"/>
        <property name="queue" ref="exampleQueue"/>
        <property name="topic" ref="exampleTopic"/>
    </bean>

    <bean id="messageListener" class="com.example.SampleListener">
    </bean>

    <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory"/>
        <property name="destination" ref="exampleTopic"/>
        <property name="messageListener" ref="messageListener"/>
    </bean>

package com.example;

import org.springframework.jms.core.JmsTemplate;

import javax.jms.Queue;
import javax.jms.Topic;

public class SampleJmsMessageSender {

    private JmsTemplate jmsTemplate;
    private Queue queue;
    private Topic topic;

    public void simpleQueueSend() {
        jmsTemplate.send(queue, s -> s.createTextMessage("hello queue world"));
    }

    public void simpleTopicSend() {
        jmsTemplate.send(topic, s -> s.createTextMessage("hello topic world"));
    }


    public JmsTemplate getJmsTemplate() {
        return jmsTemplate;
    }

    public void setJmsTemplate(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

    public Queue getQueue() {
        return queue;
    }

    public void setQueue(Queue queue) {
        this.queue = queue;
    }

    public Topic getTopic() {
        return topic;
    }

    public void setTopic(Topic topic) {
        this.topic = topic;
    }
}

package com.example;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

public class SampleListener implements MessageListener {
    @Override
    public void onMessage(Message message) {
        if (message instanceof TextMessage) {
            try {
                String msg = ((TextMessage) message).getText();
                System.out.println("Message has been consumed : " + msg);
            } catch (JMSException ex) {
                throw new RuntimeException(ex);
            }
        } else {
            throw new IllegalArgumentException("Message Error");
        }
    }
}

    <!-- 这里用 ActiveMQ Classic 的例子 -->
    <bean id="consumerAmqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <constructor-arg index="0" value="tcp://10.80.28.27:61616" />
        <property name="clientID" value="HOST-Consumer"/>
    </bean>

    <!-- ConnectionFactory Definition -->
    <bean id="consumerConnectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
        <constructor-arg ref="consumerAmqConnectionFactory" />
    </bean>

    <bean id="consumerExampleTopic" class="org.apache.activemq.command.ActiveMQTopic">
        <constructor-arg index="0" value="exampleTopic"/>
    </bean>


    <bean id="messageListener" class="com.example.SampleListener">
    </bean>


    <!-- durable subscription need set  SubscriptionName and ClientID  to identify unique Consumer -->
    <!-- 持久化订阅 需要设置 SubscriptionName 和 ClientID 来唯一标识一个 Consumer -->
    <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="consumerConnectionFactory"/>
        <property name="destination" ref="consumerExampleTopic"/>
        <property name="messageListener" ref="messageListener"/>
        <property name="subscriptionDurable" value="true"/>
        <property name="durableSubscriptionName" value="Subscriber-B"/>
    </bean>