Dict.CN 在线词典, 英语学习, 在线翻译

都市淘沙者

荔枝FM Everyone can be host

统计

留言簿(23)

积分与排名

优秀学习网站

友情连接

阅读排行榜

评论排行榜

HttpURLConnection常用处理方式

/*
 * Classname       : GameSoapProcessor
 * Create Date     : 2008-5-7
 
*/

package cn.allinpalm.sns.app.web.mxt.game;

import java.io.File;
import java.io.IOException;
import java.io.OutputStream;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.log4j.Logger;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
import org.hibernate.HibernateException;

import cn.allinpalm.sns.app.wirelessapi.HttpSend;
import cn.allinpalm.sns.app.web.filter.HibernateFilter;

/**
 * 处理从游戏服务商接收到的SOAP消息
 * 
 * 
@author   lqm
 * 
@version  1.0
 
*/

public class SoapMsgProcessorServlet extends HttpServlet {
    
    
private static final long serialVersionUID = 1L;
    
private static Logger log = Logger.getLogger(SoapMsgProcessorServlet.class);
    
    
public SoapMsgProcessorServlet() {}

    
public void doPost(HttpServletRequest request, HttpServletResponse response) {

        OutputStream out 
= null;
        
try {
            request.setCharacterEncoding(
"UTF-8");
            Document doc 
= null;
            doc 
= new SAXReader().read(request.getReader());
            log.info(doc.asXML());
            
            
/*保存从soap消息包到数据库中*/
            GameUser user 
= setSoapMsgBean(doc);
            String issaveok 
= saveSoapMoMsg(setSoapMsgBean(doc));        
            String restr 
= retOptRespPkg(setSoapMsgBean(doc),issaveok);
            
            out 
= response.getOutputStream();
            out.write(restr.getBytes(
"UTF8"));
            out.flush();

        }
 catch (IOException e) {
            log.error(e, e);
        }
 catch (Exception e) {
            log.error(e, e);
        }

        
finally{
            
if(out!=null){
                
try{
                    out.close();
                }
catch(IOException e){
                    log.error(e, e);
                }

               
            }

        }

    }

    
    
public void doGet(HttpServletRequest request, HttpServletResponse response)
            
throws ServletException,
                IOException 
{
        doPost(request, response);
    }

    
    
    
public GameUser setSoapMsgBean(Document doc) {
        
       GameUser bean 
= new GameUser();            
       Element root 
= doc.getRootElement();
       
       
for ( Iterator iter = root.elementIterator(); iter.hasNext(); ) {
             Element element 
= (Element) iter.next();
           
if(element.getName().equals("Body")) 
               Element MOReqelement
=element.element("MOReq");
               
//遍历MOReq结点的所有孩子节点,并进行处理
               for ( Iterator iterInner = MOReqelement.elementIterator(); iterInner.hasNext(); ) {
                    Element elementInner 
= (Element) iterInner.next();
                  
//  hm.put(elementInner.getName(), elementInner.getText());
                    if("Msg_Id".equals(elementInner.getName()))
                        bean.setMsgid(elementInner.getText());
                    }

                    
if("Src_terminal_Id".equals(elementInner.getName()))
                        bean.setSrcterminalid(elementInner.getText());
                    }

                    
if("Dest_Id".equals(elementInner.getName()))
                        bean.setDestid(elementInner.getText());
                    }

                    
if("MsgContent".equals(elementInner.getName()))
                        bean.setMsgcontent(elementInner.getText());
                    }

                    
if("LinkID".equals(elementInner.getName()))
                        bean.setLinkid(elementInner.getText());
                    }

                    
if("CreateDate".equals(elementInner.getName()))
                        bean.setCreatedate(elementInner.getText());
                    }

                    
//System.out.println("elementInner.getName()="+elementInner.getName()+"---=="+elementInner.getText());
               }

           }

       }
 

        
return bean;
    }

    
    
