- 浏览: 11260 次
最新评论
在网上找了许多的Flex与java 通信做ServerPush 的例子,发现有许多不正确,今天就做了一小程序。希望对大家有用
1. Product 类 package com.east.flex.serverpush.entity; /** * 产品类 * @author East(张栋芳) * * 2010-6-12 */ public class Product { private String month; private int profit; private int expenses; private int amount; public String getMonth() { return month; } public void setMonth(String month) { this.month = month; } public int getProfit() { return profit; } public void setProfit(int profit) { this.profit = profit; } public int getExpenses() { return expenses; } public void setExpenses(int expenses) { this.expenses = expenses; } public int getAmount() { return amount; } public void setAmount(int amount) { this.amount = amount; } } 2. ServerPushThread package com.east.flex.serverpush.chart; import java.util.ArrayList; import java.util.List; import java.util.Random; import com.east.flex.serverpush.entity.Product; import flex.messaging.MessageBroker; import flex.messaging.messages.AsyncMessage; import flex.messaging.util.UUIDUtils; /** * 构造数据后台线程 * * @author East(张栋芳) * * 2010-6-13 */ public class ServerPushThread extends Thread { public boolean running = true; @Override public void run() { MessageBroker msgBroker = MessageBroker.getMessageBroker(null); String clientId = UUIDUtils.createUUID(); while (running) { /* ============================== */ // TODO do someing /* ============================== */ List productList = getProductList(); AsyncMessage msg = new AsyncMessage(); msg.setDestination("serverpush"); msg.setClientId(clientId); msg.setMessageId(UUIDUtils.createUUID()); msg.setTimestamp(System.currentTimeMillis()); /* 设置消息信息,发布到客户端去 */ msg.setBody(productList); msgBroker.routeMessageToService(msg, null); try { Thread.sleep(10000); } catch (InterruptedException se) { } } } /** * 模拟数据信息 * * @return */ public List getProductList() { List productList = new ArrayList(); for (int i = 1; i --> 5. remoting-config.xml com.east.flex.serverpush.CreateProduct com.east.flex.serverpush.chart.ServerPushServer 6. Product.as package com.east.flex.entity { import mx.rpc.remoting.RemoteObject; [RemoteClass(alias="com.east.flex.serverpush.entit y.Product")] public class Product { public var month:String; public var profit:int; public var expenses:int; public var amount:int; public function Product() { } } } 7.ServerPushChart.mxml import com.east.flex.entity.Product Flex Server Push 功能*/ import mx.messaging.messages.IMessage; import mx.messaging.events.MessageEvent; import mx.utils.ArrayUtil; import mx.rpc.events.ResultEvent; import mx.collections.ArrayCollection; import mx.controls.Alert; import mx.messaging.ChannelSet; import mx.messaging.Consumer; [Bindable] private var p:Product; private var array:ArrayUtil; [Bindable] private var expensesAC:ArrayCollection = null; public var consumer2:Consumer = null; public function messageHandler(event:MessageEvent):void { linechart.dataProvider = event.message.body; trace("server push data to client.............."); } public function remoteServerCallback(event:ResultEvent):void { trace("Server is start...."); //Alert.show("Server is start....."+event.message); } public function startServer(event:MouseEvent):void { server.start(); } public function stopServer(event:MouseEvent):void { server.stop(); } /* public function submsg():void { Alert.show("click start"); consumer= new Consumer(); consumer.destination = "serverpush"; consumer.subtopic = "tick"; consumer.channelSet = new ChannelSet(["my-streaming-amf"]); consumer.addEventListener(MessageEvent.MESSAGE, messageHandler); consumer.subscribe(); Alert.show("click end"); } */ ]]--> height="100%" width="100%" layout="absolute"> height="100%" width="1030" paddingLeft="5" paddingRight="5" showDataTips="true" x="0" y="0">
发表评论
-
字符串的存储方式以及静态存储区域、栈、堆
2012-07-06 09:52 621下面两篇文章分析得比较详细.转自http://blog.c ... -
正则表达式测试工具
2012-07-06 09:45 712主要功能, 1.语法高亮显示 2.智能提示 3 ... -
perl学习日记7正则表达式
2012-07-06 09:37 6841. 正则表达式 1.1 什么是正则表 ... -
纯css实现未知大小的图片水平垂直居中的方法
2012-07-06 09:30 1090方法一: .box { /*非IE的主流浏览器识别的 ... -
net 2.0下的asp.net ajax基本使用方法 (备忘)
2012-07-05 20:45 654asp.net ajax中用到了几个dll文件,这些可以从 ... -
vb 调用c#做的com 组件
2012-07-03 13:43 1022vb 调用c#做的com 组件 1:建立c# 项目 (注 ... -
flex 界面改进
2012-07-02 12:15 575f 代码如下: ... -
flex图片截取保存本地
2012-07-02 12:15 626height="222" creat ... -
Flex4+Spring3+Hibernate3+BlazeDS整合笔记
2012-07-02 12:15 508普通Java Web工程流行使用ssh框架,而当前台使用F ... -
学习flex 初步实现与java进行数据交互
2012-07-01 09:49 481本人是从事BS架构应用开发的,现在发现客户越来越关注用户的 ... -
Flex+BlazeDS整合J2ee示例
2012-07-01 09:49 442一、首先配置好eclipse下Flex开发环境 二、下载部 ... -
将 Flex 3 的应用程序迁移到 Flex 4 ―第 1 部分:将 Flex 3 Dashboard 应用程序导入 Flash Builder 4
2012-07-01 09:49 670本系列一共 4 个部 ... -
Flex嵌入jsp开发心得
2012-07-01 09:49 640PM搞了个外包的小项目,要求使用jsp显示数据统计图表。研 ... -
笔记本频道-eNet笔记本大全-硅
2012-06-30 16:12 623笔记本频道-eNet笔记本大全-硅 2011年09月15日 ... -
笔记本电脑小知识
2012-06-30 16:12 696笔记本电脑小知识 2011年11月22日 笔记本电脑小知 ... -
[独家新闻][热门]【笔记本电脑报价】笔记本电脑
2012-06-30 16:12 341[独家新闻][热门]【笔记本电脑报价】笔记本电脑 2011年 ... -
[热门]【笔记本电脑报价】笔记本电脑
2012-06-30 16:11 302[热门]【笔记本电脑报价】笔记本电脑 2011年08月11日 ...
相关推荐
NULL 博文链接:https://dojava.iteye.com/blog/1711575
java中的Servlet实现Server_Push技术的聊天室!
java server push
ASP.NET(C#) ServerPush
基于dwr的server push ,后台是java,往页面推送数据
java-Push开源实时消息推送系统
JavaPush消息推送
asp.net server push 长连接asp.net server push 长连接已调试成功
以告警数据为例,告警数据通过mq、socket等方式进入系统,在java服务器通过监听来监听消息队列数据,接收后推送到flex各个客户端。blazeDS采用amf协议。该协议可以传输Object, Array, Date, XML。由于AMF采用二进制...
.net实现Server Push(服务器推送)源码
NULL 博文链接:https://fanfq.iteye.com/blog/1405385
Server Push入门介绍,讲术服务器推送的原理及过程
javapush消息推送
NULL 博文链接:https://packecho.iteye.com/blog/857027
一个dwr server push 做的web room ,使用服务器推技术,实现点对点聊天...
dwr serverpush chat room 点对点聊天 ==========================
asp.net server push 长连接 源码 示例 测试通过.一看就明白,
java-push-demo 用于推送案例,适合没有这方面知识的初学者参考。