1. 消息类型的选择
Java的JMS消息类型有文本类型,对象类型,字节类型,流类型,XML类型,在实际项目中,用的最多的是文本类型,对象类型和xml类型的消息。建议最好不用对象类型,因为如果用对象类型的话,调试的时候是很麻烦的,首先你必须要写专门的测试代码用来发送消息,第二,必须要管理对象所属的类的不同版本,第三,不方便查看queue或者topic中的消息内容。而如果使用文本类型或者xml类型的消息,那么可以很容易的通过JMS中间件提供的一些管理工具来发送测试消息,查看消息内容,并且更加容易管理不同版本之间的兼容性。如果一定要用对象类型消息的话,建议使用xstream把对象转化为xml。
2. 是使用queue还是topic?
这两者的定义是很清楚的,也很容易区分。但是在实际项目中,如何来取舍呢?我的建议是尽量用queue。如果你的项目用到了JMS,那么你的系统也应该是到了需要部署在集群环境的规模了。用topic在集群环境下会带来很多麻烦。举个简单的例子,如果你是用MDB来处理topic的消息,你有一个MDB名为SampleMDB,它以集群的方式分别部署在A服务器和B服务器上。那么有可能同一条topic消息被同一个MDB处理两次。虽然一些JMS中间件提供商为解决这种问题提供了一些解决方案,例如把subsriber分组,但是它为开发和调试都带来了很大的麻烦。topic消息的处理也要比queue的复杂,很难跟踪topic消息的处理过程。
那么,如果不用topic的话,怎么来实现topic这种性质的消息处理呢?可以写一个消息转发器,把一个queue上的消息转发给所有关注这个queue的其它queue中。例如,有一个queue,名为SampleQ1,一个消息发送者sender,一个消息转发器router,有三个handler A,B,C需要处理这个queue中的消息。那么,sender发送消息到SampleQ1,router接收SampleQ1的消息后分别发送到SampleQ1_A,SampleQ1_B,SampleQ1_C,handler A,B,C分别从队列SampleQ1_A,SampleQ1_B,SampleQ1_C中接收消息。
3. 用JMS来解决什么问题?
一提起JMS可以做什么,第一想到的就是异步处理。面试的时候问JMS可以做什么?大多数的回答是:用JMS来异步发送邮件!(到底应该怎么样构建一个邮件发送系统不是本文的主题,以后有时间我会专门来谈谈在我的项目中,我是怎么来设计邮件发送系统的)。其实,还可以用JMS来解决很多复杂的问题,例如分布,并发,系统解耦,负载均衡,热部署,触发器等等,这些复杂的问题因为引入了JMS而变的更加简单。下面简单介绍下解决分布,并发问题的场景。
3.1 用JMS来解决并发问题
queue的概念大家都很清楚了,那就是queue里的一条消息只会被一个消息接收者处理。基于这个概念,我们可以在系统中对并发要求很严格的模块中引入JMS的使用。例如,系统的送积分,一般这个模块是用一个定时器,例如quartz,每天定期查询数据库,如果发现有满足条件的记录,那么就把积分送给会员。如果同时有多个quartz在运行,那么必须严格控制防止并发的对同一条记录送多次积分。解决这个问题有很多方法,可以通过业务的设计,系统的部署,数据库的设计,事务的控制等方法来实现,在这里提一个用JMS来解决问题的方法:在插入记录的同时发送一个queue的消息。这样即使有多个送积分的MDB实例在运行,也只会被一个实例处理。
3.2 用JMS来解决分布的问题
解决分布有两种类型:
第一种是指消息是集中的,但消息的处理是分布的。例如,系统可能会被分为前台与后台,这两个系统是部署在不同的网段里的。那么怎么把前台发生的业务通知后台系统呢?当然,可以通过一个类似定时器的玩意定期去数据库查询。但这种方式要么就是浪费系统资源,可能在定期查询中80%的时间都是在做无用功,要么就是业务请求没有被及时处理。,因为定期的时间总是有一个时间间隔的。用JMS来处理这个问题会怎么样呢?前台系统在处理完业务请求后的同时发送一个消息到queue中,后台系统的消息接收者接收到消息后立即处理。这里消息的处理也可能有一定的延期,但这主要取决于消息服务器的硬件能力,网络带宽,消息接收者的处理速度等。
第二种是指消息也是分布的。很多消息中间件都提供了消息路由的功能,即消息发送到一个消息服务器后,这个消息服务器根据定义的规则再把这条消息路由转发到其它的消息服务器。例如,可能在北京的一个数据中心部署了数据采集系统,采集到数据后以消息的方式发送到消息服务器,然后消息服务器再把这条消息路由到上海的数据中心,再由上海数据中心部署的数据处理系统来处理这条消息。
4. JMS与事务,一定要用JTA事务吗
很多人接触到JTA事务都是从用JMS开始的,毕竟同时要连多个数据库的的系统并不是那么的多!而要用JTA事务的话,就得要在笨重的应用服务器中部署。(当然,你也可以用类似atomikos的轻量级JTA事务管理器),更重要的是,并不是事务本身的技术有多复杂,而是事务的界定,这种事务的界定有时都不是程序员能决定的事情,需要在设计的时候就要考虑清楚,甚至可能还需要业务人员的参与。(题外话:经常问面试的,用spring的aop做什么?大多数答:用来管理事务!事务要真这么简单该多好啊!)
我也不是要反对用JTA事务,而是要说明一下,用JMS,并非一定要用JTA事务。这可以分为三种场景:
一,必须用JTA事务,这种情况下,一般消息的接收者只从消息本身获得数据并进行处理。所以必须要保证消息的发送与所依赖的业务保持一致。
二,不需要用事务,这种情况下, 要么是业务无关紧要,例如用JMS来记录日志。要么是发送的消息仅仅是一个作为后续业务处理的一个触发器!消息接收者仅仅是从消息中获得一个id,然后根据这个id去查询所依赖的其它数据进行业务处理。即使消息丢失也没关系,可以通过其它的机制来补偿。
三,消息丢失可以通过补偿事务来完成。这个依赖与具体实现,就不详细说了。
5. 处理消息永远比发送消息慢!
要保证你的JMS应用稳定的运行,那么你必须在开发,部署的时候时刻重视这个问题。
首先,需要把发送消息的连接池与接收消息的连接池分开。以避免接收消息的连接过过而导致发送消息的应用拿不到连接。
在一个连接上并发的处理消息,而不是连接打开,处理一个消息,马上关闭连接。
合理的设置消息的过期时间,否则消息日积月累,最终超出queue的size。
对于非关键业务的消息处理,可以采用异步处理的方法:接收到消息后并不是立刻处理,而是放到一个任务池或者线程池中处理。如果消息处理失败,则把消息重新发送回队列中。
分享到:
相关推荐
描述"jms简单的案例,用的activemq,使用jms前请先启动activemq服务器"表明这是一个初级的JMS实践,涉及到使用ActiveMQ作为服务器,而且在运行任何JMS相关的代码之前,需要确保ActiveMQ服务已经启动。 **ActiveMQ与...
JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS
《JMS 1.1 API详解与应用实践》 Java消息服务(Java Message Service,简称JMS)是Java平台中用于企业级应用间异步通信的一种标准接口。JMS 1.1是其一个重要的版本,它为分布式系统中的应用程序提供了一种可靠的...
Java消息服务(Java Message Service,简称JMS)是Java平台中用于企业级应用集成的标准化接口,它允许应用程序创建、发送、接收和读取...通过深入学习和实践JMS,你可以提升你的技能,更好地适应复杂的企业级开发需求。
【JBOSST建立JMS应用实例】 JBOSST(Java Business Open Source ...通过实践这些步骤,开发者可以掌握如何在JBOSST环境中利用JMS进行高效的数据通信。同时,提供的文档和项目文件为深入理解和实践提供了丰富的资源。
Java消息服务(Java Message Service,简称JMS)是Java平台中...对于初学者来说,这些文档会提供一个良好的起点,帮助他们逐步掌握JMS的核心概念和实践技巧,从而在开发中有效地利用消息传递机制进行解耦和异步处理。
**标题:“JMS 使用 ActiveMQ 传送文件”** 在IT领域,Java消息服务(Java ...通过这些知识点的学习和实践,开发者可以掌握使用JMS和ActiveMQ进行文件传输的核心技能,为构建可靠的、分布式的应用打下坚实的基础。
总的来说,JMS入门实例结合WebLogic的安装和配置,为初学者提供了一个了解和实践Java消息服务的完整流程。通过这个过程,开发者可以学习到如何在WebLogic这样的企业级应用服务器上构建可靠的消息传递系统,以及如何...
Java消息服务(Java Message Service,简称JMS)是Java平台中用于企业级应用集成的API,主要用于在...通过下载并研究"JMS1.1规范(中文).pdf",开发者可以深入理解JMS的工作原理,提高其在企业级应用开发中的实践能力。
WebLogic Server是一款由Oracle公司提供的企业级Java应用服务器,它支持Java EE标准并提供各种服务,包括JMS(Java Message Service)服务器。...在实际操作中,一定要遵循最佳实践,确保系统的稳定性和安全性。
描述中的"java消息系统 JMS 学习代码 例子 jar"表明这个压缩包是为了学习JMS而准备的,里面包含了示例代码,便于开发者理解和实践JMS的工作原理。`jar`文件通常用于打包和分发Java类库,这里可能是为了方便导入和...
标题中的“jms”指的是Java消息服务(Java Message Service),它是Java平台中用于在分布式环境...如果你对JMS的具体实现、使用案例或最佳实践感兴趣,可以进一步探索相关的开源项目、文档或在线课程,以深化你的理解。
**正文** ...总的来说,"jms整合spring工程"是一个实用的示例,帮助开发者理解和实践在Spring中使用JMS与ActiveMQ进行消息通信。通过深入研究该项目,可以掌握JMS和Spring集成的关键技术和最佳实践。
6. **最佳实践** - **正确使用事务**: 根据业务需求选择合适的事务级别,保证消息的一致性。 - **合理设计消息格式**: 避免过于复杂的消息结构,便于消费和解析。 - **监控和管理**: 实时监控JMS系统的性能和健康...
通过阅读`jms_zh.chm`和`jms_en.chm`文档,你可以深入了解JMS的工作原理、配置方法、编程接口以及最佳实践。对于开发分布式、高并发的企业级应用,掌握JMS是必不可少的技能。同时,文档还可能涵盖了错误处理、性能...
在具体实践中,我们需要在`applicationContext.xml`中配置JMS连接工厂、目的地(队列或主题)、以及消息监听器。然后,创建消息生产者和消费者类,分别调用`JmsTemplate.send()`方法发送消息,和重写`onMessage()`...
Java消息服务(Java Message ..."JMS简明教程.pdf"这份文档应该详细介绍了这些概念,并可能包括实例代码和最佳实践,可以帮助初学者快速入门JMS。学习JMS不仅可以提升你的专业技能,也有助于解决复杂的企业级问题。
**七、C# JMS开发实践** 在实际开发中,C#开发者需要了解如何创建连接工厂、创建会话、创建目的地(队列或主题)、创建生产者和消费者,以及如何发送和接收消息。此外,还要关注错误处理、性能优化和资源管理。 ...
Java消息服务(Java Message Service,简称JMS)是Java平台中用于企业级应用集成的API,主要用于在分布式环境中传递消息,实现应用程序之间的异步通信。...阅读“JMS教程.pdf”将更深入地了解JMS的细节和实践技巧。
《WD MyBook JMS578固件升级:理解与实践》 在现代数字生活中,外部存储设备扮演着至关重要的角色。WD MyBook系列作为知名硬盘制造商西部数据(Western Digital)推出的高端外置硬盘,凭借其可靠性和大容量存储赢得...