/**
     * 保存是否成功 isok为1表示失败,为0表示成功
     * 
@param msgbean
     * 
@return
     
*/

    
public String  saveSoapMoMsg(GameUser msgbean){
        
        String isok 
= "1";
        PreparedStatement stmt
=null;
        String sql 
= "insert into maintain.gameuserlog(id,msgseq_id,srcterm_id,dest_id,msg_content,linkid,create_date,add_date)" +
                
" values(maintain.GAME_USER_LOG_SEQ.Nextval,?,?,?,?,?,?,sysdate)";
        
        
try {
            stmt 
= HibernateFilter.getSession().connection().prepareStatement(sql);
            stmt.setString(
1, msgbean.getMsgid() );
            stmt.setString(
2, msgbean.getSrcterminalid());
            stmt.setString(
3, msgbean.getDestid());
            stmt.setString(
4, msgbean.getMsgcontent());
            stmt.setString(
5, msgbean.getLinkid());
            stmt.setString(
6, msgbean.getCreatedate());
            stmt.executeUpdate();
            HibernateFilter.getSession().connection().commit();
            
            isok 
= "0";
        }
 catch (HibernateException e) {
            e.printStackTrace();
        }
 catch (SQLException e) {
            e.printStackTrace();
        }
finally{
            
if (stmt != null)
            
{
                
try {
                    stmt.close();
                }
 catch (SQLException e) {
                    
// TODO Auto-generated catch block
                    e.printStackTrace();
                }

            }
   
        }

        
return isok;        
    }

    
    
/**
     * 操作返回响应包
     * 
@param userid
     * 
@return
     
*/

    
public static String  retOptRespPkg(GameUser user,String flag){
        
        StringBuffer sb 
= new StringBuffer();
        sb.append(
"<?xml version = \"1.0\"  encoding=\"UTF-8\" ?>\r\n");
        sb.append(
"<SOAP-ENV:Envelope\r\n");
        sb.append(
"xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance'\r\n");      
        sb.append(
"xmlns:xsd='http://www.w3.org/2001/XMLSchema'\r\n");  
        sb.append(
"xmlns:SOAP-ENV='http://schemas.xmlsoap.org/soap/envelope/'\r\n");        
        sb.append(
"xmlns:SOAP-ENC='http://schemas.xmlsoap.org/soap/encoding/' >\r\n");                  
        sb.append(
"<SOAP-ENV:Header>\r\n");
        sb.append(
"</SOAP-ENV:Header>\r\n");       
        sb.append(
"<SOAP-ENV:Body>\r\n");    
        sb.append(
"<MOResp xmlns='http://www.infuns.com/IFXML/IFXMLSchema.xsd/'>\r\n");       
        sb.append(
"<Msg_Id>"+user.getMsgid()+"</Msg_Id>\r\n");
        sb.append(
"<LinkID>"+user.getLinkid()+"</LinkID>\r\n");
        sb.append(
"<hRet>"+flag+"</hRet><!-- 接收解析成功:0; 接收解析失败:1;-->\r\n");
        sb.append(
"</MOResp>\r\n");      
        sb.append(
"</SOAP-ENV:Body>\r\n"); 
        sb.append(
"</SOAP-ENV:Envelope>");  
        
        
return sb.toString();
    }
 
    

    
    
/**
      * 遍历整个XML文件,获取所有节点的值与其属性的值,并放入HashMap中
      * 
@param filename String 待遍历的XML文件(相对路径或者绝对路径)
      * 
@param hm       HashMap 存放遍历结果,格式:<nodename,nodevalue>或者<nodename+attrname,attrvalue>
      
*/

     
public static void iterateWholeXML(){
         
      HashMap
<String,String> hm = new HashMap<String,String>();
      SAXReader saxReader 
= new SAXReader();
      
try {
           Document document 
= saxReader.read(new File("D:\\code\\trunk_lxw\\lxwSrc\\cn\\allinpalm\\sns\\app\\web\\mxt\\game\\test.xml"));
           Element root 
= document.getRootElement();

           
for ( Iterator iter = root.elementIterator(); iter.hasNext(); ) {
                 Element element 
= (Element) iter.next();
               
if(element.getName().equals("Body")) 
                   Element MOReqelement
=element.element("MOReq");
                   
//遍历MOReq结点的所有孩子节点,并进行处理
                   for ( Iterator iterInner = MOReqelement.elementIterator(); iterInner.hasNext(); ) {
                        Element elementInner 
= (Element) iterInner.next();
                        hm.put(elementInner.getName(), elementInner.getText());
                        System.out.println(
"elementInner.getName()="+elementInner.getName()+"---=="+elementInner.getText());
                   }

               }

           }

      }
 catch (DocumentException e) {
       
// TODO Auto-generated catch block
       e.printStackTrace();
      }

     }


     
    
