AI 助理
备案控制台
开发者社区 云原生 云消息队列 文章 正文

JMS消息队列ActiveMQ(点对点模式)

2017-11-14 1035
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

生产者(producer)->消息队列(message queue)


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
64
65
66
67
68
69
70
71
72
73
package  com.java1234.activemq;
 
import  javax.jms.Connection;
import  javax.jms.ConnectionFactory;
import  javax.jms.Destination;
import  javax.jms.JMSException;
import  javax.jms.MessageProducer;
import  javax.jms.Session;
import  javax.jms.TextMessage;
 
import  org.apache.activemq.ActiveMQConnection;
import  org.apache.activemq.ActiveMQConnectionFactory;
 
/**
  * 消息生产者
  * @author Administrator
  *
  */
public  class  JMSProducer {
 
     private  static  final  String USERNAME=ActiveMQConnection.DEFAULT_USER;  // 默认的连接用户名
     private  static  final  String PASSWORD=ActiveMQConnection.DEFAULT_PASSWORD;  // 默认的连接密码
     private  static  final  String BROKEURL=ActiveMQConnection.DEFAULT_BROKER_URL;  // 默认的连接地址
     private  static  final  int  SENDNUM= 10 ;  // 发送的消息数量
     
     public  static  void  main(String[] args) {
         
         ConnectionFactory connectionFactory;  // 连接工厂
         Connection connection =  null ;  // 连接
         Session session;  // 会话 接受或者发送消息的线程
         Destination destination;  // 消息的目的地
         MessageProducer messageProducer;  // 消息生产者
         
         // 实例化连接工厂
         connectionFactory= new  ActiveMQConnectionFactory(JMSProducer.USERNAME, JMSProducer.PASSWORD, JMSProducer.BROKEURL);
         
         try  {
             connection=connectionFactory.createConnection();  // 通过连接工厂获取连接
             connection.start();  // 启动连接
             session=connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);  // 创建Session
             destination=session.createQueue( "FirstQueue1" );  // 创建消息队列
             messageProducer=session.createProducer(destination);  // 创建消息生产者
             sendMessage(session, messageProducer);  // 发送消息
             session.commit();
         }  catch  (Exception e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }  finally {
             if (connection!= null ){
                 try  {
                     connection.close();
                 }  catch  (JMSException e) {
                     // TODO Auto-generated catch block
                     e.printStackTrace();
                 }
             }
         }
     }
     
     /**
      * 发送消息
      * @param session
      * @param messageProducer
      * @throws Exception
      */
     public  static  void  sendMessage(Session session,MessageProducer messageProducer) throws  Exception{
         for ( int  i= 0 ;i<JMSProducer.SENDNUM;i++){
             TextMessage message=session.createTextMessage( "ActiveMQ 发送的消息" +i);
             System.out.println( "发送消息：" + "ActiveMQ 发送的消息" +i);
             messageProducer.send(message);
         }
     }
}


消费者(Consumer)--（监听）->消息队列

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
package  com.java1234.activemq;
 
import  javax.jms.Connection;
import  javax.jms.ConnectionFactory;
import  javax.jms.Destination;
import  javax.jms.JMSException;
import  javax.jms.MessageConsumer;
import  javax.jms.Session;
import  javax.jms.TextMessage;
 
import  org.apache.activemq.ActiveMQConnection;
import  org.apache.activemq.ActiveMQConnectionFactory;
 
/**
  * 消息消费者
  * @author Administrator
  *
  */
public  class  JMSConsumer2 {
 
     private  static  final  String USERNAME=ActiveMQConnection.DEFAULT_USER;  // 默认的连接用户名
     private  static  final  String PASSWORD=ActiveMQConnection.DEFAULT_PASSWORD;  // 默认的连接密码
     private  static  final  String BROKEURL=ActiveMQConnection.DEFAULT_BROKER_URL;  // 默认的连接地址
     
