base64type.java

Xfire文件 用于开发web service 的一个开源工具 很好用的

package org.codehaus.xfire.aegis.type.basic;

import java.io.ByteArrayOutputStream;
import java.io.IOException;

import javax.xml.stream.XMLStreamException;
import javax.xml.stream.XMLStreamReader;

import org.codehaus.xfire.MessageContext;
import org.codehaus.xfire.aegis.MessageReader;
import org.codehaus.xfire.aegis.MessageWriter;
import org.codehaus.xfire.aegis.type.Type;
import org.codehaus.xfire.aegis.type.mtom.AbstractXOPType;
import org.codehaus.xfire.aegis.type.mtom.ByteArrayType;
import org.codehaus.xfire.fault.XFireFault;
import org.codehaus.xfire.soap.SoapConstants;
import org.codehaus.xfire.util.Base64;

/**
 * Converts back and forth to byte[] objects.
 * 
 * @author <a href="mailto:[e-mail]">Dan Diephouse</a>
 */
public class Base64Type
    extends Type
{
    private static ByteArrayType optimizedType = new ByteArrayType();
    
    public Base64Type()
    {
        super();
    }

    public Object readObject(MessageReader mreader, MessageContext context)
        throws XFireFault
    {
        boolean mtomEnabled = Boolean.valueOf((String) context.getContextualProperty(SoapConstants.MTOM_ENABLED)).booleanValue();
        XMLStreamReader reader = mreader.getXMLStreamReader();
        
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        
        try
        {
            int event = reader.next();
            while(!reader.isCharacters() && !reader.isEndElement() && !reader.isStartElement()) 
            {
                event = reader.next();
            }

            if (reader.isStartElement() &&
                    reader.getName().equals(AbstractXOPType.XOP_INCLUDE))
            {
                if (mtomEnabled)
                {
                    return optimizedType.readObject(mreader, context);
                }
                else
                {
                    throw new XFireFault("Unexpected element: " + reader.getName(), XFireFault.SENDER);
                }
            }
           
            if (reader.isEndElement()) 
            {
            	reader.next();
                return new byte[0];
            }
            
            int length = reader.getTextLength();
            
            char[] myBuffer = new char[length];
            for (int sourceStart = 0;; sourceStart += length)
            {
                int nCopied = reader.getTextCharacters(sourceStart, myBuffer, 0, length);
                
                Base64.decode(myBuffer, 0, nCopied, bos);
                
                if (nCopied < length)
                    break;
            }
            
            while (reader.getEventType() != XMLStreamReader.END_ELEMENT) reader.next();
            
            // Advance just past the end element
            reader.next();
            
            return bos.toByteArray();
        }
        catch (IOException e)
        {
            throw new XFireFault("Could not parse base64Binary data.", e, XFireFault.SENDER);
        }
        catch (XMLStreamException e)
        {
            throw new XFireFault("Could not parse base64Binary data.", e, XFireFault.SENDER);
        }
    }

    public void writeObject(Object object, MessageWriter writer, MessageContext context)
        throws XFireFault
    {
        boolean mtomEnabled = Boolean.valueOf((String) context.getContextualProperty(SoapConstants.MTOM_ENABLED)).booleanValue();
        if (mtomEnabled)
        {
            optimizedType.writeObject(object, writer, context);
            return;
        }

        byte[] data = (byte[]) object;

        writer.writeValue( Base64.encode(data) );
    }
}