Java操作ActiveMQ

创建Maven项目：

  org.apache.activemq
  activemq-all
  5.15.12

第一步：创建生产者：

public class JmsProducer {
    private static String username = "admin";
    private static String password = "admin";
    private static String url = "tcp://hcmaster:61616";
    private static String QUEUE_NAME = "haha";

    public static void main(String[] args) throws JMSException {
        //1.创建连接工厂
        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(username, password, url);
        //2.通过连接工厂获取连接
        Connection conn = factory.createConnection();
        //3.启动连接
        conn.start();

        //4.创建会话Session
        //第一个参数为事务
        //第二个参数为签收
        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);

        //5.创建目的地（队列或主题）
        Queue queue = session.createQueue(QUEUE_NAME);

        //6.创建消息的生产者，生产者将它所生产的消息放到queue中
        MessageProducer producer = session.createProducer(queue);

        //7.生产消息
        for(int i =1;i