本文整理了Java中org.eclipse.jetty.server.Server.join()
方法的一些代码示例,展示了Server.join()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Server.join()
方法的具体详情如下:
包路径:org.eclipse.jetty.server.Server
类名称:Server
方法名:join
暂无
代码示例来源:origin: zhegexiaohuozi/SeimiCrawler
private void startJetty(int port, SeimiHttpHandler seimiHttpHandler) {
Server server = new Server(port);
server.setHandler(seimiHttpHandler);
try {
server.start();
server.join();
} catch (Exception e) {
logger.error("http service start error,{}", e.getMessage(), e);
}
}
}
代码示例来源:origin: stackoverflow.com
Server server = new Server(8080);
WebSocketHandler wsHandler = new WebSocketHandler()
{
@Override
public void configure(WebSocketServletFactory factory)
{
factory.register(MyEchoSocket.class);
}
};
server.addHandler(wsHandler);
server.start();
server.join();
代码示例来源:origin: Dreampie/Resty
public void start() throws Exception {
if (!isBuild) {
throw new ServerException("You must build it before start");
}
if (Constant.devEnable) {
reloadRunnable = new ReloadRunnable(this);
reloadObserver = new ReloadObserver(reloadRunnable, this);
reloadRunnable.addObserver(reloadObserver);
watchThread = new Thread(reloadRunnable, "RestyServer-Watcher");//启动文件监控线程
watchThread.start();
}
server.start();
server.join();
}
代码示例来源:origin: apache/storm
jettyServer.setHandler(context);
Utils.addShutdownHookWithForceKillIn1Sec(metricsRegistry::stopMetricsReporters);
try {
jettyServer.start();
jettyServer.join();
} catch (Throwable t) {
LOG.error("Exception in UIServer: ", t);
代码示例来源:origin: org.xipki.scep/scep-server-emulator
public ScepServerContainer(int port, List<ScepServer> scepServers) throws Exception {
ScepUtil.requireNonEmpty("scepServers", scepServers);
server = new Server(port);
ServletHandler handler = new ServletHandler();
server.setHandler(handler);
for (ScepServer m : scepServers) {
ServletHolder servletHolder = new ServletHolder(m.getName(), m.getServlet());
handler.addServletWithMapping(servletHolder, "/" + m.getName() + "/pkiclient.exe");
}
server.join();
}
代码示例来源:origin: stackoverflow.com
Server server = new Server(8080);
ServletContextHandler context = new ServletContextHandler(ServletContextHandler.SESSIONS);
context.setContextPath("/");
context.addServlet(org.eclipse.jetty.servlet.DefaultServlet.class, "/");
context.addFilter(AppFilter.class, "/*", EnumSet.of(DispatcherType.INCLUDE,DispatcherType.REQUEST));
server.setHandler(context);
server.start();
server.join();
代码示例来源:origin: google/rejoiner
public static void main(String[] args) throws Exception {
Server server = new Server(HTTP_PORT);
new PathResource(new File("./src/main/resources").toPath().toRealPath()));
context.addServlet(DefaultServlet.class, "/");
server.start();
logger.info("Server running on port " + HTTP_PORT);
server.join();
代码示例来源:origin: stackoverflow.com
// Startup stuff
final Server server = new Server(port);
ServletContextHandler handler = new ServletContextHandler();
handler.setResourceBase(path);
SessionManager sm = new HashSessionManager();
SessionHandler sh = new SessionHandler(sm);
handler.setSessionHandler(sh);
DefaultServlet defaultServlet = new DefaultServlet();
ServletHolder holder = new ServletHolder(defaultServlet);
holder.setInitParameter("useFileMappedBuffer", "false");
handler.addServlet(holder, "/");
server.setHandler(handler);
server.start();
server.join();
代码示例来源:origin: loklak/loklak_server
LoklakInstallation.server.start();
LoklakInstallation.server.join();
DAO.log("server terminated");
代码示例来源:origin: sannies/mp4parser
public static void main(String[] args) throws Exception {
Movie movie = MovieCreator.build("/home/sannies/CSI.S13E02.HDTV.x264-LOL.mp4");
Server server = new Server(8080);
server.setHandler(new ServeMp4(movie));
server.start();
server.join();
}
代码示例来源:origin: google/rejoiner
public static void main(String[] args) throws Exception {
Server server = new Server(HTTP_PORT);
new PathResource(new File("./src/main/resources").toPath().toRealPath()));
context.addServlet(DefaultServlet.class, "/");
server.start();
logger.info("Server running on port " + HTTP_PORT);
server.join();
代码示例来源:origin: stackoverflow.com
// Startup stuff
final Server server = new Server(port);
WebAppContext webAppContext = new WebAppContext(path, "/")
webAppContext.setInitParam(
"org.eclipse.jetty.servlet.Default.useFileMappedBuffer", "false");
server.setHandler(webAppContext);
server.start();
server.join();
代码示例来源:origin: apache/hbase
@Override
public int run(String[] strings) throws Exception {
processOptions(strings);
setupParamters();
startInfoServer();
if (httpEnabled) {
setupHTTPServer();
httpServer.start();
httpServer.join();
} else {
setupServer();
tserver.serve();
}
return 0;
}
代码示例来源:origin: qunarcorp/qmq
public static void main(String[] args) throws Exception {
final ServletContextHandler context = new ServletContextHandler(ServletContextHandler.SESSIONS);
context.setContextPath("/");
context.setResourceBase(System.getProperty("java.io.tmpdir"));
DynamicConfig config = DynamicConfigLoader.load("gateway.properties");
context.addServlet(PullServlet.class, "/pull/*");
context.addServlet(SendServlet.class, "/send/*");
int port = config.getInt("gateway.port", 8080);
final Server server = new Server(port);
server.setHandler(context);
server.start();
server.join();
}
}
代码示例来源:origin: zendesk/maxwell
public void startServer() throws Exception {
if (this.bindAddress != null) {
this.server = new Server(new InetSocketAddress(InetAddress.getByName(this.bindAddress), port));
}
else {
this.server = new Server(this.port);
}
ServletContextHandler handler = new ServletContextHandler(this.server, pathPrefix);
if (metricsRegistries != null) {
// TODO: there is a way to wire these up automagically via the AdminServlet, but it escapes me right now
handler.addServlet(new ServletHolder(new MetricsServlet(metricsRegistries.metricRegistry)), "/metrics");
handler.addServlet(new ServletHolder(new io.prometheus.client.exporter.MetricsServlet()), "/prometheus");
handler.addServlet(new ServletHolder(new HealthCheckServlet(metricsRegistries.healthCheckRegistry)), "/healthcheck");
handler.addServlet(new ServletHolder(new PingServlet()), "/ping");
}
if (diagnosticContext != null) {
handler.addServlet(new ServletHolder(new DiagnosticHealthCheck(diagnosticContext)), "/diagnostic");
}
this.server.start();
this.server.join();
}
代码示例来源:origin: stackoverflow.com
ServletContextHandler sch = new ServletContextHandler();
sch.setContextPath("/xxx");
TheResource resource = new TheResource();
ResourceConfig rc = new ResourceConfig();
rc.register(resource);
ServletContainer sc = new ServletContainer(rc);
ServletHolder holder = new ServletHolder(sc);
sch.addServlet(holder, "/*");
Server server = new Server(port);
server.setHandler(sch);
server.start();
server.join();
代码示例来源:origin: loklak/loklak_server
LoklakServer.server.start();
LoklakServer.caretaker = new Caretaker();
LoklakServer.caretaker.start();
LoklakServer.server.join();
DAO.log("server terminated");
代码示例来源:origin: konsoletyper/teavm
public void start() {
server = new Server();
ServerConnector connector = new ServerConnector(server);
connector.setPort(port);
server.addConnector(connector);
ServletContextHandler context = new ServletContextHandler(ServletContextHandler.SESSIONS);
context.setContextPath("/");
server.setHandler(context);
try {
ServerContainer wscontainer = WebSocketServerContainerInitializer.configureContext(context);
wscontainer.addEndpoint(new RPDEndpointConfig());
server.start();
server.join();
} catch (Exception e) {
throw new RuntimeException(e);
}
}
代码示例来源:origin: stackoverflow.com
Server server = new Server(8080);
WebSocketHandler wsHandler = new WebSocketHandler()
{
@Override
public void configure(WebSocketServletFactory factory)
{
factory.register(MyEchoSocket.class);
}
};
ContextHandler context = new ContextHandler();
context.setContextPath("/echo");
context.setHandler(wsHandler);
server.addHandler(context);
server.start();
server.join();
代码示例来源:origin: allure-framework/allure1
@Override
protected void runUnsafe() throws Exception {
Path reportDirectory = getReportDirectoryPath();
if (Files.notExists(reportDirectory)) {
throw new AllureCommandException(String.format(
"Can't open report: directory <%s> doesn't exist.", reportDirectory
));
}
LOGGER.info("Starting web server for report directory <{}>", reportDirectory);
Server server = setUpServer();
server.start();
openBrowser(server.getURI());
LOGGER.info("Server started at <{}>. Press <Ctrl+C> to exit ...", server.getURI());
server.join();
}
内容来源于网络,如有侵权,请联系作者删除!