您的位置:首页 > 运维架构 > Linux

Linux crontab定时执行任务 命令格式与详细例子

2015-02-06 16:00 836 查看
Server
--------------------------------------------------------------------------------

1) Dependencies: Jersey
import com.sun.jersey.api.container.httpserver.HttpServerFactory;
import com.sun.net.httpserver.HttpServer;

public class SimlpeServer {

public static void main(String[] args) throws IOException {
HttpServer server = HttpServerFactory.create("http://localhost:80/test");
server.start();

System.out.println("Server running");
System.out.println("Visit: http://localhost:8088/RestHelloWorld"); System.out.println("Hit return to stop...");
System.in.read();
System.out.println("Stopping server");
server.stop(0);
System.out.println("Server stopped");
}

}

2) Dependencies: Jetty

import org.mortbay.jetty.Connector;
import org.mortbay.jetty.Handler;
import org.mortbay.jetty.handler.DefaultHandler;
import org.mortbay.jetty.handler.HandlerCollection;
import org.mortbay.jetty.nio.SelectChannelConnector;
import org.mortbay.jetty.webapp.WebAppContext;

public class Server {
private int port = 8088;
private String webDir = "web";
private String contextPath = "/RestHelloWorld";

protected Server() throws Exception {
System.out.println("Starting Server");

org.mortbay.jetty.Server server = new org.mortbay.jetty.Server();
//1) Set Connector
SelectChannelConnector connector = new SelectChannelConnector();
connector.setPort(port);
server.setConnectors(new Connector[] {connector});

//2) Set Context Path
WebAppContext webappcontext = new WebAppContext();
webappcontext.setContextPath(contextPath);

//3) Set War
webappcontext.setWar(webDir);

//4) Set handler
HandlerCollection handlers = new HandlerCollection();
handlers.setHandlers(new Handler[] {webappcontext, new DefaultHandler()});
server.setHandler(handlers);

//5) Start
server.start();
System.out.println("Server ready...");
server.join();
}

public static void main(String args[]) throws Exception {
new Server();
}
}

3) Dependencies: CXF
import org.apache.cxf.jaxrs.JAXRSServerFactoryBean;
import org.apache.cxf.jaxrs.lifecycle.SingletonResourceProvider;

public class Server {

protected Server() throws Exception {
JAXRSServerFactoryBean sf = new JAXRSServerFactoryBean();
sf.setResourceClasses(CustomerService.class);
sf.setResourceProvider(CustomerService.class, new SingletonResourceProvider(new CustomerService()));
sf.setAddress("http://localhost:9000/");

sf.create();
}

public static void main(String args[]) throws Exception {
new Server();
System.out.println("Server ready...");

Thread.sleep(1000 * 60 * 1); //1 minute
System.out.println("Server exiting");
System.exit(0);
}
}


4) Sun/HTTP Server
import com.sun.net.httpserver.Headers;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import com.sun.net.httpserver.HttpServer;

public class HttpServerDemo {
public static void main(String[] args) throws IOException {
InetSocketAddress addr = new InetSocketAddress(8080);
HttpServer server = HttpServer.create(addr, 0);

server.createContext("/", new MyHandler());
server.setExecutor(Executors.newCachedThreadPool());
server.start();
System.out.println("Server is listening on port 8080");
}
}

class MyHandler implements HttpHandler {
public void handle(HttpExchange exchange) throws IOException {
String requestMethod = exchange.getRequestMethod();
if (requestMethod.equalsIgnoreCase("GET")) {
Headers responseHeaders = exchange.getResponseHeaders();
responseHeaders.set("Content-Type", "text/plain");
exchange.sendResponseHeaders(200, 0);

OutputStream responseBody = exchange.getResponseBody();
Headers requestHeaders = exchange.getRequestHeaders();
Set<String> keySet = requestHeaders.keySet();
Iterator<String> iter = keySet.iterator();
while (iter.hasNext()) {
String key = iter.next();
List<String> values = requestHeaders.get(key);
String s = key + " = " + values.toString() + "\n";
responseBody.write(s.getBytes());
}
responseBody.close();
}
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: