都市淘沙者

荔枝FM Everyone can be host

導(dǎo)航

<

2025年6月

>

日

一

二

三

四

五

六

25

26

27

28

29

30

31

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

1

2

3

4

5

公告

我的blog中的部分資源是來自于網(wǎng)絡(luò)上，如果你認(rèn)為侵犯了你的權(quán)利，請及時(shí)聯(lián)系jelver#163.com,我會盡快刪除！另外如果要留言最好通過郵件的形式跟我交流因?yàn)槲也皇呛芙?jīng)常寫文章，前面有的朋友留言好久了我才發(fā)現(xiàn)，所以對不住大家，現(xiàn)在留下MSN:jelver#163.com和QQ：253840881,歡迎交流！（用@代替#）

隨筆分類

文章分類

隨筆檔案

文章檔案

相冊

我們一家

統(tǒng)計(jì)

隨筆 - 65
文章 - 359
評論 - 122
引用 - 0

留言簿(23)

積分與排名

積分 - 564146
排名 - 85

優(yōu)秀學(xué)習(xí)網(wǎng)站

Android 優(yōu)秀源碼站點(diǎn) (rss)
Android圖標(biāo)資源 (rss)
DOM學(xué)習(xí)的好地方
EJB3.0中文學(xué)習(xí)
EJB開發(fā) (rss)
Hibernate Man
http://www.java3z.com
javabloger 優(yōu)秀網(wǎng)站 (rss)
JSTL學(xué)習(xí)
SSH實(shí)例學(xué)習(xí)好BLOG (rss)
Struts2.0系列文章 (rss)
tapestry wiki
UML技術(shù)指南
前端研究好站
國內(nèi)LAMP組織
在線API查詢 (rss)
http://www.gotapi.com/
孫衛(wèi)琴論壇 (rss)
開源pdf閱讀器
http://code.google.com/p/ebookdroid/ 非常給力 http://my.oschina.net/ernest/blog/16999
手機(jī)設(shè)計(jì)應(yīng)用
手機(jī)GUI資訊
英文電子書下載
高級運(yùn)維 (rss)
高級運(yùn)維

友情連接

AJAX (rss)
ajax資料
bst.cublog.cn
EJB學(xué)習(xí)例子 (rss)
hibernate+Spring好資料
HR面試，英語面試資料 (rss)
Javamxj
java海鷗
Java自由人
limq
mayu博客
moxie
Oksonic'Blog
spring /tapestry
spring sky
thunderzhulei的專欄
干煸四季豆
很多好的java資源
曹曉剛blog
江南白衣之射殺鋼琴師
溫昱說圖
滿江紅
老妖
螞蟻小窩----為而不爭
鄧應(yīng)華的小站
鐵手大人

閱讀排行榜

評論排行榜

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;

/**

* 處理從游戲服務(wù)商接收到的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消息包到數(shù)據(jù)庫中*/

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結(jié)點(diǎn)的所有孩子節(jié)點(diǎn)，并進(jìn)行處理

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;

}

/**

* 操作返回響應(yīng)包

* @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>\r\n");

sb.append("</MOResp>\r\n");

sb.append("</SOAP-ENV:Body>\r\n");

sb.append("</SOAP-ENV:Envelope>");

return sb.toString();

}

/**

* 遍歷整個(gè)XML文件，獲取所有節(jié)點(diǎn)的值與其屬性的值，并放入HashMap中

* @param filename String 待遍歷的XML文件（相對路徑或者絕對路徑）

* @param hm HashMap 存放遍歷結(jié)果，格式：<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結(jié)點(diǎn)的所有孩子節(jié)點(diǎn)，并進(jìn)行處理

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 都市淘沙者閱讀(1194) 評論(0) 編輯收藏所屬分類: Java Basic/Lucene/開源資料

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發(fā)表評論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關(guān)文章: BeanComparator實(shí)現(xiàn)ArrayList復(fù)合排序[轉(zhuǎn)] 開源中最好的Web開發(fā)的資源 java中傳輸對象時(shí)候的問題（轉(zhuǎn)） Java Float類型減法運(yùn)算時(shí)精度丟失問題 ConcurrentHashMap原理分析 http請求的詳細(xì)過程【推薦】既有魚肉又有熊掌——ListOrderedMap JAVA異常詳解 javaIO總結(jié) j2ee的性能調(diào)優(yōu)