ActiveMq消费者消息处理 activemq有消费者不消费

转载

阿里云AI实训营云栖上新！本期Agent创客：Jack-cui教你用Qwen最新模型秒搭爆火数字人博主，一键体验AI灰姑娘的一天。还有tokens超值优惠包，最低20元可抵千万tokens！立即点击链接，观看课程： https://click.aliyun.com/m/1000407000/

概念：

消息生产者发送消息到Queue中，然后消息消费者从Queue中获取并消费消息。

消息消费以后，Queue中不在存储消息，消费者不可能消费到已经被消费的消息，

Queue支持多个消费者，但单条消息，只会有一个消费者可以消费，其他的则不能消费此消息

当消费者不存在时，消息会一直保存，直到有消费者消费（在空间允许的情况下）

PTP处理模式（Queue）：

我使用的是maven构建的项目

使用的ActiveMQ版本是5.4.0

<project xmlns="http:///POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http:///POM/4.0.0 http:///xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.project</groupId> <artifactId>activemq-demo</artifactId> <version>0.0.1-SNAPSHOT</version> <dependencies><dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-spring</artifactId> <version>5.4.0</version></dependency> </dependencies> </project>1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.

producer代码段

consumer代码段

package com.project.first; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.Message; import javax.jms.MessageConsumer; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnectionFactory; /** * 消息消费者 * @author Administrator * */ public class TestConsumer {public String receiveTextMessage(){String resultCode = "";ConnectionFactory factory = null;Connection connection = null;Session session = null;Destination destination = null;//消息的消费者，用于接收消息的对象MessageConsumer consumer = null;Message message = null;try{factory = new ActiveMQConnectionFactory("admin", "admin","tcp://192.168.0.109:61616");//消息的消费者必须启动连接，否则无法消费消息connection = factory.createConnection();connection.start();session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);destination = session.createQueue("first-mq");//创建消息消费者对象，在指定的目的地中获取消息consumer = session.createConsumer(destination);//获取队列中的消息。receive方法是一个主动获取消息的方法，执行一次，拉去一个消息，学习使用，开发不使用message = consumer.receive();//处理消息文本resultCode = ((TextMessage)message).getText();}catch(Exception e){e.printStackTrace();}finally{try{if(consumer != null) consumer.close();//回收消息消费者if(session != null) session.close();//回收会话对象if(connection != null) connection.close();//回收连接对象}catch(Exception e){}}return resultCode;}public static void main(String[] args) {TestConsumer consumer = new TestConsumer();String messagestr = consumer.receiveTextMessage();System.out.println("消费消息内容是："+messagestr);} }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.41.42.43.44.45.46.47.48.49.50.51.52.53.54.55.56.57.58.59.60.61.62.63.

IP地址根据自己搭建的环境配置

界面运行效果如下：

本文章为转载内容，我们尊重原作者对文章享有的著作权。如有内容错误或侵权问题，欢迎原作者联系我们进行内容更正或删除文章。

相关文章