HessianProxyFactory是HessianProxy的工厂类，其通过HessianProxy来生成代理类。
如下面代码：
HessianProxyFactory factory = new HessianProxyFactory();
HelloService helloService = (HelloService) factory.create(HelloService.class, url);
System.out.println(helloService.helloWorld("jimmy"));
HessianProxyFactory的create函数如下：
public Object create(Class api, String urlName)
throws MalformedURLException
{
return create(api, urlName, _loader);
}
public Object create(Class<?> api, String urlName, ClassLoader loader)
throws MalformedURLException
{
URL url = new URL(urlName);
return create(api, url, loader);
}
create函数的最终实现是：
public Object create(Class<?> api, URL url, ClassLoader loader)
{
if (api == null)
throw new NullPointerException("api must not be null for HessianProxyFactory.create()");
InvocationHandler handler = null;
handler = new HessianProxy(url, this, api);
return Proxy.newProxyInstance(loader,
new Class[] { api,
HessianRemoteObject.class },
handler);
}
由上面代码段我们可以看到，HessianProxyFactory的create函数最终是创建了一个HessianProxy代理类的目标类。
HessianProxyFactory的作用就是通过代理类HessianProxy来生成目标类。
HessianProxyFactory源码如下：
public class HessianProxyFactory implements ServiceProxyFactory, ObjectFactory {
protected static Logger log
= Logger.getLogger(HessianProxyFactory.class.getName());
private final ClassLoader _loader;
private SerializerFactory _serializerFactory;
private HessianConnectionFactory _connFactory;
private HessianRemoteResolver _resolver;
private String _user;
private String _password;
private String _basicAuth;
private boolean _isOverloadEnabled = false;
private boolean _isHessian2Reply = true;
private boolean _isHessian2Request = false;
private boolean _isChunkedPost = true;
private boolean _isDebug = false;
private long _readTimeout = -1;
private long _connectTimeout = -1;
public HessianProxyFactory()
{
this(Thread.currentThread().getContextClassLoader());
}
public HessianProxyFactory(ClassLoader loader)
{
_loader = loader;
_resolver = new HessianProxyResolver(this);
}
public void setUser(String user)
{
_user = user;
_basicAuth = null;
}
public void setPassword(String password)
{
_password = password;
_basicAuth = null;
}
public String getBasicAuth()
{
if (_basicAuth != null)
return _basicAuth;
else if (_user != null && _password != null)
return "Basic " + base64(_user + ":" + _password);
else
return null;
}
public void setConnectionFactory(HessianConnectionFactory factory)
{
_connFactory = factory;
}
public HessianConnectionFactory getConnectionFactory()
{
if (_connFactory == null) {
_connFactory = createHessianConnectionFactory();
_connFactory.setHessianProxyFactory(this);
}
return _connFactory;
}
public void setDebug(boolean isDebug)
{
_isDebug = isDebug;
}
public boolean isDebug()
{
return _isDebug;
}
/**
* Returns true if overloaded methods are allowed (using mangling)
*/
public boolean isOverloadEnabled()
{
return _isOverloadEnabled;
}
/**
* set true if overloaded methods are allowed (using mangling)
*/
public void setOverloadEnabled(boolean isOverloadEnabled)
{
_isOverloadEnabled = isOverloadEnabled;
}
/**
* Set true if should use chunked encoding on the request.
*/
public void setChunkedPost(boolean isChunked)
{
_isChunkedPost = isChunked;
}
/**
* Set true if should use chunked encoding on the request.
*/
public boolean isChunkedPost()
{
return _isChunkedPost;
}
/**
* The socket timeout on requests in milliseconds.
*/
public long getReadTimeout()
{
return _readTimeout;
}
/**
* The socket timeout on requests in milliseconds.
*/
public void setReadTimeout(long timeout)
{
_readTimeout = timeout;
}
/**
* The socket connection timeout in milliseconds.
*/
public long getConnectTimeout()
{
return _connectTimeout;
}
/**
* The socket connect timeout in milliseconds.
*/
public void setConnectTimeout(long timeout)
{
_connectTimeout = timeout;
}
/**
* True if the proxy can read Hessian 2 responses.
*/
public void setHessian2Reply(boolean isHessian2)
{
_isHessian2Reply = isHessian2;
}
/**
* True if the proxy should send Hessian 2 requests.
*/
public void setHessian2Request(boolean isHessian2)
{
_isHessian2Request = isHessian2;
if (isHessian2)
_isHessian2Reply = true;
}
/**
* Returns the remote resolver.
*/
public HessianRemoteResolver getRemoteResolver()
{
return _resolver;
}
/**
* Sets the serializer factory.
*/
public void setSerializerFactory(SerializerFactory factory)
{
_serializerFactory = factory;
}
/**
* Gets the serializer factory.
*/
public SerializerFactory getSerializerFactory()
{
if (_serializerFactory == null)
_serializerFactory = new SerializerFactory(_loader);
return _serializerFactory;
}
protected HessianConnectionFactory createHessianConnectionFactory()
{
String className
= System.getProperty(HessianConnectionFactory.class.getName());
HessianConnectionFactory factory = null;
try {
if (className != null) {
ClassLoader loader = Thread.currentThread().getContextClassLoader();
Class<?> cl = Class.forName(className, false, loader);
factory = (HessianConnectionFactory) cl.newInstance();
return factory;
}
} catch (Exception e) {
throw new RuntimeException(e);
}
return new HessianURLConnectionFactory();
}
public Object create(String url)
throws MalformedURLException, ClassNotFoundException
{
HessianMetaInfoAPI metaInfo;
metaInfo = (HessianMetaInfoAPI) create(HessianMetaInfoAPI.class, url);
String apiClassName =
(String) metaInfo._hessian_getAttribute("java.api.class");
if (apiClassName == null)
throw new HessianRuntimeException(url + " has an unknown api.");
Class<?> apiClass = Class.forName(apiClassName, false, _loader);
return create(apiClass, url);
}
public Object create(Class api, String urlName)
throws MalformedURLException
{
return create(api, urlName, _loader);
}
public Object create(Class<?> api, String urlName, ClassLoader loader)
throws MalformedURLException
{
URL url = new URL(urlName);
return create(api, url, loader);
}
public Object create(Class<?> api, URL url, ClassLoader loader)
{
if (api == null)
throw new NullPointerException("api must not be null for HessianProxyFactory.create()");
InvocationHandler handler = null;
handler = new HessianProxy(url, this, api);
return Proxy.newProxyInstance(loader,
new Class[] { api,
HessianRemoteObject.class },
handler);
}
public AbstractHessianInput getHessianInput(InputStream is)
{
return getHessian2Input(is);
}
public AbstractHessianInput getHessian1Input(InputStream is)
{
AbstractHessianInput in;
if (_isDebug)
is = new HessianDebugInputStream(is, new PrintWriter(System.out));
in = new HessianInput(is);
in.setRemoteResolver(getRemoteResolver());
in.setSerializerFactory(getSerializerFactory());
return in;
}
public AbstractHessianInput getHessian2Input(InputStream is)
{
AbstractHessianInput in;
if (_isDebug)
is = new HessianDebugInputStream(is, new PrintWriter(System.out));
in = new Hessian2Input(is);
in.setRemoteResolver(getRemoteResolver());
in.setSerializerFactory(getSerializerFactory());
return in;
}
public AbstractHessianOutput getHessianOutput(OutputStream os)
{
AbstractHessianOutput out;
if (_isHessian2Request)
out = new Hessian2Output(os);
else {
HessianOutput out1 = new HessianOutput(os);
out = out1;
if (_isHessian2Reply)
out1.setVersion(2);
}
out.setSerializerFactory(getSerializerFactory());
return out;
}
public Object getObjectInstance(Object obj, Name name,
Context nameCtx, Hashtable<?,?> environment)
throws Exception
{
Reference ref = (Reference) obj;
String api = null;
String url = null;
for (int i = 0; i < ref.size(); i++) {
RefAddr addr = ref.get(i);
String type = addr.getType();
String value = (String) addr.getContent();
if (type.equals("type"))
api = value;
else if (type.equals("url"))
url = value;
else if (type.equals("user"))
setUser(value);
else if (type.equals("password"))
setPassword(value);
}
if (url == null)
throw new NamingException("`url' must be configured for HessianProxyFactory.");
// XXX: could use meta protocol to grab this
if (api == null)
throw new NamingException("`type' must be configured for HessianProxyFactory.");
Class apiClass = Class.forName(api, false, _loader);
return create(apiClass, url);
}
private String base64(String value)
{
StringBuffer cb = new StringBuffer();
int i = 0;
for (i = 0; i + 2 < value.length(); i += 3) {
long chunk = (int) value.charAt(i);
chunk = (chunk << 8) + (int) value.charAt(i + 1);
chunk = (chunk << 8) + (int) value.charAt(i + 2);
cb.append(encode(chunk >> 18));
cb.append(encode(chunk >> 12));
cb.append(encode(chunk >> 6));
cb.append(encode(chunk));
}
if (i + 1 < value.length()) {
long chunk = (int) value.charAt(i);
chunk = (chunk << 8) + (int) value.charAt(i + 1);
chunk <<= 8;
cb.append(encode(chunk >> 18));
cb.append(encode(chunk >> 12));
cb.append(encode(chunk >> 6));
cb.append('=');
}
else if (i < value.length()) {
long chunk = (int) value.charAt(i);
chunk <<= 16;
cb.append(encode(chunk >> 18));
cb.append(encode(chunk >> 12));
cb.append('=');
cb.append('=');
}
return cb.toString();
}
public static char encode(long d)
{
d &= 0x3f;
if (d < 26)
return (char) (d + 'A');
else if (d < 52)
return (char) (d + 'a' - 26);
else if (d < 62)
return (char) (d + '0' - 52);
else if (d == 62)
return '+';
else
return '/';
}
}