如此，我们就得到了一个安全的DataRow对象，除了构造时可以为它分配rowID，其他时毫无论在服务器端还是客户端都无法对rowID进行修改。从它继承的类都可以获得这项好处，前提是服务器端的Java类和客户端的ActionScript都需要继承相应的DataRow。

1.4 BlazeDS和Spring整合

如果需要BlazeDs与Spring框架整合使用，是非常简单的事情，因为，SpringSource和Adobe已经合作为BlazeDS提供了Spring支持，即Spring BlazeDS Integration，关于这个项目的更多信息可以访问http://www.springsource.org/spring-flex。

Spring BlazeDS Integration 是 SpringSource 的开源项目，用于整合 Spring 与 BlazeDS。不使用 Spring BlazeDS Integration 同样可以整合 Spring 与 BlazeDS。但这种整合方式不自然，需要额外维护一个 BlazeDS 配置文件，Spring BlazeDS Integration 会改善这种处境。

Spring BlazeDS Integration 需要的软件环境：

Ø Java 5 或更高

Ø Spring 2.5.6 或更高

Ø BlazeDS 3.2 或更高

Spring BlazeDS Integration 特征

Ø MessageBroker（BlazeDS 的核心组件）被配置为 Spring 管理的 Bean

Ø Flex 客户端发出的 HTTP 消息通过 Spring 的 DispatcherServlet 路由给 MessageBroker

Ø Remote objects 以 Spring 的方式配置在 Spring 配置文件内

下面我们演示BlazeDS和Spring的整合。

（1）准备所需 jar 包

下载 Spring Framework dependencies和Spring BlazeDS Integration解压备用，在项目中添加Spring支持，并将以下 2 部分 jar 包拷贝到项目的 lib 下：

Ø Spring Framework dependencies

org.aopalliance 内的 com.springsource.org.aopalliance-1.0.0.jar

edu.emory.mathcs.backport 内的 com.springsource.edu.emory.mathcs.backport-3.0.0.jar

net.sourceforge.cglib 内的 com.springsource.net.sf.cglib-2.2.0.jar

Ø Spring BlazeDS Integration

org.springframework.flex-1.0.3.RELEASE.jar

（2）：修改 web.xml 文件

将 web.xml 内所有 Flex 相关配置删除掉，添加以下内容（改用 Spring web 应用的前端控制器处理所有应用请求）

<servlet>

<servlet-name>Spring MVC Dispatcher Servlet</servlet-name>

<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>

<init-param>

<param-name>contextConfigLocation</param-name>

<param-value>/WEB-INF/web-application-config.xml</param-value>

</init-param>

<load-on-startup>1</load-on-startup>

</servlet>

<servlet-mapping>

<servlet-name>Spring MVC Dispatcher Servlet</servlet-name>