     public  static  void  main(String[] args) {
         ConnectionFactory connectionFactory;  // 连接工厂
         Connection connection =  null ;  // 连接
         Session session;  // 会话 接受或者发送消息的线程
         Destination destination;  // 消息的目的地
         MessageConsumer messageConsumer;  // 消息的消费者
         
         // 实例化连接工厂
         connectionFactory= new  ActiveMQConnectionFactory(JMSConsumer2.USERNAME, JMSConsumer2.PASSWORD, JMSConsumer2.BROKEURL);
                 
         try  {
             connection=connectionFactory.createConnection();   // 通过连接工厂获取连接
             connection.start();  // 启动连接
             session=connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);  // 创建Session
             destination=session.createQueue( "FirstQueue1" );   // 创建连接的消息队列
             messageConsumer=session.createConsumer(destination);  // 创建消息消费者
             messageConsumer.setMessageListener( new  Listener());  // 注册消息监听
         }  catch  (JMSException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         } 
     }
}


监听(Listener)消息队列

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
package  com.java1234.activemq;
 
import  javax.jms.JMSException;
import  javax.jms.Message;
import  javax.jms.MessageListener;
import  javax.jms.TextMessage;
 
/**
  * 消息监听
  * @author Administrator
  *
  */
public  class  Listener  implements  MessageListener{
 
     @Override
     public  void  onMessage(Message message) {
         // TODO Auto-generated method stub
         try  {
             System.out.println( "收到的消息：" +((TextMessage)message).getText());
         }  catch  (JMSException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }
     }
 
}










本文转自 hgditren 51CTO博客，原文链接：http://blog.51cto.com/phpme/1952847，如需转载请自行联系原作者
文章标签：
消息中间件
Apache
关键词：
消息队列模式
消息队列activemq
jms消息队列
jms消息队列activemq模式
余二五
目录
相关文章
墨鸦_comorant
|
消息中间件 Java 数据库连接
JMS 消息队列接口基本使用指南
JMS 消息队列接口基本使用指南
墨鸦_comorant
662 0
码农阿豪
|
8月前
|
消息中间件 负载均衡 NoSQL
Redis系列学习文章分享---第七篇（Redis快速入门之消息队列--List实现消息队列 Pubsub实现消息队列 stream的单消费模式 stream的消费者组模式 基于stream消息队列）
Redis系列学习文章分享---第七篇（Redis快速入门之消息队列--List实现消息队列 Pubsub实现消息队列 stream的单消费模式 stream的消费者组模式 基于stream消息队列）
码农阿豪
97 0
三分钟热度的鱼
|
7月前
|
消息中间件 传感器 负载均衡
消息队列 MQ使用问题之如何配置一主一从的同步复制模式
消息队列（MQ）是一种用于异步通信和解耦的应用程序间消息传递的服务，广泛应用于分布式系统中。针对不同的MQ产品，如阿里云的RocketMQ、RabbitMQ等，它们在实现上述场景时可能会有不同的特性和优势，比如RocketMQ强调高吞吐量、低延迟和高可用性，适合大规模分布式系统；而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集，这些场景涵盖了多种行业和业务需求。
三分钟热度的鱼
80 0
消息队列 MQ使用问题之如何配置一主一从的同步复制模式
三分钟热度的鱼
|
7月前
|
消息中间件 Java Apache
消息队列 MQ使用问题之如何在内外网环境下使用单组节点单副本模式
消息队列（MQ）是一种用于异步通信和解耦的应用程序间消息传递的服务，广泛应用于分布式系统中。针对不同的MQ产品，如阿里云的RocketMQ、RabbitMQ等，它们在实现上述场景时可能会有不同的特性和优势，比如RocketMQ强调高吞吐量、低延迟和高可用性，适合大规模分布式系统；而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集，这些场景涵盖了多种行业和业务需求。
三分钟热度的鱼
137 0
weixin_836869520
|
7月前
|
消息中间件 Java Apache
使用Spring Boot实现与ActiveMQ的消息队列集成
使用Spring Boot实现与ActiveMQ的消息队列集成
weixin_836869520
102 0
花开富贵111
|
8月前
|
消息中间件 Apache C语言
消息队列 MQ产品使用合集之在Cluster部署模式下，使用dashboard无法查询到消费组信息，一般是什么导致的
阿里云消息队列MQ（Message Queue）是一种高可用、高性能的消息中间件服务，它允许您在分布式应用的不同组件之间异步传递消息，从而实现系统解耦、流量削峰填谷以及提高系统的可扩展性和灵活性。以下是使用阿里云消息队列MQ产品的关键点和最佳实践合集。
花开富贵111
124 0
花开富贵111
|
8月前
|
消息中间件 负载均衡 Apache
消息队列 MQ产品使用合集之是否支持Master/Slave模式进行部署？
阿里云消息队列MQ（Message Queue）是一种高可用、高性能的消息中间件服务，它允许您在分布式应用的不同组件之间异步传递消息，从而实现系统解耦、流量削峰填谷以及提高系统的可扩展性和灵活性。以下是使用阿里云消息队列MQ产品的关键点和最佳实践合集。
花开富贵111
57 0
花开富贵111
|
8月前
|
消息中间件 存储 负载均衡
消息队列 MQ产品使用合集之POP消费模式是否可以保证消息顺序性
阿里云消息队列MQ（Message Queue）是一种高可用、高性能的消息中间件服务，它允许您在分布式应用的不同组件之间异步传递消息，从而实现系统解耦、流量削峰填谷以及提高系统的可扩展性和灵活性。以下是使用阿里云消息队列MQ产品的关键点和最佳实践合集。
花开富贵111
66 0
阿里云博主-阿演
|
消息中间件 Java Maven
ActiveMQ向消息队列存入消息（点对点模式）
创建一个maven工程， 引入ActiveMQ的依赖
阿里云博主-阿演
121 1
云松雪
|
9月前
|
消息中间件
三、消息队列中的交换机三种模式
三、消息队列中的交换机三种模式
云松雪
73 0
云原生

