BlazeDs Messaging service filtering
?BlazeDs?? Message service 为Producer组件提供一种,为自己产生的消息添加信息头(message headers)和副主题(subtopic )的功能,然后Consumer组件基于这些信息指定自己的过滤标准,这样以来,只有符合这些过滤标准的信息才能被Consumer接收。Consumer会把过滤标准发送给server当它调用自身subscribe() 方法时。所以实际上过滤是在server端进行的,在信息被送到consumer之前。(注:过滤是基于信息头和副主题的,所以不需要同时再用其它技术过滤。) ? 用选择器(selectors) ????????? Producer把额外的信息以信息头的形式加入到自己生产的信息中,而Consumer再用信息选择器属性,基于信息头值过滤信息。 ????????? 我们可以用信息的AsyncMessage.headers?属性去指明信息头。然后这个信息头就被关联到一个数组中,这个数组的key值是信息头名称,value就是一个数字或者是一个字串。(注:不要以“JMS'“”DS“来作为信息头名称的开始,这些前缀是被保留的。) 以下代码把一个名为”prop1“信息头加入信息中,并设置了它的值。 <?xml version="1.0"?> <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"> <mx:Script> <![CDATA[ import mx.messaging.*; import mx.messaging.messages.*; import mx.messaging.events.*; private function sendMessage():void { var message:AsyncMessage = new AsyncMessage(); message.headers = new Array(); message.headers["prop1"] = 5; message.body = input.text; producer.send(message); } ]]> </mx:Script> <mx:Producer id="producer" destination="chat"/> <mx:TextInput id="userName"/> <mx:TextInput id="input"/> <mx:Button label="Send" click="sendMessage();"/> </mx:Application> ? 过滤信息是基于信息头的,用?Consumer.selector?去指明一个选择器。一个信息选择器是一个字串,这是一个基于SQL92条件表达式语法的一个条件表达式。Consumer只接受信息头符合过滤标准的信息。 以下代码设置一个Consumer.selector,让它只接受信息头名为”?prop1?“,并且值大于4的信息。? <?xml version="1.0"?> <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" creationComplete="logon();"> <mx:Script> <![CDATA[ import mx.messaging.*; import mx.messaging.messages.*; import mx.messaging.events.*; // Subscribe to destination. private function logon():void { consumer.subscribe(); } // Write received message to TextArea control. private function messageHandler(event:MessageEvent):void { // Handle message event. ta.text += event.message.body + "/n"; } ]]> </mx:Script> <mx:Consumer id="consumer" destination="chat" selector="prop1 > 4" message="messageHandler(event);"/> <mx:TextArea id="ta" width="100%" height="100%"/> </mx:Application> ? ? 用副主题(subtopics ) ??? Producer能产生发送信息并指明它的类别(category ),我们叫副主题,你可以配置一个组件让他接受一个分配了某个或某些副主题的信息。(注:你不能使用副主题到JMS destination,你可以用message headers 和selector 来完成相似的功能。) ??? 在一个Producer中用“subtopic?”属性去为一个信息分配副主题,如下形式: ???? producer.subtopic =? mainToken[.secondaryToken][.additionalToken][...]。 ???? 例如:你可以定义“"chat",? "chat.fds.newton"副主题,“.”是默认的分割符号,你可以在配置文件中用<subtopic-separator>?属性定义一个不同的分割符。 ????? 在Consumer组件中,同样用subtopic 属性去指明要接收的信息拥有的副主题。当用通配符时,可以让你的Consumer接收更多信息?副主题。? ????? Messaging Service支持单字符通配在副主题字串中。比如 "foo.*"匹配"foo.bar" and "foo.baz",and also "foo.bar.aaa" and "foo.bar.bbb.ccc"。如果通配符在除了最后位置以外的地方,它只能匹配在这个位置上的字符,比如"foo.*.baz"匹配"foo.bar.baz" and "foo.aaa.baz",but not "foo.bar.cookie"and? "foo.aaa.ccc.baz". ? ?下面是Producer 设置destination?and?subtopic?的实践代码 ? <?xml version="1.0"?> <!-- ds/messaging/Subtopic1.mxml --> <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"> <mx:Script> <![CDATA[ import mx.messaging.*; import mx.messaging.messages.*; import mx.messaging.events.*; private function useSubtopic():void { var message:AsyncMessage = new AsyncMessage(); producer.subtopic = "chat.fds.newton"; // Generate message. producer.send(message); } ]]> </mx:Script> <mx:Producer id="producer" destination="chat"/> </mx:Application> ? 然后我们用Consumer 来订阅某个destination 和subtopic下的信息。这次我们用通配符去接收所有拥有在chat.fds下副主题的信息。 <?xml version="1.0"?> <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" creationComplete="logon();"> <mx:Script> <![CDATA[ import mx.messaging.*; import mx.messaging.messages.*; import mx.messaging.events.*; private function messageHandler(event:MessageEvent):void { // Handle message event. ta.text += event.message.body + "/n"; } private function logon():void { consumer.subtopic = "chat.fds.*"; consumer.subscribe(); } ]]> </mx:Script> <mx:Consumer id="consumer" destination="chat" message="messageHandler(event);"/> <mx:TextArea id="ta" width="100%" height="100%"/> </mx:Application> ? 为了让一个destination启动subtopics功能 ,你要设置 <allow-subtopics?>为true,在messaging-config.xml文件destination定义中,而<subtopic-separator?>是设置subtopics分割符的,the default value is?"."?。 ? <destination id="ChatTopic"> <properties> <network> <subscription-timeout-minutes>0</subscription-timeout-minutes> </network> <server> <message-time-to-live>0</message-time-to-live>? <subtopic-separator>.</subtopic-separator> </server> </properties> <channels> <channel ref="my-streaming-amf"/> </channels> </destination> From: http://www.voidcn.com/article/p-aryurnya-rm.html (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |