java1.6的httpServer。可直接获取和处理http请求

介绍摘自网络:

JDK6提供了一个简单的Http Server API,据此我们可以构建自己的嵌入式Http Server,它支持Http和Https协议,提供了HTTP1.1的部分实现，没有被实现的那部分可以通过扩展已有的Http Server API来实现,程序员必须自己实现HttpHandler接口,HttpServer会调用HttpHandler实现类的回调方法来处理客户端请求,在这里,我们把一个Http请求和它的响应称为一个交换,包装成HttpExchange类,HttpServer负责将HttpExchange传给HttpHandler实现类的回调方法

我想开发一个j2se的小程序，它能接受网页传来的参数，并对传来参数做些处理。我希望这个小程序即可能接受网页传过来的参数，也能接受OutputStream流传来参数，JDK6新特性能够实现。

一、提供http服务的类

Java代码  

1. package com.tdt.server.httpserver;
2. import java.io.BufferedReader;
3. import java.io.IOException;
4. import java.io.InputStream;
5. import java.io.InputStreamReader;
6. import java.io.OutputStream;
7. import java.net.InetSocketAddress;
8. import com.sun.net.httpserver.HttpExchange;
9. import com.sun.net.httpserver.HttpHandler;
10. import com.sun.net.httpserver.HttpServer;
11. import com.sun.net.httpserver.spi.HttpServerProvider;
12. /**
13. * @project SimpleHttpServer
14. * @author sunnylocus
15. * @vresion 1.0 2009-9-2
16. * @description  自定义的http服务器
17. */
18. public class MyHttpServer {
19. //启动服务，监听来自客户端的请求
20. public static void httpserverService() throws IOException {
21. HttpServerProvider provider = HttpServerProvider.provider();
22. HttpServer httpserver =provider.createHttpServer(new InetSocketAddress(6666), 100);//监听端口6666,能同时接 受100个请求
23. httpserver.createContext("/myApp", new MyHttpHandler());
24. httpserver.setExecutor(null);
25. httpserver.start();
26. System.out.println("server started");
27. }
28. //Http请求处理类
29. static class MyHttpHandler implements HttpHandler {
30. public void handle(HttpExchange httpExchange) throws IOException {
31. String responseMsg = "ok";   //响应信息
32. InputStream in = httpExchange.getRequestBody(); //获得输入流
33. BufferedReader reader = new BufferedReader(new InputStreamReader(in));
34. String temp = null;
35. while((temp = reader.readLine()) != null) {
36. System.out.println("client request:"+temp);
37. }
38. httpExchange.sendResponseHeaders(200, responseMsg.length()); //设置响应头属性及响应信息的长度
39. OutputStream out = httpExchange.getResponseBody();  //获得输出流
40. out.write(responseMsg.getBytes());
41. out.flush();
42. httpExchange.close();
43. }
44. }
45. public static void main(String[] args) throws IOException {
46. httpserverService();
47. }
48. }

二、测试类

Java代码  

1. package com.tdt.server.test;
2. import java.io.BufferedReader;
3. import java.io.IOException;
4. import java.io.InputStream;
5. import java.io.InputStreamReader;
6. import java.io.OutputStream;
7. import java.net.HttpURLConnection;
8. import java.net.URL;
9. import java.util.concurrent.ExecutorService;
10. import java.util.concurrent.Executors;
11. /**
12. * @project SimpleHttpServer
13. * @author sunnylocus
14. * @vresion 1.0 2009-9-2
15. * @description 测试类
16. */
17. public class Test {
18. public static void main(String[] args) {
19. ExecutorService exec = Executors.newCachedThreadPool();
20. // 测试并发对MyHttpServer的影响
21. for (int i = 0; i < 20; i++) {
22. Runnable run = new Runnable() {
23. public void run() {
24. try {
25. startWork();
26. } catch (IOException e) {
27. e.printStackTrace();
28. }
29. }
30. };
31. exec.execute(run);
32. }
33. exec.shutdown();// 关闭线程池
34. }
35. public static void startWork() throws IOException {
36. URL url = new URL("http://127.0.0.1:6666/myApp");
37. HttpURLConnection urlConn = (HttpURLConnection) url.openConnection();
38. urlConn.setDoOutput(true);
39. urlConn.setDoInput(true);
40. urlConn.setRequestMethod("POST");
41. // 测试内容包
42. String teststr = "this is a test message";
43. OutputStream out = urlConn.getOutputStream();
44. out.write(teststr.getBytes());
45. out.flush();
46. while (urlConn.getContentLength() != -1) {
47. if (urlConn.getResponseCode() == 200) {
48. InputStream in = urlConn.getInputStream();
49. BufferedReader reader = new BufferedReader(new InputStreamReader(in));
50. String temp = "";
51. while ((temp = reader.readLine()) != null) {
52. System.err.println("server response:" + temp);// 打印收到的信息
53. }
54. reader.close();
55. in.close();
56. urlConn.disconnect();
57. }
58. }
59. }
60. }

注意：经过我测试发现httpExchange.sendResponseHeaders(200, responseMsg.length())有bug,如果responseMsg里面包含中文的话，客户端不会收到任何信息，因为一个汉字用二个字节表示。

应修改为：

httpExchange.sendResponseHeaders(HttpURLConnection.HTTP_OK, responseMsg.getBytes().length);