文档章节

java消息机制

Dylan1009
 Dylan1009
发布于 2017/04/01 11:41
字数 2406
阅读 8
收藏 0

1、问: 什么是 Java 消息服务?
答: Java 消息服务(Java Message Service,JMS) API 是一个用于访问企业消息传递系统的 API。是 Java 2 Platform, Enterprise(J2EE)的一部分。

2、目前流行的消息传送产品有哪些?
答:目前流行的有ActiveMQ、IBM WebSphere MQ、SonicMQ等

3、什么时候可以用到java消息机制?
答:(1)异构系统集成,整合现有资源,提高资源的利用率
       (2)异步请求处理,减轻或消除系统瓶颈,提高用户生产率和系统的整体可伸缩性
       (3)组件解偶,增加系统的灵活性

4、消息传送的两种模型
发布/订阅模型
客户端发送消息到一个名为主题(topic)的虚拟通道中,每个订阅该主题的消费者都会接收到每条消息的一个副本。
点对点模型
客户端通过队列(queue)这个虚拟通道来同步和异步发送、接收消息,发送到队列的消息只能被一个接收者所接收,即使有多个消费者时也只能有一个消费者处理消息

5、JMS包含哪些接口?
JMS API可以分为3个主要部分:公共API、点对点API和发布/订阅API。在JMS1.1中,公共API可被用于向一个队列或一个主题发送消息,或从其中接收消息。点对点API专门用于使用队列的消息传送,而发布/订阅API则专门用于使用主题的消息传送。
在JMS公共API内部,和发送和接收JMS消息有关的JMS API接口主要有7个:
l          ConnectionFactory
l          Destination
l          Connection
l          Session
l          Message
l          MessageProducer
l          MessageConsumer
在这些公共接口中,ConnectionFactory和Destination必须使用JNDI(遵照JMS规范要求)从提供者处获得。其他接口则可以通过工厂方法在不同的API接口中创建。举例来说,一旦有了一个ConnectionFactory,就可以创建一个 Connection。一旦有了一个Connection,就可以创建一个Session。而一旦有了一个Session,就可以创建一个 Message、MessageProducer和MessageConsumer。这7个主要的JMS公共API接口之间的关系如图1-5所示。
在JMS中,是Session对象保存着用于消息传送的事务性工作单元(transactional unit),而不是Connection对象。这和JDBC不同,JDBC中是Connection对象保存事务性工作单元。这就意味着在使用JMS时,一个应用程序通常只会有一个Connection对象,但是它可以有一个Session对象池。
另外,还有和异常处理、消息优先级及消息持久性有关的其他接口


6、java消息分为哪些部分?
消息头、消息属性、消息自身

7、消息过滤
消息订阅者需要对消息进行过滤,否则订阅者就会接受到主题或队列的每一条消息,浪费了不必要的资源(CPU、内存等),而使用消息过滤技术,能让订阅者只接受它需要的消息。(消息过滤对于队列消费尤其重要,因为一个队列消费者消费消息后其他消费者就不再可用,此时如果不对消息进行过滤处理,这条消息就很可能被浪费掉)。
消息选择器使用消息属性和消息头作为条件表达式的传送载体(消息体不能作为消息选择器的参考对象)。
消息选择器由标识符、常量和比较运算符组成:
例:
     创建一个消息如下:
        TextMessage textMessage = Session.createTextMessage();
         textMessage.setText(“mytestMsg”);
         textMessage.setStringProperty(“city”,”hangzhou”);
         textMessage.setStringProperty(“company”,”mycompany”);
         这条消息中设置的消息属性名“city”和“company”代表消息选择器的标识符,”hangzhou”和”mycompany”代表常量

          在消费端创建一个选择器:
          String selector = “city = 'hangzhou' AND company='mycompany'”;
          QueueReceiver qReceiver = qSession.createReceiver(testQ,selector);
          其中“=”和“AND”为比较运算符,其他常用比较运算符还有:
          算数比较运算符(=、>、<、<=、<>等)
          like运算符、BETWEEN运算符、IN运算符、IS NULL运算符等
          

8 、消息过滤

消息订阅者需要对消息进行过滤,否则订阅者就会接受到主题或队列的每一条消息,浪费了不必要的资源( CPU、内存等),而使用消息过滤技术,能让订阅者只接受它需要的消息。(消息过滤对于队列消费尤其重要,因为一个队列消费者消费消息后其他消费者就不再可用,此时如果不对消息进行过滤处理,这条消息就很可能被浪费掉)。

消息选择器使用消息属性和消息头作为条件表达式的传送载体(消息体不能作为消息选择器的参考对象)。

消息选择器由标识符、常量和比较运算符组成:

例:

     创建一个消息如下:

        TextMessage textMessage = Session.createTextMessage();

         textMessage.setText(“mytestMsg”);

          textMessage.setStringProperty(“city”,”hangzhou”);

         textMessage.setStringProperty(“company”,”alibaba”);

         这条消息中设置的消息属性名 “city” 和 “company” 代表消息选择器的标识符, ”hangzhou” 和 ”alibaba”代表常量

 

          在消费端创建一个选择器:

          String selector = “city = 'hangzhou' AND company='alibaba' ”;

          QueueReceiver qReceiver = qSession.createReceiver(testQ,selector);

          其中 “=” 和 “AND” 为比较运算符,其他常用比较运算符还有:

          算数比较运算符( = 、 > 、 < 、 <= 、 <> 等)

          like 运算符、 BETWEEN 运算符、 IN 运算符、 IS NULL 运算符等

         

 

 

9 、消息传送的可靠性

在消息的传送过程中由于网络、软硬件故障等都会导致消息的发送失败, jms 为保证消息的传送定义了 3 条法则:

( 1 )消息自主性,消息是自包含的自主性实体,当发送端发出这条消息后这条消息就不再受发送端的限制,它可以在多个进程间被多次发送。

( 2 )存储转发,当消息被标记位持久性消息时,就由 jms 提供者利用 “ 保存并转发 ” 机制,将消息保存在可信的介质上,防止发生故障时仍然可以正常恢复

( 3 )消息确认机制,服务器确认已经从发送端收到了消息,消费者则从确认从服务器接收了消息,对消息传送过程的监控,保证了消息的可靠传送。 消息确认的 3 种模式:

1 、 AUTO_ACKNOWLEDGE 
从消息生产者角度:发送消息后就开始阻塞,直到从消息服务器收到回复,期间如发生异常则认为消息未被传送   

从消息服务器角度:非持久消息在接受到消息后通知生产者,并将消息存入内存,持久性消息在接受道消息后先存入磁盘,然后通知生产者   

从消费者角度:接受到消息后就向服务器发送确认信息,如果服务器没有收到确认,会重新发送   

2 、 CLIENT_ACKNOWLEDGE 
消费者可在处理完业务逻辑后在代码重显示调用 message.acknowledge() 通知 jms 提供者已成功接收道消息   
3 、 DUPS_ACKNOWLEDGE 
可将一条消息向同一目的地发送两次以上  

 

 

这里介绍两个概念:

( 1 )持久化消息:消息持久化就是在发送者将消息发送出去后,消息中心首先将消息存储到本地数据文件、内存数据库或者远程数据库等,然后试图将消息发送给接收 者,发送成功则将消息从存储中删除,失败则继续尝试。消息中心启动以后首先要检查制定的存储位置,如果有未发送成功的消息,则需要把消息发送出去。通过在消息头设置来实现:如

MessageProducer producer = session.createProducer(destination);

producer.setDeliveryMode(DeliveryMode.PERSISTENT);

(2) 持久订阅者和非持久订阅者:非持久订阅者是指某个订阅者由于某种原因停止运行,那么在停止运行期间发布到该订阅者所订阅主题的消息就会无法获得,持久订阅者则刚好相反,持久订阅者会接收发送到订阅主题的所有消息,无论订阅者是否正常运行,电子邮件就是类似的一个例子。

持久化消息和持久订阅者在服务器和消费者端之间的消息传送保证机制比较类似,但在有一种情况下他们还是存在区别的,对持久订阅者来说,当消息服务器向发送者发送确认消息之后,并为当前未运行的持久订阅者将消息保存到介质之间如果发送故障,该消息就会丢失,而持久化消息则是先保存消息道介质,然后才向发送者发送确认消息,所以不存在这个问题,因此严格来说持久化消息的可靠性会更高。

10 、事务性消息

jms 事务性保证了一组发送的消息或接收的消息要么全部成功要么全部失败,概念上和我们在java 中使用的jta 相似,但jms 事务是由jms 提供者来管理的,而不是jta 。

