ActiveMQ生产者和消费者案例

灰太狼 2021-10-14 01:52 330阅读 0赞

### 一、启动ActiveMQ ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70 1][]

### 二、生产者代码  ###

/**
     * @program: activemqdemo
     * @description:
     * @author: hq.zheng
     * @create: 2019-08-17 14:45
     */
    public class Producer {
    
        public static void main(String[] args) throws JMSException {
            // ConnectionFactory ：连接工厂，JMS 用它创建连接
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
                    ActiveMQConnection.DEFAULT_PASSWORD, "tcp://127.0.0.1:61616");
    
            //JMS 客户端到JMS Provider 的连接
            Connection connection = connectionFactory.createConnection();
            //启动连接
            connection.start();
    
            //Session： 一个发送或接收消息的线程,自动签收
            Session session = connection.createSession(Boolean.FALSE, 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);
    
            // 发送一条消息
            TextMessage textMessage = session.createTextMessage("This is my first ActiveMQ");
            producer.send(textMessage);
    
            //关闭连接
            session.close();
            connection.close();
        }
    
    }

运行后

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70 2][]

### 三、消费者代码  ###

/**
     * @program: activemqdemo
     * @description:
     * @author: hq.zheng
     * @create: 2019-08-17 15:08
     */
    public class Receiver {
        public static void main(String[] args) throws JMSException {
            // ConnectionFactory ：连接工厂，JMS 用它创建连接
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
                    ActiveMQConnection.DEFAULT_PASSWORD, "tcp://127.0.0.1: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();
                if (null != message) {
                    System.out.println("收到消息：" + message.getText());
                    session.commit();
                } else
                    break;
            }
            session.close();
            connection.close();
    
        }
    }

运行后

![20190817152614526.png][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70]: /images/20211013/788a8f247d7a428d8c3a34cd8cecb371.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70 1]: /images/20211013/87918fb24c224d73b197e77e27f24e4d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70 2]: /images/20211013/518d07d408424bf1b553bfd167f98f33.png
[20190817152614526.png]: /images/20211013/7709f1b3dd3842feaeae08d7bfdfe98d.png