提交 07fba932 编写于 作者: J Juergen Hoeller

updated to Hessian 3.2.1 (remaining compatible with Hessian 3.1.3 and above)

上级 81e683b3
...@@ -29,7 +29,7 @@ ...@@ -29,7 +29,7 @@
</publications> </publications>
<dependencies> <dependencies>
<dependency org="com.caucho" name="com.springsource.com.caucho" rev="3.1.5" <dependency org="com.caucho" name="com.springsource.com.caucho" rev="3.2.1"
conf="optional, hessian, burlap->compile"/> conf="optional, hessian, burlap->compile"/>
<dependency org="javax.el" name="com.springsource.javax.el" rev="1.0.0" conf="provided, el->compile"/> <dependency org="javax.el" name="com.springsource.javax.el" rev="1.0.0" conf="provided, el->compile"/>
<dependency org="javax.faces" name="com.springsource.javax.faces" rev="1.2.0.08" <dependency org="javax.faces" name="com.springsource.javax.faces" rev="1.2.0.08"
......
/* /*
* Copyright 2002-2008 the original author or authors. * Copyright 2002-2009 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
...@@ -21,11 +21,13 @@ import java.io.InputStream; ...@@ -21,11 +21,13 @@ import java.io.InputStream;
import java.io.OutputStream; import java.io.OutputStream;
import java.io.PrintWriter; import java.io.PrintWriter;
import com.caucho.hessian.io.AbstractHessianInput;
import com.caucho.hessian.io.AbstractHessianOutput; import com.caucho.hessian.io.AbstractHessianOutput;
import com.caucho.hessian.io.Hessian2Input; import com.caucho.hessian.io.Hessian2Input;
import com.caucho.hessian.io.Hessian2Output; import com.caucho.hessian.io.Hessian2Output;
import com.caucho.hessian.io.HessianDebugInputStream; import com.caucho.hessian.io.HessianDebugInputStream;
import com.caucho.hessian.io.HessianDebugOutputStream; import com.caucho.hessian.io.HessianDebugOutputStream;
import com.caucho.hessian.io.HessianInput;
import com.caucho.hessian.io.HessianOutput; import com.caucho.hessian.io.HessianOutput;
import com.caucho.hessian.io.SerializerFactory; import com.caucho.hessian.io.SerializerFactory;
import com.caucho.hessian.server.HessianSkeleton; import com.caucho.hessian.server.HessianSkeleton;
...@@ -34,7 +36,6 @@ import org.apache.commons.logging.Log; ...@@ -34,7 +36,6 @@ import org.apache.commons.logging.Log;
import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.InitializingBean;
import org.springframework.remoting.support.RemoteExporter; import org.springframework.remoting.support.RemoteExporter;
import org.springframework.util.Assert; import org.springframework.util.Assert;
import org.springframework.util.ClassUtils;
import org.springframework.util.CommonsLogWriter; import org.springframework.util.CommonsLogWriter;
/** /**
...@@ -43,7 +44,7 @@ import org.springframework.util.CommonsLogWriter; ...@@ -43,7 +44,7 @@ import org.springframework.util.CommonsLogWriter;
* <p>Hessian is a slim, binary RPC protocol. * <p>Hessian is a slim, binary RPC protocol.
* For information on Hessian, see the * For information on Hessian, see the
* <a href="http://www.caucho.com/hessian">Hessian website</a>. * <a href="http://www.caucho.com/hessian">Hessian website</a>.
* This exporter requires Hessian 3.0.20 or above. * This exporter requires Hessian 3.1.3 or above.
* *
* @author Juergen Hoeller * @author Juergen Hoeller
* @since 2.5.1 * @since 2.5.1
...@@ -53,9 +54,6 @@ import org.springframework.util.CommonsLogWriter; ...@@ -53,9 +54,6 @@ import org.springframework.util.CommonsLogWriter;
*/ */
public class HessianExporter extends RemoteExporter implements InitializingBean { public class HessianExporter extends RemoteExporter implements InitializingBean {
private static final boolean debugOutputStreamAvailable = ClassUtils.isPresent(
"com.caucho.hessian.io.HessianDebugOutputStream", HessianExporter.class.getClassLoader());
private SerializerFactory serializerFactory = new SerializerFactory(); private SerializerFactory serializerFactory = new SerializerFactory();
private Log debugLogger; private Log debugLogger;
...@@ -129,31 +127,43 @@ public class HessianExporter extends RemoteExporter implements InitializingBean ...@@ -129,31 +127,43 @@ public class HessianExporter extends RemoteExporter implements InitializingBean
if (this.debugLogger != null && this.debugLogger.isDebugEnabled()) { if (this.debugLogger != null && this.debugLogger.isDebugEnabled()) {
PrintWriter debugWriter = new PrintWriter(new CommonsLogWriter(this.debugLogger)); PrintWriter debugWriter = new PrintWriter(new CommonsLogWriter(this.debugLogger));
isToUse = new HessianDebugInputStream(inputStream, debugWriter); isToUse = new HessianDebugInputStream(inputStream, debugWriter);
if (debugOutputStreamAvailable) { osToUse = new HessianDebugOutputStream(outputStream, debugWriter);
osToUse = DebugStreamFactory.createDebugOutputStream(outputStream, debugWriter);
}
} }
Hessian2Input in = new Hessian2Input(isToUse); int code = isToUse.read();
if (this.serializerFactory != null) { int major;
in.setSerializerFactory(this.serializerFactory); int minor;
}
int code = in.read(); AbstractHessianInput in;
if (code != 'c') { AbstractHessianOutput out;
throw new IOException("expected 'c' in hessian input at " + code);
}
AbstractHessianOutput out = null; if (code == 'H') {
int major = in.read(); major = isToUse.read();
int minor = in.read(); minor = isToUse.read();
if (major >= 2) { if (major != 0x02) {
throw new IOException("Version " + major + "." + minor + " is not understood");
}
in = new Hessian2Input(isToUse);
out = new Hessian2Output(osToUse); out = new Hessian2Output(osToUse);
in.readCall();
}
else if (code == 'c') {
major = isToUse.read();
minor = isToUse.read();
in = new HessianInput(isToUse);
if (major >= 2) {
out = new Hessian2Output(osToUse);
}
else {
out = new HessianOutput(osToUse);
}
} }
else { else {
out = new HessianOutput(osToUse); throw new IOException("Expected 'H' (Hessian 2.0) or 'c' (Hessian 1.0) in hessian input at " + code);
} }
if (this.serializerFactory != null) { if (this.serializerFactory != null) {
in.setSerializerFactory(this.serializerFactory);
out.setSerializerFactory(this.serializerFactory); out.setSerializerFactory(this.serializerFactory);
} }
...@@ -178,15 +188,4 @@ public class HessianExporter extends RemoteExporter implements InitializingBean ...@@ -178,15 +188,4 @@ public class HessianExporter extends RemoteExporter implements InitializingBean
} }
} }
/**
* Inner class to avoid hard dependency on Hessian 3.1.3's HessianDebugOutputStream.
*/
private static class DebugStreamFactory {
public static OutputStream createDebugOutputStream(OutputStream os, PrintWriter debug) {
return new HessianDebugOutputStream(os, debug);
}
}
} }
/* /*
* Copyright 2002-2008 the original author or authors. * Copyright 2002-2009 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
...@@ -17,7 +17,6 @@ ...@@ -17,7 +17,6 @@
package org.springframework.remoting.caucho; package org.springframework.remoting.caucho;
import java.io.IOException; import java.io.IOException;
import javax.servlet.ServletException; import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
...@@ -36,7 +35,7 @@ import org.springframework.web.util.NestedServletException; ...@@ -36,7 +35,7 @@ import org.springframework.web.util.NestedServletException;
* <p>Hessian is a slim, binary RPC protocol. * <p>Hessian is a slim, binary RPC protocol.
* For information on Hessian, see the * For information on Hessian, see the
* <a href="http://www.caucho.com/hessian">Hessian website</a>. * <a href="http://www.caucho.com/hessian">Hessian website</a>.
* This exporter requires Hessian 3.0.20 or above. * This exporter requires Hessian 3.1.3 or above.
* *
* <p>Note: Hessian services exported with this class can be accessed by * <p>Note: Hessian services exported with this class can be accessed by
* any Hessian client, as there isn't any special handling involved. * any Hessian client, as there isn't any special handling involved.
......
/* /*
* Copyright 2002-2008 the original author or authors. * Copyright 2002-2009 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
...@@ -33,7 +33,7 @@ import org.springframework.util.FileCopyUtils; ...@@ -33,7 +33,7 @@ import org.springframework.util.FileCopyUtils;
* <p>Hessian is a slim, binary RPC protocol. * <p>Hessian is a slim, binary RPC protocol.
* For information on Hessian, see the * For information on Hessian, see the
* <a href="http://www.caucho.com/hessian">Hessian website</a>. * <a href="http://www.caucho.com/hessian">Hessian website</a>.
* This exporter requires Hessian 3.0.20 or above. * This exporter requires Hessian 3.1.3 or above.
* *
* <p>Note: Hessian services exported with this class can be accessed by * <p>Note: Hessian services exported with this class can be accessed by
* any Hessian client, as there isn't any special handling involved. * any Hessian client, as there isn't any special handling involved.
......
此差异已折叠。
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册