burlapinvoker.java

AJAX的一个好东西哦,国人的一个AJAX的实现不错的东西

/*
 * Copyright (c) 2001-2002 Caucho Technology, Inc.  All rights reserved.
 *
 * The Apache Software License, Version 1.1
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 *
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in
 *    the documentation and/or other materials provided with the
 *    distribution.
 *
 * 3. The end-user documentation included with the redistribution, if
 *    any, must include the following acknowlegement:
 *       "This product includes software developed by the
 *        Caucho Technology (http://www.caucho.com/)."
 *    Alternately, this acknowlegement may appear in the software itself,
 *    if and wherever such third-party acknowlegements normally appear.
 *
 * 4. The names "Hessian", "Resin", and "Caucho" must not be used to
 *    endorse or promote products derived from this software without prior
 *    written permission. For written permission, please contact
 *    [e-mail].
 *
 * 5. Products derived from this software may not be called "Resin"
 *    nor may "Resin" appear in their names without prior written
 *    permission of Caucho Technology.
 *
 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 * DISCLAIMED.  IN NO EVENT SHALL CAUCHO TECHNOLOGY OR ITS CONTRIBUTORS
 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY,
 * OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT
 * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
 * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
 * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
 * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * @author Scott Ferguson
 */

package net.buffalo.service.invoker.burlap;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.util.HashMap;

import net.buffalo.service.invoker.ServiceInvoker;

import com.caucho.burlap.io.BurlapInput;
import com.caucho.burlap.io.BurlapOutput;

/**
 * Proxy class for Burlap services.
 * 
 * Note: this implentation is copied from
 * com.caucho.burlap.server.BurlapSkeleton, because some user reported that it
 * conflict with the resin server.
 * 
 */
public class BurlapInvoker implements ServiceInvoker {
	private HashMap _methodMap = new HashMap();

	private Object _service;

	/**
	 * Create a new burlap skeleton.
	 * 
	 * @param service
	 *            the underlying service object.
	 */
	public BurlapInvoker(Object service) {
		_service = service;
		Method[] methodList = service.getClass().getMethods();

		for (int i = 0; i < methodList.length; i++) {
			Method method = methodList[i];

			if (_methodMap.get(method.getName()) == null)
				_methodMap.put(method.getName(), methodList[i]);

			Class[] param = method.getParameterTypes();
			String mangledName = method.getName() + "__" + param.length;
			_methodMap.put(mangledName, methodList[i]);

			_methodMap.put(mangleName(method, false), methodList[i]);
		}
	}

	/**
	 * Creates a unique mangled method name based on the method name and the
	 * method parameters.
	 * 
	 * @param method
	 *            the method to mangle
	 * @param isFull
	 *            if true, mangle the full classname
	 * 
	 * @return a mangled string.
	 */
	protected String mangleName(Method method, boolean isFull) {
		StringBuffer sb = new StringBuffer();

		sb.append(method.getName());

		Class[] params = method.getParameterTypes();
		for (int i = 0; i < params.length; i++) {
			sb.append('_');
			mangleClass(sb, params[i], isFull);
		}

		return sb.toString();
	}

	/**
	 * Mangles a classname.
	 */
	private void mangleClass(StringBuffer sb, Class cl, boolean isFull) {
		String name = cl.getName();

		if (name.equals("boolean") || name.equals("java.lang.Boolean"))
			sb.append("boolean");
		else if (name.equals("int") || name.equals("java.lang.Integer")
				|| name.equals("short") || name.equals("java.lang.Short")
				|| name.equals("byte") || name.equals("java.lang.Byte"))
			sb.append("int");
		else if (name.equals("long") || name.equals("java.lang.Long"))
			sb.append("long");
		else if (name.equals("float") || name.equals("java.lang.Float")
				|| name.equals("double") || name.equals("java.lang.Double"))
			sb.append("double");
		else if (name.equals("java.lang.String")
				|| name.equals("com.caucho.util.CharBuffer")
				|| name.equals("char") || name.equals("java.lang.Character")
				|| name.equals("java.io.Reader"))
			sb.append("string");
		else if (name.equals("java.util.Date")
				|| name.equals("com.caucho.util.QDate"))
			sb.append("date");
		else if (InputStream.class.isAssignableFrom(cl) || name.equals("[B"))
			sb.append("binary");
		else if (cl.isArray()) {
			sb.append("[");
			mangleClass(sb, cl.getComponentType(), isFull);
		} else if (name.equals("org.w3c.dom.Node")
				|| name.equals("org.w3c.dom.Element")
				|| name.equals("org.w3c.dom.Document"))
			sb.append("xml");
		else if (isFull)
			sb.append(name);
		else {
			int p = name.lastIndexOf('.');
			if (p > 0)
				sb.append(name.substring(p + 1));
			else
				sb.append(name);
		}
	}

	/**
	 * Invoke the object with the request from the input stream.
	 * 
	 * @param instream
	 *            the input stream
	 * @param outstream
	 *            the output stream
	 */
	public void invoke(InputStream instream, OutputStream outstream)
			throws Throwable {

		BurlapInput in = new BurlapInput(instream);
		BurlapOutput out = new BuffaloBurlapOutput(outstream);

		in.startCall();

		String methodName = in.getMethod();
		Method method = (Method) _methodMap.get(methodName);

		if (method != null) {
		} else if (methodName.equals("_burlap_getAttribute")) {
			getBurlapAttribute(in, out);
			return;
		} else
			throw new IOException("No server method matching:" + in.getMethod());

		Class[] args = method.getParameterTypes();
		Object[] values = new Object[args.length];

		for (int i = 0; i < args.length; i++)
			values[i] = in.readObject(args[i]);

		in.completeCall();

		Object result = null;

		try {
			result = method.invoke(_service, values);
		} catch (Throwable e) {
			if (e instanceof InvocationTargetException)
				e = ((InvocationTargetException) e).getTargetException();
			out.startReply();
			out.writeFault("ServiceException", e.getMessage(), e);
			out.completeReply();
			return;
		}

		out.startReply();

		out.writeObject(result);

		out.completeReply();
	}

	/**
	 * Returns special attributes.
	 * 
	 * @param in
	 *            the Burlap input stream
	 * @param out
	 *            the Burlap output stream
	 */
	public void getBurlapAttribute(BurlapInput in, BurlapOutput out)
			throws IOException {
		String name = in.readString();
		in.completeCall();

		out.startReply();

		if (name.equals("home-class") || name.equals("remote-class")) {
			Class cl = _service.getClass();
			Class[] interfaces = cl.getInterfaces();

			String homeClass = null;

			for (int i = 0; i < interfaces.length; i++) {
				if (java.rmi.Remote.class.isAssignableFrom(interfaces[i])
						&& java.rmi.Remote.class != interfaces[i])
					homeClass = interfaces[i].getName();
			}

			if (homeClass == null)
				homeClass = cl.getName();

			out.writeString(homeClass);
		} else
			out.writeObject(null);

		out.completeReply();
	}
}