Flex經過Blazeds利用Remoteservice與後臺java消息推送

Flex經過Blazeds利用Remoteservice與後臺java消息推送

準備工做：Myeclipse中先創建一個Web project工程，而後導入Blazeds的文件，再轉換爲Flex項目類型。

前言：Flex 經過開源的 BlazeDS消息服務來支持訂閱及發佈消息。這個消息服務管理着Flex客戶端能夠訂閱或發佈的目標地址。Flex提供了 Producer和Consumer這兩個組件，讓你用來向目標地址發送或訂閱消息。若是要訂閱消息，你就使用Consumer類的 subscribe()方法。當有消息發送到你訂閱了的目標地址時，Consumer上就會觸發message事件。

消息傳遞的目標地址是在 Flex應用根下一個叫messaging-config.xml中配置的。一個目標地址配置的關鍵元素是在客戶端和服務器創建交換數據的通道。使用BlazeDS，消息傳遞的目標地址一般使用流通道或者輪詢通道。

 

1， 使用流通道，服務器響應會一直保持開放狀態，直到通道鏈接關閉，這樣能夠讓服務器持續向客戶端發送變化的數據。

2，若是數據沒有馬上準備好（長輪詢），就能夠經過一個簡單的時間間隔或者服務器等待時間來配置 輪詢通道。

修改兩個配置文件services-config.xml，messaging-config.xml

services-config.xml 加入如下代碼：

 

<channel-definition id="my-streaming-amf" class="mx.messaging.channels.StreamingAMFChannel">
<endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/streamingamf" class="flex.messaging.endpoints.StreamingAMFEndpoint"/>
    <properties>
          <idle-timeout-minutes>0</idle-timeout-minutes>
          <max-streaming-clients>10</max-streaming-clients>
<server-to-client-heartbeat-millis>5000
</server-to-client-heartbeat-millis>
      <user-agent-settings>
       <user-agent match-on="MSIE" kickstart-bytes="2048" max-streaming-connections-per-session="1"/>
       <user-agent match-on="Firefox" kickstart-bytes="2048" max-streaming-connections-per-session="1"/>
       </user-agent-settings>
     </properties>
</channel-definition>

messaging-config.xml 加入如下代碼

 

<destination id="message-data-feed">
       <properties>
        <server>
           <allow-subtopics>true</allow-subtopics>
           <subtopic-separator>.</subtopic-separator>
        </server>
      </properties>
      <channels>
           <channel ref="my-polling-amf" />
           <channel ref="my-streaming-amf" />
      </channels>
</destination>

注：這裏的 id就是目標地址，也就是在flex代碼中須要訂閱消息的Consumer的屬性destination所要設置的值，以及發佈消息java後臺代碼AsyncMessage的setDestination()所要傳遞的參數，必須保證這三個地方名稱一致。正是經過這一個目標地址，信息發佈者就會將信息發佈到該目標地址，而後全部已經設置訂閱了該目標地址的flex就會觸發MessageEvent.MESSAGE事件，來獲取發佈的消息。

Flex前端代碼：

 

<?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">
    <fx:Script>
       <![CDATA[
           import mx.messaging.Channel;
           import mx.messaging.ChannelSet;
           import mx.messaging.Consumer;
           import mx.messaging.events.MessageEvent;
           import mx.rpc.events.ResultEvent;
           private var myConsumer:Consumer = new Consumer();

           //直接利用Remote來進行遠程的消息調用
           //開始訂閱消息
           protected function rbt_clickHandler(event:MouseEvent):void
           {
              // TODO Auto-generated method stub
              //利用遠程調用來觸發開始工做
              subMessage.startSendMessage("start");
              //準備開始訂閱消息
        myConsumer.destination = " message -data-feed";
 //這裏也要與後臺的主題名稱必須相同
        myConsumer.subtopic = "tick";
        myConsumer.channelSet = new ChannelSet(["my-streaming-amf"]);
        myConsumer.addEventListener(MessageEvent.MESSAGE, remote_messageHandler);
        myConsumer.subscribe();
        }
 //獲取訂閱的消息，以文原本顯示顯示
 private function remote_messageHandler(event:MessageEvent):void
 {
        var mess:String = event.message.body as String;
        demot.appendText("\n"+ mess);
 }
 //退訂該消息
 protected function cbr_clickHandler(event:MouseEvent):void
 {
        subMessage.stopSendMessage("stop");
        myConsumer.unsubscribe(false);
 }
 protected function subMessage_resultHandler(event:ResultEvent):void
 {}
 ]]>
</fx:Script>
<fx:Declarations>
     <!—用來啓動消息發佈 -->
<mx:RemoteObject id="subMessage" destination="RemoteMessage"
    result="subMessage_resultHandler(event)"> </mx:RemoteObject>
</fx:Declarations>
    <s:TextArea x="445" y="42" width="257" id="demot"/>
    <s:Button x="445" y="210" label="訂閱消息Remote" id="rbt" click="rbt_clickHandler(event)"/>
    <s:Button x="597" y="207" label="退訂消息R" id="cbr" click="cbr_clickHandler(event)"/>
</s:Application>

 

Java 後臺代碼：

package com.whut.daemon;
import flex.messaging.MessageBroker;
import flex.messaging.messages.AsyncMessage;
import flex.messaging.util.UUIDUtils;
public class DaemonMessage {
    private static FeedThread thread;
    //開始傳遞消息
    public void startSendMessage(String flags)
    {
       if (thread == null)
       {
           thread = new FeedThread();
           thread.start();
       }
    }
    //中止消息發佈
    public void stopSendMessage(String flags)
    {
       thread.running=false;
       thread=null;
    }
    public static class FeedThread extends Thread
    {
       public boolean running = true;
       public void run() {
           MessageBroker msgBroker = MessageBroker.getMessageBroker(null);
           String clientID = UUIDUtils.createUUID();
           System.out.println("clientID="+clientID);
           while (running) {
              //異步消息
              AsyncMessage msg = new AsyncMessage();
              msg.setDestination("tick-data-feed111");
              msg.setHeader("DSSubtopic", "tick");
              msg.setClientId(clientID);
              msg.setMessageId(UUIDUtils.createUUID());
              msg.setTimestamp(System.currentTimeMillis());
              msg.setBody("hello");
              msgBroker.routeMessageToService(msg, null);
              try {
                  Thread.sleep(500);
              } catch (InterruptedException e) {}}}}}

remoting-config.xml 加入如下代碼：

 

<destination id="RemoteMessage">
 <properties>
      <source>com.whut.daemon.DaemonMessage</source>
  </properties>
</destination>