痴心VS绝对 发表于 2017-2-26 08:23:40

通过Java代码启动Jetty【programmatically start a jetty server】

通过Java代码启动Jetty的方式有以下几种:
【第一种】在java代码中通过标准的jetty.xml配置文件启动,示例代码如下:
EmbeddedViaXml.java
////////////////////////////////begin/////////////////////////////////
package jetty;

import java.io.File;
import java.net.URL;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.xml.XmlConfiguration;

public class EmbeddedViaXml
{
    public static void main(String[] args)
    {
      try
      {
            // The configuration files
            List<URL> configs = new ArrayList<>();
            configs.add(new File("jetty.xml").toURI().toURL());
            configs.add(new File("jetty-plus.xml").toURI().toURL());

            // The properties
            Map<String, String> props = new HashMap<String, String>();
            props.put("jetty.home",new File(System.getProperty("user.dir")).getCanonicalPath());

            Server server = load(configs,props);
            server.start();
            server.join();
      }
      catch (Throwable t)
      {
            t.printStackTrace();
      }
    }

    public static Server load(List<URL> xmlConfigUrls, Map<String, String> props) throws Exception
    {
      XmlConfiguration last = null;
      // Hold list of configured objects
      Object[] obj = new Object;

      // Configure everything
      for (int i = 0; i < xmlConfigUrls.size(); i++)
      {
            URL configURL = xmlConfigUrls.get(i);
            XmlConfiguration configuration = new XmlConfiguration(configURL);
            if (last != null)
            {
                // Let configuration know about prior configured objects
                configuration.getIdMap().putAll(last.getIdMap());
            }
            configuration.getProperties().putAll(props);
            obj = configuration.configure();
            last = configuration;
      }

      // Find Server Instance.
      Server foundServer = null;
      int serverCount = 0;
      for (int i = 0; i < xmlConfigUrls.size(); i++)
      {
            if (obj instanceof Server)
            {
                if (obj.equals(foundServer))
                {
                  // Identical server instance found
                  continue; // Skip
                }
                foundServer = (Server)obj;
                serverCount++;
            }
      }

      if (serverCount <= 0)
      {
            throw new IllegalStateException("Load failed to configure a " + Server.class.getName());
      }

      if (serverCount == 1)
      {
            return foundServer;
      }

      throw new IllegalStateException(String.format("Configured %d Servers, expected 1",serverCount));
    }
}
////////////////////////////////end///////////////////////////////////


【第二种】在java代码中通过spring bean格式的jetty.xml配置文件启动,示例代码如下:
//////////////////////////////////begin///////////////////////

public static final String DEFAULT_CONFIG_URI_FOR_JETTY = "xbean:jetty.xml";

configURI4Jetty = new URI(DEFAULT_CONFIG_URI_FOR_JETTY);

if (configURI4Jetty != null) {
                  System.out.println("Loading jetty server from: "
                            + configURI4Jetty);
                  ApplicationContext context = createApplicationContext(configURI4Jetty);
                  server = (Server) context.getBean("Server");

                  server.start();
                  server.join();
                }
            

protected ApplicationContext createApplicationContext(URI config)
            throws MalformedURLException, URISyntaxException {
      String uri = config.getSchemeSpecificPart();
      if (uri.lastIndexOf('?') != -1) {
            IntrospectionSupport
                  .setProperties(this, URISupport.parseQuery(uri));
            uri = uri.substring(0, uri.lastIndexOf('?'));
      }
      Resource resource = Utils.resourceFromString(uri);
      try {
            return new ResourceXmlApplicationContext(resource) {
                @Override
                protected void initBeanDefinitionReader(
                        XmlBeanDefinitionReader reader) {
                  reader.setValidating(isValidate());
                }
            };
      } catch (FatalBeanException errorToLog) {
            throw errorToLog;
      }
    }


public static Resource resourceFromString(String uri) throws MalformedURLException {
      Resource resource;
      File file = new File(uri);
      if (file.exists()) {
            resource = new FileSystemResource(uri);
      } else if (ResourceUtils.isUrl(uri)) {
            try {
                resource = new UrlResource(ResourceUtils.getURL(uri));
            } catch (FileNotFoundException e) {
                MalformedURLException malformedURLException = new MalformedURLException(uri);
                malformedURLException.initCause(e);
                throwmalformedURLException;
            }
      } else {
            resource = new ClassPathResource(uri);
      }
      return resource;
    }
//////////////////////////////////end/////////////////////////
页: [1]
查看完整版本: 通过Java代码启动Jetty【programmatically start a jetty server】