瞌睡虫 2014-05-15
Spring Web Flow 是Spring Framework 中的web应用组件,它提供了一种编写有状态和基于会话的web应用的简便手段。Spring Web Flow 使得逻辑流程成为Web应用中的一等公民,它能让你定义为自包含模块,以独立于应用的其它部分来配置和重用。
Spring Web Flow 引入了几种有状态数据域:request、flash、flow和conversation等,这让你能用新的方式来开发有状态Web应用。它也提供了定制应用状态管理的扩展点。
Terracotta for Spring是通过在多个JVM集群来给基于Spring的应用提供高可用性的运行时。它给Spring Web Flows的所有域都提供了透明的声明式集群服务(普通的Spring beans同样适用)。
在这篇文章中我们会首先给你一个Spring Web Flow和Terracotta for Spring的总体介绍。然后会向你展示如何联合使用这些技术来进入构建有状态、基于会话、可扩展和高可用的Web应用的新领域。
Spring Web Flow是Spring Framework中的web应用组件,它提供了一种编写有状态和基于会话的web应用的简便手段。Spring Web Flow 使得逻辑流程成为web应用中的一等公民,它能让你定义为自包含模块,以独立于应用的其它部分来配置和重用。它不依赖于框架从而能够方便的与可选的web应用框架一同使用,比如Spring MVC、Struts或者JSF等。
页面流转使用一种领域定义语言(DSL)来配置,这个语言专门开发用来定义和组合页面流转。目前的实现方式是XML和Java.
Spring Web Flow引入了能满足多种用户案例和需求的几种有状态数据域:request、flash、flow和conversation,这给你开发有状态web应用提供了很大的灵活性和能力。
这里是1.0 release中最有趣特性的快速概要。(来自release notes on InfoQ):
听上去很有趣?到目前为止还仅仅是概念和理论,但我们很快会看到这些都能在实践中应用。所以请多等一会。
集群在企业应用开发中变得越来越重要,开发人员经常会碰到这样的问题:
为了支撑业务,可预测的扩展性和高可用性是一个生产应用必须展示的运行特性。一些企业需要超过99.9999%的正常运行时间,另一些不要求这么 高,但所有的应用都需要保证SLA规定的可运行性。从预测的角度看,开发一个系统在99.9%和99.9999%级别是一样困难的。
集群一直以来都是难以解决的问题。在Spring Web Flow和普通web应用上下文中,这尤其意味着保证用户状态的高可用性和故障恢复能力是满足性能且值得信赖的。在一个节点出现故障(应用服务器或JVM 崩溃),使用session粘滞(这是配置负载均衡最通用的首选方式)是一个开始,但我们需要一个有效手段来无缝的将用户状态从一个节点迁移到另一个节 点。
当我们说集群时意味着什么,它和缓存有什么区别?我们使用的集群定义是: 在多个JMV间共享应用状态,而缓存可以被定义为: 让应用状态靠近执行上下文。从这个角度看,缓存是集群的一个子集。
我们所认为的企业级Web/企业集群最小解决方案集至少需要包括:
让我们关注一个能解决所有这些看上去无关的需求的解决方案。通常解决一个问题有很多方案,而且市场上也有很多宣称能给web应用提供高可用性的产品。Terracotta就提供了这样一个解决方案。
Terracotta for Spring是基于Spring应用的运行时,它为Spring 应用提供了透明的高性能集群支持,对应用代码和部署及配置流程影响都很小。它通过在应用下面的堆级别进行集群而不是直接集群应用。
这让开发者能够开发与无状态方式不同的单节点有状态Spring应用。这使得在需要扩展的应用开始设计时不考虑集群。而在应用需要扩展或者要保证搞可用性和故障恢复时,他们只需要在Terracotta 配置文件中定义哪些Spring应用上下文中的beans需要进行集群。Terracotta for Spring 使得应用能够被自动和透明的集群,还保证在集群间的语义和单节点一样。
对于Spring Web Flow来说,这实际上更简单。用户为了获得web应用的状态和持续仓库的集群能力, 只需要在Terracotta配置文件中把特定的web应用声明为启用“session-support”。(详细内容见下面的章节“声明式配置”)
从宏观上看,Terracotta for Spring提供了:
Terracotta for Spring 使用aspect-oriented技术来在类载入时适配应用。在这个阶段它扩展了应用以保证Java语义在集群间被正确的维护,包括对象引用,进程调用和垃圾收集等
我们在前面提到Terracotta并没有使用serialization。这意味着任何Spring Web Flow 维护的会话都可以在集群间共享。这也意味着Terracotta并没有把会话状态的全部对象图发给所有节点,而是把图分解成纯粹的数据,并在网络间传输实际的“差量”和改变--数据的“原始信息”在其它节点上。
因为有一个记录节点间相互引用的中心调度器(见下文),它能以lazy的方式工作,而只把改变传送到引用了这些“dirty”数据的节点。这需要使 用局部引用。如果负载均衡配置为使用"session粘滞" 就更有效率,因为这意味着很多数据可能永远不会脱离实际的session而不用复制到其它节点。
这个架构是中心辐射的,也就是有一个管理客户端的中心调度器。在这里客户端就是你配有Terracotta for Spring 运行时的普通应用。调度器不是单点失败的,但你可以配置一组备用调度器,并在主调度器崩溃时选择一个来接替。你也可以独立于客户端,对调度器进行集群扩展。
这里我们使用一个叫Sellitem的示例应用来推动讨论并展示给大家:
Sellitem示例应用可以在Spring Web Flow的发布版本中找到。(更多信息见文章末尾的“Resources” 章节)
Sellitem是展示结合了有条件转移、会话域、流程执行转向和延续性的示例应用。用户在几个页面间导航,可以定义货物的价格、可以销售的货物数量、折扣比率、送货详情(如果需要)和最后查看所有信息。
我们不会通读应用的所有源码,而是主要介绍一些关键概念,如怎么配置Spring Web Flow输出的不同标准服务(Bean)和怎么定义页面流转(使用针对页面流转的Spring Web FlowDSL的XML版本)。
应用的入口是一个标准的Spring MVC DispatcherServlet,它在web.xml中注册并在web application context中映射到*.htm。
<servlet> <servlet-name>sellitem</servlet-name> <servlet-class> org.springframework.web.servlet.DispatcherServlet </servlet-class> <init-param> <param-name>contextConfigLocation</param-name> <param-value> /WEB-INF/sellitem-servlet-config.xml /WEB-INF/sellitem-webflow-config.xml </param-value> </init-param> </servlet> <servlet-mapping> <servlet-name>sellitem</servlet-name> <url-pattern>*.htm</url-pattern> </servlet-mapping>
DispatcherServlet配置在Spring的配置文件sellitem-servlet-config.xml和sellitem- webflow-config.xml中。 sellitem-servlet-config.xml中有一个映射到"/pos.htm"的控制器,它将所有该URL的请求转发到Spring Web Flow系统(它的入口是一个流程执行器):
<bean name="/pos.htm" class="org.springframework.webflow.executor.mvc.FlowController"> <property name="flowExecutor" ref="flowExecutor" /> </bean>
Spring flowExecutor bean配置使用一个flowRegistry bean来执行"/WEB-INF/flows/"目录中的基于XML的流转定义。
<flow:executor id="flowExecutor" registry-ref="flowRegistry"/> <flow:registry id="flowRegistry"> <flow:location path="/WEB-INF/flows/**-flow.xml" /> </flow:registry>
剩余的逻辑在我们已经注册的flowRegistry bean的流转定义中。(参照前面的'配置flow executor和flow registry beans章节)。
在深入流转实现细节前,我们先看一下页面流转的状态图(如下图)。
从上面我们可以看到流转在结束前经过了几个步骤,在决定销售是否需要送货时有一个决策状态。
一个很好的针对上面导航规则的初始流转定义实现如下:
<flow xmlns="http://www.springframework.org/schema/webflow" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation=" http://www.springframework.org/schema/webflow http://www.springframework.org/schema/webflow/spring-webflow-1.0.xsd"> <var name="sale" class="org.springframework.webflow.samples.sellitem.Sale"/> <start-state idref="enterPriceAndItemCount"/> <view-state id="enterPriceAndItemCount" view="priceAndItemCountForm"> <transition on="submit" to="enterCategory"/> </view-state> <view-state id="enterCategory" view="categoryForm"> <transition on="submit" to="requiresShipping"/> </view-state> <decision-state id="requiresShipping"> <if test="${flowScope.sale.shipping}" then="enterShippingDetails" else="finish"/> </decision-state> <view-state id="enterShippingDetails" view="shippingDetailsForm"> <transition on="submit" to="finish"/> </view-state> <end-state id="finish" view="costOverview"/> </flow>
我们从上面的定义可以看到,实际状态与状态图中的状态对应,状态转换与图中的箭头对应。"sale" bean是流转开始时分配的流转变量实例。它持有了Sale相关的属性。
上面的定义展示了所有的导航逻辑,但还没有实现任何应用行为。特别是在用户提交时更新Sale Bean的逻辑还没有实现。另外后台的sale处理逻辑还没有定义。
实现了所有必需行为的完整Spring Web Flow定义如下:
<flow xmlns="http://www.springframework.org/schema/webflow" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation=" http://www.springframework.org/schema/webflow http://www.springframework.org/schema/webflow/spring-webflow-1.0.xsd"> <var name="sale" class="org.springframework.webflow.samples.sellitem.Sale"/> <start-state idref="enterPriceAndItemCount"/> <view-state id="enterPriceAndItemCount" view="priceAndItemCountForm"> <render-actions> <action bean="formAction" method="setupForm"/> </render-actions> <transition on="submit" to="enterCategory"> <action bean="formAction" method="bindAndValidate"> <attribute name="validatorMethod" value="validatePriceAndItemCount"/> </action> </transition> </view-state> <view-state id="enterCategory" view="categoryForm"> <transition on="submit" to="requiresShipping"> <action bean="formAction" method="bind"/> </transition> </view-state> <decision-state id="requiresShipping"> <if test="${flowScope.sale.shipping}" then="enterShippingDetails" else="processSale"/> </decision-state> <view-state id="enterShippingDetails" view="shippingDetailsForm"> <transition on="submit" to="processSale"> <action bean="formAction" method="bind"/> </transition> </view-state> <action-state id="processSale"> <bean-action bean="saleProcessor" method="process"> <method-arguments> <argument expression="flowScope.sale"/> </method-arguments> </bean-action> <transition on="success" to="finish"/> </action-state> <end-state id="finish" view="costOverview"> <entry-actions> <action bean="formAction" method="setupForm"/> </entry-actions> </end-state> <import resource="sellitem-beans.xml"/> </flow>
在定义导航逻辑之外,也定义了适时调用恰当应用行为的action。这包括处理用户提交事件和调用后台处理器来处理sale的逻辑。
当进入展示表单的视图状态时,流转调用一个FormAction command bean来进行表单的装配和提交逻辑。在提交时,FormAction把用户的请求参数绑定到相应的sale属性上并同时验证它们。
<bean id="formAction" class="org.springframework.webflow.action.FormAction"> <property name="formObjectName" value="sale"/> <property name="validator"> <bean class="org.springframework.webflow.samples.sellitem.SaleValidator"/> </property> </bean>
Spring Web Flow全部的代码、文档和10个示例应用(包括sellitem)都可以在Spring网站上找到http://www.springframework.org/webflow。
现在我们已经看过了如何使用Spring Web Flow来实现一个有状态web应用。接下来让我们更高兴的看如何给我们的示例应用启用高可用性和故障恢复,如何使用Terracotta for Spring进行集群来提供透明容错性和在节点间共享状态。
听上去很难? 你会发现这实际上很简单。
Sellitem示例应用使用一个Sale类的实例来保存当前销售的会话数据;同样Spring Web Flow executor repository 也使用HTTP session 来保存所有的会话数据。
要使用Terracotta for Spring,我们需要确保为给定的web应用启用了HTTP session集群,包括所有可能被保存在 HTTP session中(或者能被保存在HTTP session中的实例引用)的类,以便于检测。这里是Terracotta for Spring的tc-config.xml配置文件的一个例子:
<application> <spring> <jee-application name="swf-sellitem"> <session-support>true</session-support> <instrumented-classes> <include> <class-expression> org.springframework.webflow.samples.sellitem.Sale </class-expression> </include> </instrumented-classes> </jee-application> </spring> </application>
这里我们为swf-sellitem WAR文件启用了HTTP session集群并配置了Sale类。
就是这样,我们已经做了很多了。
我们唯一需要做的就是在应用中启用Terracotta for Spring运行时。这可以通过修改Tomcat web服务器的启动脚本并在脚本最前面加入下面的环境变量完成:
set JAVA_OPTS=-Xbootclasspath/p:"%DSO_BOOT_JAR%" set JAVA_OPTS=%JAVA_OPTS% -Dtc.install-root="%TC_INSTALL_DIR%" set JAVA_OPTS=%JAVA_OPTS% -Dtc.config="%LOCAL_DIR%\tc-config.xml"
这里面:
Sellitem应用预配置了Terracotta for Spring集群的代码可以在下面的'Resources'章节找到。也包括了开箱即用的Tomcat集群配置。
注解:Spring应用上下文中的集群bean可以在服务(bean)级别配置,并依赖于Terracotta for Spring的 auto-include检测机制.例如,大多数情况下我们不需要关心引入哪个类,而只需要在tc-config.xml文件中定义希望集群的bean的名称。
Spring Web Flow 给包括文章中看到的这种简单应用到有很多页面流转的大型企业应用,都提供了构建基于会话的有状态应用的有力手段。 Terracotta for Spring给你的Spring Web Flow提供了高可用性。
简而言之, Terracotta for Spring 提供了:
Spring Web Flow和Terracotta for Spring结合在一起,给你提供了构建有状态、基于会话、可扩展和高可用性web应用的新方式。
Spring Web Flow
主页、下载和文档:http://www.springframework.org/webflow 。
示例应用:在文章中使用的Sellitem应用包含在Spring Web Flow发布版本中。
Sellitem应用在线演示:http://spring.ervacon.com/swf-sellitem/。
Terracotta for Spring
Terracotta for Spring是提供JVM级集群开源项目Open Terracotta的一部分: http://terracotta.org/。
下载:http://terracotta.org/confluence/display/orgsite/Download
示例应用:Sellitem应用包含了Terracotta for Spring简化版本的发布包,它已经预配置了且能直接运行(甚至打包了Tomcat和负载均衡)。
文档:http://terracotta.org/confluence/display/docs1/Spring+Quick+Start。
查看英文原文:Web Applications with Spring Web Flow and Terracotta for Spring