RMI不依赖其他http服务实现代码动态下载

import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.OutputStream; import java.net.InetSocketAddress; import java.util.concurrent.Executors; import com.sun.net.httpserver.HttpExchange; import com.sun.net.httpserver.HttpHandler; import com.sun.net.httpserver.HttpServer; import com.sun.net.httpserver.spi.HttpServerProvider; public class RmiHttpServer { private int port; private HttpServer httpServer; private boolean isRunning = false; private String folder = ""; private String context = "/"; public RmiHttpServer() { this.port = 80; } public RmiHttpServer(int port) { this.port = port; } public RmiHttpServer(String context, String folder, int port) { this.folder = folder; this.context = context; this.port = port; } public synchronized void service() { if (isRunning) { System.out.println("HTTP服务已启动..."); } else { HttpServerProvider httpServerProvider = HttpServerProvider .provider(); InetSocketAddress addr = new InetSocketAddress(port); try { httpServer = httpServerProvider.createHttpServer(addr, 1); httpServer.createContext(context, new RmiHttpHandler(folder)); httpServer.setExecutor(Executors.newCachedThreadPool()); httpServer.start(); System.out.println("HTTP服务已启动..."); isRunning = true; } catch (IOException e) { e.printStackTrace(); System.out.println("HTTP服务启动失败"); } } } public synchronized void close() { isRunning = false; httpServer.stop(0); System.out.println("HTTP服务关闭"); } } class RmiHttpHandler implements HttpHandler { public static int BUFFER_LENGTH = 1024; private String folder; public RmiHttpHandler(String folder) { this.folder = folder; } public void handle(HttpExchange httpExchange) throws IOException { String response; OutputStream out = httpExchange.getResponseBody(); String path; if (folder.equals("")) path = httpExchange.getRequestURI().getPath().substring(1); else path = folder + httpExchange.getRequestURI().getPath(); //System.out.println(path); File file = new File(path); if (file.exists() && file.canRead()) { httpExchange.sendResponseHeaders(200, file.length()); FileInputStream in = new FileInputStream(file); byte[] buffer = new byte[BUFFER_LENGTH]; int count = 0; for (int i = 0; count != -1; i++) { count = in.read(buffer); if (count != -1) out.write(buffer, 0, count); } in.close(); } else { response = "error"; httpExchange.sendResponseHeaders(404, response.length()); out.write(response.getBytes()); } out.close(); } }