- 为什么要消息?
工行直连要用到深证通数据交换平台(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. 消息适配器该用哪一个?
<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.文件的内容如下:
<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文件。
<?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前端订阅消息
<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管理。下面几篇文章,将会带你慢慢解决这些问题。
目前,J2EE 项目中基本上都用到Spring,Spring整合Blazeds实现ActiveMQ JMS消息服务,如果想进一步了解Blazeds的JMS消息服务,请大家参考我这篇博客。
分享到:
相关推荐
Flex PureMVC Flex BlazeDS Spring Hibernate 整合 里面一些图标是包双击可查看源代码
使用flex 4.5 + Spring 3.0 + Hibernate 3.3 + Cairngorm 2.2.1 + BlazeDS 3.3.0 + Spring BlazeDS Integration 1.0.3整合出的一个登录的小demo·
一步一步讲解了PureMVC+Flex+BlazeDS+Spring+Hibernate的搭建,适合初学者参照
跟我一步步搭建 PureMVC+Flex+BlazeDS+Spring+Hibernate
跟我一步步搭建PureMVC+Flex+BlazeDS+Spring+Hibernate
一步步搭建+PureMVC+Flex+BlazeDS+Spring+Hibernate
自己写的一个Flex+J2EE实例(cairngorm+blazeDS+hibernate+spring)part1.pdf
本课程主要是讲解Flex 4.6和ActionScript 3.0使用方法和技巧
整合spring3 blazeds activeMQ(jms) 通过flex consumer来订阅消息。时时更新消息内容
Flex+J2EE实例(cairngorm+blazeDS+hibernate+spring) part4.pdf 终结版
NULL 博文链接:https://keren021.iteye.com/blog/1163165
本课程主要是讲解Flex 4.6和ActionScript 3.0使用方法和技巧
Flex+J2EE实例(cairngorm+blazeDS+hibernate+spring) part3.pdf 第三部分。。add spring and hibernate
一个 Flex+J2EE实例(cairngorm+blazeDS+hibernate+spring) 本实例为一个 flex 与 java通信项目。前端采用cairngorm框架,后台 采用hibernate+spring 每个部署 步骤,附详细 图文解释。旨在 采用 一种快速开发 ...
自己写的一个Flex+J2EE实例(cairngorm+blazeDS+hibernate+spring) part2.pdf 这个是第二部分,循序渐进,让初学者慢慢掌握搭框架的方法
Flex+Gilead+BlazeDS+Spring+Hibernate示例Demo,使用1:n和m:n两个双向关系,很好的演示了Gilead的Hibernate Lazy Killer特性,借助Gilead可以有效规避DTO模式的大量繁琐代码。效果图展示地址:...
BlazeDS+Flex+Tomcat开发J2EE
flex 结合spring,完成前后台数据传递。
flex4+blazeDS+blazeSpringIntegration+spring+ibatis开发教程
Flex订阅JMS实现实时刷新 利用BlazeDS和JMS的消息机制实现数据的推送,从而实现页面的实时刷新(含详细的说明文档和源码)