flex与java通信四：Message

一个利用blazeds的message机制完成的一个chat聊天小程序（flex与java分开的那种）：

下载地址：http://yunpan.cn/QDzrutaytbDrq

程序主要部分：

1、聊天界面

消息本身包含消息头和消息体，消息头的格式是固定的，消息体的内容可以随意写

消息服务允许Flex客户端可以发布(Publish)和订阅(Subscribe)消息，相应的，客户端的被称为生产者(Producer)和消费者(Consumer)，其实也就是发送和接受消息了。

<?xml version="1.0" encoding="utf-8"?>
<s:Application xmlns:fx="http://ns.adobe.com/mxml/2009" 
			   xmlns:s="library://ns.adobe.com/flex/spark" 
			   xmlns:mx="library://ns.adobe.com/flex/mx" minWidth="955" minHeight="600" creationComplete="consumer.subscribe()">
	<fx:Script>
		<![CDATA[
			import mx.controls.Alert;
			import mx.messaging.events.MessageFaultEvent;
			import mx.messaging.messages.AsyncMessage;
			import mx.messaging.messages.IMessage;
			
			private function send():void
			{
				var message:IMessage = new AsyncMessage();
				message.body.chatMessage = msg.text;
				producer.send(message);
				msg.text = "";
			}
			
			private function messageHandler(message:IMessage):void
			{
				log.text += message.body.chatMessage + "n";	
			}
			
			protected function producer_faultHandler(event:MessageFaultEvent):void
			{
				Alert.show(event.faultString);
			}
			
		]]>
	</fx:Script>
	<fx:Declarations>
		<!-- 将非可视元素（例如服务、值对象）放在此处 -->
		<s:Producer id="producer" destination="chat" fault="producer_faultHandler(event)"/>
		<s:Consumer id="consumer" destination="chat" message="messageHandler(event.message)"/>
	</fx:Declarations>
	
	<s:Panel title="Chat" width="50%" height="50%">
		<s:controlBarContent>
			<s:TextInput id="msg" width="100%" enter="send()"/>
			<s:Button label="Send" click="send()"/> 
		</s:controlBarContent>
		<s:TextArea id="log" width="100%" height="100%"/>
	</s:Panel>
	
</s:Application>

当一个消息被发到已订阅的目的地(destination)时，就会触发一个客户端的message事件。

发布的任何消息会发给所有订阅的人，即使是生产者自己。

如果某一订阅方只想收到特定的消息，可以在订阅时使用selecor属性来指定过滤条件，只有符合条件的消息才会被服务器转发。

如果想要服务器产生消息，可以产生一个flex.messaging.messages.AsyncMessage类的实例，用flex.messaging.MessageBroker发送出去。

<?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="true" />
        <adapter-definition id="jms" class="flex.messaging.services.messaging.adapters.JMSAdapter"/>
    </adapters>

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

	<destination id="chat"/>
	
</service>

-----------------------------------------------华丽丽的分割线-----------------------------------------------