`

Blazeds+JMS（ActiveMQ）+Spring实现消息

    博客分类：
  • JMS
JMSActiveMQSpringFlexApache 
阅读更多

转载：http://yunzhongxia.iteye.com/blog/565249

 

 

  1. 为什么要消息？

工行直连要用到深证通数据交换平台（MDEP），MDEP的请求是不同步的。托管行每天会推过来一些头寸报表信息，这些信息要及时的反应给业务人员。另外，文件扫描和预警都要及时的通知给业务人员。因此，平台利用Blazeds的消息。值得说明的一点是：BlazeDS 是一个基于服务器的 Java 远程控制 (remoting) 和 Web 消息传递 (messaging) 技术，以LGPL（Lesser GNU Public License）公共许可证书发布。它能够使得后端的 Java 应用程序和运行在浏览器上的 Adobe Flex 应用程序相互通信。在Java应用服务器上，它以servlet的形式存在， 因此可以在任何标准Java网络应用中运用它。Blazeds的消息机制是采用不断的轮询来实现的，因此性能不怎么好，并发数最大为100，LCDS的消息机制是采用java的NIO，最高并发数是1000，Blazeds和LCDS相比性能还是比较差的，不过***系统的用户数比较少的情况下，Blazeds还是可以的，毕竟，客户都是比较吝啬的，有免费的肯定不想掏钱买昂贵的LCDS。

 

    2. 消息适配器该用哪一个？

 

Java代码 复制代码
  1. <adapters>   
  2.         <adapter-definition id="actionscript"  
  3.             class="flex.messaging.services.messaging.adapters.ActionScriptAdapter"  
  4.             default="true" />   
  5.         <adapter-definition id="jms"  
  6.             class="flex.messaging.services.messaging.adapters.JMSAdapter" />   
  7.     </adapters>  
<adapters>
		<adapter-definition id="actionscript"
			class="flex.messaging.services.messaging.adapters.ActionScriptAdapter"
			default="true" />
		<adapter-definition id="jms"
			class="flex.messaging.services.messaging.adapters.JMSAdapter" />
	</adapters>

 

Blazeds提供了两种消息适配器，actionscript和jms.项目一期用的是actionscript适配器，但是有的时候发现文件扫描的消息不能发送到客户端，一直也没有找到原因，关键是Log里面找不到原因。二期应该会有大量的消息要推送到前端，因此打算用jms消息适配器。消息先发送到消息服务器上，flex端订阅消息，如果服务器上有消息在客户端就显示出来。消息服务器很多都是收费的，开源的有ActiveMQ、OPENJMS等。

 

   3.消息服务器该用哪个？

    

　ActiveMQ 是Apache的产品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。在网上查阅了一下关于ActiveMQ 的文档也比较多，而且是开放源代码的，blazeds的官方文档上的例子就是用的ActiveMQ作为消息服务器，因此消息服务器就选它了。

 

   4. 如何搭建环境？

 

      首先要在J2EE服务器（tomcat6）中提供消息服务（JNDI）。在WebRoot/WETA-INFw文件夹下新建一个context.xml.文件的内容如下：

 

Xml代码 复制代码
  1. <Context privileged="true" antiResourceLocking="false"  
  2.     antiJARLocking="false" reloadable="false">  
  3.     <!-- Resourced needed for JMS -->  
  4.     <Resource name="jms/flex/TopicConnectionFactory"  
  5.         type="org.apache.activemq.ActiveMQConnectionFactory"  
  6.         description="JMS Connection Factory"  
  7.         factory="org.apache.activemq.jndi.JNDIReferenceFactory"  
  8.         brokerURL="tcp://localhost:61616"  
  9.         brokerName="LocalActiveMQBroker" />  
  10.     <Resource name="jms/topic/flex/simpletopic"  
  11.         type="org.apache.activemq.command.ActiveMQTopic"  
  12.         description="my Topic"  
  13.         factory="org.apache.activemq.jndi.JNDIReferenceFactory"  
  14.         physicalName="FlexTopic" />  
  15.     <Resource name="jms/flex/QueueConnectionFactory"  
  16.         type="org.apache.activemq.ActiveMQConnectionFactory"  
  17.         description="JMS Connection Factory"  
  18.         factory="org.apache.activemq.jndi.JNDIReferenceFactory"  
  19.         brokerURL="tcp://localhost:61616"  
  20.         brokerName="LocalActiveMQBroker" />  
  21.     <Resource name="jms/queue/flex/simplequeue"  
  22.         type="org.apache.activemq.command.ActiveMQQueue"  
  23.         description="my Queue"  
  24.         factory="org.apache.activemq.jndi.JNDIReferenceFactory"  
  25.         physicalName="FlexQueue" />  
  26.     <!--   
  27.     <Valve className="flex.messaging.security.TomcatValve" />  
  28.      -->  
  29. </Context>   
<Context privileged="true" antiResourceLocking="false"
	antiJARLocking="false" reloadable="false">
	<!-- Resourced needed for JMS -->
	<Resource name="jms/flex/TopicConnectionFactory"
		type="org.apache.activemq.ActiveMQConnectionFactory"
		description="JMS Connection Factory"
		factory="org.apache.activemq.jndi.JNDIReferenceFactory"
		brokerURL="tcp://localhost:61616"
		brokerName="LocalActiveMQBroker" />
	<Resource name="jms/topic/flex/simpletopic"
		type="org.apache.activemq.command.ActiveMQTopic"
		description="my Topic"
		factory="org.apache.activemq.jndi.JNDIReferenceFactory"
		physicalName="FlexTopic" />
	<Resource name="jms/flex/QueueConnectionFactory"
		type="org.apache.activemq.ActiveMQConnectionFactory"
		description="JMS Connection Factory"
		factory="org.apache.activemq.jndi.JNDIReferenceFactory"
		brokerURL="tcp://localhost:61616"
		brokerName="LocalActiveMQBroker" />
	<Resource name="jms/queue/flex/simplequeue"
		type="org.apache.activemq.command.ActiveMQQueue"
		description="my Queue"
		factory="org.apache.activemq.jndi.JNDIReferenceFactory"
		physicalName="FlexQueue" />
	<!-- 
	<Valve className="flex.messaging.security.TomcatValve" />
	 -->
</Context>

 

      备注：其实通过上面的配置后，在tomcat6\conf\Catalina\localhost文件下生成了一个utmost.xml文件。关于上面的配置，请继续关注我的博客，我会在以后的写博客的。

 

     修改WEB-INF/flex/messaging-config.xml文件。

Java代码 复制代码
  1. <?xml version="1.0" encoding="UTF-8"?>   
  2. <service id="message-service" class="flex.messaging.services.MessageService">   
  3.     <adapters>   
  4.         <adapter-definition id="actionscript"  
  5.             class="flex.messaging.services.messaging.adapters.ActionScriptAdapter"  
  6.             default="false" />   
  7.         <adapter-definition id="jms"  
  8.             class="flex.messaging.services.messaging.adapters.JMSAdapter"  
  9.             default="true" />   
  10.     </adapters>   
  11.   
  12.     <default-channels>   
  13.         <channel ref="my-streaming-amf" />   
  14.         <channel ref="my-polling-amf" />   
  15.     </default-channels>   
  16.   
  17.     <destination id="scanfile" />   
  18.     <!-- active MQ stock feed -->   
  19.     <destination id="jmsamc"">   
  20.         <adapter ref="jms" />   
  21.         <properties>   
  22.             <!--这里的配置是最关键的，只有durable属性设计为true才能实现持久化订阅-->   
  23.             <server>   
  24.                 <durable>true</durable>   
  25.             </server>   
  26.             <jms>   
  27.                 <connection-factory>   
  28.                     java:comp/env/jms/flex/TopicConnectionFactory   
  29.                 </connection-factory>   
  30.                 <destination-type>Topic</destination-type>   
  31.                 <destination-jndi-name>   
  32.                     java:comp/env/jms/topic/flex/simpletopic   
  33.                 </destination-jndi-name>   
  34.                 <message-type>javax.jms.TextMessage</message-type>   
  35.                 <!-- 持久性 -->   
  36.                 <delivery-mode>PERSISTENT</delivery-mode>   
  37.                 <!-- 优先级  -->   
  38.                 <message-priority>DEFAULT_PRIORITY</message-priority>   
  39.                 <!--应答模式   -->   
  40.                 <acknowledge-mode>AUTO_ACKNOWLEDGE</acknowledge-mode>   
  41.                 <initial-context-environment>   
  42.                     <property>   
  43.                         <name>Context.SECURITY_PRINCIPAL</name>   
  44.                         <value>anonymous</value>   
  45.                     </property>   
  46.                     <property>   
  47.                         <name>Context.SECURITY_CREDENTIALS</name>   
  48.                         <value>anonymous</value>   
  49.                     </property>   
  50.                     <property>   
  51.                         <name>Context.INITIAL_CONTEXT_FACTORY</name>   
  52.                         <value>   
  53.                             org.apache.activemq.jndi.ActiveMQInitialContextFactory   
  54.                         </value>   
  55.                     </property>   
  56.                     <property>   
  57.                         <name>Context.PROVIDER_URL</name>   
  58.                         <value>tcp://192.168.124.114:61616</value>   
  59.                     </property>   
  60.                 </initial-context-environment>   
  61.             </jms>   
  62.         </properties>   
  63.         <channels>   
  64.             <channel ref="my-polling-amf" />   
  65.             <channel ref="my-streaming-amf" />   
  66.         </channels>   
  67.     </destination>   
  68. </service>  
<?xml version="1.0" encoding="UTF-8"?>
<service id="message-service" class="flex.messaging.services.MessageService">
	<adapters>
		<adapter-definition id="actionscript"
			class="flex.messaging.services.messaging.adapters.ActionScriptAdapter"
			default="false" />
		<adapter-definition id="jms"
			class="flex.messaging.services.messaging.adapters.JMSAdapter"
			default="true" />
	</adapters>

	<default-channels>
		<channel ref="my-streaming-amf" />
		<channel ref="my-polling-amf" />
	</default-channels>

	<destination id="scanfile" />
	<!-- active MQ stock feed -->
	<destination id="jmsamc"">
		<adapter ref="jms" />
		<properties>
			<!--这里的配置是最关键的，只有durable属性设计为true才能实现持久化订阅-->
			<server>
				<durable>true</durable>
			</server>
			<jms>
				<connection-factory>
					java:comp/env/jms/flex/TopicConnectionFactory
				</connection-factory>
				<destination-type>Topic</destination-type>
				<destination-jndi-name>
					java:comp/env/jms/topic/flex/simpletopic
				</destination-jndi-name>
				<message-type>javax.jms.TextMessage</message-type>
				<!-- 持久性 -->
				<delivery-mode>PERSISTENT</delivery-mode>
				<!-- 优先级  -->
				<message-priority>DEFAULT_PRIORITY</message-priority>
				<!--应答模式   -->
				<acknowledge-mode>AUTO_ACKNOWLEDGE</acknowledge-mode>
				<initial-context-environment>
					<property>
						<name>Context.SECURITY_PRINCIPAL</name>
						<value>anonymous</value>
					</property>
					<property>
						<name>Context.SECURITY_CREDENTIALS</name>
						<value>anonymous</value>
					</property>
					<property>
						<name>Context.INITIAL_CONTEXT_FACTORY</name>
						<value>
							org.apache.activemq.jndi.ActiveMQInitialContextFactory
						</value>
					</property>
					<property>
						<name>Context.PROVIDER_URL</name>
						<value>tcp://192.168.124.114:61616</value>
					</property>
				</initial-context-environment>
			</jms>
		</properties>
		<channels>
			<channel ref="my-polling-amf" />
			<channel ref="my-streaming-amf" />
		</channels>
	</destination>
</service>

 

felx前端订阅消息

Java代码 复制代码
  1. <mx:ChannelSet id="cs">    
  2.         <mx:AMFChannel url="http://192.168.124.114:8099/utmost/messagebroker/amfpolling"/>    
  3.         <mx:AMFChannel url="http://192.168.124.114:8099/utmost/messagebroker/streamingamf"/>    
  4.     </mx:ChannelSet>    
  5.     
  6.     <mx:Consumer id="consumer" destination="jmsamc" channelSet="{cs}"    
  7.          message="messageHandler(event.message)" selector=""/>    
  8.         
<mx:ChannelSet id="cs"> 
        <mx:AMFChannel url="http://192.168.124.114:8099/utmost/messagebroker/amfpolling"/> 
        <mx:AMFChannel url="http://192.168.124.114:8099/utmost/messagebroker/streamingamf"/> 
    </mx:ChannelSet> 
 
    <mx:Consumer id="consumer" destination="jmsamc" channelSet="{cs}" 
         message="messageHandler(event.message)" selector=""/>

 

 

通过以上的配置，基本上实现了Blazeds和JMS的结合。但是还没有解决二期项目的问题，服务器一启动，文件扫描就应该开始；预警是达到一定时间要发送消息给客户端的；ActiveMQ怎么交给Spring管理。下面几篇文章，将会带你慢慢解决这些问题。
 

分享到：
| Jms之ActiveMQ学习笔记
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    PureMVC+Flex+BlazeDS+Spring+Hibernate.doc

    标题中的“PureMVC+Flex+BlazeDS+Spring+Hibernate.doc”指的是一项整合了多种技术的Web应用开发方案，这些技术包括PureMVC、Flex、BlazeDS、Spring和Hibernate。这篇文档可能是指导读者如何将这些技术结合在一起...

    BlazeDS+Spring+activeMQ outofmemory

    标题 "BlazeDS+Spring+activeMQ outofmemory" 指的是在使用BlazeDS、Spring和ActiveMQ集成的环境中遇到了内存溢出问题。BlazeDS是一个开放源码的服务器端技术，它允许双向通信，使Flex或AJAX客户端能够与Java后端...

    Flex4.X+BlazeDS+Spring3L实战开发在线书店四

    【标题】"Flex4.X+BlazeDS+Spring3实战开发在线书店四"涉及的核心技术栈是Adobe Flex 4.6、BlazeDS、Spring 3框架以及Java相关的JPA和Hibernate，配合MySQL数据库实现一个在线书店的完整系统。下面将详细阐述这些...

    spring3+ActiveMQ+blazeds+flex consumer

    本项目“spring3+ActiveMQ+blazeds+flex consumer”旨在整合一系列技术，以实现这样的功能。下面将详细阐述这些技术及其整合过程。 首先，Spring框架（Spring3）是Java领域最流行的轻量级应用框架之一，它提供了...

    flex+blazeds+spring

    标题“flex+blazeds+spring”表明我们要探讨的是如何将Flex前端与BlazeDS中继层和Spring后端框架结合起来，实现完整的数据交互和应用程序逻辑。 在Flex与Spring集成的环境中，Flex作为用户界面展示层，负责与用户...

    Flex4.X+BlazeDS+Spring3L实战开发在线书店二

    BlazeDS还包含了LiveCycle Data Services组件，提供数据推送、消息队列和Remoting服务，有助于实现实时Web应用。 接下来，我们讨论Spring 3，这是一个广泛使用的Java企业级应用框架。Spring提供了依赖注入（DI）和...

    flex+Spring+Hibernate+Cairngorm+BlazeDS+Spring BlazeDS Integration整合框架

    使用flex 4.5 + Spring 3.0 + Hibernate 3.3 + Cairngorm 2.2.1 + BlazeDS 3.3.0 + Spring BlazeDS Integration 1.0.3整合出的一个登录的小demo·

    Flex+J2EE实例（cairngorm+blazeDS+hibernate+spring）完整版本

    一个 Flex+J2EE实例（cairngorm+blazeDS+hibernate+spring） 本实例为一个 flex 与 java通信项目。前端采用cairngorm框架，后台 采用hibernate+spring 每个部署 步骤，附详细 图文解释。旨在 采用 一种快速开发 ...

    Flex+Gilead+BlazeDS+Spring+Hibernate Demo

    Flex+Gilead+BlazeDS+Spring+Hibernate示例Demo，使用1:n和m:n两个双向关系，很好的演示了Gilead的Hibernate Lazy Killer特性，借助Gilead可以有效规避DTO模式的大量繁琐代码。效果图展示地址：...

    Flex4.X+BlazeDS+Spring3L实战开发在线书店三

    《Flex4.X+BlazeDS+Spring3 实战开发在线书店》是一门深入探讨使用Adobe Flex 4.6、BlazeDS、Spring 3框架以及Java相关技术进行Web应用程序开发的课程。这门课程旨在帮助开发者掌握如何构建功能丰富的、交互性强的...

    跟我一步步搭建PureMVC+Flex+BlazeDS+Spring+Hibernate

    根据提供的文件信息，本文将详细介绍如何一步步搭建PureMVC+Flex+BlazeDS+Spring+Hibernate的技术栈。这个过程涉及到了多个技术领域的整合，包括前端的Flex开发、后端的Java开发以及数据库交互等多个方面。 ### 一...

    PureMVC+Flex+BlazeDS+Spring+Hibernate

    标题中的“PureMVC+Flex+BlazeDS+Spring+Hibernate”是一个常见的技术栈组合，用于构建企业级的 Rich Internet Applications (RIA)。这个技术栈包括前端开发框架、后端服务通讯、应用服务器、服务端架构和数据持久化...

    Spring整合Blazeds实现ActiveMQ JMS消息服务

    标题中的“Spring整合Blazeds实现ActiveMQ JMS消息服务”指的是在Java应用程序中使用Spring框架与Blazeds（一个Flex和Java之间的消息传递中间件）集成，通过ActiveMQ（一个流行的开源JMS提供商）来实现消息队列服务...

    flex4+blazeDS+spring+ibatis开发教程

    ### Flex4+BlazeDS+Spring+iBatis 开发教程详解 #### 一、富互联网应用（RIA）概念与背景 ##### RIA定义 富互联网应用（Rich Internet Application，简称RIA）是一种新兴的应用程序形式，它结合了客户端与服务器端...

    Flex + BlazeDS + Java + JMS 通信实例(附源码)

    这种消息传递方式适用于异步处理，可以实现消息的可靠传输和解耦。在本例中，JMS被用来实现实时数据推送，当Java后端有新数据时，通过JMS推送到Flex客户端，进而更新UI。 5. **消息模型**：在JMS中，有两种主要的...

    Myeclipse6.5+flex3+Blazeds+spring+hibernate完美整合

    Myeclipse6.5+flex3+Blazeds+spring+hibernate完美整合，写的非常详细

    跟我一步步搭建 PureMVC+Flex+BlazeDS+Spring+Hibernate

    通过以上步骤，你将成功构建一个完整的PureMVC+Flex+BlazeDS+Spring+Hibernate RIA系统，实现前端与后端的无缝集成，提供高效的数据交换和复杂的业务处理能力。在实际开发中，你可能还需要考虑错误处理、安全性和...

    flex+spring +BlazeDs+spring+ibatis+Cairngorm整合教程（以前下的，忘了来源了，感激这位大神...）

    标题中的“flex+spring +BlazeDs+spring+ibatis+Cairngorm整合教程”涉及到的是一个基于Adobe Flex前端、Spring后端服务、BlazeDS作为数据通信中间件、Spring框架进行服务管理以及Ibatis作为持久层操作的典型企业级...

    Flex+J2EE实例（cairngorm+blazeDS+hibernate+spring） part3.pdf

    ### Flex+J2EE 实例（Cairngorm+BlazeDS+Hibernate+Spring）Part 3 #### 概述 本章节主要介绍了如何在已有的Flex+J2EE架构项目中集成Spring框架和Hibernate持久层框架。通过这种方式，我们可以更好地实现业务逻辑...

Magicbox
Global site tag (gtag.js) - Google Analytics