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

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

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

?

?

<adapters><adapter-definition id="actionscript"/><adapter-definition id="jms"/></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" /><adapter-definition id="jms"/></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管理。下面几篇文章，将会带你慢慢解决这些问题。
?