相信设计到通讯的工程，都会需要用的通讯协议http、soap...，相信也写过很多的接口soap接口、HTTP+XML接口，每次调用我们写的接口的时候传给我们的都是个XML格式的数据信息，我们需要把这些数据解析出来，然后再拼装成一个info发出去，以下写了一个通用的方法，利用JAVA的反射机制来实现：

 

代码如下：

Java代码

/**

 * <p>

 * Copyright (C), 1988-2008, Huawei Tech. Co., Ltd.

 * </p>

 * <p>

 * FileName: Transform.java

 * </p>

 * <p>

 * Author:tangtao Version :1.0 Date:2010-8-31

 * </p>

 * <p>

 * Description:

 * </p>

 * <p>

 * Version: 1.0

 * </p>

 * <p>

 * Function List:

 * </p>

 */ 

package com.huawei.nvs.sys.conn.http; 

 

import java.io.ByteArrayInputStream; 

import java.lang.reflect.AccessibleObject; 

import java.lang.reflect.Field; 

import java.util.ArrayList; 

import java.util.Iterator; 

import java.util.List; 

import java.util.Locale; 

import java.util.Map; 

import java.util.regex.Matcher; 

import java.util.regex.Pattern; 

 

import org.w3c.dom.Element; 

import org.w3c.dom.Node; 

 

import com.huawei.nvs.sys.conn.http.bean.FieldInfo; 

import com.huawei.nvs.sys.conn.http.bean.HttpInfo; 

import com.huawei.nvs.sys.conn.http.bean.MessageInfo; 

import com.huawei.nvs.sys.conn.http.bean.SendFieldInfo; 

import com.huawei.nvs.sys.conn.http.conf.HttpEnv; 

import com.huawei.nvs.sys.conn.http.exception.HttpException; 

import com.huawei.nvs.sys.conn.http.util.ListMap; 

import com.huawei.nvs.sys.conn.http.util.XmlTools; 

 

/**

 * <p>

 * Title: Transform

 * </p>

 * <p>

 * Description: HTTP消息转换类,把指定的内部实体对象转换成xml,把xml转换成指定的内部实体对象

 * </p>

 * <p>

 * Copyright: Copyright (c) 2010-8-31

 * </p>

 * <p>

 * Company: www.huawei.com

 * </p>

 * 

 * @author wanghui

 * @version 1.0

 */ 

public class Transform 

{ 

    /**

     * 把实体bean转换成xml字符串

     * 

     * @param bean 实体对象

     * @throws HttpException HttpException

     * @return 转换成功的xml字符串

     */ 

    public static String beanToXml(HttpInfo bean) 

        throws HttpException 

    { 

        if (null == bean) 

        { 

            throw new HttpException("Parameter bean is null."); 

        } 

        StringBuffer sbf = new StringBuffer("<?xml version='1.0' encoding='UTF-8'?>"); 

         

        ListMap headFieldMap = new ListMap(); 

        ListMap bodyFieldMap = new ListMap(); 

         

        Class<?> c = bean.getClass(); 

         

        try 

        { 

            // 获取消息类型和实体对象类路径

            Field f = c.getDeclaredField("msgType"); 

            Field v = c.getDeclaredField("version"); 

             

            // 修改checkstyle 问题by wangzheng at 20101015 begin 

            // f.setAccessible(true); 

            AccessibleObject.setAccessible(new Field[] {f}, true); 

            AccessibleObject.setAccessible(new Field[] {v}, true); 

            // 修改checkstyle 问题by wangzheng at 20101015 end 

             

            String msgType = f.get(bean).toString(); 

            String version = (String)v.get(bean); 

             

            //因为这个是发到SMC的消息，不存在多版本，所以这里默认赋值为1.0版本

            version = null == version ? "smc" : version; 

             

            String path = c.getName(); 

            Field[] fields = c.getDeclaredFields(); 

            AccessibleObject.setAccessible(fields, true); 

            // 找出bean中的消息头和消息体

            for (Field field : fields) 

            { 

                String fieldName = field.getName(); 

                if (isUseField(msgType, path, fieldName, version)) 

                { 

                    if ("MsgType".equalsIgnoreCase(fieldName) || "Expires".equalsIgnoreCase(fieldName) 

                        || "callID".equalsIgnoreCase(fieldName)) 

                    { 

                        headFieldMap.put(fieldName, field); 

                    } 

                    else 

                    { 

                        bodyFieldMap.put(fieldName, field); 

                    } 

                } 

            } 

            sbf.append("<NVS_SMS_REQ>"); 

            // 拼装消息头xml字符串

            String headStr = buildHead(version, msgType, headFieldMap, bean); 

            // 拼装消息体xml字符串

            String bodyStr = buildBody(version, msgType, bodyFieldMap, bean); 

             

            // 拼装整个xml消息字符串

            sbf.append(headStr).append(bodyStr); 

            sbf.append("</NVS_SMS_REQ>"); 

        } 

        catch (Exception e) 

        { 

            e.printStackTrace(); 

            throw new HttpException("The xml conversion bean fail.", e); 

        } 

        return sbf.toString(); 

    } 

     

    /**

     * 把实体bean转换成xml字符串

     * 

     * @param msgType 消息类型

     * @param bean 实体对象

     * @throws HttpException HttpException

     * @return 转换成功的xml字符串

     */ 

    public static String beanToXml(String msgType, Object bean) 

        throws HttpException 

    { 

        if (null == bean) 

        { 

            throw new HttpException("Parameter bean is null."); 

        } 

        StringBuffer sbf = new StringBuffer(""); 

         

        ListMap headFieldMap = new ListMap(); 

        ListMap bodyFieldMap = new ListMap(); 

         

        Class<?> c = bean.getClass(); 

         

        try 

        { 

            String path = c.getName(); 

            String version = (String)(c.getDeclaredMethod("getVersion").invoke(bean, new Object[] {})); 

             

            Field[] fields = c.getDeclaredFields(); 

            AccessibleObject.setAccessible(fields, true); 

             

            // 找出bean中的消息头和消息体

            for (Field field : fields) 

            { 

                String fieldName = field.getName(); 

                if (isUseField(msgType, path, fieldName, version)) 

                { 

                    if ("MsgType".equalsIgnoreCase(fieldName) || "Expires".equalsIgnoreCase(fieldName) 

                        || "callID".equalsIgnoreCase(fieldName)) 

                    { 

                        headFieldMap.put(fieldName, field);  

                    } 

                    else 

                    { 

                        bodyFieldMap.put(fieldName, field); 

                    } 

                } 

            } 

            sbf.append("<Msg_Body>"); 

            // 拼装消息头xml字符串

            String headStr = buildHead(version, msgType, headFieldMap, bean); 

            // 拼装消息体xml字符串

            String bodyStr = buildBody(version, msgType, bodyFieldMap, bean); 

             

            // 拼装整个xml消息字符串

            sbf.append(headStr).append(bodyStr); 

            sbf.append("</Msg_Body>"); 

        } 

        catch (Exception e) 

        { 

            e.printStackTrace(); 

            throw new HttpException("The bean conversion xml fail.", e); 

        }  

        return sbf.toString(); 

    } 

     

    /**

     * 根据传入的消息头字段拼装成xml格式字符串

     * 

     * @param headListMap 消息头Field

     * @param c 实体对象

     * @return 拼装后的xml消息头字符串

     * @throws IllegalAccessException 反射失败

     */ 

    private static String buildHead(String version, String msgType, ListMap headListMap, Object c) 

        throws IllegalAccessException 

    { 

        // mod by wangzheng at 20100920 begin 

        // StringBuffer sbf = new StringBuffer("<head>"); 

        StringBuffer sbf = new StringBuffer(); 

         

        List<?> keyList = headListMap.getKeyList(); 

        for (int i = 0; i < keyList.size(); i++) 

        { 

            String key = keyList.get(i).toString(); 

            // 获取属性节点对应的消息节点名称

            String msgFieldName = getMsgField(version, msgType, c.getClass().getName(), key); 

            msgFieldName = null == msgFieldName ? key : msgFieldName; 

            Field field = (Field)headListMap.get(key); 

            Object obj = field.get(c); 

            sbf.append("<").append(msgFieldName).append(">"); 

            sbf.append(changeStrToXml(obj)); 

            sbf.append("</").append(msgFieldName).append(">"); 

        } 

        // sbf.append("</head>"); 

        // mod by wangzheng at 20100920 begin 

        return sbf.toString(); 

    } 

     

    /**

     * 根据传入的消息体字段拼装成xml格式字符串

     * 

     * @param bodyListMap 消息头Field

     * @param c 实体对象

     * @return 拼装后的xml消息体字符串

     * @throws IllegalAccessException

     */ 

    private static String buildBody(String version, String msgType, ListMap bodyListMap, Object c) 

        throws IllegalAccessException 

    { 

        // mod by wangzheng at 20100920 begin 

        // StringBuffer sbf = new StringBuffer("<body>"); 

        StringBuffer sbf = new StringBuffer(); 

         

        List<?> keyList = bodyListMap.getKeyList(); 

        for (int i = 0; i < keyList.size(); i++) 

        { 

            String key = keyList.get(i).toString(); 

             

            // 获取属性节点对应的消息节点名称

            String msgFieldName = getMsgField(version, msgType, c.getClass().getName(), key); 

            msgFieldName = null == msgFieldName ? key : msgFieldName; 

             

            Field field = (Field)bodyListMap.get(key); 

            Object obj = field.get(c); 

            if (obj instanceof List) 

            { 

                String buildResult = Transform.buildList(version, msgType, (List<Object>)obj, msgFieldName); 

                sbf.append(buildResult); 

            } 

            else if (obj instanceof String[]) 

            { 

                String buildResult = buildArray((String[])obj, msgFieldName); 

                sbf.append(buildResult); 

            } 

            else if (obj instanceof HttpInfo) 

            { 

                String buildResult = Transform.buildBean(version, msgType, obj); 

                sbf.append(buildResult); 

            } 

            else 

            { 

                sbf.append("<").append(msgFieldName).append(">"); 

                sbf.append(changeStrToXml(obj)); 

                sbf.append("</").append(msgFieldName).append(">"); 

            } 

        } 

         

        // sbf.append("</body>"); 

        // mod by wangzheng at 20100920 begin 

        return sbf.toString(); 

    } 

     

    /**

     * 根据传入的List消息体字段拼装成xml格式字符串

     * 

     * @param list 消息实体对象列表

     * @param listName 列表名称

     * @return 拼装后的xml消息体字符串

     * @throws IllegalAccessException

     */ 

    private static String buildArray(String[] value, String listName) 

        throws IllegalAccessException 

    { 

        StringBuffer sbf = new StringBuffer(); 

         

        for (int i = 0; i < value.length; i++) 

        { 

            sbf.append("<").append(listName).append(">"); 

            sbf.append(value[i]); 

            sbf.append("</").append(listName).append(">"); 

        } 

         

        return sbf.toString(); 

    } 

     

    /**

     * 根据传入的List消息体字段拼装成xml格式字符串

     * 

     * @param list 消息实体对象列表

     * @param listName 列表名称

     * @return 拼装后的xml消息体字符串

     * @throws IllegalAccessException

     */ 

    private static String buildList(String version, String msgType, List<Object> list, String listName) 

        throws IllegalAccessException 

    { 

        StringBuffer sbf = new StringBuffer(); 

        sbf.append("<").append(listName).append(">"); 

        for (int i = 0; i < list.size(); i++) 

        { 

            sbf.append(buildBean(version, msgType, list.get(i))); 

        } 

        sbf.append("</").append(listName).append(">"); 

        return sbf.toString(); 

    } 

     

    /**

     * 把简单的实体对象中的属性转换成xml格式的字符串

     * 

     * @param bean 简单的实体对象

     * @return 转换后的字符串

     * @throws IllegalAccessException

     */ 

    private static String buildBean(String version, String msgType, Object bean) 

        throws IllegalAccessException 

    { 

        StringBuffer sbf = new StringBuffer(); 

         

        Class<?> c = bean.getClass(); 

        String path = c.getName(); 

        //String className = path.substring(path.lastIndexOf(".") + 1, path.length()); 

        //className = className.substring(0, className.indexOf("Info")); 

        String infoName = getMsgField(version, msgType, path); 

        infoName = null == infoName ? "" : infoName; 

        sbf.append("<").append(infoName).append(">"); 

          

        Field[] fields = c.getDeclaredFields(); 

        AccessibleObject.setAccessible(fields, true); 

        for (Field f : fields) 

        { 

            String fieldName = f.getName(); 

            // 只封装在配置文件中配置过的字段

            if (isUseField(msgType, path, fieldName, version)) 

            { 

                // 获取属性节点对应的消息节点名称

                String msgFieldName = getMsgField(version, msgType, path, fieldName); 

                msgFieldName = null == msgFieldName ? fieldName : msgFieldName; 

                 

                Object obj = f.get(bean); 

                if (obj instanceof List) 

                { 

                    String buildResult = Transform.buildList(version, msgType, (List)obj, msgFieldName); 

                    sbf.append(buildResult); 

                } 

                else 

                { 

                    sbf.append("<").append(msgFieldName).append(">"); 

                    Object value = f.get(bean); 

                    sbf.append(changeStrToXml(value)); 

                    sbf.append("</").append(msgFieldName).append(">"); 

                } 

            } 

        } 

        sbf.append("</").append(infoName).append(">"); 

         

        return sbf.toString(); 

    } 

     

    private static boolean isUseField(String msgID, String infoName, String fieldName, String version) 

    { 

        // 根据消息ID从内存中取出发送消息配置Map 

        SendFieldInfo sendMsgInfo = HttpEnv.getSendMsgMap().get(version).get(msgID); 

        if (null != sendMsgInfo) 

        { 

            // 根据info的详细类名称取出发送消息字段

            Map<String, MessageInfo> messageMap = sendMsgInfo.getMessageMap(); 

            if (null != messageMap) 

            { 

                // 根据info路径获取配置的info 

                MessageInfo msgInfo = messageMap.get(infoName); 

                if (null != msgInfo) 

                { 

                    Map<String, FieldInfo> fieldMap = msgInfo.getFieldMap(); 

                    // 根据消息字段获取匹配的属性字段

                    fieldName = fieldName.toLowerCase(Locale.getDefault()); 

                    FieldInfo fieldInfo = fieldMap.get(fieldName); 

                    if (null != fieldInfo) 

                    {