public static void main(String[] args) {
        
//iterateWholeXML();
        StringBuffer sb = new StringBuffer();
        sb.append(
"<?xml version = \"1.0\"  encoding=\"UTF-8\" ?>\r\n");
        sb.append(
"<SOAP-ENV:Envelope\r\n");
        sb.append(
"xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance'\r\n");      
        sb.append(
"xmlns:xsd='http://www.w3.org/2001/XMLSchema'\r\n");  
        sb.append(
"xmlns:SOAP-ENV='http://schemas.xmlsoap.org/soap/envelope/'\r\n");        
        sb.append(
"xmlns:SOAP-ENC='http://schemas.xmlsoap.org/soap/encoding/' >\r\n");                  
        sb.append(
"<SOAP-ENV:Header>\r\n");
        sb.append(
"</SOAP-ENV:Header>\r\n");       
        sb.append(
"<SOAP-ENV:Body>\r\n");    
        sb.append(
"<MOReq xmlns='http://www.infuns.com/IFXML/IFXMLSchema.xsd/'>\r\n");       
        sb.append(
"<Msg_Id>2e5fb10009610029</Msg_Id>\r\n");
        sb.append(
"<Dest_Id>33000015</Dest_Id>\r\n");
        sb.append(
"<Src_terminal_Id>15810912222</Src_terminal_Id>\r\n");
        sb.append(
"<MsgContent>YXBY15 07M003155 IF5</MsgContent>\r\n");        
        sb.append(
"<LinkID>23590311470360662046</LinkID>\r\n");
        sb.append(
"<CreateDate>2006-08-01 00:00:00.000</CreateDate>\r\n");
        sb.append(
"</MOReq>\r\n");      
        sb.append(
"</SOAP-ENV:Body>\r\n"); 
        sb.append(
"</SOAP-ENV:Envelope>"); 
           
        log.info(HttpSend.connectURL(
"http://localhost:6060/SoapMsgProcessorServlet",sb.toString()));

    }

    
    
}


public class HttpSend {
    
    
private static Logger log = Logger.getLogger(HttpSend.class);
    
    
public static String connectURL(String dest_url, String commString)
    
{
        log.debug(
"send data to Url:"+dest_url);
        String rec_string 
= "";
        URL url 
= null;
        OutputStream out 
= null;
        BufferedReader rd 
= null;
        HttpURLConnection urlconn 
= null;
        
try
        
{
            url 
= new URL(dest_url);
            urlconn 
= (HttpURLConnection) url.openConnection();
            urlconn.setReadTimeout(
5000);
            urlconn.setRequestProperty(
"content-type""text/plain");
            urlconn.setRequestMethod(
"POST");
            urlconn.setDoInput(
true);
            urlconn.setDoOutput(
true);
            out 
= urlconn.getOutputStream();
            out.write(commString.getBytes(
"UTF8"));
            out.flush();
            out.close();
            rd 
= new BufferedReader(new InputStreamReader(
                    urlconn.getInputStream()));
            StringBuffer sb 
= new StringBuffer();
            
int ch;
            
while ((ch = rd.read()) > -1){
//                System.out.println(ch);
                sb.append((char) ch);
            }

            rec_string 
= sb.toString();
            log.info(
"resp="+rec_string);
            rd.close();
            urlconn.disconnect();
        }

        
catch (Exception e)
        
{
            log.error(e, e);
            
return "";
        }
finally {
            
try {
                
if (out != null{
                    out.close();
                }

                
if (urlconn != null{
                    urlconn.disconnect();
                }

                
if (rd != null{
                    rd.close();
                }

            }
 catch (Exception e) {
                log.error(e, e);
            }

        }


        
return rec_string;
    }


}

posted on 2008-05-09 13:25 都市淘沙者 阅读(1190) 评论(0)  编辑  收藏 所属分类: Java Basic/Lucene/开源资料


只有注册用户登录后才能发表评论。


网站导航: