WebService的客户端和服务端的全套代码

/***************************************************************** * <p>Filename: AuthReceiver.java * <p>Description: * <p> * <p>Copyright: Copyright (c)2008 * <p>Company: Linkage Group * <p>Create at: 2013-9-7上午01:40:47 * @author jinkun * @version 1.0 * @since JDK1.5 *********************************************************************/ package com.linkage.auth.sender; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.URLDecoder; import java.util.Date; import java.util.HashMap; import java.util.Map; import javax.servlet.ServletConfig; 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.apache.log4j.NDC; import com.linkage.ngi.sender.IBossSerialHttpSender; import com.linkage.processor.HTTPDataReceiverFCU; import com.linkage.uip.data.TradeInfo; import com.linkage.uip.data.UIPDataContext; import com.linkage.uip.filecore.common.FilecoreCommonTools; import com.linkage.uip.sender.SerialHttpSender; import com.linkage.util.bml.BML; import com.linkage.util.common.Sequencer; import com.linkage.util.common.StringTools; import com.linkage.util.common.TimeProcessor; import com.linkage.util.common.UUIDGenerator; import com.linkage.util.configmanager.BusiSignManager; import com.linkage.util.configmanager.BusiSignVO; import com.linkage.util.configmanager.ConfigManager; import com.linkage.util.logger.UIPBizInfo; import com.linkage.util.logger.UIPLogger; import com.linkage.xml.saxproc.assit.ResNodeVO; import com.linkage.xml.saxproc.assit.SAXNodeTreeHelper; import com.linkage.xml.saxproc.sax.Node; import com.linkage.xml.saxproc.sax.SAXNodeTree; /***************************************************************** * <p>Filename: AuthReceiver.java * <p>Description: * <p> * <p>Copyright: Copyright (c)2008 * <p>Company: Linkage Group * <p>Create at: 2013-9-7上午01:40:47 * <p> * <p>Modification History: * <p>Date Author Version Description * <p>------------------------------------------------------------------ * <p>2008-12-26 jinkun 1.0 first Version * <p>------------------------------------------------------------------ * * @author jinkun * @version 1.0 * @since JDK1.5 *********************************************************************/ public class AuthReceiver extends HttpServlet{ private static final long serialVersionUID = -1705739622307111627L; /** * http数据编码 */ private String encode="UTF-8"; /** * 日志管理器 */ private static final Logger logger=UIPLogger.getLogger(AuthReceiver.class); /** * 配置管理器 */ ConfigManager configManager = ConfigManager.getInstance(); /** * http的监听的配置名 */ String dataReceiverName = null; /** * 处理类型 */ private String processType = null; /** * 发起方domain */ private String origSysID = null; /** * 落地方domain */ private String homeSysID = null; /** * 子系统的名字 */ private String subSystemName = null; /** * init 初始化servlet. * * @param servletConfig * ServletConfig * @throws ServletException * @todo Implement this javax.servlet.Servlet method */ public void init(ServletConfig servletConfig) throws ServletException { /* <servlet> <servlet-name>AuthReceiver</servlet-name> <servlet-class>com.linkage.auth.sender.AuthReceiver</servlet-class> <init-param> <param-name>AuthReceiver</param-name> <param-value>HTTPDataReceiverIBOSS</param-value> </init-param> <load-on-startup>1</load-on-startup> </servlet> <servlet-mapping> <servlet-name>AuthReceiver</servlet-name> <url-pattern>services/SVC_UACP9980_RealTimeInterface</url-pattern> </servlet-mapping> */ dataReceiverName = servletConfig.getInitParameter("AuthReceiver"); logger.debug("TSOPHTTP监听初始化.ServletName: " + servletConfig.getServletName() + " DataReceiverName: " + dataReceiverName); origSysID = StringTools.nvl(configManager.getParamValue(dataReceiverName, "OrigSysID"), "UNKNOWN", 2); homeSysID = StringTools.nvl(configManager.getParamValue(dataReceiverName, "HomeSysID"), "UNKNOWN", 2); processType = StringTools.nvl(configManager.getParamValue(dataReceiverName, "ProcessType"), "UNKNOWN", 2); subSystemName = StringTools.nvl(configManager.getParamValue(dataReceiverName, "SubSystemName"), "UNKNOWN", 2); } /** * get请求处理 * @param request http请求 * @param response http响应 * @throws ServletException * @throws IOException */ protected void doGet(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException { response.setContentType("text/xml;charset="+encode); doPost(request,response); } /** * post请求处理 * @param request http请求 * @param response http响应 * @throws ServletException * @throws IOException */ @SuppressWarnings("unchecked") protected void doPost(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException { //记录时间 Date time=new Date(); // 设置编码 request.setCharacterEncoding(encode); //跳过Header的校验 //以字节流方式取参数 BufferedReader in = new BufferedReader(new InputStreamReader(request.getInputStream(),encode)); StringBuffer sb = new StringBuffer(); String tmp = ""; while ((tmp = in.readLine()) != null){ sb.append(tmp).append("\n"); } String reqParamString=sb.toString().trim(); reqParamString=reqParamString.indexOf("%")>-1?URLDecoder.decode(reqParamString,encode):reqParamString;//兼容get方式编码 System.out.println("---------接收的报文-------"+sb.toString()); //响应字符串，真坑爹，成功失败都返回这个 String rspParamString=""; try{ //初始化日志信息报文头信息以及报文体信息，分3个接口 String address=request.getRemoteAddr(); String bipCode=StringTools.getFirstXmlStrByFlag(reqParamString,"ns1:BIPCode"); String activityCode=StringTools.getFirstXmlStrByFlag(reqParamString,"ns1:ActivityCode"); String transIdO=StringTools.getFirstXmlStrByFlag(reqParamString,"ns1:TransIDO"); String testFlag=StringTools.getFirstXmlStrByFlag(reqParamString,"ns1:TestFlag"); String busiSign=bipCode+"_"+activityCode+"_1_"+testFlag; String procId=StringTools.getFirstXmlStrByFlag(reqParamString,"ns1:ProcID"); String processTime=StringTools.getFirstXmlStrByFlag(reqParamString,"ns1:ProcessTime"); UIPBizInfo ubi = new UIPBizInfo(); ubi.setStr0(UUIDGenerator.getNextId()); ubi.setStr1(address); ubi.setStr2(busiSign); ubi.setStr3(transIdO); NDC.push(ubi.toString()); String MSISDN=""; String ChannelID=""; String UserType=""; String IdentCode=""; String EffectiveTime=""; String OperCode=""; String Password=""; String PwdType=""; String CustomerId=""; String IdentCodeType=""; String IDLevel=""; if(reqParamString.contains("<cmcc:authdelay>")){ OperCode="authdelay"; MSISDN=StringTools.getFirstXmlStrByFlag(reqParamString,"cmcc:MSISDN"); ChannelID=StringTools.getFirstXmlStrByFlag(reqParamString,"cmcc:ChannelID"); UserType=StringTools.getFirstXmlStrByFlag(reqParamString,"cmcc:UserType"); IdentCode=StringTools.getFirstXmlStrByFlag(reqParamString,"cmcc:IdentCode"); EffectiveTime=StringTools.getFirstXmlStrByFlag(reqParamString,"cmcc:EffectiveTime"); System.out.println("---------执行报文解析了-----