使用方法如下:

   // 此处用true ,表示使用事务性消息

Session session =connection.createSession(true, Session.AUTO_ACKNOWLEDGE);

// 用来发送的3 个消息

MessageProducer sender = session.createProducer(“queue/testQueue”);

try{

    TextMessage message1 = session.createTextMessage(“ 要发送的消息1”);

      sender.send(message);

    TextMessage message2 = session.createTextMessage(“ 要发送的消息2”);

      sender.send(message);

    TextMessage message3 = session.createTextMessage(“ 要发送的消息3”);

      sender.send(message);

        session.commit();

    }catch(Exception e){

        try{

          session.rollback();

       }catch(JMSException e){

       }

    }

 

© 著作权归作者所有

Dylan1009
粉丝 5
博文 194
码字总数 130862
作品 0
广州
程序员
私信 提问
晒晒你看过的哪些Java相关的书。

@红薯 要我们晒Jar包 , 我倒想看看大家都看过什么Java编程相关的书籍,我先来:如下 1、iText in Action 主要内容: a、自动化静态和动态XFA表单 b、如何从XML生成动态PDF或数据库 c、如何添...

刘学炜
2012/09/27
317
4
Akka v2.4.9 发布,Actor 模型开发库

Akka v2.4.9 发布了。Akka 是一个用 Scala 编写的库,用于简化编写容错的、高可伸缩性的 Java 和 Scala 的 Actor 模型应用。 该版本更新如下: Akka Documentation HTML for Java and Scala...

局长
2016/08/20
547
0
【项目管理】软件项目经理须知的 Java 8 安全知识

【译者按】作为软件研发项目的项目经理,只懂项目管理知识是不够的,需要对软件技术本身有基本的了解。Java 是一种主流的系统开发语言,其安全设计对于构建安全的信息系统有至关重要的意义。...

军雷
2017/06/08
0
0
关于java共享内存模型之间,下面两段话是不是相互矛盾啊。谁给解释一下?

1 同步是指程序用于控制不同线程之间操作发生相对顺序的机制。在共享内存并发模型里,同步是显式进行的。程序员必须显式指定某个方法或某段代码需要在线程之间互斥执行。在消息传递的并发模型...

_凤求凰_
2015/11/25
94
1
一线互联网公司研发工程师(Java)月薪25-50k的技能要求整理

良好的开发基础,精通Java语言基础,熟练掌握多线程开发技术, 对于Java基础技术体系(包括JVM、类装载机制、JUC、NIO、网络)有深入的理解和实践经验; 熟练掌握常用Java技术框架,能编写高...

vvx1024
2018/01/06
0
0

没有更多内容

加载失败,请刷新页面

加载更多

fabric-sdk-java 1.4安装说明

Hyperledger Fabric Java SDK是开发基于Hyperledger Fabric区块链的Java应用之必备开发包。本文将介绍如何在Maven、Gradle和Eclipse中安装使用最新1.4版本的Hyperledger Fabric Java SDK。 ...

汇智网教程
30分钟前
1
0
Linux基础优化与安全归纳总结

一名运维工程师在运维岗位上时间久了,就会发现Linux优化的重要性,同时会给运维工作带来很多的便利性。本人逐渐认识到了这一点,所以特意在工作闲暇之余,通过阅读Linux相关书籍及向同事、同...

xiangyunyan
31分钟前
2
0
要996还是要生活?

今天早上,嗅嗅还在被窝的时候,睁开朦胧的双眼,习惯性的打开手机,一行小字映入眼帘:要996还是要生活 当真是垂死病中惊坐起,嗅嗅瞬间就清醒过来了。 其实嗅嗅当时的内心活动是:别闹了,...

forespider
32分钟前
4
0
SpringCloud微服务构建

遇到问题 修改server.port后,端口变更不起作用,总是8080 src/java/resources应该和rc/java/java在同一个层级,否则boot读取不到配置信息

铲平王
32分钟前
2
0
[IntelliJ IDEA][maven]properties in parent definition are prohibited报错

<parent> ... <version>${platform.version}</version><parent> IntelliJ报错: properties in parent definition are prohibited 解决: idea的错误提示,不用管 或者升级到maven3.5.......

Danni3
33分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部