基于Flex三种通讯方式的Java配置与整合.docx

基于flex三种通讯方式的java配置与整合2013年8月13日目录一、前言3二、基础信息准备61.spring-flex 1.0.3（amf）72.blazeds（amf）83.backport-util-concurrent 3.1（amf）84.struts-（httpservice）95.cxf 2.7.6（webservice）10三、具体配置方案与测试101.第一步我们先来配置sh(spring + hibernate)102.增flex-spring服务支持，是项目支持amf通讯协议（fsh）273.增struts服务支持，是项目支持http通讯协议（httpservice）304.增cxf服务支持，是项目支持sopa通讯协议（webservice）35四、总结38一、 前言在项目开发过程中，很多时候需要给第三方提供一些接口来处理项目中的一下数据，然而在使用flex的amf通信方式来配置我们的java web project的时候，我们就无法来处理这样的需求，所以这个时候我们可以合理的引入httpservice通讯方式和webservice通讯方式来弥补java服务端这一缺陷。下面我们提一下flex三种通讯方式：通讯方式通信协议数据交互格式优点缺点httpservice常用的http协议xml数据格式通用，便于不同应用系统间交换数据1数据在发送前需要转换成xml格式，接收后要解析xml数据。哪怕是只发送一个简单的的数字也要如此2在处理复杂数据类型如图片，对象的时候，非常不方便webservicesoap协议xml同上同上remoteobjectflex自定义的高效二进制数据通讯协议：amf任意（可以是数字，字符串，对象，图片等等）能够处理各种类型的数据类型，速度快需要专门的服务器端软件lcds（fds）或amfphp。lcds（fds）是收费的，价格不菲。其中也可使用免费版本（blazeds），但是有限制。（#）这里简单说明一下lcds与blanzeds的区别。blazeds可以看成是lcds的一个子集，而且是一个开源产品，在一般的项目中完全可以替代lcds。（抱歉，adobe官方的图片找不到了，所以找了张有水印的） 代表此功能可用featuresblazedslcdsdata management servicesclient-server synchronizationconflict resolutiondata pagingsql adapterhibernate adapterdocument serviceslivecycle remotingria-to-pdf conversionenterprise-class flex application servicesdata access/remotingproxy serviceautomated testing supportsoftware clusteringweb tier compilerenterprise integrationwsrp generationajax data servicesflex-ajax bridgeruntime configurationopen adapter architecturejms adapterserver-side component framework integrationcoldfusion integrationoffline application supportoffline data cachelocal message queuingreal - time datapublish and subscribe messagingreal -time data quality of servicertmp tunnelingfeaturesblazedslivecycle data services es2rpc servicesjava remoting/action message format (amf)yesyesajax client libraries to java remotingyesyesws/json proxy serviceyesyesmessagingservlet-based messaging services (hundreds of clients per cpu)yesyesjava nio high-performance messaging (thousands of clients per cpu)noyesreal time messaging protocol (rtmp)noyesdata throttlingnoyesreliable communicationsnoyesdata managementtransaction (batch processing)noyesdata pagingnoyeslazy loading (on demand)noyesconflict resolution and synchronizationnoyessql adapternoyeshibernate adapternoyesfiber-aware assemblernoyesoffline web applicationsnoyesdevelopment and deploymentspring integration supportyesyesadobe flash builder modeling plug-innoyesenterprise supportnoyesria pdf generationnoyeswsrp portal integrationnoyesload/stress testing toolnoyesedge servernoyesenterprise support plansnoyes这份是adobe公司给的对比二、 基础信息准备基础准备，在这里我们使用的ide是myeclipse10.7.1（因为在使用jar包的时候使用的是myeclipse自带包）。jdk使用的是5基本配置与框架使用web层:1) spring-flex 1.0.3（amf）2) struts (httpservice)3) cxf 2.7.6(webservice)service层: 1) spring 3.1 使用myeclipse自带dao层:1) hibernate 3.3 使用myeclipse自带下载jar包1. spring-flex 1.0.3（amf）/download/community这里我们使用的是1.0.3这个版本。2. blazeds（amf）adobe blazeds-bin-4931.zip/cfusion/entitlement/index.cfm?e=lc_blazeds登录，下载blazeds，最新版本为4931。3. backport-util-concurrent 3.1（amf）/projects/backport-jsr166/files/backport-jsr166/3.1/这个在下载时请注意版本，这里下载backport-util-concurrent-java60-3.1.zip，这个为jdk1.6下的jar文件。4. struts-（httpservice）/download.cgi#struts2315配置过ssh的程序员都知道，在eclipse中使用软件自带的struts时，在项目中展现的形式是这样的形式，而不能直接加入到web-inf/lib文件夹下面。5. cxf 2.7.6（webservice）/download.html这里使用cxf框架来对webservice中spring的整合。三、 具体配置方案与测试1. 第一步我们先来配置sh(spring + hibernate)1) 创建java web project2) 增加spring支持点击next 按钮下一步finish3) 增加hibernate支持点击next 按钮 下一步点击next 按钮下一步点击next 按钮下一步这里配置数据库连接信息，点击next 按钮进入下一个步骤finish 完成hibernate的配置4) 配置项目中的web.xml文件，使其支持spring、hibernate服务。springorg.springframework.web.context.contextloaderlistenercontextconfiglocationclasspath:applicationcontext.xmlhibernatefilterorg.springframework.orm.hibernate3.support.opensessioninviewfiltersinglesessiontrueflushmodeauto hibernatefilter/*5) 配置applicationcontext.xml文件，增加spring事务管理功能org.hibernate.dialect.sqlserverdialectpropagation_requiredpropagation_required,readonlypropagation_required,readonlypropagation_required,readonlypropagation_requiredpropagation_requiredpropagation_required*service配置spring通过service层来管理数据库事务。其中，datasource和sessionfactory由eclipse自动产生。6) 测试spring、hibernate配置是否成功a) 在数据库中新建表person,包含id(int自增）、name(varchar(16)和age(int)三字段。b) 增加hibernate annotation配置方式类person.javapackage com.bean;import javax.persistence.column;import javax.persistence.entity;import javax.persistence.generatedvalue;import javax.persistence.generationtype;import javax.persistence.id;import javax.persistence.table;entitytable(name = person, schema = dbo, catalog = report)public class person implements java.io.serializable private static final long serialversionuid = 1l;/ fieldsprivate integer id;private string name;private integer age;/ constructors/* default constructor */public person() /* full constructor */public person(integer id, string name, integer age) this.id = id; = name;this.age = age;/ property accessorsidgeneratedvalue(strategy = generationtype.auto)column(name = id, unique = true, nullable = false)public integer getid() return this.id;public void setid(integer id) this.id = id;column(name = name, nullable = false, length = 16)public string getname() return ;public void setname(string name) = name;column(name = age, nullable = false)public integer getage() return this.age;public void setage(integer age) this.age = age;注意：这里由于id是自增类型所以需要增加generatedvalue(strategy = generationtype.auto)的注解c) 建立dao层java类persondao.javapackage com.dao;import java.util.list;import org.hibernate.query;import org.springframework.orm.hibernate3.support.hibernatedaosupport;import com.bean.person;suppresswarnings(unchecked)public class persondao extends hibernatedaosupport public void saveorupdate(person ps) try gethibernatetemplate().saveorupdate(ps); catch (runtimeexception e) throw e;public list query() try query query = getsession().createquery(from person);return query.list(); catch (runtimeexception e) throw e;d) 建立service层java类person.javapackage com.service;import java.util.list;import com.bean.person;import com.dao.persondao;public class personservice private persondao persondao;public void save(person ps) try persondao.saveorupdate(ps); catch (runtimeexception e) throw e;public list query() try return persondao.query(); catch (runtimeexception e) throw e;public persondao getpersondao() return persondao;public void setpersondao(persondao persondao) this.persondao = persondao;e) 配置spring，增加上面几个类的服务支持f) 编写测试类public static void main(string args) applicationcontext ac = new classpathxmlapplicationcontext(applicationcontext.xml);personservice service = (personservice) ac.getbean(personservice);person ps = new person();ps.setname(name);ps.setage(10);service.save(ps);list list = service.query();for (person vo : list) system.out.println(vo.getid() + , + vo.getname() + , + vo.getage();报错误信息java.lang.noclassdeffounderror: org/objectweb/asm/type原因是缺少asm-3.3.jar包，可以从前面准备的struts-中获取，并服务在项目的web-inf/lib文件夹下。运行成功，控制台输出：1,name,10测试成功，spring、hibernate整合（包含数据）没有问题。接下去，我增加flex与spring直接的通讯整合。2. 增flex-spring服务支持，是项目支持amf通讯协议（fsh）1) 解压blazeds-bin-4931.zip中blazeds.war文件2) 复制./blazeds/web-inf/lib下的jar包到项目的web-inf/lib文件夹下3) 复制./blazeds/web-inf/flex下的jar包到项目的web-inf文件夹下4) 删除messaging-config.xml、proxy-config.xml、remoting-config.xml和perties文件5) 修改services-config.xml文件删除和部分增加6) 增加flex-spring jar包将backport-util-concurrent.jar和org.springframework.flex-1.0.3.release.jar复制到项目的wen-inf/lib文件夹下。7) 配置web.xml使项目支持flex-springflexorg.springframework.web.servlet.dispatcherservletcontextconfiglocation1flex/messagebroker/*8) 配置spring文件使其支持flex remote修改beans头文件为增加flex支持7) 测试amf通讯配置方式是否正确a) java web项目中增加dest类。persondest.javapackage com.dest;import java.util.list;import com.bean.person;import com.service.personservice;public class persondest private personservice personservice;public list query() return personservice.query();public string save(person ps) personservice.save(ps);return success;public personservice getpersonservice() return personservice;public void setpersonservice(personservice personservice) this.personservice = personservice;b) 在spring中配置persondest为flex remoteobject对接类c) 建立flex测试applicationperson.aspackage com.bean remoteclass(alias=com.bean.person) public class person / public var id:int;public var name:string;public var age:int;public function person() fsh_fb.mxmld) 测试结果运行结果界面数据库3. 增struts服务支持，是项目支持http通讯协议（httpservice）1) 解压下载的struts--all.zip文件。2) 解压struts-/apps/ struts2-blank.war文件。struts2-blank项目是struts2的一个基础配置项目，接下来我们可以使用这个项目来参考配置我们的struts框架。3) 复制struts2-blank/web-inf/lib中的jar文件到我们项目的web-inf/lib文件夹中。4) 复制struts2-blank/web-inf/classes中的struts.xml文件到我们的src文件目录下。5) 配置web.xml使其支持struts服务struts2org.apache.struts2.dispatcher.ng.filter.strutsprepareandexecutefilterstruts2*.do6) 建立action类personaction.javapackage com.dest;import java.io.printwriter;import java.util.list;import javax.servlet.http.httpservletrequest;import javax.servlet.http.httpservletresponse;import org.apache.struts2.servletactioncontext;import com.bean.person;import com.opensymphony.xwork2.actioncontext;import com.opensymphony.xwork2.actionsupport;import com.service.personservice;public class personaction extends actionsupport private static final long serialversionuid = 1l;private personservice personservice;private httpservletrequest request;private httpservletresponse response;public string save() system.out.println(action save);try setservlet();string name = request.getparameter(name);int age = integer.parseint(request.getparameter(age);person person = new person();person.setname(name);person.setage(age);personservice.save(person);printwriter out =