web.xml
<servlet>
<servlet-name>flex</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>flex</servlet-name>
<url-pattern>/messagebroker/*</url-pattern>
</servlet-mapping>
spring
<flex:message-broker>
<flex:message-service
default-channels="my-streaming-amf,my-longpolling-amf,my-polling-amf" />
</flex:message-broker>
<flex:message-destination id="simple-feed" />
<!-- Pojo used to start and stop the data feed that pushes data in the 'simple-feed' destination -->
<bean id="simpleFeedStarter" class="SimpleFeed 类路径">
<constructor-arg ref="defaultMessageTemplate" />
<flex:remoting-destination />
</bean>
java:
import java.util.Random;
import org.springframework.flex.messaging.MessageTemplate;
public class SimpleFeed {
private static FeedThread thread;
private final MessageTemplate template;
public SimpleFeed(MessageTemplate template) {
this.template = template;
}
public void start() {
if (thread == null) {
thread = new FeedThread(this.template);
thread.start();
}
}
public void stop() {
thread.running = false;
thread = null;
}
public static class FeedThread extends Thread {
public boolean running = false;
private final MessageTemplate template;
public FeedThread(MessageTemplate template) {
this.template = template;
}
@Override
public void run() {
this.running = true;
Random random = new Random();
double initialValue = 35;
double currentValue = 35;
double maxChange = initialValue * 0.005;
while (this.running) {
double change = maxChange - random.nextDouble() * maxChange * 2;
double newValue = currentValue + change;
if (currentValue < initialValue + initialValue * 0.15 && currentValue > initialValue - initialValue * 0.15) {
currentValue = newValue;
} else {
currentValue -= change;
}
this.template.send("simple-feed", new Double(currentValue));
System.out.println("" + currentValue);
try {
Thread.sleep(300);
} catch (InterruptedException e) {
}
}
}
}
}
flex:
<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" fontSize="20" backgroundColor="#FFFFFF">
<mx:Script>
<![CDATA[
import mx.messaging.messages.IMessage;
private function messageHandler(message:IMessage):void
{
pushedValue.text = ""+ message.body;
}
]]>
</mx:Script>
<mx:ChannelSet id="cs">
<!-- <mx:StreamingAMFChannel url="http://localhost:8080/testdrive/messagebroker/streamingamf"/> -->
<mx:AMFChannel url="http://localhost:8080/testdrive/messagebroker/amflongpolling"/>
<mx:AMFChannel url="http://localhost:8080/testdrive/messagebroker/amfpolling"/>
</mx:ChannelSet>
<mx:Consumer id="consumer" destination="simple-feed" channelSet="{cs}"
message="messageHandler(event.message)"/>
<mx:TextInput id="pushedValue" width="250"/>
<mx:Button label="Subscribe" click="consumer.subscribe()" enabled="{!consumer.subscribed}"/>
<mx:Button label="Unsubscribe" click="consumer.unsubscribe()" enabled="{consumer.subscribed}"/>
</mx:Application>
分享到:
相关推荐
Spring BlazeDS Integration,Flex通过remoteObject与java通讯,附带例子 文档
最简单的BlazeDS实现flex与java通信..无积分下载...最简单的BlazeDS实现flex与java通信..无积分下载...最简单的BlazeDS实现flex与java通信..无积分下载...最简单的BlazeDS实现flex与java通信..无积分下载...最简单的...
Spring BlazeDS Integration 1.0.0
使用flex 4.5 + Spring 3.0 + Hibernate 3.3 + Cairngorm 2.2.1 + BlazeDS 3.3.0 + Spring BlazeDS Integration 1.0.3整合出的一个登录的小demo·
使用BlazeDS实现flex与java 整合 使用BlazeDS实现flex与java 整合 flex+java
Flex + blazeds + Java推送Demo 本例实现由Flex一端客户端发送消息, 然后由Java端在发布到所有订阅的其它Flex端. 里面有说明与源码, 还有一个直接放到Tomcat里面的直接发布的项目 小编使用工具 eclipse3.5 flex sdk...
Flex技术本身和Java就有很强的关联性,它提供了一个基于Eclipse的IDE和BlazeDS.BlazeDS是个基于服务端的Java远程调用和Web消息的一个开源的技术。有许多应用都是以Java为后端处理的。Flex用于前端。由于Java和Flex...
Java 服务器端技术Spring BlazeDS Integration.docx,看了启示很多
详解spring BlazeDS 与 flex 集成应用,希望对各位大栳有用
spring+blazeDS+flex4整合的例子,项目可以直接运行,jar包都齐全 模拟数据库返回的list 在页面上 输出
BLAZEDS实现Java后台数据推送到Flex
BlazeDS实现flex与java通信
flex+blazeds+java后台消息推送(简单示例)[借鉴].pdf
NULL 博文链接:https://madfroghe.iteye.com/blog/935337
Spring MVC+BlazeDS+Flex框架实践
Blazeds_Flex_Java_new 希望对大家有用.
Flex Spring JAVA BLAZEDS整合,永固整合将flex与Spring整合
基于Java_BlazeDS_Flex_服务器消息推的聊天室 了解BlazeDS推送机制,flex调用java web BlazeDS的过程 服务器推,摒弃ajax的轮询,减轻服务器压力!
FLEX,BlazeDS,JAVA实现服务器端数据推送技术,下载后直接导到你的MYECLIPSE即可运行。先在IE内输入:http://localhost:8080/pushDemo/flex/pushDemo.html,点击“button”后,再另一个IE窗口内输入:...