- 浏览: 284774 次
- 性别:
- 来自: 上海
文章分类
- 全部博客 (163)
- ETL (4)
- Oracle (24)
- Win (2)
- Apache (5)
- struts2 (1)
- ArcGIS (21)
- Java (17)
- other (6)
- JavaScript (4)
- Xml (4)
- c# (2)
- webSphere (5)
- Ext (2)
- Flex (35)
- Svn (3)
- tomcat (3)
- MyEclipse (4)
- MySQL (2)
- ibatis (2)
- log4j (4)
- spring (1)
- SqlServer (2)
- android (4)
- ios (3)
- SDE (2)
- mac (1)
- Linux (9)
- Mina2 (1)
最新评论
-
markss:
您好,请问kettle循环处理的内存泄漏问题是否已经解决了?毕 ...
Kettle -
1qqqqqq:
图呢 ???
Myeclipse 9.0集成FLASH BUILDER 4.5 -
hanyi366:
现在MyEclipse 都2014版了,好像MyEclipse ...
Visual Editor 插件 安装 -
cnjmwr:
MyEclipse8.6的Eclipse版本是3.5的 ve1 ...
Visual Editor 插件 安装 -
cloudphoenix:
大神 我特地登陆来回帖,真是帮了我的大忙了。看了一个多月的AS ...
FlexGlobals.topLevelApplication
XmlHttpProxy
XmlHttpProxyServlet
HttpClient
/* Copyright 2007 You may not modify, use, reproduce, or distribute this software except in compliance with the terms of the License at: http://developer.sun.com/berkeley_license.html $Id: XmlHttpProxy.java 2660 2008-10-29 14:40:28Z heiko.braun@jboss.com $ */ package jmaki.xhp; /* Copyright 2007 You may not modify, use, reproduce, or distribute this software except in compliance with the terms of the License at: http://developer.sun.com/berkeley_license.html $Id: XmlHttpProxy.java 2660 2008-10-29 14:40:28Z heiko.braun@jboss.com $ */ import java.io.*; import java.net.MalformedURLException; import java.net.URL; import java.util.*; import java.util.logging.*; import javax.xml.transform.*; import javax.xml.transform.stream.*; import org.json.*; public class XmlHttpProxy { public static String GET = "GET"; public static String POST = "POST"; public static String DELETE = "DELETE"; public static String PUT = "PUT"; private String userName = null; private String password = null; private static Logger logger; private String proxyHost = ""; int proxyPort = -1; private JSONObject config; private static String USAGE = "Usage: -url service_URL -id service_key [-url or -id required] -xslurl xsl_url [optional] -format json|xml [optional] -callback[optional] -config [optional] -resources base_directory_containing XSL stylesheets [optional]"; public XmlHttpProxy() {} public XmlHttpProxy(String proxyHost, int proxyPort) { this.proxyHost = proxyHost; this.proxyPort = proxyPort; } public XmlHttpProxy(String proxyHost, int proxyPort, String userName, String password) { this.proxyHost = proxyHost; this.proxyPort = proxyPort; this.userName = userName; this.password = password; } /** * This method will go out and make the call and it will apply an XSLT Transformation with the * set of parameters provided. * * @param urlString - The URL which you are looking up * @param out - The OutputStream to which the resulting document is written * @param xslInputStream - An input Stream to an XSL style sheet that is provided to the XSLT processor. If set to null there will be no transformation * @param paramsMap - A Map of parameters that are feed to the XSLT Processor. These params may be used when generating content. This may be set to null if no parameters are necessary. * @param method - The HTTP method used. * */ public void processRequest(String urlString, OutputStream out, InputStream xslInputStream, Map paramsMap, Map headers, String method, String userName, String password) throws IOException, MalformedURLException { doProcess(urlString, out, xslInputStream, paramsMap, headers,method, null,null, userName,password); } /** * This method will go out and make the call and it will apply an XSLT Transformation with the * set of parameters provided. * * @param urlString - The URL which you are looking up * @param out - The OutputStream to which the resulting document is written * */ public void doPost(String urlString, OutputStream out, InputStream xslInputStream, Map paramsMap, Map headers, String postData, String postContentType, String userName, String password) throws IOException, MalformedURLException { doProcess(urlString, out, xslInputStream, paramsMap, headers, XmlHttpProxy.POST, postData, postContentType, userName, password); } /** * This method will go out and make the call and it will apply an XSLT Transformation with the * set of parameters provided. * * @param urlString - The URL which you are looking up * @param out - The OutputStream to which the resulting document is written * @param xslInputStream - An input Stream to an XSL style sheet that is provided to the XSLT processor. If set to null there will be no transformation * @param paramsMap - A Map of parameters that are feed to the XSLT Processor. These params may be used when generating content. This may be set to null if no parameters are necessary. * @param method - the HTTP method used. * @param postData - A String of the bodyContent to be posted. A doPost will be used if this is parameter is not null. * @param postContentType - The request contentType used when posting data. Will not be set if this parameter is null. * @param userName - userName used for basic authorization * @param password - password used for basic authorization */ public void doProcess(String urlString, OutputStream out, InputStream xslInputStream, Map paramsMap, Map headers, String method, String postData, String postContentType, String userName, String password) throws IOException, MalformedURLException { if (paramsMap == null) { paramsMap = new HashMap(); } String format = (String)paramsMap.get("format"); if (format == null) { format = "xml"; } InputStream in = null; BufferedOutputStream os = null; HttpClient httpclient = null; if (userName != null && password != null) { httpclient = new HttpClient(proxyHost, proxyPort, urlString, headers, method, userName, password); } else { httpclient = new HttpClient(proxyHost, proxyPort, urlString, headers, method); } // post data determines whether we are going to do a get or a post if (postData == null) { in = httpclient.getInputStream(); } else { in = httpclient.doPost(postData, postContentType); } if(null==in) { throw new IOException("Failed to open input stream"); } // read the encoding from the incoming document and default to UTF-8 // if an encoding is not provided String ce = httpclient.getContentEncoding(); if (ce == null) { String ct = httpclient.getContentType(); if (ct != null) { int idx = ct.lastIndexOf("charset="); if (idx >= 0) { ce = ct.substring(idx+8); } else { ce = "UTF-8"; } } else { ce = "UTF-8"; } } // get the content type String cType = null; // write out the content type //http://www.ietf.org/rfc/rfc4627.txt if (format.equals("json")) { cType = "application/json;charset="+ce; } else { cType = "text/xml;charset="+ce; } try { byte[] buffer = new byte[1024]; int read = 0; if (xslInputStream == null) { while (true) { read = in.read(buffer); if (read <= 0) break; out.write(buffer, 0, read ); } } else { transform(in, xslInputStream, paramsMap, out, ce); } } catch (Exception e) { getLogger().severe("XmlHttpProxy transformation error: " + e); } finally { try { if (in != null) { in.close(); } if (out != null) { out.flush(); out.close(); } } catch (Exception e) { // do nothing } } } /** * Do the XSLT transformation */ public void transform( InputStream xmlIS, InputStream xslIS, Map params, OutputStream result, String encoding) { try { TransformerFactory trFac = TransformerFactory.newInstance(); Transformer transformer = trFac.newTransformer(new StreamSource(xslIS)); Iterator it = params.keySet().iterator(); while (it.hasNext()) { String key = (String)it.next(); transformer.setParameter(key, (String)params.get(key)); } transformer.setOutputProperty("encoding", encoding); transformer.transform(new StreamSource(xmlIS), new StreamResult(result)); } catch (Exception e) { getLogger().severe("XmlHttpProxy: Exception with xslt " + e); } } /** * * CLI to the XmlHttpProxy */ public static void main(String[] args) throws IOException, MalformedURLException { getLogger().info("XmlHttpProxy 1.8"); XmlHttpProxy xhp = new XmlHttpProxy(); if (args.length == 0) { System.out.println(USAGE); } String method = XmlHttpProxy.GET; InputStream xslInputStream = null; String serviceKey = null; String urlString = null; String xslURLString = null; String format = "xml"; String callback = null; String urlParams = null; String configURLString = "xhp.json"; String resourceBase = "file:src/conf/META-INF/resources/xsl/"; String username = null; String password = null; // read in the arguments int index = 0; while (index < args.length) { if (args[index].toLowerCase().equals("-url") && index + 1 < args.length) { urlString = args[++index]; } else if (args[index].toLowerCase().equals("-key") && index + 1 < args.length) { serviceKey = args[++index]; } else if (args[index].toLowerCase().equals("-id") && index + 1 < args.length) { serviceKey = args[++index]; } else if (args[index].toLowerCase().equals("-callback") && index + 1 < args.length) { callback = args[++index]; } else if (args[index].toLowerCase().equals("-xslurl") && index + 1 < args.length) { xslURLString = args[++index]; } else if (args[index].toLowerCase().equals("-method") && index + 1 < args.length) { method = args[++index]; } else if (args[index].toLowerCase().equals("-username") && index + 1 < args.length) { username = args[++index]; } else if (args[index].toLowerCase().equals("-password") && index + 1 < args.length) { password = args[++index]; } else if (args[index].toLowerCase().equals("-urlparams") && index + 1 < args.length) { urlParams = args[++index]; } else if (args[index].toLowerCase().equals("-config") && index + 1 < args.length) { configURLString = args[++index]; } else if (args[index].toLowerCase().equals("-resources") && index + 1 < args.length) { resourceBase = args[++index]; } index++; } if (serviceKey != null) { try { InputStream is = (new URL(configURLString)).openStream(); JSONObject services = loadServices(is); JSONObject service = services.getJSONObject(serviceKey); // default to the service default if no url parameters are specified if (urlParams == null && service.has("defaultURLParams")) { urlParams = service.getString("defaultURLParams"); } String serviceURL = service.getString("url"); // build the URL properly if (urlParams != null && serviceURL.indexOf("?") == -1){ serviceURL += "?"; } else if (urlParams != null){ serviceURL += "&"; } String apiKey = ""; if (service.has("apikey")) apiKey = service.getString("apikey"); urlString = serviceURL + apiKey + "&" + urlParams; if (service.has("xslStyleSheet")) { xslURLString = service.getString("xslStyleSheet"); // check if the url is correct of if to load from the classpath } } catch (Exception ex) { getLogger().severe("XmlHttpProxy Error loading service: " + ex); System.exit(1); } } else if (urlString == null) { System.out.println(USAGE); System.exit(1); } // The parameters are feed to the XSL Stylsheet during transformation. // These parameters can provided data or conditional information. Map paramsMap = new HashMap(); if (format != null) { paramsMap.put("format", format); } if (callback != null) { paramsMap.put("callback", callback); } if (xslURLString != null) { URL xslURL = new URL(xslURLString); if (xslURL != null) { xslInputStream = xslURL.openStream(); } else { getLogger().severe("Error: Unable to locate XSL at URL " + xslURLString); } } xhp.processRequest(urlString, System.out, xslInputStream, paramsMap, null, method, username, password); } public static Logger getLogger() { if (logger == null) { logger = Logger.getLogger("jmaki.xhp.Log"); } return logger; } public static JSONObject loadServices(InputStream is) { JSONObject config = null; JSONObject services = new JSONObject(); try { config = loadJSONObject(is).getJSONObject("xhp"); JSONArray sA = config.getJSONArray("services"); for (int l=0; l < sA.length(); l++) { JSONObject value = sA.getJSONObject(l); String key = value.getString("id"); services.put(key,value); } } catch (Exception ex) { getLogger().severe("XmlHttpProxy error loading services." + ex); } return services; } public static JSONObject loadJSONObject(InputStream in) { ByteArrayOutputStream out = null; try { byte[] buffer = new byte[1024]; int read = 0; out = new ByteArrayOutputStream(); while (true) { read = in.read(buffer); if (read <= 0) break; out.write(buffer, 0, read ); } return new JSONObject(out.toString()); } catch (Exception e) { getLogger().severe("XmlHttpProxy error reading in json " + e); } finally { try { if (in != null) { in.close(); } if (out != null) { out.flush(); out.close(); } } catch (Exception e) { } } return null; } }
XmlHttpProxyServlet
/* Copyright 2007 You may not modify, use, reproduce, or distribute this software except in compliance with the terms of the License at: http://developer.sun.com/berkeley_license.html $Id: XmlHttpProxyServlet.java 2660 2008-10-29 14:40:28Z heiko.braun@jboss.com $ */ package jmaki.xhp; import java.io.*; import java.util.*; import java.net.URL; import java.net.URLConnection; import java.util.logging.*; import javax.servlet.*; import javax.servlet.http.*; import org.json.*; /** XmlHttpProxyServlet * @author Greg Murray */ public class XmlHttpProxyServlet extends HttpServlet { public static String REMOTE_USER = "REMOTE_USER"; private static String XHP_LAST_MODIFIED = "xhp_last_modified_key"; private static String XHP_CONFIG = "xhp.json"; private static boolean allowXDomain = false; private static boolean requireSession = false; private static boolean createSession = false; private static String responseContentType = "application/json;charset=UTF-8"; private static boolean rDebug = false; private Logger logger = null; private XmlHttpProxy xhp = null; private ServletContext ctx; private JSONObject services = null; private String resourcesDir = "/resources/"; private String classpathResourcesDir = "/META-INF/resources/"; private String headerToken = "jmaki-"; private String testToken = "xtest-"; public XmlHttpProxyServlet() { if (rDebug) { logger = getLogger(); } } public void init(ServletConfig config) throws ServletException { super.init(config); ctx = config.getServletContext(); // set the response content type if (ctx.getInitParameter("responseContentType") != null) { responseContentType = ctx.getInitParameter("responseContentType"); } // allow for resources dir over-ride at the xhp level otherwise allow // for the jmaki level resources if (ctx.getInitParameter("jmaki-xhp-resources") != null) { resourcesDir = ctx.getInitParameter("jmaki-xhp-resources"); } else if (ctx.getInitParameter("jmaki-resources") != null) { resourcesDir = ctx.getInitParameter("jmaki-resources"); } // allow for resources dir over-ride if (ctx.getInitParameter("jmaki-classpath-resources") != null) { classpathResourcesDir = ctx.getInitParameter("jmaki-classpath-resources"); } String requireSessionString = ctx.getInitParameter("requireSession"); if (requireSessionString == null) requireSessionString = ctx.getInitParameter("jmaki-requireSession"); if (requireSessionString != null) { if ("false".equals(requireSessionString)) { requireSession = false; getLogger().severe("XmlHttpProxyServlet: intialization. Session requirement disabled."); } else if ("true".equals(requireSessionString)) { requireSession = true; getLogger().severe("XmlHttpProxyServlet: intialization. Session requirement enabled."); } } String xdomainString = ctx.getInitParameter("allowXDomain"); if (xdomainString == null) xdomainString = ctx.getInitParameter("jmaki-allowXDomain"); if (xdomainString != null) { if ("true".equals(xdomainString)) { allowXDomain = true; getLogger().severe("XmlHttpProxyServlet: intialization. xDomain access is enabled."); } else if ("false".equals(xdomainString)) { allowXDomain = false; getLogger().severe("XmlHttpProxyServlet: intialization. xDomain access is disabled."); } } String createSessionString = ctx.getInitParameter("jmaki-createSession"); if (createSessionString != null) { if ("true".equals(createSessionString)) { createSession = true; getLogger().severe("XmlHttpProxyServlet: intialization. create session is enabled."); } else if ("false".equals(xdomainString)) { createSession = false; getLogger().severe("XmlHttpProxyServlet: intialization. create session is disabled."); } } // if there is a proxyHost and proxyPort specified create an HttpClient with the proxy String proxyHost = ctx.getInitParameter("proxyHost"); String proxyPortString = ctx.getInitParameter("proxyPort"); if (proxyHost != null && proxyPortString != null) { int proxyPort = 8080; try { proxyPort= new Integer(proxyPortString).intValue(); xhp = new XmlHttpProxy(proxyHost, proxyPort); } catch (NumberFormatException nfe) { getLogger().severe("XmlHttpProxyServlet: intialization error. The proxyPort must be a number"); throw new ServletException("XmlHttpProxyServlet: intialization error. The proxyPort must be a number"); } } else { xhp = new XmlHttpProxy(); } } private void getServices(HttpServletResponse res) { InputStream is = null; try { URL url = ctx.getResource(resourcesDir + XHP_CONFIG); // use classpath if not found locally. //if (url == null) url = XmlHttpProxyServlet.class.getResource(classpathResourcesDir + XHP_CONFIG); if (url == null) url = XmlHttpProxyServlet.class.getResource(XHP_CONFIG); // same package is = url.openStream(); } catch (Exception ex) { try { getLogger().severe("XmlHttpProxyServlet error loading xhp.json : " + ex); PrintWriter writer = res.getWriter(); writer.write("XmlHttpProxyServlet Error: Error loading xhp.json. Make sure it is available in the /resources directory of your applicaton."); writer.flush(); } catch (Exception iox) {} } services = xhp.loadServices(is); } public void doDelete(HttpServletRequest req, HttpServletResponse res) { doProcess(req,res, XmlHttpProxy.DELETE); } public void doGet(HttpServletRequest req, HttpServletResponse res) { doProcess(req,res, XmlHttpProxy.GET); } public void doPost(HttpServletRequest req, HttpServletResponse res) { doProcess(req,res, XmlHttpProxy.POST); } public void doPut(HttpServletRequest req, HttpServletResponse res) { doProcess(req,res, XmlHttpProxy.PUT); } public void doProcess(HttpServletRequest req, HttpServletResponse res, String method) { boolean isPost = XmlHttpProxy.POST.equals(method); StringBuffer bodyContent = null; OutputStream out = null; PrintWriter writer = null; String serviceKey = null; try { BufferedReader in = req.getReader(); String line = null; while ((line = in.readLine()) != null) { if (bodyContent == null) bodyContent = new StringBuffer(); bodyContent.append(line); } } catch (Exception e) { } try { HttpSession session = null; // it really does not make sense to use create session with require session as // the create session will always result in a session created and the requireSession // will always succeed. Leaving the logic for now. if (createSession) { session = req.getSession(true); } if (requireSession) { // check to see if there was a session created for this request // if not assume it was from another domain and blow up // Wrap this to prevent Portlet exeptions session = req.getSession(false); if (session == null) { res.setStatus(HttpServletResponse.SC_FORBIDDEN); return; } } serviceKey = req.getParameter("id"); // only to preven regressions - Remove before 1.0 if (serviceKey == null) serviceKey = req.getParameter("key"); // check if the services have been loaded or if they need to be reloaded if (services == null || configUpdated()) { getServices(res); } String urlString = null; String xslURLString = null; String userName = null; String password = null; String format = "json"; String callback = req.getParameter("callback"); String urlParams = req.getParameter("urlparams"); String countString = req.getParameter("count"); boolean passthrough = false; // encode the url to prevent spaces from being passed along if (urlParams != null) { urlParams = urlParams.replace(' ', '+'); } // get the headers to pass through Map headers = null; // Forward all request headers starting with the header token jmaki- // and chop off the jmaki- Enumeration hnum = req.getHeaderNames(); // test hack while (hnum.hasMoreElements()) { String name = (String)hnum.nextElement(); if (name.startsWith(headerToken)) { if (headers == null) headers = new HashMap(); String value = ""; // handle multi-value headers Enumeration vnum = req.getHeaders(name); while (vnum.hasMoreElements()) { value += (String)vnum.nextElement(); if (vnum.hasMoreElements()) value += ";"; } String sname = name.substring(headerToken.length(), name.length()); headers.put(sname,value); } else if(name.startsWith(testToken)) { // hack test capabilities for authentication if("xtest-user".equals(name)) userName = req.getHeader("xtest-user"); if("xtest-pass".equals(name)) password = req.getHeader("xtest-pass"); } } try { String actualServiceKey = serviceKey != null ? serviceKey : "default"; if (services.has(actualServiceKey)) { JSONObject service = services.getJSONObject(actualServiceKey); String serviceURL = service.getString("url"); if(null==serviceURL) throw new IllegalArgumentException("xhp.json: service url is mising"); if (service.has("passthrough")) passthrough = Boolean.valueOf(service.getString("passthrough")); if (service.has("username")) userName = service.getString("username"); if (service.has("password")) password = service.getString("password"); String apikey = ""; if (service.has("apikey")) apikey = service.getString("apikey"); if (service.has("xslStyleSheet")) xslURLString = service.getString("xslStyleSheet"); // default to the service default if no url parameters are specified if(!passthrough) { if (urlParams == null && service.has("defaultURLParams")) { urlParams = service.getString("defaultURLParams"); } // build the URL if (urlParams != null && serviceURL.indexOf("?") == -1){ serviceURL += "?"; } else if (urlParams != null) { serviceURL += "&"; } urlString = serviceURL + apikey; if (urlParams != null) urlString += "&" + urlParams; } if(passthrough) { // override service url and url params String path = req.getPathInfo(); path = path.substring(path.indexOf("xhp/")+3, path.length()); urlString = serviceURL + path + "?" + req.getQueryString(); } } else { writer = res.getWriter(); if (serviceKey == null) writer.write("XmlHttpProxyServlet Error: id parameter specifying serivce required."); else writer.write("XmlHttpProxyServlet Error : service for id '" + serviceKey + "' not found."); writer.flush(); return; } } catch (Exception ex) { getLogger().severe("XmlHttpProxyServlet Error loading service: " + ex); res.setStatus(500); } Map paramsMap = new HashMap(); paramsMap.put("format", format); // do not allow for xdomain unless the context level setting is enabled. if (callback != null && allowXDomain) { paramsMap.put("callback", callback); } if (countString != null) { paramsMap.put("count", countString); } InputStream xslInputStream = null; if (urlString == null) { writer = res.getWriter(); writer.write("XmlHttpProxyServlet parameters: id[Required] urlparams[Optional] format[Optional] callback[Optional]"); writer.flush(); return; } // support for session properties and also authentication name if (urlString.indexOf("${") != -1) { urlString = processURL(urlString, req, res); } // default to JSON res.setContentType(responseContentType); out = res.getOutputStream(); // get the stream for the xsl stylesheet if (xslURLString != null) { // check the web root for the resource URL xslURL = null; xslURL = ctx.getResource(resourcesDir + "xsl/"+ xslURLString); // if not in the web root check the classpath if (xslURL == null) { xslURL = XmlHttpProxyServlet.class.getResource(classpathResourcesDir + "xsl/" + xslURLString); } if (xslURL != null) { xslInputStream = xslURL.openStream(); } else { String message = "Could not locate the XSL stylesheet provided for service id " + serviceKey + ". Please check the XMLHttpProxy configuration."; getLogger().severe(message); res.setStatus(500); try { out.write(message.getBytes()); out.flush(); return; } catch (java.io.IOException iox){ } } } if (!isPost) { xhp.processRequest(urlString, out, xslInputStream, paramsMap, headers, method, userName, password); } else { final String content = bodyContent != null ? bodyContent.toString() : ""; if (bodyContent == null) getLogger().info("XmlHttpProxyServlet attempting to post to url " + urlString + " with no body content"); xhp.doPost(urlString, out, xslInputStream, paramsMap, headers, content, req.getContentType(), userName, password); } } catch (Exception iox) { iox.printStackTrace(); getLogger().severe("XmlHttpProxyServlet: caught " + iox); res.setStatus(500); /*try { writer = res.getWriter(); writer.write("XmlHttpProxyServlet error loading service for " + serviceKey + " . Please notify the administrator."); writer.flush(); } catch (java.io.IOException ix) { ix.printStackTrace(); }*/ return; } finally { try { if (out != null) out.close(); if (writer != null) writer.close(); } catch (java.io.IOException iox){} } } /* Allow for a EL style replacements in the serviceURL * * The constant REMOTE_USER will replace the contents of ${REMOTE_USER} * with the return value of request.getRemoteUserver() if it is not null * otherwise the ${REMOTE_USER} is replaced with a blank. * * If you use ${session.somekey} the ${session.somekey} will be replaced with * the String value of the session varialble somekey or blank if the session key * does not exist. * */ private String processURL(String url, HttpServletRequest req, HttpServletResponse res) { String serviceURL = url; int start = url.indexOf("${"); int end = url.indexOf("}", start); if (end != -1) { String prop = url.substring(start + 2, end).trim(); // no matter what we will remove the ${} // default to blank like the JSP EL String replace = ""; if (REMOTE_USER.equals(prop)) { if (req.getRemoteUser() != null) replace = req.getRemoteUser(); } if (prop.toLowerCase().startsWith("session.")) { String sessionKey = prop.substring("session.".length(), prop.length()); if (req.getSession().getAttribute(sessionKey) != null) { // force to a string replace = req.getSession().getAttribute(sessionKey).toString(); } } serviceURL = serviceURL.substring(0, start) + replace + serviceURL.substring(end + 1, serviceURL.length()); } // call recursively to process more than one instance of a ${ in the serviceURL if (serviceURL.indexOf("${") != -1) serviceURL = processURL(serviceURL, req, res); return serviceURL; } /** * Check to see if the configuration file has been updated so that it may be reloaded. */ private boolean configUpdated() { try { URL url = ctx.getResource(resourcesDir + XHP_CONFIG); URLConnection con; if (url == null) return false ; con = url.openConnection(); long lastModified = con.getLastModified(); long XHP_LAST_MODIFIEDModified = 0; if (ctx.getAttribute(XHP_LAST_MODIFIED) != null) { XHP_LAST_MODIFIEDModified = ((Long)ctx.getAttribute(XHP_LAST_MODIFIED)).longValue(); } else { ctx.setAttribute(XHP_LAST_MODIFIED, new Long(lastModified)); return false; } if (XHP_LAST_MODIFIEDModified < lastModified) { ctx.setAttribute(XHP_LAST_MODIFIED, new Long(lastModified)); return true; } } catch (Exception ex) { getLogger().severe("XmlHttpProxyServlet error checking configuration: " + ex); } return false; } public Logger getLogger() { if (logger == null) { logger = Logger.getLogger("jmaki.services.xhp.Log"); } return logger; } private void logMessage(String message) { if (rDebug) { getLogger().info(message); } } }
HttpClient
/* Copyright 2006-2008 Sun Microsystems, Inc. All rights reserved. You may not modify, use, reproduce, or distribute this software except in compliance with the terms of the License at: http://developer.sun.com/berkeley_license.html $Id: HttpClient.java 2631 2008-10-27 17:25:05Z heiko.braun@jboss.com $ */package jmaki.xhp; import java.io.*; import java.util.Map; import java.util.Iterator; import java.net.*; import java.util.logging.*; import java.security.Security; /** * @author Yutaka Yoshida, Greg Murray * * Minimum set of HTTPclient supporting both http and https. * It's aslo capable of POST, but it doesn't provide doGet because * the caller can just read the inputstream. */ public class HttpClient { private static Logger logger; private String proxyHost = null; private int proxyPort = -1; private boolean isHttps = false; private boolean isProxy = false; private HttpURLConnection urlConnection = null; private Map headers; /** * @param phost PROXY host name * @param pport PROXY port string * @param url URL string * @param headers Map */ public HttpClient( String phost, int pport, String url, Map headers, String method) throws MalformedURLException { if (phost != null && pport != -1) { this.isProxy = true; } this.proxyHost = phost; this.proxyPort = pport; if (url.trim().startsWith("https:")) { isHttps = true; } this.urlConnection = getURLConnection(url); try { this.urlConnection.setRequestMethod(method); } catch (java.net.ProtocolException pe) { HttpClient.getLogger().severe("Unable protocol method to " + method + " : " + pe); } this.headers = headers; // seat headers if (headers != null) { Iterator it = headers.keySet().iterator(); if (it != null) { while (it.hasNext()) { String key = (String)it.next(); String value = (String)headers.get(key); this.urlConnection.setRequestProperty (key, value); } } } } /** * @param phost PROXY host name * @param pport PROXY port string * @param url URL string * @param headers Map * @param userName string * @param password string */ public HttpClient(String phost, int pport, String url, Map headers, String method, String userName, String password) throws MalformedURLException { try { if (phost != null && pport != -1) { this.isProxy = true; } this.proxyHost = phost; this.proxyPort = pport; if (url.trim().startsWith("https:")) { isHttps = true; } this.urlConnection = getURLConnection(url); try { this.urlConnection.setRequestMethod(method); } catch (java.net.ProtocolException pe) { HttpClient.getLogger().severe("Unable protocol method to " + method + " : " + pe); } // set basic authentication information String auth = userName + ":" + password; String encoded = new sun.misc.BASE64Encoder().encode (auth.getBytes()); // set basic authorization this.urlConnection.setRequestProperty ("Authorization", "Basic " + encoded); this.headers = headers; // seat headers if (headers != null) { Iterator it = headers.entrySet().iterator(); if (it != null) { while (it.hasNext()) { String key = (String)it.next(); String value = (String)headers.get(key); this.urlConnection.setRequestProperty (key, value); } } } } catch (Exception ex) { HttpClient.getLogger().severe("Unable to set basic authorization for " + userName + " : " +ex); } } /** * private method to get the URLConnection * @param str URL string */ private HttpURLConnection getURLConnection(String str) throws MalformedURLException { try { if (isHttps) { /* when communicating with the server which has unsigned or invalid * certificate (https), SSLException or IOException is thrown. * the following line is a hack to avoid that */ Security.addProvider(new com.sun.net.ssl.internal.ssl.Provider()); System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol"); if (isProxy) { System.setProperty("https.proxyHost", proxyHost); System.setProperty("https.proxyPort", proxyPort + ""); } } else { if (isProxy) { System.setProperty("http.proxyHost", proxyHost); System.setProperty("http.proxyPort", proxyPort + ""); } } URL url = new URL(str); HttpURLConnection uc = (HttpURLConnection)url.openConnection(); // if this header has not been set by a request set the user agent. if (headers == null || (headers != null && headers.get("user-agent") == null)) { // set user agent to mimic a common browser String ua="Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; .NET CLR 1.1.4322)"; uc.setRequestProperty("user-agent", ua); } return uc; } catch (MalformedURLException me) { throw new MalformedURLException(str + " is not a valid URL"); } catch (Exception e) { throw new RuntimeException("Unknown error creating UrlConnection: " + e); } } /** * returns the inputstream from URLConnection * @return InputStream */ public InputStream getInputStream() { try { // logger doesnt work, because it writes to stderr, // which causes GwtTest to interpret it as failure System.out.println( this.urlConnection.getRequestMethod()+ " " + this.urlConnection.getURL() +": "+ this.urlConnection.getResponseCode() ); return (this.urlConnection.getInputStream()); } catch (Exception e) { e.printStackTrace(); return null; } } /** * return the OutputStream from URLConnection * @return OutputStream */ public OutputStream getOutputStream() { try { return (this.urlConnection.getOutputStream()); } catch (Exception e) { e.printStackTrace(); return null; } } /** * posts data to the inputstream and returns the InputStream. * @param postData data to be posted. must be url-encoded already. * @param contentType allows you to set the contentType of the request. * @return InputStream input stream from URLConnection */ public InputStream doPost(String postData, String contentType) { this.urlConnection.setDoOutput(true); if (contentType != null) this.urlConnection.setRequestProperty( "Content-type", contentType ); OutputStream os = this.getOutputStream(); PrintStream ps = new PrintStream(os); ps.print(postData); ps.close(); return (this.getInputStream()); } public String getContentEncoding() { if (this.urlConnection == null) return null; return (this.urlConnection.getContentEncoding()); } public int getContentLength() { if (this.urlConnection == null) return -1; return (this.urlConnection.getContentLength()); } public String getContentType() { if (this.urlConnection == null) return null; return (this.urlConnection.getContentType()); } public long getDate() { if (this.urlConnection == null) return -1; return (this.urlConnection.getDate()); } public String getHeader(String name) { if (this.urlConnection == null) return null; return (this.urlConnection.getHeaderField(name)); } public long getIfModifiedSince() { if (this.urlConnection == null) return -1; return (this.urlConnection.getIfModifiedSince()); } public static Logger getLogger() { if (logger == null) { logger = Logger.getLogger("jmaki.xhp.Log"); } return logger; } }
- XmlHttpProxy.rar (10.6 KB)
- 下载次数: 4
发表评论
-
Java中byte与16进制字符串的互相转换
2014-09-07 07:43 716Java中byte用二进制表示占用8位,而我们知道16进制 ... -
SynchronizedMap和ConcurrentHashMap的深入分析
2014-06-19 10:33 594在开始之前,先介绍下Map是什么? javadoc中对M ... -
多线程下使用 SimpleDateFormat 的问题
2014-03-18 12:38 743最近用到多线程写通信服务,发现在解析时间是一直莫名的错误, ... -
java内存限制
2012-07-12 20:38 890回顾一下java内存限制的几个参数的具体含义 -Xm ... -
UTC GMT CST时间
2012-07-05 15:59 2497GMT(Greenwich Mean Time,格林威治 ... -
java 操作 excel 2010
2012-03-14 15:28 1635前段时间,需要进行excel2010数据的解析。先是找组件, ... -
FLEX权限--使用RemoteObject交互结合spring AOP控制项目权限教程
2012-03-04 16:55 812FLEX使用remoteobject交互结合sprin ... -
iBatis中的insert如何返回个类数据库的主键
2012-02-24 11:03 954<SPAN style="COLOR: #ff ... -
java.util.ConcurrentModificationException异常
2012-01-14 12:59 9421、 今天在写一个带缓 ... -
JAVA中ArrayList 与 Vector 的线程安全问题
2012-01-13 18:45 3615JAVA中ArrayList是否允许两个线程同时进行插入和删除 ... -
java calendar
2011-12-22 16:27 1701import java.text.DateFormat; ... -
Servlet中init-param and content-param
2011-11-08 08:56 804Servlet中init-param and content- ... -
HttpRequestProxy 请求代理 post方法
2011-10-28 15:31 4247* * * * Title: Ht ... -
HttpRequestProxy 请求代理 post方法
2011-10-28 15:30 1301写道 * * * * Title: HttpR ... -
super.init(config)
2011-08-22 11:45 2981servlet的init(ServletConfig conf ... -
URL工具类
2011-08-18 14:45 971package ssh.util; import ...
相关推荐
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
30KW三相PFC充电桩项目开发设计方案CCS源码AD原理图bom测试报告
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
JAVA五子棋手机网络对战游戏的设计与实现(源代码+LW)JAVA五子棋手机网络对战游戏的设计与实现(源代码+LW)JAVA五子棋手机网络对战游戏的设计与实现(源代码+LW)JAVA五子棋手机网络对战游戏的设计与实现(源代码+LW)JAVA五子棋手机网络对战游戏的设计与实现(源代码+LW)JAVA五子棋手机网络对战游戏的设计与实现(源代码+LW)JAVA五子棋手机网络对战游戏的设计与实现(源代码+LW)JAVA五子棋手机网络对战游戏的设计与实现(源代码+LW)JAVA五子棋手机网络对战游戏的设计与实现(源代码+LW)JAVA五子棋手机网络对战游戏的设计与实现(源代码+LW)
【项目资源】:汇聚了云计算、区块链、网络安全、前端设计、后端架构、UI/UX设计、游戏开发、移动应用开发、虚拟现实(VR)、增强现实(AR)、3D建模与渲染、云计算服务、网络安全工具等各类技术项目的素材和模板。包括AWS、Azure、Docker、Kubernetes、React、Vue、Angular、Node.js、Django、Flask、Unity、Unreal Engine、Blender、Sketch、Figma、Wireshark、Nmap等项目的素材和模板。【项目质量】:所有素材和模板都经过精心筛选和整理,确保满足专业标准。在发布前,我们已经对功能进行了全面测试,确保其稳定性和可用性。【适用人群】:适合对技术充满热情的初学者、希望提升专业技能的中级开发者、以及寻求创新解决方案的高级工程师。无论是个人项目、团队合作、课程设计还是商业应用,都能在这里找到合适的资源。【附加价值】:这些项目资源不仅具有很高的学习价值,而且能够直接应用于实际项目中,提高开发效率。对于有志于深入研究或拓展新领域的人来说,它们提供了丰富的灵感和基础框架,帮助你快速构建出令人惊艳的作品。
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
Hnase课程-概念资料
太原理工软件工程Linux与Python编程实验报告,各位当个参考即可,不用过分较真,如果与你们想法不同,请以自己为主。
开发语言:Java JDK版本:JDK1.8(或11) 服务器:tomcat 数据库:mysql 5.6/5.7(或8.0) 数据库工具:Navicat 开发软件:idea 依赖管理包:Maven 代码+数据库保证完整可用,可提供远程调试并指导运行服务(额外付费)~ 如果对系统的中的某些部分感到不合适可提供修改服务,比如题目、界面、功能等等... 声明: 1.项目已经调试过,完美运行 2.需要远程帮忙部署项目,需要额外付费 3.本项目有演示视频,如果需要观看,请联系我v:19306446185 4.调试过程中可帮忙安装IDEA,eclipse,MySQL,JDK,Tomcat等软件 重点: 需要其他Java源码联系我,更多源码任你选,你想要的源码我都有! https://img-blog.csdnimg.cn/direct/e73dc0ac8d27434b86d886db5a438c71.jpeg
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
PiP-Tool-master
保姆式教学,手把手学习,让你清晰认识waf设备
base.apk
电脑游戏,是指在计算机上能够运转的游戏软件。这种软件具有较强的娱乐性。电脑游戏的创新和发展与硬件、软件的发展紧密相关。它能够给玩家提供一个虚拟的环境,使游戏带给了人们很多的享受和欢乐。雷电游戏因为操作简单,节奏明快,一直是纵轴射击游戏的经典之作。经常能够在手机或者计算机中见到这款游戏,深得广大玩家的喜爱,可以说是妇孺皆知的一款益智类游戏。 本游戏基于Eclipse开发平台,以java作为编程语言,整个项目开发旨在模拟雷电游戏的飞机射击游戏。游戏界面的下部是玩家的飞机,可以根据按键控制子弹的发射,上部为敌方飞机,在界面中随机出现。在游戏过程当中,用户飞机的移动是被电脑键盘的方向键所控制的,在整个游戏过程当中,如果用户飞机的子弹与敌方飞机发生相撞时,敌方飞机就会有爆炸的效果产生。游戏中使用到的飞机、子弹均采用对应的类实现。
【作品名称】:基于FPGA的深度学习加速器的设计与实现 【适用人群】:适用于希望学习不同技术领域的小白或进阶学习者。可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。 【项目介绍】:基于FPGA的深度学习加速器的设计与实现