ActiveMQ学习笔记

ConnectionFactory connectionFactory;//连接工厂
Connection connection;//连接
Session session;
Destination destination;//目的
MessageProducer messageProducer;//消息生产者
Message message;//消息
MessageConsumer messageConsumer;//消息消费者

//ActiveMQ用户名、ActiveMQ密码、ActiveMQ地址
connectionFactory = new ActiveMQXAConnectionFactory("admin", "admin", "failover://tcp://localhost:61616");
//连接
connection = connectionFactory.createConnection();
//第一个参数是否使用事务,第二个参数消息的确认模式
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//指定消息提供者在每次收到消息时自动发送确认。消息只向目标发送一次
//目的地，ActiveMQ中已存在队列
destination = session.createQueue("SecondQueue");
//消息生产者[发送者]
messageProducer = session.createProducer(destination);
//持久性设置
messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
//消息
message = session.createTextMessage("发了一条消息给SecondQueue");
//发送
messageProducer.send(message);
session.close();
connection.close();