在Flex中使用消息服务

在Flex中使用消息服务

目录结构:

FlexMessage.mxml:
<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" fontSize="13">

<mx:Script>
 <![CDATA[
  import mx.messaging.events.MessageEvent;
  import mx.messaging.messages.AsyncMessage;  
  private function onToggleButtonClicked():void{
   if(toggleButton.label=="subscribe"){
    consumer.subscribe(); //订阅消息
    toggleButton.label="unsubscribe";
   }else{
    consumer.unsubscribe(); //取消订阅
    toggleButton.label="subscribe";
   }
  }
  private function sendChartInfo():void{
   var message:AsyncMessage=new AsyncMessage;
   message.body={msg:chartInput.text,sender:txtme.text,receiver:txtto.text};
   if(consumer.subscribed){
    producer.send(message);//发布消息
   }
   //if (txtto.text != null && txtto.text != ""){
   // chartField.text += "您对"+txtto.text+"说:" + chartInput.text + "\n";
   //}
   chartInput.text="";
  }
  private function messageHandler(event:MessageEvent):void{
   var chat:Object = event.message.body;
   //if ((chat.receiver != null && chat.receiver != "") && (chat.receiver == txtme.text)){
   // chartField.text += chat.sender+"对您说:"+chat.msg+"\n";
   //} else if (txtto.text == null || txtto.text == "" && chat.sender != txtme.text){
   
    chartField.text += chat.sender+"对大家说:"+chat.msg+"\n";
   //}
  }
 ]]>
</mx:Script>  
 <mx:Button id="toggleButton" label="subscribe" x="454" y="40" width="125" click="onToggleButtonClicked()"/>
 <mx:TextArea id="chartField" x="220" y="88" width="359" height="144"/>
 <mx:TextInput id="chartInput" x="220" y="255" width="290"/>
 <mx:Button x="518" y="255" label="send" click="sendChartInfo()"/>
 <mx:Producer id="producer" destination="ChartDestination"/>
 <mx:Consumer id="consumer" destination="ChartDestination" message="messageHandler(event)"/>
 <mx:TextInput x="266" y="289" width="76" id="txtme"/>
 <mx:Text x="220" y="292" text="自己:&#xa;" width="42" height="24" fontSize="12"/>
 <mx:TextInput x="266" y="323" width="76" height="26" id="txtto"/>
 <mx:Label x="220" y="325" text="对方:"/>
</mx:Application>

messaging-config.xml:
<destination id="ChartDestination" channels="my-polling-amf"/>

services-config.xml: 
<channel-definition id="my-polling-amf" class="mx.messaging.channels.AMFChannel">
            <endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/amfpolling" class="flex.messaging.endpoints.AMFEndpoint"/>
            <properties>
                <polling-enabled>true</polling-enabled>
               <!-- 表示1秒钟轮询一次 -->
                <polling-interval-seconds>1</polling-interval-seconds>
            </properties>
        </channel-definition>