18.7.使用發布/訂閱消息

2024-04-27 13:52:26

字體：大中小

來源：轉載

供稿：網友

18.7.1. 問題
我想在服務端數據改變能通知客戶端Flex 應用程序或廣播消息給所有的監聽器。
18.7.2. 解決辦法
使用mx.messaging.Producer和mx.messaging.Consumer 標簽配置用于通信的目標通道和消息事件設置事件處理器。配置這些需要使用Adobe LiveCycle 或BlazeDS 服務器。
18.7.3. 討論
發布/訂閱模式使用兩個組件：mx.messaging.Producer 和mx.messaging.Consumer。Producer 發送消息給目標，服務器上處理信息的地址。Consumer 在目標上訂閱這些信息，當獲取數據時處理這些消息。

Flex 的消息可以是ActionScript 消息和Java Message Service (JMS) 消息。ActionScript 消息只支持客戶端"講"AMF 以及所需的類。JMS 消息允許LiveCycle 或BlazeDS 處理Java Message服務，與JMS 客戶端交互。任何可以"講"JMS 的應用程序都可被Flex 客戶端調用，任何Java應用程序都可發布事件給Flex。

Consumer 通過mx.messaging.events.MessageEvent 接收消息：

-ActionScript

private function receiveChatMessage(msgEvent:MessageEvent):void
{
var msg:AsyncMessage = AsyncMessage(msgEvent.message);
trace("msg.body "+msg.body);
}
Producer 

使用send 方法發送消息，該方法接受mx.messaging.AsyncMessage 作為參數。

AsyncMessage 的主體作為值發送給通道的所有訂閱者：

-ActionScript

var msg:AsyncMessage = new AsyncMessage();
msg.body = "test message";
producer.send(msg);

完整代碼如下：

-XML

<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" xmlns="*" pageTitle="Simple Flex Chat" creationComplete="chatSubscriber.subscribe()">
<!-- Messaging Declarations -->
<mx:Producer id="producer" destination="http://localhost:8400/chatDestination"/>
<mx:Consumer id="subscriber" destination="http://localhost:8400/chatDestination" message="receiveChatMessage(event)" />
<mx:Script>
<![CDATA[
import mx.messaging.events.MessageEvent;
import mx.messaging.messages.AsyncMessage;
private function sendChatMessage():void
{
var msg:AsyncMessage = new AsyncMessage();
msg.body="test message";
producer.send(msg);
}
private function
receiveChatMessage(msgEvent:MessageEvent):void
{
var msg:AsyncMessage = AsyncMessage(msgEvent.message);
trace("msg.body "+msg.body);
}]
]>
</mx:Script>
</mx:Application>