|
public class ProducerTest {
public static void main(String[] args) throws JMSException {
// 创建连接工厂
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(“tcp://192.168.67.201:61616”);
Connection connection = connectionFactory.createConnection();
connection.start();
// 创建session 第一个参数表示是否支持事务，false时，第二个参数Session.AUTO_ACKNOWLEDGE自动签收，Session.CLIENT_ACKNOWLEDGE手动签收，DUPS_OK_ACKNOWLEDGE 订阅时签收其中一个
// 第一个参数设置为true时，第二个参数可以忽略 服务器设置为SESSION_TRANSACTED
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 创建队列
Queue queue = session.createQueue(“Atguigu”);
MessageProducer producer = session.createProducer(queue);
// 创建消息对象
ActiveMQTextMessage activeMQTextMessage = new ActiveMQTextMessage();
activeMQTextMessage.setText(“hello ActiveMq!”);
// 发送消息
producer.send(activeMQTextMessage);
producer.close();
connection.close();
}
} |
注意：如果有事务需要先提交事务session.commit();
Number Of Pending Messages 等待消费的消息 这个是当前未出队列的数量。可以理解为总接收数-总出队列数
Number Of Consumers 消费者 这个是消费者端的消费者数量
Messages Enqueued 进入队列的消息 进入队列的总数量,包括出队列的。 这个数量只增不减
Messages Dequeued 出了队列的消息 可以理解为是消费者消费掉的数量
总结：
当有一个消息进入这个队列时，等待消费的消息是1，进入队列的消息是1。
当消息消费后，等待消费的消息是0，进入队列的消息是1，出队列的消息是1.
在来一条消息时，等待消费的消息是1，进入队列的消息就是2.
想要了解跟多关于java培训课程内容欢迎关注尚硅谷java培训，尚硅谷除了这些技术文章外还有免费的高质量java培训课程视频供广大学员下载学习。
