关键接口和类:
ConnectionFactory connectionFactory;//连接工厂 Connection connection;//连接 Session session; Destination destination;//目的 MessageProducer messageProducer;//消息生产者 Message message;//消息 MessageConsumer messageConsumer;//消息消费者
1.发送消息
//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();
2.发送文件
关键:BlogMessage
时间: 2024-10-11 17:29:07