<url-pattern>/messagebroker/*</url-pattern>

</servlet-mapping>

（3）：配置 web-application-config.xml

1）创建应用上下文配置文件 web-application-config.xml

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://www.springframework.org/schema/beans       http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">

</beans>

2）为了使用 Spring BlazeDS Integration 的 tag，增加命名空间

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:flex="http://www.springframework.org/schema/flex"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://www.springframework.org/schema/beans       http://www.springframework.org/schema/beans/spring-beans-3.0.xsd       http://www.springframework.org/schema/flex       http://www.springframework.org/schema/flex/spring-flex-1.0.xsd">

</beans>

3）为了把请求路由给 MessageBroker，添加以下 tag

<flex:message-broker />

4）定义 Bean，并用 remoting-destination tag 把它暴露给 Flex

<bean id="employeeServiceDest" class="com.sample.EmployeeService">

<flex:remoting-destination />

</bean>

至此BlazeDS与Spring的整合就完成了。

1.5 BlazeDS的消息服务

BlazeDS消息服务(Message Service )提供发布(publish)/订阅(subscribe)机制，允许 Flex 应用程序发布消息、订阅消息终端(messaging destination)，从而实现实时数据的推动和协作传送。

（1）Message Service

Message Service 提供发布(publish)/订阅(subscribe)机制允许Flex 应用 程序发布消息、订阅消息终端(messaging destination)，从而实现数据的实时 推动和协作传送。

消息终端在messaging-config.xml配置，其中频道(channel)是其关键元素， 它用来实现客户端和服务器端交换数据。使用BlazeDS，消息终端通常用作 streaming频道或者polling频道。

使用streaming频道，服务器端会一直响应HTTP请求直到该频道连接被关闭， 它允许服务器向客户端不断传送大量的数据。因为HTTP连接是独一无二的，这实 现数据的双向传送，每个streaming AMF或者HTTP频道事实上需要两个浏览器 HTTP连接， 一个连接需要不断处理服务器端与频道紧密相关的客户端的响应。 另外需要一个短暂连接,只有当数据需要传送到服务器时，它才脱离浏览器连接 池；当短暂连接不再需要时，它立即被释放回浏览器连接池。

polling频道可以通过简单的时间间隔或者使用服务器等待来配置，如果数据 不马上可用 (长轮循)的话。另外，每次轮循响应完成请求。默认下浏览器HTTP 1.1的连接是持续的，浏览器轮循已有的连接，发送并发的轮循请求，以此来减 轻轮循的开销。

当需要准实时通信时，streaming 频道是最好选择。

（2）IE 与 Firefox浏览器下的不同

浏览器对每个session都有连接数限制。不同的浏览器，连接最大数以及对 session的处理方式都不一样。

IE中每个session的最大连接数为2。 但如果从开始菜单或快捷方式打开多个 IE实例，每个IE实例开启不同的进程并拥有各自session。另外，如果我们通过 CTRL+N 开启对已有的IE实例一个新的IE窗口，该窗口将与创建它的IE实例共用 一个session 。也就是说，如果程序实例开启不同的进程，我们可以通过HTTP streaming建立不限量应用取得服务器端数据；如果通过CTRL+N开启多个窗口， 每个session最多建立2个连接。

Firefox中每个session最多建立8个连接。如果从开始菜单或快捷方式打开多 个Firefox实例，所有实例开启使用同一进程并共用一个session。既然浏览器对 普通的HTTP请求通常只需要一个连接， 理论上我们可以最多可以建立7个HTTP streaming连接。

（3）messaging-config.xml

另外，如果每个session到达最大连接数，使用streaming channel连接到服务器的下一次尝试将失败并抛出以下异常：

Endpoint with id 'my-streaming-amf' cannot grant streaming connection to FlexClient with id 'D640B86F-6B1D-92DF- 8288-1B737A371AFE' because max-streaming-connections-per-session limit of '1' has been reached。

不过，BlazeDS提供一种优雅的退后机制来处理这种情况：

客户端始终会尝试使用频道表(messaging-config.xml中为服务终端定义) 中的第一个频道来连接。如果该连接失败, 客户端将自动退后到频道表中的下一频道。我们可以为所有的服务终端定义了如下默认的ChannelSet：

<default-channels>

<channel ref="my-streaming-amf"/>

<channel ref="my-polling-amf"/>

</default-channels>

也就是说，客户端应用会首先尝试使用streaming channel连接，如果连接失 败会使用polling channel。

在客户端，Flex提供了 Producer和Consumer这两个组件，让你用来向目标地址发送或订阅消息。如果要订阅消息，你就使用Consumer类的 subscribe()方法。当有消息发送到你订阅了的目标地址时，Consumer上就会触发message事件。

示例5.4

客户端代码：

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

creationComplete="consumer.subscribe();"

xmlns:mx="library://ns.adobe.com/flex/mx" minWidth="955" minHeight="600">

<fx:Script>

<![CDATA[

import mx.controls.Alert;

import mx.messaging.events.MessageFaultEvent;

import mx.messaging.messages.AsyncMessage;

import mx.messaging.messages.IMessage;

private function send():void

{

var message:IMessage = new AsyncMessage();

message.body.chatMessage = msg.text+consumer.clientId;

producer.send(message);

msg.text = "";

}

private function messageHandler(message:IMessage):void

{

log.text += message.body.chatMessage + "\n";

}

protected function consumer_faultHandler(event:MessageFaultEvent):void

{

Alert.show(event.faultDetail);

}

protected function producer_faultHandler(event:MessageFaultEvent):void

{

Alert.show(event.faultDetail);

}

]]>

</fx:Script>

<fx:Declarations>

<mx:ChannelSet id="cs">

<mx:StreamingAMFChannel url="http://localhost:8400/MsgService/messagebroker/streamingamf"/>

</mx:ChannelSet>

<mx:Producer id="producer"  fault="producer_faultHandler(event)" destination="chat" channelSet="{cs}"/>

<mx:Consumer id="consumer" destination="chat" channelSet="{cs}" message="messageHandler(event.message)" fault="consumer_faultHandler(event)"/>

</fx:Declarations>

<s:Panel title="Chat Test!"   x="20" y="19" width="518" height="295">

<s:TextArea id="log" x="19" y="11" width="473" height="166"/>

<s:TextInput id="msg" x="19" y="191" width="377" height="46" enter="send()"/>

<s:Button x="411" y="192" label="发送消息" height="43" width="77" click="send()"/>

</s:Panel>

</s:Application>

服务器端services-config.xml定义Streaming通道：

<?xml version="1.0" encoding="UTF-8"?>

<service id="message-service"

class="flex.messaging.services.MessageService">

<adapters>

<adapter-definition id="actionscript" class="flex.messaging.services.messaging.adapters.ActionScriptAdapter" default="true" />

<adapter-definition id="jms" class="flex.messaging.services.messaging.adapters.JMSAdapter"/>

</adapters>

<!--   <default-channels>

<channel ref="my-polling-amf"/>

</default-channels>-->

<destination id="chat">

<properties>

<network>

<session-timeout>0</session-timeout>

</network>

<server>

<max-cache-size>1000</max-cache-size>

<message-time-to-live>0</message-time-to-live>

<durable>false</durable>

</server>

</properties>

<channels>

<channel ref="my-streaming-amf" />

</channels>

</destination>

</service>

服务器端messaging-config.xm中定义目标并指定通道:

<?xml version="1.0" encoding="UTF-8"?>

<services-config>

<services>

<service-include file-path="remoting-config.xml" />

<service-include file-path="proxy-config.xml" />

<service-include file-path="messaging-config.xml" />

</services>

<security>

<login-command class="flex.messaging.security.TomcatLoginCommand" server="Tomcat"/>

<!-- Uncomment the correct app server

<login-command class="flex.messaging.security.TomcatLoginCommand" server="JBoss">

<login-command class="flex.messaging.security.JRunLoginCommand" server="JRun"/>

<login-command class="flex.messaging.security.WeblogicLoginCommand" server="Weblogic"/>

<login-command class="flex.messaging.security.WebSphereLoginCommand" server="WebSphere"/>

-->

<!--

<security-constraint id="basic-read-access">

<auth-method>Basic</auth-method>

<roles>

<role>guests</role>

<role>accountants</role>

<role>employees</role>

<role>managers</role>

</roles>

</security-constraint>

-->

</security>

<channels>

<channel-definition id="my-streaming-amf" class="mx.messaging.channels.StreamingAMFChannel">

<endpoint url="http://localhost:8400/MsgService/messagebroker/streamingamf" class="flex.messaging.endpoints.StreamingAMFEndpoint"/>

<properties>

<idle-timeout-minutes>0</idle-timeout-minutes>

<max-streaming-clients>50</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>

<channel-definition id="my-amf" class="mx.messaging.channels.AMFChannel">

<endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/amf" class="flex.messaging.endpoints.AMFEndpoint"/>

</channel-definition>

<channel-definition id="my-secure-amf" class="mx.messaging.channels.SecureAMFChannel">

<endpoint url="https://{server.name}:{server.port}/{context.root}/messagebroker/amfsecure" class="flex.messaging.endpoints.SecureAMFEndpoint"/>

<properties>

<add-no-cache-headers>false</add-no-cache-headers>

</properties>

</channel-definition>

<channel-definition id="my-polling-amf" class="mx.messaging.channels.AMFChannel">

<endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/amfpolling" class="flex.messaging.endpoints.AMFEndpoint"/>

<properties>

<polling-enabled>true</polling-enabled>

<polling-interval-seconds>4</polling-interval-seconds>

</properties>

</channel-definition>

<channel-definition id="my-http" class="mx.messaging.channels.HTTPChannel">

<endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/http" class="flex.messaging.endpoints.HTTPEndpoint"/>

</channel-definition>

<!--

<channel-definition id="my-secure-http" class="mx.messaging.channels.SecureHTTPChannel">

<endpoint url="https://{server.name}:{server.port}/{context.root}/messagebroker/httpsecure" class="flex.messaging.endpoints.SecureHTTPEndpoint"/>

<properties>

<add-no-cache-headers>false</add-no-cache-headers>

</properties>

</channel-definition>

-->

</channels>

<logging>

<target class="flex.messaging.log.ConsoleTarget" level="Error">

<properties>

<prefix>[BlazeDS] </prefix>

<includeDate>false</includeDate>

<includeTime>false</includeTime>

<includeLevel>false</includeLevel>

<includeCategory>false</includeCategory>

</properties>

<filters>

<pattern>Endpoint.*</pattern>

<pattern>Service.*</pattern>

<pattern>Configuration</pattern>

</filters>

</target>

</logging>

<system>

<redeploy>

<enabled>false</enabled>

<!--

<watch-interval>20</watch-interval>

<watch-file>{context.root}/WEB-INF/flex/services-config.xml</watch-file>

<watch-file>{context.root}/WEB-INF/flex/proxy-config.xml</watch-file>

<watch-file>{context.root}/WEB-INF/flex/remoting-config.xml</watch-file>

<watch-file>{context.root}/WEB-INF/flex/messaging-config.xml</watch-file>

<watch-file>{context.root}/WEB-INF/flex/data-management-config.xml</watch-file>

<touch-file>{context.root}/WEB-INF/web.xml</touch-file>

-->

</redeploy>

</system>

</services-config>

运行应用效果如图5.1.11所示，轻松实现了数据的推送：

图5.1.11 Flex数据推送

任务实训部分 

实训任务1：使用HttpServcie方式与后台通信

训练技能点

HttpServcie

需求说明

使用HttpService对象开发Flex应用程序 按条件查询数据库中某张表的数据并显示在表格中。

实现思路

（1）创建Flex项目，将此项目的服务器技术选择为J2EE服务器（无需使用远程对象访问服务）。

（2）切换到MyEclipese java 开发视图，创建一个POJO类用于描述奥运会各个国家获得的奖牌情况。

package com.soft.flex.flex4sj.pojo;

public class Cup {

private int id;

//国家代号

private String countryId;

//国家名称

private String countryName;

//金牌数

private int goldMedal;

//银牌数

private int silverMedal;

//铜牌数

private int bronzeMedal;

public int getId() {

return id;

}

public void setId(int id) {

this.id = id;

}

public String getCountryId() {

return countryId;

}

public void setCountryId(String countryId) {

this.countryId = countryId;

}

public String getCountryName() {

return countryName;

}

public void setCountryName(String countryName) {

this.countryName = countryName;

}

public int getGoldMedal() {

return goldMedal;

}

public void setGoldMedal(int goldMedal) {

this.goldMedal = goldMedal;

}

public int getSilverMedal() {

return silverMedal;

}

public void setSilverMedal(int silverMedal) {

this.silverMedal = silverMedal;

}

public int getBronzeMedal() {

return bronzeMedal;

}

public void setBronzeMedal(int bronzeMedal) {

this.bronzeMedal = bronzeMedal;

}

public Cup(String countryId, String countryName, int goldMedal,

int silverMedal, int bronzeMedal) {

super();

this.countryId = countryId;

this.countryName = countryName;

this.goldMedal = goldMedal;

this.silverMedal = silverMedal;

this.bronzeMedal = bronzeMedal;

}

public Cup() {

super();

// TODO Auto-generated constructor stub

}

}

（3）创建业务类，在该类 中定义根据国家查询获取奖牌情况的方法。

package com.soft.flex.flex4sj.service;

import java.util.*;

import com.soft.flex.flex4sj.pojo.Cup;

public class CupService {

private List<Cup> cupList;

//模拟数据库数据

public CupService(){

cupList  = new ArrayList();

Cup cup1 = new Cup("china", "中国",30 ,20 ,10 );

Cup cup2 = new Cup("america", "美国",20 ,23 ,12 );

Cup cup3 = new Cup("japan", "日本",25 ,27 ,15 );

Cup cup4 = new Cup("france", "法国",10 ,18 ,20 );

Cup cup5 = new Cup("russia", "俄罗斯",16 ,30,25 );

Cup cup6 = new Cup("singapore", "新加坡",12 ,25 ,18 );

cupList.add( cup1);

cupList.add( cup2);

cupList.add( cup3);

cupList.add( cup4);

cupList.add( cup5);

cupList.add( cup6);

}

public List getAll(){

return cupList;

}

public Cup getCupByCountryId(String countryId){

Cup c = null;

for(Cup cup : cupList){

if(countryId.equals(cup.getCountryId())){

c = cup;

break;

}

}

return c;

}

}

（4）创建servlet 路径为/query, 该servlet根据传入的cid 调用业务类获取结果，并转化为xml格式返回。

public class QueryServlet extends HttpServlet {

public void doGet(HttpServletRequest request, HttpServletResponse response)

throws ServletException, IOException {

doPost(request, response);

}

public void doPost(HttpServletRequest request, HttpServletResponse response)

throws ServletException, IOException {

response.setContentType("text/html;charset=utf-8");

PrintWriter out = response.getWriter();

//构造xml头标记

String xml="<?xml version=\"1.0\" encoding=\"utf-8\"?><cups>";

String method = request.getParameter("method");

CupService service = new CupService();

//如果是查询所有

if("all".equals(method)){

List<Cup> list = service.getAll();

for(Cup cup : list){

String cid = cup.getCountryId();

String cname = cup.getCountryName();

int gm = cup.getGoldMedal();

int sm = cup.getSilverMedal();

int bm = cup.getBronzeMedal();

//构造xml节点

xml += "<cup countryId='"+cid+"' countryName='"+cname+"' goldMedal='"+gm+"' silverMedal='"+sm+"' bronzeMedal='"+bm+"'/>";

}

}else{

String countryId =  request.getParameter("cid");

Cup cup = service.getCupByCountryId(countryId);

String cid = cup.getCountryId();

String cname = cup.getCountryName();

int gm = cup.getGoldMedal();

int sm = cup.getSilverMedal();

int bm = cup.getBronzeMedal();

xml += "<cup countryId='"+cid+"' countryName='"+cname+"' goldMedal='"+gm+"' silverMedal='"+sm+"' bronzeMedal='"+bm+"'/>";

}

xml+="</cups>";

//输出结尾标志

out.print(xml);

out.flush();

out.close();

}

}

（5）创建MXML界面，通过HttpService对象访问servlet 并获取查询结果。

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

initialize="application1_initializeHandler(event)"

>

<fx:Script>

<![CDATA[

import mx.controls.Alert;

import mx.events.FlexEvent;

import mx.rpc.events.FaultEvent;

import mx.rpc.events.ResultEvent;

import spark.events.IndexChangeEvent;

private var flag:int;

protected function application1_initializeHandler(event:FlexEvent):void

{

this.flag=0;

this.myhttp.url = "/sj41/query?method=all&cid=all";

this.myhttp.send();

}

protected function myhttp_resultHandler(event:ResultEvent):void

{

//如果是初始化时返回的结果

if(flag==0){

this.ddl.dataProvider=event.result.cups.cup;

this.ddl.labelField = "countryName";

this.adg1.dataProvider=event.result.cups.cup;

}

else{//如果是选择下拉列表返回的结果

this.adg1.dataProvider=event.result.cups.cup;

}

}

protected function myhttp_faultHandler(event:FaultEvent):void

{

Alert.show(event.fault.faultString);

}

protected function ddl_changeHandler(event:IndexChangeEvent):void

{

var cid:String = this.ddl.selectedItem.countryId;

this.flag=1;

this.myhttp.url = "/sj41/query?method=getById&cid="+cid;

this.myhttp.send();

}

]]>

</fx:Script>

<fx:Declarations>

<s:HTTPService id="myhttp"  showBusyCursor="true" result="myhttp_resultHandler(event)" fault="myhttp_faultHandler(event)"/>

</fx:Declarations>

<s:Panel width="557" height="376" title="使用HttpService 与后台通信" horizontalCenter="0" verticalCenter="0">

<mx:AdvancedDataGrid x="2" y="9" id="adg1" designViewDataType="flat" width="545" height="274">

<mx:columns>

<mx:AdvancedDataGridColumn headerText="代号" dataField="countryId"/>

<mx:AdvancedDataGridColumn headerText="国家" dataField="countryName"/>

<mx:AdvancedDataGridColumn headerText="金牌数" dataField="goldMedal"/>

<mx:AdvancedDataGridColumn headerText="银牌数" dataField="silverMedal"/>

<mx:AdvancedDataGridColumn headerText="铜牌数" dataField="bronzeMedal"/>

</mx:columns>

</mx:AdvancedDataGrid>

<s:Label x="216" y="305" text="选择国家：" height="23" verticalAlign="middle"/>

<s:Button x="475" y="305" label="显示全部" click="application1_initializeHandler(event as FlexEvent)"/>

<s:DropDownList x="306" y="305" id="ddl" prompt="请选择国家" change="ddl_changeHandler(event)"></s:DropDownList>

</s:Panel>

</s:Application>

（6）运行应用程序，效果如图5.2.1所示。

图5.2.1 HttpService 示例

实训任务2：使用RemotingObject 与后台通信

训练技能点

RemotingObject。

需求说明

使用RemotingObject 重构任务1。

实现思路：

（1）创建Flex项目，将此项目的服务器技术选择为J2EE服务器（使用远程对象访问服务）。 如图5.2.2所示。

图5.2.2 创建Flex项目

（2）修改WebRoot/WEB-INFO/flex/remoting-config.xml，配置业务类：

<?xml version="1.0" encoding="UTF-8"?>

<service id="remoting-service"

class="flex.messaging.services.RemotingService">

<adapters>

<adapter-definition id="java-object" class="flex.messaging.services.remoting.adapters.JavaAdapter" default="true"/>

</adapters>

<default-channels>

<channel ref="my-amf"/>

</default-channels>

<destination id="service">

<properties>

<source>com.soft.flex.flex4sj.service.CupService</source>

</properties>

</destination>

</service>

（1）修改MXML应用程序 添加RemotingObject对象。

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

initialize="application1_initializeHandler(event)"

>

<fx:Script>

<![CDATA[

import mx.collections.IList;

import mx.controls.Alert;

import mx.events.FlexEvent;

import mx.rpc.events.FaultEvent;

import mx.rpc.events.ResultEvent;

import spark.events.IndexChangeEvent;

private var flag:int;

protected function application1_initializeHandler(event:FlexEvent):void

{

this.flag=0;

this.myremoting.getAll();

}

protected function ddl_changeHandler(event:IndexChangeEvent):void

{

var cid:String = this.ddl.selectedItem.countryId;

this.flag=1;

this.myremoting.getCupByCountryId(cid);

}

protected function myremoting_resultHandler1(event:ResultEvent):void

{

this.ddl.dataProvider=event.result as IList;

this.ddl.labelField = "countryName";

this.adg1.dataProvider=event.result;

}

protected function myremoting_resultHandler2(event:ResultEvent):void

{

this.adg1.dataProvider=event.result;

}

protected function myremoting_faultHandler(event:FaultEvent):void

{

Alert.show(event.fault.faultString);

}

]]>

</fx:Script>

<fx:Declarations>

<s:RemoteObject id="myremoting" showBusyCursor="true" destination="service"

endpoint="http://localhost:8080/sj42/messagebroker/amf"

fault="myremoting_faultHandler(event)"

>

<s:method name="getAll" result="myremoting_resultHandler1(event)" />

<s:method name="getCupByCountryId" result="myremoting_resultHandler2(event)"/>

</s:RemoteObject>

</fx:Declarations>

<s:Panel width="557" height="376" title="使用HttpService 与后台通信" horizontalCenter="0" verticalCenter="0">

<mx:AdvancedDataGrid x="2" y="9" id="adg1" designViewDataType="flat" width="545" height="274">

<mx:columns>

<mx:AdvancedDataGridColumn headerText="代号" dataField="countryId"/>

<mx:AdvancedDataGridColumn headerText="国家" dataField="countryName"/>

<mx:AdvancedDataGridColumn headerText="金牌数" dataField="goldMedal"/>

<mx:AdvancedDataGridColumn headerText="银牌数" dataField="silverMedal"/>

<mx:AdvancedDataGridColumn headerText="铜牌数" dataField="bronzeMedal"/>

</mx:columns>

</mx:AdvancedDataGrid>

<s:Label x="216" y="305" text="选择国家：" height="23" verticalAlign="middle"/>

<s:Button x="475" y="305" label="显示全部" click="application1_initializeHandler(event as FlexEvent)"/>

<s:DropDownList x="306" y="305" id="ddl" prompt="请选择国家" change="ddl_changeHandler(event)"></s:DropDownList>

</s:Panel>

</s:Application>

 

运行应用，效果如图5.2.1所示。

实训任务3：RemotingObject 整合Hibernate Spring

训练技能点

Ø RemotingObject。

Ø 整合Spring框架。

需求说明

使用RemotingObject 整合Hibernate Spring 重构任务1。

实现思路：

（1）创建Flex项目，将此项目的服务器技术选择为J2EE服务器（使用远程对象访问服务）。

（2）创建数据库表tb_cup 表字段与实体类属性对应 如图5.2.3所示。

图5.2.2 tb_Cup表

（3）切换到MyEclipes视图，分别添加hibernate支持和spring支持，并使用逆向工程生成视图类，映射文件等。

（4）创建业务类，在该类 中定义根据国家查询获取奖牌情况的方法。

package com.soft.flex.flex4sj.service;

import java.util.List;

import com.soft.flex.flex4sj.dao.Cup;

import com.soft.flex.flex4sj.dao.CupDao;

public class CupService {

private CupDao dao;

public List<Cup> getAll(){

return dao.findAll();

}

public List<Cup> getCupByCountryId(String cid){

return dao.findByCountryId(cid);

}

public CupDao getDao() {

return dao;

}

public void setDao(CupDao dao) {

this.dao = dao;

}

}

（5）添加整合Spring框架的响应jar包 并在applicationContext.xml中配置业务类。

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:flex="http://www.springframework.org/schema/flex"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

http://www.springframework.org/schema/flex

http://www.springframework.org/schema/flex/spring-flex-1.0.xsd">

<flex:message-broker />

<bean id="service" class="com.soft.flex.flex4sj.service.CupService">

<flex:remoting-destination />

<property name="dao" ref="CupDAO"></property>

</bean>

<!--其他配置省略-->

</beans>

（6）修改工程的web.xml文件如下：

<?xml version="1.0" encoding="UTF-8"?>

<web-app id="WebApp_ID" version="2.4" xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">

<display-name>sj43</display-name>

<context-param>

<param-name>flex.class.path</param-name>

<param-value>/WEB-INF/flex/hotfixes,/WEB-INF/flex/jars</param-value>

</context-param>

<!-- Http Flex Session attribute and binding listener support -->

<listener>

<listener-class>flex.messaging.HttpFlexSession</listener-class>

</listener>

<!-- MessageBroker Servlet -->

<servlet>

<servlet-name>Spring MVC Dispatcher Servlet</servlet-name>

<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>

<init-param>

<param-name>contextConfigLocation</param-name>

<param-value>classpath:applicationContext.xml</param-value>

</init-param>

<load-on-startup>1</load-on-startup>

</servlet>

<servlet-mapping>

<servlet-name>Spring MVC Dispatcher Servlet</servlet-name>

<url-pattern>/messagebroker/*</url-pattern>

</servlet-mapping>

<welcome-file-list>

<welcome-file>index.html</welcome-file>

<welcome-file>index.htm</welcome-file>

<welcome-file>index.jsp</welcome-file>

<welcome-file>default.html</welcome-file>

<welcome-file>default.htm</welcome-file>

<welcome-file>default.jsp</welcome-file>

</welcome-file-list>

</web-app>

（7）修改MXML代码如下：

<s:RemoteObject id="myremoting" showBusyCursor="true" destination="service"

endpoint="http://localhost:8080/sj43/messagebroker/amf"

fault="myremoting_faultHandler(event)"

>

其中destination=“service” service要与applicationContext.xml中业务bean的id一致。

运行应用程序，效果如图5.2.1.所示(注意要在服务器中将重复的cglib.jar删去)。

实训任务4：实现分页

训练技能点

Ø RemotingObject。

Ø 整合Spring框架。

需求说明

在任务3的基础上实现分页功能。

实现步骤：

（1）切换到MyEclipse视图 创建Page.java用来封装分页数据。

import java.util.List;

public class Page {

private List data;

private int currentPage;

private int totalPage;

private int pageSize;

private int totalClum;

public List getData() {

return data;

}

public void setData(List data) {

this.data = data;

}

public int getCurrentPage() {

return currentPage;

}

public void setCurrentPage(int currentPage) {

this.currentPage = currentPage;

}

public int getTotalPage() {

return totalPage;

}

public void setTotalPage(int totalPage) {

this.totalPage = totalPage;

}

public int getPageSize() {

return pageSize;

}

public void setPageSize(int pageSize) {

this.pageSize = pageSize;

}

public int getTotalClum() {

return totalClum;

}

public void setTotalClum(int totalClum) {

this.totalClum = totalClum;

this.totalPage=( totalClum%pageSize==0  ?totalClum/pageSize:totalClum/pageSize+1);

}

}

（2）在dao类中添加分页查询的方法

public List findByPage(Page page) {

String hql = "from Cup";

try {

Session session = getSession();

Query query = session.createQuery(hql);

query.setFirstResult((page.getCurrentPage()-1)*page.getPageSize());

query.setMaxResults(page.getPageSize());

List list = query.list();

releaseSession(session);

return list;

} catch (RuntimeException re) {

log.error("delete failed", re);

throw re;

}

}

public int count() {

log.debug("deleting User instance");

String hql = "select count(cup) from Cup as cup";

try {

Session session = getSession();

Query query = session.createQuery(hql);

long l = (Long)query.uniqueResult();

return (int)l;

} catch (RuntimeException re) {

log.error("delete failed", re);

throw re;

}

}

（3）在service类中添加相应的方法。

public Page findByPage(Page page){

List data= dao.findByPage(page);

int count = dao.count();

page.setData(data);

page.setTotalClum(count);

return page;

}

（4）切换回Flash视图 开发与Java端Page类对应的as类。

package com.oa.vo

{

import mx.collections.ArrayCollection;

[RemoteClass(alias="com.soft.flex.flex4sj.dao.Page")]

public class Page

{

public function Page()

{

}

public var data :ArrayCollection;

public var  currentPage:int;

public var  totalPage:int;

public var  pageSize:int;

public var  totalClum:int;

}

}

（5）修改主程序的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"

initialize="application1_initializeHandler(event)"

xmlns:ns1="*">

<fx:Script>

<![CDATA[

import com.oa.vo.Page;

import mx.collections.IList;

import mx.controls.Alert;

import mx.events.FlexEvent;

import mx.rpc.events.FaultEvent;

import mx.rpc.events.ResultEvent;

import spark.events.IndexChangeEvent;

[Bindable]

private var pageData:Page;

public  function loadData(currentPage:int):void{

var page:Page = new Page();

page.currentPage=currentPage;

page.pageSize=this.setPageSize.selectedItem.data;

this.myremoting.findByPage(page);

}

protected function application1_initializeHandler(event:FlexEvent):void

{

loadData(1);

}

protected function ddl_changeHandler(event:IndexChangeEvent):void

{

var cid:String = this.ddl.selectedItem.countryId;

this.myremoting.getCupByCountryId(cid);

}

protected function myremoting_resultHandler1(event:ResultEvent):void

{

pageData =Page( event.result) ;

Alert.show(pageData.currentPage+'c');

Alert.show(pageData.totalPage+'t');

this.ddl.dataProvider=pageData.data;

this.ddl.labelField = "countryName";

this.adg1.dataProvider=pageData.data;

}

protected function myremoting_resultHandler2(event:ResultEvent):void

{

this.adg1.dataProvider=event.result;

}

protected function myremoting_faultHandler(event:FaultEvent):void

{

Alert.show(event.fault.toString());

}

]]>

</fx:Script>

<fx:Declarations>

<s:RemoteObject id="myremoting" showBusyCursor="true" destination="service"

endpoint="http://localhost:8080/sj43/messagebroker/amf"

fault="myremoting_faultHandler(event)"

>

<s:method name="findByPage" result="myremoting_resultHandler1(event)" />

<s:method name="getCupByCountryId" result="myremoting_resultHandler2(event)"/>

</s:RemoteObject>

</fx:Declarations>

<s:Panel width="741" height="427" title="使用HttpService 与后台通信" horizontalCenter="0" verticalCenter="25">

<mx:AdvancedDataGrid x="2" y="9" id="adg1" designViewDataType="flat" width="727" height="274">

<mx:columns>

<mx:AdvancedDataGridColumn headerText="代号" dataField="countryId"/>

<mx:AdvancedDataGridColumn headerText="国家" dataField="countryName"/>

<mx:AdvancedDataGridColumn headerText="金牌数" dataField="goldMedal"/>

<mx:AdvancedDataGridColumn headerText="银牌数" dataField="silverMedal"/>

<mx:AdvancedDataGridColumn headerText="铜牌数" dataField="bronzeMedal"/>

</mx:columns>

</mx:AdvancedDataGrid>

<s:Label x="215" y="361" text="选择国家：" height="23" verticalAlign="middle"/>

<s:Button x="475" y="361" label="显示全部" click="application1_initializeHandler(event as FlexEvent)"/>

<s:DropDownList x="306" y="361" id="ddl" prompt="请选择国家" change="ddl_changeHandler(event)"></s:DropDownList>

<!--以下为分页栏-->

<mx:HBox cornerRadius="0" borderStyle="solid" horizontalAlign="left" verticalAlign="middle" width="722" x="7" y="305" height="27">

<mx:Text fontSize="12" text="{' 第'+pageData.currentPage+'页/共'+pageData.totalPage+'页'+' 共'+pageData.totalClum+'条记录'}"/>

<mx:LinkButton id="lbtnFirst" label="首页"  click="loadData(1)"  enabled="{lbtnPrevious.enabled}" fontSize="12"/>

<mx:LinkButton id="lbtnPrevious" label="上一页" click="loadData(pageData.currentPage-1)"   enabled="{pageData.currentPage!=1?true:false}"  fontSize="12"/>

<mx:LinkButton id="lbtnNext" label="下一页"   click="loadData(pageData.currentPage+1)" enabled="{pageData.totalPage>=(pageData.currentPage+1)?true:false}"  fontSize="12"/>

<mx:LinkButton id="lbtnLast" label="尾页" click="loadData(pageData.totalPage)" enabled="{lbtnNext.enabled}" fontSize="12"/>

<mx:Label   text="每页显示："/>

<mx:ComboBox id="setPageSize"  width="71" change="loadData(1)">

<mx:dataProvider>

<mx:ArrayList  >

<fx:Object label="5" data="5" />

<fx:Object label="10" data="10" />

<fx:Object label="20" data="20" />

</mx:ArrayList>

</mx:dataProvider>

</mx:ComboBox>

<mx:Label   text="条"/>

<mx:NumericStepper id="nsPageNum" stepSize="1" minimum="1" maximum="{pageData.totalPage}"  enabled="{lbtnJump.enabled}" cornerRadius="0" width="54"/>

<mx:LinkButton id="lbtnJump" label="跳转"  click="loadData(nsPageNum.value)" enabled="{pageData.totalPage>1?true:false}"  fontSize="12"/>

</mx:HBox>

</s:Panel>

</s:Application>

（6）运行应用程序，效果如图5.2.4所示。

图5.2.4  分页

 

巩固练习

选择题

1.  Flex与外部进行数据通信的方式有（）

A.  HTTPService。

B.  WebService。

C.  Remoting。

D.  HttpRequest。

2.  以下关于Flex中Remoting数据通信方式的说法，正确的是（）

A.  Remoting使用AMF二进制信息格式化传递数据。

B.  在Flex应用中使用Remoting 技术需要有第三方软件支持。

C.  数据量越大，Remoting方式传输效率越高。

D.  Remoting不支持序列化与反序列化。

3.  以下关于remoting-config.xml文件配置信息的描述 正确的是（）。

A.  使用destination节点配置远程调用类的标示。

B.  Source节点代表远程调用类的class文件路径。

C.  一个remoting-config.xml文件只允许配置一个destination节点。

D.  一个remoting-config.xml文件只允许配置多个destination节点。

简答题

（1）什么Remoting数据通信技术？

操作题

开发一个WebService ,用于查询Oracle数据库中的商品信息表，并返回结果。然后通过Flex的WebService组件调用webservice,将获取到的结果显示在表格组件中。

Flex与外部的数据通信相关推荐

1. 用ExternalInterface实现Flex与外部容器交互

   有时候Flex需要与外部容器交互,比如和别的项目交互,调用外部数据,则可以通过ExternalInterface来实现.毕竟Flex版本还是比较"年轻",有些地方还不完美,需要借助 ...

2. flex 读取外部txt文件时候出现中文乱码现象

   首先,flash读取txt出现乱码涉及到System.useCodepage这个静态属性属性 官方描述:"A Boolean value  that tells Flash Player w ...

3. Flash/Flex与外部对象或数据交互的几种方式

   1.首先当然是发布的swf和浏览器容器直接的通信,有三种方式  1)使用flashvar直接传参数给swf,这是早期swf最主要的方式,也是美工们喜欢的  2)通过url 使用BrowserManag ...

4. flex加载外部swf文件[flex-swf and flash as3 swf],并且互相通讯-加强原来的帖

   第一步:建立加载类[CtmObjLoader],此类可以加载文件类型 [图片文件或swf文件] package { import flash.display.DisplayObject;  impor ...

5. FLEX里的CSS样式设置教材

   FLEX3中应用 CSS完全详解手册! 编辑完这个FLEX下的CSS说明后,我基本已经兵临崩溃边缘了.在些天在AIRIA下了不少好东西,今天终于有空,也发一个比较不错的东西给大家,相信 都比较需要这个 ...

6. Flex css 运用

   申明:本文不是由我所写,是原作者 digman 发布在AIRIA论坛上面.转载自此方便自己查看.若作者不允许转载,请联系我.我会及时删除. FLEX3中应用CSS完全详解手册! 原文地址:http:/ ...

7. HTML部分知识点整理

   一,主流浏览器的内核分别是什么? IE:trident;   1997年的ie4首次被采用沿用至今,腾讯,猎豹,360等浏览器都是用ie的内核.因其稳定性,目前国内银行政府等办公主要还是ie浏览器为主 ...

8. 重新定义未来的汽车芯片角色 拼算力只是第一步

   汽车芯片赛道,正在经历"三年河东.三年河西"的变化. 随着L2级辅助驾驶增速加快,L2+甚至是L3成为上游芯片厂商争夺的下一个赛道.同时,整车电子架构的革新,整车OTA也驱动车企在 ...

9. 前端小白如何学习 CSS

   很多人想让我给他们推荐有关CSS部分的教程,或者问我如何学习CSS. 我也看到很多人对CSS的部分内容感到困惑,一部分原因是由于对语言的过时认识. 鉴于CSS在过去几年中发生了相当大的变化,这是一个更 ...

最新文章

1. qt与python互联_PYQT5 vscode联合操作qtdesigner的方法
2. ROS教程（3)---静态NAT配置及应用 (
3. Mac下修改环境变量
4. webservice的css哪里添加,jQuery_XML+XSLT+CSS+JQuery+WebService组建Asp.Net网(2)， 3.　　　　　　 更 - phpStudy...
5. git学习资料整理（知乎搜集的）
6. Min_25 筛小结
7. 大数据之Hive教程
8. matlab销量预测的数学模型,数学建模:酒店最优化问题.用matlab算出《酒店价格预测模型》...
9. PHP如何在微信中聊天_迷你微信私有聊天系统PHP源码支持PC、移动APP
10. 《精通Spring MVC 4》——1.3　start.Spring.io简介
11. Leetcode 214.最短回文串
12. 光伏组件为何出现白色线条？
13. MathType快捷键
14. 字母消消乐游戏（C语言版本_2023首篇新作）
15. Java - 什么是ORM？
16. C++ 单词转换例子
17. 有哪些好用的微信群管理工具？
18. 【MM32F5270开发板试用】六、如何用 星辰内核 + 国产RTOS 通过I2S播放 “星辰大海”
19. audioread-支持多种解码 (GStreamer + Core Audio + MAD + FFmpeg) 的python音频解码库
20. pre 图像稳定_什么是图像稳定，它如何工作？

热门文章

1. java中wait和sleep的区别
2. 浅谈RDMA流控设计
3. 关于Storm Tick
4. springMVC 的工作原理和机制
5. Gradle学习目录
6. me)不支持html,属于me的vue练习（参考菜鸟教程）.html
7. java 实现 tcp_java实现TCP通信
8. php投票系统制作,php简单的投票系统[原创]
9. MiniGUI编程之Helloworld(一)
10. html正则表达式的书写,前端正则表达式书写及常用的方法