消息队列-ActiveMQ P2P模式
程序员文章站
2022-07-01 15:31:24
...
1.导依赖包
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-all</artifactId>
<version>5.15.10</version>
</dependency>
2.消息生产者
public class Sender {
public static void main(String[] args) throws JMSException, InterruptedException {
// 1. 建立工厂对象
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(
ActiveMQConnectionFactory.DEFAULT_BROKER_URL,
ActiveMQConnectionFactory.DEFAULT_PASSWORD,
"tcp://localhost:61616");
//2. 从工厂里获取一个连接
Connection connection = factory.createConnection();
connection.start();
//3. 从连接中获取Session(会话)
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//4. 从会话中获取目的地(Destination),消费者会从这个目的地取消息
Queue queue = session.createQueue("lance");
//5. 从会话中创建消息提供者
MessageProducer producer = session.createProducer(queue);
int i = 1;
try {
while (true) {
//从会话中创建文本消息(也可以创建其它类型的消息体)
TextMessage textMessage = session.createTextMessage("hello" + i);
Thread.sleep(1000);
// 通过消息提供者发送消息到ActiveMQ
producer.send(textMessage);
i++;
}
} catch (JMSException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
// 关闭连接
connection.close();
}
System.out.println("exit");
}
}
3.消息消费者
public class Recviver {
public static void main(String[] args) throws JMSException {
// 1. 建立工厂对象
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(
ActiveMQConnectionFactory.DEFAULT_BROKER_URL,
ActiveMQConnectionFactory.DEFAULT_PASSWORD,
"tcp://localhost:61616");
//2. 从工厂里获取一个连接
Connection connection = factory.createConnection();
connection.start();
//3. 从连接中获取Session(会话)
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//4. 从会话中获取目的地(Destination),消费者会从这个目的地取消息
Destination destination = session.createQueue("lance");
//5. 从会话中创建消息消费者
MessageConsumer consumer = session.createConsumer(destination);
//6. 持续的消费
try {
while (true) {
TextMessage textMessage = (TextMessage) consumer.receive();
System.out.println("消费:" + textMessage.getText());
}
} catch (Exception e) {
e.printStackTrace();
} finally {
//关闭连接
connection.close();
}
}
}
上一篇: RFC4575协议解读
推荐阅读
-
rabbitmq启动命令(rabbitmq消息队列5种模式)
-
rabbitmq启动命令(rabbitmq消息队列5种模式)
-
消息队列的两种模式
-
浅谈Java消息队列总结篇(ActiveMQ、RabbitMQ、ZeroMQ、Kafka)
-
JAVAEE——宜立方商城08:Zookeeper+SolrCloud集群搭建、搜索功能切换到集群版、Activemq消息队列搭建与使用
-
消息队列的作用以及kafka和activemq的对比
-
activemq消息队列-使用监听器来接收消息(常用)
-
activemq消息队列-点对点通讯
-
activemq消息队列-发布/订阅
-
ActiveMQ——消息队列基础篇 企业应用JMSActiveMQ消息队列MQ