云消息队列

热门文章

最新文章

  • 1
    Redis Stream——作为消息队列的典型应用场景
  • 2
    什么是消息队列？
  • 3
    消息队列（MQ）重磅推出MQTT移动物联套件
  • 4
    消息队列的exclusive consumer功能是如何保证消息有序和防止脑裂的
  • 5
    使用阿里云消息队列
  • 6
    消息队列服务Kafka揭秘：痛点、优势以及适用场景
  • 7
    MQ消息队列.NET SDK的使用
  • 8
    Redis笔记（七）Java实现Redis消息队列
  • 9
    SpringBoot使用RabbitMQ消息队列
  • 10
    阿里最新38道Java面试题解析（MyBatis+消息队列+Redis）
  • 1
    RocketMQ Controller 模式 始终更新成本机ip
    70
  • 2
    云消息队列 RabbitMQ 版实践解决方案评测
    142
  • 3
    RocketMQ体验测评
    100
  • 4
    关键成果与技术应用
    102
  • 5
    消息队列 MQ使用问题之如何使用DefaultMQPushConsumer来消费消息
    271
  • 6
    消息队列 MQ使用问题之遇到消费速度是固定的并且导致了堆积，该怎么办
    274
  • 7
    消息队列 MQ使用问题之如何在grpc客户端中设置负载均衡器
    89
  • 8
    消息队列 MQ使用问题之如何配置生产环境
    159
  • 9
    消息队列 MQ使用问题之在使用C++客户端和GBase的ESQL进行编译时出现core dump，该怎么办
    150
  • 10
    消息队列 MQ使用问题之如何将RocketMQ中某个集群的topic迁移到另一个集群
    195

    • 相关课程

    更多
  • 消息队列Kafka入门课程
  • 消息队列RocketMQ 5.0 云原生架构升级课程
  • 消息队列 RocketMQ 全类型业务消息学习课程
  • 消息队列 RocketMQ 消息集成
  • 消息队列 MNS 入门课程
  • 使用Redis消息队列完成秒杀过期订单处理

    • 相关电子书

    更多
  • 企业互联网架构之消息队列
  • 基于消息队列RocketMQ的大型分布式应用上云最佳实践
  • 云原生消息队列Apache RocketMQ

    • 相关实验场景

    更多
  • 快速体验云消息队列RocketMQ版
  • 消息队列RocketMQ版：基础消息收发功能体验
  • 快速学会使用云消息队列RabbitMQ版
  • 消息队列RocketMQ版：定时消息通知功能体验
  • 消息队列+Serverless+Tablestore：实现高弹性的电商订单系统
  • 部署RabbitMQ
    • 下一篇
    PAI Model Gallery 支持云上一键部署 DeepSeek-V3、DeepSeek-R1 系列模型