Blazeds推送到Flex（详细版）

huanggua12353719

浏览: 21388 次

最近访客更多访客>>

kinglien

wecley

shuzheng5201314

xyhsoft

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

flex

重要提示：WEB应用服务器要用tomcat6,blazeds和tomcat7有兼容性问题。

1、先创建一个web工程整合Flex，如果不会参考：

http://huanggua12353719.iteye.com/blog/2295720

2、我的工程名为test，在services-config.xml的channels节点内加入

<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>

3、在messaging-config.xml的service节点内加入

4、在java文件目录src/com包下创建Tick.java

package com;

import java.math.BigDecimal;
import java.util.Date;

public class Tick {
    private BigDecimal askPrice;

    private BigDecimal bidPrice;

   private BigDecimal midPrice;

   private Date tickTime;

   private String seqno;

   public String getSeqno() {
       return seqno;
   }

   public void setSeqno(String seqno) {
        this.seqno = seqno;
    }

    public BigDecimal getAskPrice() {
        return askPrice;
    }

    public void setAskPrice(BigDecimal askPrice) {
        this.askPrice = askPrice;
   }

    public BigDecimal getBidPrice() {
        return bidPrice;
    }

    public void setBidPrice(BigDecimal bidPrice) {
        this.bidPrice = bidPrice;
    }

   public BigDecimal getMidPrice() {
        return midPrice;
    }

    public void setMidPrice(BigDecimal midPrice) {
        this.midPrice = midPrice;
    }

    public Date getTickTime() {
        return tickTime;
   }

    public void setTickTime(Date tickTime) {
        this.tickTime = tickTime;
    }

}

5、在java文件目录src/com包下创建DaemonMessage.java

package com;
import java.math.BigDecimal;
import java.util.Date;

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);
            int i = 0;
            while (running)
            {
            //异步消息
            Tick tick = new Tick();
            tick.setAskPrice(new BigDecimal("100"));
            tick.setBidPrice(new BigDecimal("100"));
            tick.setMidPrice(new BigDecimal("100"));
            tick.setTickTime(new Date());
            tick.setSeqno(String.valueOf(i));
            System.out.println(i);

            AsyncMessage msg = new AsyncMessage();
            msg.setDestination("tick-data-feed");
            msg.setHeader("DSSubtopic", "tick");
            msg.setClientId(clientID);
            msg.setMessageId(UUIDUtils.createUUID());
            msg.setTimestamp(System.currentTimeMillis());
            msg.setBody(tick);
            msgBroker.routeMessageToService(msg, null);
            i++;
            try {
            Thread.sleep(1000);
            } catch (InterruptedException e) {}}}
    }
}

6、在flex文件目录flex_src下创建Tick.as

package
{
    [RemoteClass(alias="com.Tick")]
    [Bindable]
    public class Tick
    {
        public function Tick()
        {
        }
        public var askPrice:Number;
        public var bidPrice:Number;
        public var midPrice:Number;
        public var tickTime:Date;;
        public var seqno:String;

    }
}

7、在flex主文件test.mxml的内容改成

<?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.controls.Alert;
            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 = "tick-data-feed";
                //这里也要与后台的主题名称必须相同 www.it165.net
                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 tick:Tick = event.message.body as Tick;
                demot.text = tick.seqno;
            }
            //退订该消息
            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>