非安插容器,Java多线程第七章

时间:2019-09-23 07:11来源: 操作系统
难度 初级 1. 证实:依旧利用tomcat作为容器,Jetty在此地只作为开辟时测验方便,所以采纳工具类情势,而非下载Jetty容器包配置形式。 上学时间 10分钟 2. 怎么要用Jetty? 适合人群 零基
难度

初级

1. 证实:依旧利用tomcat作为容器,Jetty在此地只作为开辟时测验方便,所以采纳工具类情势,而非下载Jetty容器包配置形式。

上学时间

10分钟

2. 怎么要用Jetty?

适合人群

零基础

此处用Jetty只是有益测验,运营个main方法就可以运转Jetty容器,然后就足以调用接口和拜望jsp等页面。没有须求运转tomcat,个人认为Jetty运转速度远快于tomcat。所以方便测验,改变代码只必要再一次运营main方法就能够。(Jetty自带热陈设)
支出语言

Java

3. 什么行使?

  • ###### pom.xml定义如下
<!-- jetty plugin -->
      <dependency>
          <groupId>org.eclipse.jetty.aggregate</groupId>
          <artifactId>jetty-all-server</artifactId>
          <version>8.1.18.v20150929</version>
      </dependency>
      <dependency>
          <groupId>org.eclipse.jetty</groupId>
          <artifactId>jetty-jsp</artifactId>
          <version>8.1.18.v20150929</version>
      </dependency>
  • ###### 工具类
package test.bshf.clinic.util;

import org.eclipse.jetty.jmx.MBeanContainer;
import org.eclipse.jetty.server.Handler;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.util.Scanner;
import org.eclipse.jetty.webapp.WebAppContext;

import javax.management.MBeanServer;
import java.io.File;
import java.io.IOException;
import java.lang.management.ManagementFactory;
import java.net.DatagramSocket;
import java.net.ServerSocket;
import java.util.ArrayList;
import java.util.List;


public class JettyServerStarter {
    private int           port;
    private String        context;
    private String        webappPath;
    private int           scanIntervalSeconds;
    private boolean       jmxEnabled;
    private Server        server;
    private WebAppContext webapp;

    public JettyServerStarter(String webappPath, int port, String context) {
        this(webappPath, port, context, 0, false);
    }

    public JettyServerStarter(String webappPath, int port, String context, int scanIntervalSeconds, boolean jmxEnabled) {
        this.webappPath = webappPath;
        this.port = port;
        this.context = context;
        this.scanIntervalSeconds = scanIntervalSeconds;
        this.jmxEnabled = jmxEnabled;
        validateConfig();
    }

    private void validateConfig() {
        if (port < 0 || port > 65536) {
            throw new IllegalArgumentException("Invalid port of web server: " + port);
        }
        if (context == null) {
            throw new IllegalStateException("Invalid context of web server: " + context);
        }
        if (webappPath == null) {
            throw new IllegalStateException("Invalid context of web server: " + webappPath);
        }
    }

    public void start() {
        if (server == null || server.isStopped()) {
            try {
                doStart();
            } catch (Throwable e) {
                e.printStackTrace();
                System.err.println("System.exit() ......");
                System.exit(1);
            }
        } else {
            throw new RuntimeException("Jetty Server already started.");
        }
    }

    private void doStart() throws Throwable {
        if (!portAvailable(port)) {
            throw new IllegalStateException("port: " + port + " already in use!");
        }

        System.setProperty("org.eclipse.jetty.util.URI.charset", "UTF-8");
        System.setProperty("org.eclipse.jetty.util.log.class", "org.eclipse.jetty.util.log.Slf4jLog");
        System.setProperty("org.eclipse.jetty.server.Request.maxFormContentSize", "20000000");

        server = new Server(port);
        server.setHandler(getHandler());

        if (jmxEnabled) {
            MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
            MBeanContainer mBeanContainer = new MBeanContainer(mBeanServer);
            server.addBean(mBeanContainer);
        }

        if (scanIntervalSeconds > 0) {
            startFileWatchScanner();
        }

        long ts = System.currentTimeMillis();
        server.start();

        ts = System.currentTimeMillis() - ts;
        System.err.println("Jetty Server started: " + String.format("%.2f sec", ts / 1000d));

        server.join();
    }


