javatar
- 浏览: 1680384 次
- 性别:
- 来自: 杭州699号
-
文章分类
最新评论
-
莫莫摸：
为什么不用dubbo
RCP数据传输模型回顾 -
大胡子爸爸：
String, Class 都实现了Serializable接 ...
RPC框架几行代码就够了 -
lss598018587：
谢谢大神分享，比起新手看复杂的dubbo框架还不如看大神的这一 ...
RPC框架几行代码就够了 -
15606915740：
你好，请问一下。<dubbo:consumer filt ...
Dubbo文档 -
joqk12345：
...
一些设计上的基本常识
因Webx3是开源的，所以把这个简单的Webx3扩展发在博客上。
很久没弄Web框架，因要将服务框架的控制台换成Webx3，就折腾一下，
一种使用Webx3的方式如下：
1. 注入HttpServletRequest
这样写没有问题，但感觉不是很优雅，过多的强依赖于Request等容器对象。
Webx3还提供另外一种写法：
2. 基于注解自动从请求中获取参数
但感觉这样写，注解一大把，看起来也很复杂，而且依赖Param，Context，Navigator等框架类。
因为webx3提供了DataResolver扩展点，基于扩展点将写法改成了：
3. 使用标准Map接口封装所有输入输出
在webx3中配置：
扩展点实现类如下：
另外，还有一种办法是，
4. 通过asm字节码分析参数名称，去掉上面第二种写法的注解
很久没弄Web框架，因要将服务框架的控制台换成Webx3，就折腾一下，
一种使用Webx3的方式如下：
1. 注入HttpServletRequest
public class ProvidersAction extends BaseAction {
@Autowired
private ProviderDAO providerDAO; // 注入DAO依赖
@Autowired
private HttpServletRequest request; // 注入HTTP请求
public void execute(Context context, Navigator navigator) throws Exception { // 传入模板变量上下文，跳转导航器
String serviceName = request.getParameter("serviceName"); // 从请求中获取参数
List<Provider> providers = providerDAO.findProvidersByServiceName(serviceName); // 从数据库查询数据
context.put("providers", providers); // 输出模板变量
}
}
这样写没有问题，但感觉不是很优雅，过多的强依赖于Request等容器对象。
Webx3还提供另外一种写法：
2. 基于注解自动从请求中获取参数
public class ProvidersAction extends BaseAction {
@Autowired
private ProviderDAO providerDAO;
// 基于注解自动从请求中获取参数，可以减少对Request的依赖
public void execute(@Param(“serviceName”) String serviceName, Context context, Navigator navigator) throws Exception {
List<Provider> providers = providerDAO.findProvidersByServiceName(serviceName);
context.put("providers", providers);
}
}
但感觉这样写，注解一大把，看起来也很复杂，而且依赖Param，Context，Navigator等框架类。
因为webx3提供了DataResolver扩展点，基于扩展点将写法改成了：
3. 使用标准Map接口封装所有输入输出
public class ProvidersAction extends BaseAction {
@Autowired
private ProviderDAO providerDAO; // 注入DAO依赖
// 使用标准Map接口封装所有输入输出，get为输入，put为输出
public void execute(Map<String, Object> context) throws Exception {
String serviceName = (String) context.get("serviceName");
List<Provider> providers = providerDAO.findProvidersByServiceName(serviceName);
context.put("providers", providers);
}
}
在webx3中配置：
<services:data-resolver xmlns="http://www.alibaba.com/schema/services/data-resolver/factories">
<dr-factories:factory class="com.alibaba.citrus.extension.resolver.MapDataResolverFactory" />
</services:data-resolver>
扩展点实现类如下：
package com.alibaba.citrus.extension.resolver;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import org.springframework.beans.factory.annotation.Autowired;
import com.alibaba.citrus.service.dataresolver.DataResolver;
import com.alibaba.citrus.service.dataresolver.DataResolverContext;
import com.alibaba.citrus.service.dataresolver.DataResolverFactory;
import com.alibaba.citrus.service.moduleloader.ModuleInfo;
import com.alibaba.citrus.turbine.Context;
import com.alibaba.citrus.turbine.TurbineRunDataInternal;
import com.alibaba.citrus.turbine.util.TurbineUtil;
/**
* MapDataResolverFactory
*
* @author william.liangf
*/
public class MapDataResolverFactory implements DataResolverFactory {
@Autowired
private HttpServletRequest request;
public DataResolver getDataResolver(DataResolverContext context) {
if (Map.class == context.getTypeInfo().getRawType()) {
return new MapDataResolver(context);
}
return null;
}
public class MapDataResolver implements DataResolver {
public final DataResolverContext context;
public MapDataResolver(DataResolverContext context){
this.context = context;
}
public Object resolve() {
TurbineRunDataInternal rundata = (TurbineRunDataInternal) TurbineUtil.getTurbineRunData(request);
return new ParameterMap(request, rundata.getContext(), rundata);
}
}
}
package com.alibaba.citrus.extension.resolver;
import java.util.Collection;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import com.alibaba.citrus.turbine.Context;
import com.alibaba.citrus.turbine.TurbineRunDataInternal;
/**
* ParameterMap
*
* @author william.liangf
*/
public class ParameterMap implements Map<String, Object> {
private static final String CONTEXT_PREFIX = "context.";
private static final String PARAMETER_PREFIX = "parameter.";
private static final String REQUEST_PREFIX = "request.";
private static final String SESSION_PREFIX = "session.";
private static final String COOKIE_PREFIX = "cookie.";
private static final String APPLICATION_PREFIX = "application.";
private static final String NAVIGATOR_PREFIX = "navigator.";
private static final String TARGET_KEY = "target";
private static final String FORWARD_KEY = "forward";
private static final String REDIRECT_KEY = "redirect";
private static final String REDIRECTED_KEY = "redirected";
private final HttpServletRequest request;
private final Context context;
private final TurbineRunDataInternal navigator;
public ParameterMap(HttpServletRequest request, Context context, TurbineRunDataInternal navigator){
super();
this.request = request;
this.context = context;
this.navigator = navigator;
}
public int size() {
return 0;
}
public boolean isEmpty() {
return false;
}
public boolean containsValue(Object value) {
if (value == null) {
return false;
}
Set<String> keys = context.keySet();
if (keys != null && keys.size() > 0) {
for (String key : keys) {
if (value.equals(context.get(key))) {
return true;
}
}
}
return false;
}
public boolean containsKey(Object key) {
String k = (String) key;
if (k == null || k.length() == 0) {
return false;
}
return context.containsKey(k) || request.getParameter(k) != null;
}
public Object get(Object key) {
String k = (String) key;
if (k == null || k.length() == 0) {
return null;
}
if (k.startsWith(CONTEXT_PREFIX)) {
return context.get(k.substring(CONTEXT_PREFIX.length()));
} else if (k.startsWith(PARAMETER_PREFIX)) {
return getParameterValue(k.substring(PARAMETER_PREFIX.length()));
} else if (k.startsWith(REQUEST_PREFIX)) {
return request.getAttribute(k.substring(REQUEST_PREFIX.length()));
} else if (k.startsWith(SESSION_PREFIX)) {
return request.getSession().getAttribute(k.substring(SESSION_PREFIX.length()));
} else if (k.startsWith(COOKIE_PREFIX)) {
return getCookieValue(k.substring(COOKIE_PREFIX.length()));
} else if (k.startsWith(APPLICATION_PREFIX)) {
return request.getSession().getServletContext().getAttribute(k.substring(APPLICATION_PREFIX.length()));
} else if (TARGET_KEY.equals(k) || (NAVIGATOR_PREFIX + TARGET_KEY).equals(k)) {
return navigator.getTarget();
} else if (FORWARD_KEY.equals(k) || (NAVIGATOR_PREFIX + FORWARD_KEY).equals(k)) {
return navigator.getRedirectTarget();
} else if (REDIRECT_KEY.equals(k) || (NAVIGATOR_PREFIX + REDIRECT_KEY).equals(k)) {
return navigator.getRedirectLocation();
} else if (REDIRECTED_KEY.equals(k) || (NAVIGATOR_PREFIX + REDIRECTED_KEY).equals(k)) {
return navigator.isRedirected();
} else {
Object value = context.get(k);
if (value == null) {
value = getParameterValue(k);
if (value == null) {
value = request.getAttribute(k);
if (value == null) {
value = request.getSession().getAttribute(k);
if (value == null) {
value = getCookieValue(k);
if (value == null) {
value = request.getSession().getServletContext().getAttribute(k);
}
}
}
}
}
return value;
}
}
private Object getParameterValue(String key) {
String[] values = request.getParameterValues(key);
if (values == null || values.length == 0) {
return null;
} else if (values.length == 1) {
return values[0];
} else {
return values;
}
}
private Object getCookieValue(String key) {
Cookie[] cookies = request.getCookies();
if (cookies != null && cookies.length > 0) {
for (Cookie cookie : cookies) {
if (key.equals(cookie.getName())) {
return cookie.getValue();
}
}
}
return null;
}
public Object put(String key, Object value) {
if (key == null || key.length() == 0) {
return null;
}
if (TARGET_KEY.equals(key) || (NAVIGATOR_PREFIX + TARGET_KEY).equals(key)) {
navigator.setTarget((String) value);
return null;
} else if (FORWARD_KEY.equals(key) || (NAVIGATOR_PREFIX + FORWARD_KEY).equals(key)) {
navigator.setRedirectTarget((String) value);
return null;
} else if (REDIRECT_KEY.equals(key) || (NAVIGATOR_PREFIX + REDIRECT_KEY).equals(key)) {
navigator.setRedirectLocation((String) value);
return null;
} else {
if (key.startsWith(REQUEST_PREFIX)) {
key = key.substring(APPLICATION_PREFIX.length());
Object old = request.getAttribute(key);
if (value == null) {
request.removeAttribute(key);
} else {
request.setAttribute(key, value);
}
return old;
} else if (key.startsWith(SESSION_PREFIX)) {
key = key.substring(APPLICATION_PREFIX.length());
Object old = request.getSession().getAttribute(key);
if (value == null) {
request.getSession().removeAttribute(key);
} else {
request.getSession().setAttribute(key, value);
}
return old;
} else if (key.startsWith(COOKIE_PREFIX)) {
key = key.substring(APPLICATION_PREFIX.length());
Object old = null;
Cookie[] cookies = request.getCookies();
if (cookies != null && cookies.length > 0) {
for (Cookie cookie : cookies) {
if (key.equals(cookie.getName())) {
old = cookie.getValue();
if (value == null) {
cookie.setMaxAge(-1);
} else {
cookie.setValue((String) value);
}
break;
}
}
}
return old;
} else if (key.startsWith(APPLICATION_PREFIX)) {
key = key.substring(APPLICATION_PREFIX.length());
Object old = request.getSession().getServletContext().getAttribute(key);
if (value == null) {
request.getSession().getServletContext().removeAttribute(key);
} else {
request.getSession().getServletContext().setAttribute(key, value);
}
return old;
} else {
if (key.startsWith(APPLICATION_PREFIX)) {
key = key.substring(APPLICATION_PREFIX.length());
}
Object old = context.get(key);
if (value == null) {
context.remove(key);
} else {
context.put(key, value);
}
return old;
}
}
}
public Object remove(Object key) {
return put((String) key, null);
}
public void putAll(Map<? extends String, ? extends Object> map) {
if (map != null && map.size() > 0) {
for (Map.Entry<? extends String, ? extends Object> entry : map.entrySet()) {
put(entry.getKey(), entry.getValue());
}
}
}
public void clear() {
Set<String> keys = context.keySet();
if (keys != null && keys.size() > 0) {
for (String key : keys) {
context.remove(key);
}
}
}
public Set<String> keySet() {
return context.keySet();
}
public Collection<Object> values() {
Set<String> keys = context.keySet();
Set<Object> values = new HashSet<Object>();
if (keys != null && keys.size() > 0) {
for (String key : keys) {
values.add(context.get(key));
}
}
return values;
}
public Set<Entry<String, Object>> entrySet() {
Set<String> keys = context.keySet();
Set<Entry<String, Object>> entries = new HashSet<Entry<String, Object>>();
if (keys != null && keys.size() > 0) {
for (String key : keys) {
entries.add(new ParameterEntry(key));
}
}
return entries;
}
private class ParameterEntry implements Entry<String, Object> {
private final String key;
private volatile Object value;
public ParameterEntry(String key){
this.key = key;
this.value = ParameterMap.this.get(key);
}
public String getKey() {
return key;
}
public Object getValue() {
return value;
}
public Object setValue(Object value) {
this.value = value;
return ParameterMap.this.put(key, value);
}
}
}
另外，还有一种办法是，
4. 通过asm字节码分析参数名称，去掉上面第二种写法的注解
public class ProvidersAction extends BaseAction {
@Autowired
private ProviderDAO providerDAO;
// 基于asm字节码分析，自动获取参数的名称为serviceName，但感觉有点奇技淫巧，
// 因为该Action为实现类，而非接口，所以其参数名，在字节码的code区，作为局部变量名有记录
public void execute(String serviceName, Context context, Navigator navigator) throws Exception {
List<Provider> providers = providerDAO.findProvidersByServiceName(serviceName);
context.put("providers", providers);
}
}
分享到：
发表评论
-
能力成长模型
2012-05-09 00:28 22673最近看了温伯格1986年出版的《技术领导之路》， 很老的书，讲 ... -
以HTTL为例讲讲模块分包&领域模型&扩展框架
2011-10-09 20:08 16451注：该博客内容已加入 ... -
Netty内存泄露
2011-08-02 20:09 24866转于自己在公司的Blog： ... -
Grizzly和Netty以及Mina简单性能对比
2011-07-17 02:48 29614转于自己在公司的Blog： http://pt.alibaba ... -
RPC框架几行代码就够了
2011-07-14 00:34 89499转于自己在公司的Blog： http://pt.alibaba ... -
魔鬼在细节中
2011-05-24 14:50 32255转于自己在公司的Blog： ... -
Dubbo扩展点重构
2011-05-12 22:09 38760转于自己在公司的Blog： http://pt.alibaba ... -
配置设计
2011-03-09 23:41 23432转于自己在公司的Blog： ... -
[转]HTML5设计原理
2011-03-09 22:57 7656Jeremy Keith在 Fronteers 2010 ... -
Hessian序列化不设SerializerFactory性能问题
2010-12-27 11:38 6382转于自己在公司的Blog： http://pt.alibaba ... -
动态代理方案性能对比
2010-11-17 21:38 45645转于自己在公司的Blog： http://pt.alibaba ... -
防痴呆设计
2010-11-05 18:58 17511转于自己在公司的Blog： ... -
负载均衡扩展接口重构
2010-11-05 18:53 8629转于自己在公司的Blog： ... -
分布式服务框架常被质疑的价值
2010-11-05 18:52 5677转于自己在公司的Blog： http://pt.alibaba ... -
Hessian3.2.1在序列化32.5k字符串时的问题
2010-11-05 18:49 7115转于自己在公司的Blog： http://pt.alibaba ... -
一些设计上的基本常识
2010-07-05 19:28 27439转于自己在公司的Blog： ... -
谈谈扩充式扩展与增量式扩展
2010-06-12 19:46 18973转于自己在公司的Blog： http://pt.alibaba ... -
Scaling Architecture
2010-02-25 10:31 4053Scaling Second Life: http://p ... -
EBay SOA
2010-02-23 18:23 4736EBay SOA PPT -
服务化基础设施
2009-11-15 23:11 6216服务化，也可以叫SOA， ...
相关推荐
Webx3_Guide_Book 用户指南 2001年，阿里巴巴内部开始使用Java Servlet作为WEB服务器端的技术，以取代原先的 Apache HTTPD server和mod_perl的组合。 • 2002年，选择Jakarta Turbine作为WEB框架，并开始在此之上...
Webx及框架简介 ppt 格式
webx3 启动顺序，webx使用总结，webx表单提交（感觉你还是看webx文档 貌似更加好哦！那个表单提交写的很是详细）
该文档为官方webx框架文档，对webx进行了全面的讲解，非常实用。
Webx是一个在阿里巴巴集团内部广泛使用的，层次化、模块化的一个Web框架。 Webx是基于经典MVC设计模式的WEB框架，推崇页面驱动和约定胜于配置的理念。 Webx是一个基于 Spring的组件框架。组件是一个软件包，它可以被...
webx页面使用了velocity模板，WEB层使用的是WEBX框架里面的TemplateAction,TemplateScreen,AbstractModule,TemplateControl，解决了操作和页面的跳转。持久层使用ibatis，Bean容器使用的是Spring。
webx3 PDF(阿里巴巴 前端web框架)
阿里开源框架webx的文档，想要学习webx或者维护webx的开发者可以下载
阿里巴巴公司的开发框架webx3介绍 Webx3_Guide_Book.pdf
根据webx3的官方网站，www.openwebx.org，找到“创建一个webx应用”，按照上面说的流程，就可以创建一个webx的项目。具体流程这里就不说了，官网上已经写得很清楚了。
Webx3_Guide_Book主要讲解webx框架的使用引导教程，方便您更好的使用Webx3
快速使用 webx 开发web 应用 Webx框架指南 Michael Zhou
webx3.0学习小结
webx框架（淘宝框架），webx+spring+ibatis
NULL 博文链接：https://xj84.iteye.com/blog/1850955
WEBX框架详解，更好的了解Taobao的开发过程，对于新手更容易上手。
paoding-webx3-solr-lucene
Webx框架指南 Michael Zhou 出版日期 2010-11-13
NULL 博文链接：https://trent-luo.iteye.com/blog/1071745
淘宝开源Web开发框架Webx3.0介绍，内附宠物店程序作为例子详细解说webx框架的方方面面。