| /* |
| * Copyright 2001-2002,2004 The Apache Software Foundation. |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package org.apache.webapp.admin.connector; |
| |
| import java.net.URLEncoder; |
| import java.util.Iterator; |
| import java.util.Locale; |
| import java.io.IOException; |
| import javax.management.Attribute; |
| import javax.management.MBeanServer; |
| import javax.management.MBeanServerFactory; |
| import javax.management.QueryExp; |
| import javax.management.Query; |
| import javax.management.ObjectInstance; |
| import javax.management.ObjectName; |
| import javax.management.JMException; |
| import javax.servlet.ServletException; |
| import javax.servlet.http.HttpServletRequest; |
| import javax.servlet.http.HttpServletResponse; |
| import javax.servlet.http.HttpSession; |
| import org.apache.struts.action.Action; |
| import org.apache.struts.action.ActionError; |
| import org.apache.struts.action.ActionErrors; |
| import org.apache.struts.action.ActionForm; |
| import org.apache.struts.action.ActionForward; |
| import org.apache.struts.action.ActionMapping; |
| import org.apache.struts.util.MessageResources; |
| import org.apache.webapp.admin.ApplicationServlet; |
| import org.apache.webapp.admin.TomcatTreeBuilder; |
| import org.apache.webapp.admin.TreeControl; |
| import org.apache.webapp.admin.TreeControlNode; |
| |
| |
| /** |
| * The <code>Action</code> that completes <em>Add Connector</em> and |
| * <em>Edit Connector</em> transactions. |
| * |
| * @author Manveen Kaur |
| * @version $Revision$ $Date$ |
| */ |
| |
| public final class SaveConnectorAction extends Action { |
| |
| |
| // ----------------------------------------------------- Instance Variables |
| |
| /** |
| * Signature for the <code>createStandardConnector</code> operation. |
| */ |
| private String createStandardConnectorTypes[] = |
| { "java.lang.String", // parent |
| "java.lang.String", // address |
| "int" // port |
| }; |
| |
| /** |
| * The MBeanServer we will be interacting with. |
| */ |
| private MBeanServer mBServer = null; |
| |
| // --------------------------------------------------------- Public Methods |
| |
| |
| /** |
| * Process the specified HTTP request, and create the corresponding HTTP |
| * response (or forward to another web component that will create it). |
| * Return an <code>ActionForward</code> instance describing where and how |
| * control should be forwarded, or <code>null</code> if the response has |
| * already been completed. |
| * |
| * @param mapping The ActionMapping used to select this instance |
| * @param actionForm The optional ActionForm bean for this request (if any) |
| * @param request The HTTP request we are processing |
| * @param response The HTTP response we are creating |
| * |
| * @exception IOException if an input/output error occurs |
| * @exception ServletException if a servlet exception occurs |
| */ |
| public ActionForward perform(ActionMapping mapping, |
| ActionForm form, |
| HttpServletRequest request, |
| HttpServletResponse response) |
| throws IOException, ServletException { |
| |
| // Acquire the resources that we need |
| HttpSession session = request.getSession(); |
| Locale locale = getLocale(request); |
| MessageResources resources = getResources(request); |
| |
| // Acquire a reference to the MBeanServer containing our MBeans |
| try { |
| mBServer = ((ApplicationServlet) getServlet()).getServer(); |
| } catch (Throwable t) { |
| throw new ServletException |
| ("Cannot acquire MBeanServer reference", t); |
| } |
| |
| // Identify the requested action |
| ConnectorForm cform = (ConnectorForm) form; |
| String adminAction = cform.getAdminAction(); |
| String cObjectName = cform.getObjectName(); |
| String connectorType = cform.getConnectorType(); |
| ObjectName coname = null; |
| |
| // Perform a "Create Connector" transaction (if requested) |
| if ("Create".equals(adminAction)) { |
| |
| String operation = null; |
| Object values[] = null; |
| |
| try { |
| // get service name which is same as domain |
| String serviceName = cform.getServiceName(); |
| ObjectName soname = new ObjectName(serviceName); |
| String domain = soname.getDomain(); |
| StringBuffer sb = new StringBuffer(domain); |
| StringBuffer searchSB = new StringBuffer("*"); |
| sb.append(TomcatTreeBuilder.CONNECTOR_TYPE); |
| searchSB.append(TomcatTreeBuilder.CONNECTOR_TYPE); |
| sb.append(",port=" + cform.getPortText()); |
| searchSB.append(",port=" + cform.getPortText()); |
| |
| ObjectName search = new ObjectName(searchSB.toString()+",*"); |
| |
| String address = cform.getAddress(); |
| if ((address!=null) && (address.length()>0) && |
| (!address.equalsIgnoreCase(" "))) { |
| sb.append(",address=" + address); |
| } else { |
| address = null; |
| } |
| ObjectName oname = new ObjectName(sb.toString()); |
| |
| // Ensure that the requested connector name and port is unique |
| if (mBServer.isRegistered(oname) || |
| (!mBServer.queryNames(search, null).isEmpty())) { |
| ActionErrors errors = new ActionErrors(); |
| errors.add("connectorName", |
| new ActionError("error.connectorName.exists")); |
| saveErrors(request, errors); |
| return (new ActionForward(mapping.getInput())); |
| } |
| |
| // Look up our MBeanFactory MBean |
| ObjectName fname = TomcatTreeBuilder.getMBeanFactory(); |
| |
| // Create a new Connector object |
| values = new Object[3]; |
| values[0] = serviceName; //service parent object name |
| values[1] = address; |
| values[2] = new Integer(cform.getPortText()); |
| |
| if ("HTTP".equalsIgnoreCase(connectorType)) { |
| operation = "createHttpConnector"; // HTTP |
| } else if ("HTTPS".equalsIgnoreCase(connectorType)) { |
| operation = "createHttpsConnector"; // HTTPS |
| } else { |
| operation = "createAjpConnector"; // AJP(HTTP) |
| } |
| |
| cObjectName = (String) |
| mBServer.invoke(fname, operation, |
| values, createStandardConnectorTypes); |
| |
| // Add the new Connector to our tree control node |
| TreeControl control = (TreeControl) |
| session.getAttribute("treeControlTest"); |
| if (control != null) { |
| String parentName = serviceName; |
| TreeControlNode parentNode = control.findNode(parentName); |
| if (parentNode != null) { |
| String nodeLabel = resources.getMessage(locale, |
| "server.service.treeBuilder.connector") + " (" + |
| cform.getPortText() + ")"; |
| String encodedName = |
| URLEncoder.encode(cObjectName); |
| TreeControlNode childNode = |
| new TreeControlNode(cObjectName, |
| "Connector.gif", |
| nodeLabel, |
| "EditConnector.do?select=" + |
| encodedName, |
| "content", |
| true, domain); |
| // FIXME--the node should be next to the rest of |
| // the Connector nodes.. |
| parentNode.addChild(childNode); |
| // FIXME - force a redisplay |
| } else { |
| getServlet().log |
| ("Cannot find parent node '" + parentName + "'"); |
| } |
| } else { |
| getServlet().log |
| ("Cannot find TreeControlNode!"); |
| } |
| |
| } catch (Exception e) { |
| |
| getServlet().log |
| (resources.getMessage(locale, "users.error.invoke", |
| operation), e); |
| response.sendError |
| (HttpServletResponse.SC_INTERNAL_SERVER_ERROR, |
| resources.getMessage(locale, "users.error.invoke", |
| operation)); |
| return (null); |
| |
| } |
| |
| } |
| |
| // Perform attribute updates as requested |
| String attribute = null; |
| try { |
| |
| coname = new ObjectName(cObjectName); |
| |
| attribute = "acceptCount"; |
| int acceptCount = 60000; |
| try { |
| acceptCount = Integer.parseInt(cform.getAcceptCountText()); |
| } catch (Throwable t) { |
| acceptCount = 60000; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute("acceptCount", new Integer(acceptCount))); |
| attribute = "compression"; |
| String compression = cform.getCompression(); |
| if ((compression != null) && (compression.length()>0)) { |
| mBServer.setAttribute(coname, |
| new Attribute("compression", compression)); |
| } |
| attribute = "connectionLinger"; |
| int connectionLinger = -1; |
| try { |
| connectionLinger = Integer.parseInt(cform.getConnLingerText()); |
| } catch (Throwable t) { |
| connectionLinger = 0; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute("connectionLinger", new Integer(connectionLinger))); |
| attribute = "connectionTimeout"; |
| int connectionTimeout = 0; |
| try { |
| connectionTimeout = Integer.parseInt(cform.getConnTimeOutText()); |
| } catch (Throwable t) { |
| connectionTimeout = 0; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute("connectionTimeout", new Integer(connectionTimeout))); |
| attribute = "connectionUploadTimeout"; |
| int connectionUploadTimeout = 0; |
| try { |
| connectionUploadTimeout = Integer.parseInt(cform.getConnUploadTimeOutText()); |
| } catch (Throwable t) { |
| connectionUploadTimeout = 0; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute("connectionUploadTimeout", new Integer(connectionUploadTimeout))); |
| attribute = "bufferSize"; |
| int bufferSize = 2048; |
| try { |
| bufferSize = Integer.parseInt(cform.getBufferSizeText()); |
| } catch (Throwable t) { |
| bufferSize = 2048; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute("bufferSize", new Integer(bufferSize))); |
| attribute = "disableUploadTimeout"; |
| mBServer.setAttribute(coname, |
| new Attribute("disableUploadTimeout", new Boolean(cform.getDisableUploadTimeout()))); |
| attribute = "enableLookups"; |
| mBServer.setAttribute(coname, |
| new Attribute("enableLookups", new Boolean(cform.getEnableLookups()))); |
| |
| attribute = "redirectPort"; |
| int redirectPort = 0; |
| try { |
| redirectPort = Integer.parseInt(cform.getRedirectPortText()); |
| } catch (Throwable t) { |
| redirectPort = 0; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute("redirectPort", new Integer(redirectPort))); |
| attribute = "minProcessors"; |
| int minProcessors = 5; |
| try { |
| minProcessors = Integer.parseInt(cform.getMinProcessorsText()); |
| } catch (Throwable t) { |
| minProcessors = 5; |
| } |
| //mBServer.setAttribute(coname, |
| // new Attribute("minProcessors", new Integer(minProcessors))); |
| attribute = "maxProcessors"; |
| int maxProcessors = 20; |
| try { |
| maxProcessors = Integer.parseInt(cform.getMaxProcessorsText()); |
| } catch (Throwable t) { |
| maxProcessors = 20; |
| } |
| //mBServer.setAttribute(coname, |
| // new Attribute("maxProcessors", new Integer(maxProcessors))); |
| |
| attribute = "maxKeepAliveRequests"; |
| int maxKeepAliveRequests = 100; |
| try { |
| maxKeepAliveRequests = Integer.parseInt(cform.getMaxKeepAliveText()); |
| } catch (Throwable t) { |
| maxKeepAliveRequests = 100; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute("maxKeepAliveRequests", new Integer(maxKeepAliveRequests))); |
| attribute = "maxSpareThreads"; |
| int maxSpare = 50; |
| try { |
| maxSpare = Integer.parseInt(cform.getMaxSpare()); |
| } catch (Throwable t) { |
| maxSpare = 50; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute(attribute, (new Integer(maxSpare)).toString())); |
| attribute = "maxThreads"; |
| int maxThreads = 200; |
| try { |
| maxThreads = Integer.parseInt(cform.getMaxThreads()); |
| } catch (Throwable t) { |
| maxThreads = 200; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute(attribute, (new Integer(maxThreads)).toString())); |
| |
| attribute = "minSpareThreads"; |
| int minSpare = 4; |
| try { |
| minSpare = Integer.parseInt(cform.getMinSpare()); |
| } catch (Throwable t) { |
| minSpare = 4; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute(attribute, (new Integer(minSpare)).toString())); |
| |
| attribute = "threadPriority"; |
| int threadPriority = Thread.NORM_PRIORITY; |
| try { |
| threadPriority = Integer.parseInt(cform.getThreadPriority()); |
| } catch (Throwable t) { |
| threadPriority = Thread.NORM_PRIORITY; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute(attribute, (new Integer(threadPriority)))); |
| |
| attribute = "secure"; |
| mBServer.setAttribute(coname, |
| new Attribute("secure", new Boolean(cform.getSecure()))); |
| attribute = "tcpNoDelay"; |
| mBServer.setAttribute(coname, |
| new Attribute("tcpNoDelay", new Boolean(cform.getTcpNoDelay()))); |
| |
| attribute = "xpoweredBy"; |
| mBServer.setAttribute(coname, |
| new Attribute("xpoweredBy", new Boolean(cform.getXpoweredBy()))); |
| |
| attribute = "URIEncoding"; |
| String uriEnc = cform.getURIEncodingText(); |
| if ((uriEnc != null) && (uriEnc.length()==0)) { |
| uriEnc = null; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute(attribute, uriEnc)); |
| |
| attribute = "useBodyEncodingForURI"; |
| mBServer.setAttribute(coname, |
| new Attribute(attribute, new Boolean(cform.getUseBodyEncodingForURIText()))); |
| |
| attribute = "allowTrace"; |
| mBServer.setAttribute(coname, |
| new Attribute(attribute, new Boolean(cform.getAllowTraceText()))); |
| |
| // proxy name and port do not exist for AJP connector |
| if (!("AJP".equalsIgnoreCase(connectorType))) { |
| attribute = "proxyName"; |
| String proxyName = cform.getProxyName(); |
| if ((proxyName != null) && (proxyName.length()>0)) { |
| mBServer.setAttribute(coname, |
| new Attribute("proxyName", proxyName)); |
| } |
| |
| attribute = "proxyPort"; |
| int proxyPort = 0; |
| try { |
| proxyPort = Integer.parseInt(cform.getProxyPortText()); |
| } catch (Throwable t) { |
| proxyPort = 0; |
| } |
| mBServer.setAttribute(coname, |
| new Attribute("proxyPort", new Integer(proxyPort))); |
| } |
| |
| // HTTPS specific properties |
| if("HTTPS".equalsIgnoreCase(connectorType)) { |
| attribute = "algorithm"; |
| String algorithm = cform.getAlgorithm(); |
| if ((algorithm != null) && (algorithm.length()>0)) |
| mBServer.setAttribute(coname, |
| new Attribute("algorithm", algorithm)); |
| |
| attribute = "clientAuth"; |
| mBServer.setAttribute(coname, |
| new Attribute("clientAuth", |
| cform.getClientAuthentication())); |
| |
| attribute = "ciphers"; |
| String ciphers = cform.getCiphers(); |
| if ((ciphers != null) && (ciphers.length()>0)) |
| mBServer.setAttribute(coname, |
| new Attribute("ciphers", ciphers)); |
| |
| attribute = "keystoreFile"; |
| String keyFile = cform.getKeyStoreFileName(); |
| if ((keyFile != null) && (keyFile.length()>0)) |
| mBServer.setAttribute(coname, |
| new Attribute("keystoreFile", keyFile)); |
| |
| attribute = "keystorePass"; |
| String keyPass = cform.getKeyStorePassword(); |
| if ((keyPass != null) && (keyPass.length()>0)) |
| mBServer.setAttribute(coname, |
| new Attribute("keystorePass", keyPass)); |
| // request.setAttribute("warning", "connector.keyPass.warning"); |
| |
| attribute = "keystoreType"; |
| String keyType = cform.getKeyStoreType(); |
| if ((keyType != null) && (keyType.length()>0)) |
| mBServer.setAttribute(coname, |
| new Attribute("keystoreType", keyType)); |
| |
| attribute = "sslProtocol"; |
| String sslProtocol = cform.getSslProtocol(); |
| if ((sslProtocol != null) && (sslProtocol.length()>0)) |
| mBServer.setAttribute(coname, |
| new Attribute("sslProtocol", sslProtocol)); |
| } |
| |
| } catch (Exception e) { |
| |
| getServlet().log |
| (resources.getMessage(locale, "users.error.attribute.set", |
| attribute), e); |
| response.sendError |
| (HttpServletResponse.SC_INTERNAL_SERVER_ERROR, |
| resources.getMessage(locale, "users.error.attribute.set", |
| attribute)); |
| return (null); |
| } |
| // Forward to the success reporting page |
| session.removeAttribute(mapping.getAttribute()); |
| return (mapping.findForward("Save Successful")); |
| |
| } |
| |
| } |
