本文共 1392 字，大约阅读时间需要 4 分钟。

`package com.demo.activemq.queue;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**

• @author

• @create 2021-05-20

  */
  public class JmsProduce {
  private static final String ACTIVEMQ_URL = “tcp://192.168.56.10:61616”;
  private static final String QUEUE_NAME=“queue01”;

  public static void main(String[] args) throws JMSException {

  //1.创建连接工厂，按照给定的URL，采用默认的用户名密码
  ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);
  //2.通过连接工厂,获得connection并启动访问
  Connection connection = activeMQConnectionFactory.createConnection();
  connection.start();
  //3.创建会话session
  //两个参数transacted=事务,acknowledgeMode=确认模式(签收) 自动
  Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
  //4.创建目的地(具体是队列queue还是主题topic)
  //Destination destination = session.createQueue(QUEUE_NAME) 不用队列用目的地
  Queue queue = session.createQueue(QUEUE_NAME);
  //5.创建消息生产者
  MessageProducer messageProducer = session.createProducer(queue);
  // messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT);
  // 6.通过使用消息生产者,生产三条消息,发送到MQ的队列里面
  for (int i = 1; i <=3 ; i++) {
  //7.创建消息
  TextMessage textMessage = session.createTextMessage(“msg–”+i);//理解为一个字符串
  //8.通过messageProducer发送给MQ队列
  messageProducer.send(textMessage);
  }
  //9.关闭资源 顺着申请 倒着关闭
  messageProducer.close();
  session.close();
  connection.close();//链接中断
  System.out.println("****消息发布到MQ队列完成");
  }

}

转载地址：https://blog.csdn.net/liufeifeihuawei/article/details/117064939 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！