    protected Handler getHandler(){
        webapp = new WebAppContext(webappPath, context);
        return webapp;
    }

    private void startFileWatchScanner() throws Exception {
        List<File> scanList = new ArrayList<File>();
        scanList.add(new File(webappPath, "WEB-INF"));

        Scanner scanner = new Scanner();
        scanner.setReportExistingFilesOnStartup(false);
        scanner.setScanInterval(scanIntervalSeconds);
        scanner.setScanDirs(scanList);
        scanner.addListener(new Scanner.BulkListener() {

            @SuppressWarnings("rawtypes")
            public void filesChanged(List changes) {
                try {
                    System.err.println("Loading changes ......");
                    webapp.stop();
                    webapp.start();
                    System.err.println("Loading complete.n");
                } catch (Exception e) {
                    System.err.println("Error reconfiguring/restarting webapp after change in watched files");
                    e.printStackTrace();
                }
            }
        });
        System.err.println("Starting scanner at interval of " + scanIntervalSeconds + " seconds.");
        scanner.start();
    }

    private static boolean portAvailable(int port) {
        if (port <= 0) {
            throw new IllegalArgumentException("Invalid start port: " + port);
        }

        ServerSocket ss = null;
        DatagramSocket ds = null;
        try {
            ss = new ServerSocket(port);
            ss.setReuseAddress(true);
            ds = new DatagramSocket(port);
            ds.setReuseAddress(true);
            return true;
        } catch (IOException e) {
        } finally {
            if (ds != null) {
                ds.close();
            }
            if (ss != null) try {
                ss.close();
            } catch (IOException e) {
            }
        }
        return false;
    }
}
  • ###### 主方法
package test.bshf.clinic.demo;

import test.bshf.clinic.util.JettyServerStarter;

/**
 * 启动jetty容器
 * 
 */
public class JettyStarterTest {

    public static void main(String[] args) {
        String webapp = "src/main/webapp";

        new JettyServerStarter(webapp, 8012, "/clinic-demo").start();
    }
}
开荒条件
  • JDK v11
  • IntelliJ IDEA v2018.3
批注表明:
小说最先的文章链接

“全栈2019”Java八线程第七章:等待线程寿终正寝join()方法详解

pom和工具类直接复制粘贴
永利皇宫463娱乐网址,下一章

“全栈2019”Java四线程第八章:扬弃试行权yield()方法详解

主方法
  • ###### String webapp = "src/main/webapp";: 是方今web项目标webapp那层目录结构(因为内部含有了class和页面等)

  • ###### new JettyServerStarter(webapp, 8012, "/clinic-demo").start(); new 一个Jetty容器,第叁个参数是webapp地址,第1个参数是端口号(自定义),第四个参数是近期web项目名称。

  • ###### 访谈路线:http://localhost:8012(自定义Jetty的端口)/clinic-demo

若有意思味,迎接来到场群,【Java初学者学习交换群】:458430385,此群有Java开荒人士、UI设计职员和前端技术员。有问必答,共同钻探学习,一齐前进!
迎接关怀自己的微信徒人号【Java码农社区】,会按时推送种种干货:

永利皇宫463娱乐网址 1

qrcode_for_gh_577b64e73701_258.jpg

学习小组

参与一同学习小组,共同交换与提升。

  • ###### 格局一:关怀头条号Gorhaf,私信“Java学习小组”。

  • ###### 格局二:关怀公众号Gorhaf,回复“Java学习小组”。

全栈技术员学习布署

关怀备至我们,参与“全栈程序员学习安插”。
永利皇宫463娱乐网址 2

版权申明

原创不易,未经同意不得转载!

打听更加的多

编辑: 操作系统 本文来源:非安插容器,Java多线程第七章

关键词: