`

JAVA实现HTTP服务器端

    博客分类：
  • Java
 
阅读更多

用java socket实现了一个简单的http服务器， 可以处理GET, POST,以及带一个附件的multipart类型的POST。虽然中途遇到了很多问题， 不过通过在论坛和几个高手交流了一下，问题都解决了。如果你觉得程序有些地方看不明白,可以参看这个帖子:http://topic.csdn.net/u/20090625/22/59a5bfc8-a6b6-445d-9829-ea6d462a4fe6.html .

虽然解析http头不是很规范，本来应该用原始的字节流， 我采用了一个折衷的方案，用DataInputStream.

本代码的实用性==0，但是可以帮助很好地了解http协议，然后其他的应用层协议大都如此。

如果你从来都没有了解过http协议，建议先搜索阅读一下，或者你还可以用下面的代码来简单的看一看到底浏览器和服务器之间都相互发送了什么数据。

MyHttpClient.java: 模拟浏览器的行为， 向服务器发送get/post请求，然后打印出服务器返回的消息。这样就可以查看当一个请求到来之后， 服务器到底都给浏览器发送了哪些消息。

package socket;

import java.io.*;
import java.net.*;

public class MyHttpClient {
	public static void main(String[] args) throws Exception{
		InetAddress inet = InetAddress.getByName("www.baidu.com");
		System.out.println(inet.getHostAddress());
		Socket socket = new Socket(inet.getHostAddress(),80);
		InputStream in = socket.getInputStream();
		OutputStream out = socket.getOutputStream();
		BufferedReader reader = new BufferedReader(new InputStreamReader(in));
		PrintWriter writer = new PrintWriter(out);
		writer.println("GET /home.html HTTP/1.1");//home.html是关于百度的页面
		writer.println("Accept: image/gif, image/x-xbitmap, image/jpeg, image/pjpeg, application/x-shockwave-flash, application/xaml+xml, application/vnd.ms-xpsdocument, application/x-ms-xbap, application/x-ms-application, application/msword, application/vnd.ms-excel, application/vnd.ms-powerpoint, */*");
		writer.println("Accept-Language: en-us,zh-cn;q=0.5");
		writer.println("Accept-Encoding: gzip, deflate");
		writer.println("Host: www.baidu.com");
		writer.println("User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; .NET CLR 1.1.4322; .NET CLR 2.0.50727; .NET CLR 3.0.04506.30; .NET CLR 3.0.4506.2152; .NET CLR 3.5.30729)");
		writer.println("Connection: Keep-Alive");
		writer.println();
		writer.flush();
		String line = reader.readLine();
		while(line!=null){
			System.out.println(line);
			line = reader.readLine();
		}
		reader.close();
		writer.close();
	}
}

 MyServer.java: 模拟server端接收浏览器的请求，然后把整个请求的报文打印出来。程序运行之后直接用浏览器测试。

package socket;

import java.io.*;
import java.net.*;

public class MyServer {
	public static void main(String[] args) throws IOException{
		ServerSocket svrSocket = new ServerSocket(8080);
		while(true){
			Socket socket = svrSocket.accept();
			//足够大的一个缓冲区
			byte[] buf = new byte[1024*1024];
			InputStream in = socket.getInputStream();
			int byteRead = in.read(buf, 0, 1024*1024);
			String dataString = new String(buf, 0, byteRead);
			System.out.println(dataString);
			in.close();
			socket.close();
		}
	}
}

 主程序MyHttpServer.

package socket;

import java.io.*;
import java.net.*;
/**
 * MyHttpServer 实现一个简单的HTTP服务器端，可以获取用户提交的内容
 * 并给用户一个response
 * 因为时间的关系，对http头的处理显得不规范
 * 对于上传附件，暂时只能解析只上传一个附件而且附件位置在第一个的情况
 * 转载请注明来自http://blog.csdn.net/sunxing007
 * **/
public class MyHttpServer {
    //服务器根目录，post.html, upload.html都放在该位置
    public static String WEB_ROOT = "c:/root";
    //端口
    private int port;
    //用户请求的文件的url
    private String requestPath;
    //mltipart/form-data方式提交post的分隔符, 
    private String boundary = null;
    //post提交请求的正文的长度
    private int contentLength = 0;

    public MyHttpServer(String root, int port) {
        WEB_ROOT = root;
        this.port = port;
        requestPath = null;
    }
    //处理GET请求
    private void doGet(DataInputStream reader, OutputStream out) throws Exception {
        if (new File(WEB_ROOT + this.requestPath).exists()) {
            //从服务器根目录下找到用户请求的文件并发送回浏览器
            InputStream fileIn = new FileInputStream(WEB_ROOT + this.requestPath);
            byte[] buf = new byte[fileIn.available()];
            fileIn.read(buf);
            out.write(buf);
            out.close();
            fileIn.close();
            reader.close();
            System.out.println("request complete.");
        }
    }
    //处理post请求
    private void doPost(DataInputStream reader, OutputStream out) throws Exception {
        String line = reader.readLine();
        while (line != null) {
            System.out.println(line);
            line = reader.readLine();
            if ("".equals(line)) {
                break;
            } else if (line.indexOf("Content-Length") != -1) {
                this.contentLength = Integer.parseInt(line.substring(line.indexOf("Content-Length") + 16));
            }
            //表明要上传附件， 跳转到doMultiPart方法。
            else if(line.indexOf("multipart/form-data")!= -1){
                //得multiltipart的分隔符
                this.boundary = line.substring(line.indexOf("boundary") + 9);
                this.doMultiPart(reader, out);
                return;
            }
        }
        //继续读取普通post（没有附件）提交的数据
        System.out.println("begin reading posted data......");
        String dataLine = null;
        //用户发送的post数据正文
        byte[] buf = {};
        int size = 0;
        if (this.contentLength != 0) {
            buf = new byte[this.contentLength];
            while(size<this.contentLength){
                int c = reader.read();
                buf[size++] = (byte)c;
                
            }
            System.out.println("The data user posted: " + new String(buf, 0, size));
        }
        //发送回浏览器的内容
        String response = "";
        response += "HTTP/1.1 200 OK/n";
        response += "Server: Sunpache 1.0/n";
        response += "Content-Type: text/html/n";
        response += "Last-Modified: Mon, 11 Jan 1998 13:23:42 GMT/n";
        response += "Accept-ranges: bytes";
        response += "/n";
        String body = "<html><head><title>test server</title></head><body><p>post ok:</p>" + new String(buf, 0, size) + "</body></html>";
        System.out.println(body);
        out.write(response.getBytes());
        out.write(body.getBytes());
        out.flush();
        reader.close();
        out.close();
        System.out.println("request complete.");
    }
    //处理附件
    private void doMultiPart(DataInputStream reader, OutputStream out) throws Exception {
        System.out.println("doMultiPart ......");
        String line = reader.readLine();
        while (line != null) {
            System.out.println(line);
            line = reader.readLine();
            if ("".equals(line)) {
                break;
            } else if (line.indexOf("Content-Length") != -1) {
                this.contentLength = Integer.parseInt(line.substring(line.indexOf("Content-Length") + 16));
                System.out.println("contentLength: " + this.contentLength);
            } else if (line.indexOf("boundary") != -1) {
                //获取multipart分隔符
                this.boundary = line.substring(line.indexOf("boundary") + 9);
            }
        }
        System.out.println("begin get data......");
        /*下面的注释是一个浏览器发送带附件的请求的全文，所有中文都是说明性的文字*****
        <HTTP头部内容略>
        ............
        Cache-Control: no-cache
        <这里有一个空行，表明接下来的内容都是要提交的正文>
        -----------------------------7d925134501f6<这是multipart分隔符>
        Content-Disposition: form-data; name="myfile"; filename="mywork.doc"
        Content-Type: text/plain
        
        <附件正文>........................................
        .................................................
        
        -----------------------------7d925134501f6<这是multipart分隔符>
        Content-Disposition: form-data; name="myname"<其他字段或附件>
        <这里有一个空行>
        <其他字段或附件的内容>
        -----------------------------7d925134501f6--<这是multipart分隔符，最后一个分隔符多两个->
        ****************************************************************/
        /**
         * 上面的注释是一个带附件的multipart类型的POST的全文模型，
         * 要把附件去出来，就是要找到附件正文的起始位置和结束位置
         * **/
        if (this.contentLength != 0) {
            //把所有的提交的正文，包括附件和其他字段都先读到buf.
            byte[] buf = new byte[this.contentLength];
            int totalRead = 0;
            int size = 0;
            while (totalRead < this.contentLength) {
                size = reader.read(buf, totalRead, this.contentLength - totalRead);
                totalRead += size;
            }
            //用buf构造一个字符串，可以用字符串方便的计算出附件所在的位置
            String dataString = new String(buf, 0, totalRead);
            System.out.println("the data user posted:/n" + dataString);
            int pos = dataString.indexOf(boundary);
            //以下略过4行就是第一个附件的位置
            pos = dataString.indexOf("/n", pos) + 1;
            pos = dataString.indexOf("/n", pos) + 1;
            pos = dataString.indexOf("/n", pos) + 1;
            pos = dataString.indexOf("/n", pos) + 1;
            //附件开始位置
            int start = dataString.substring(0, pos).getBytes().length;
            pos = dataString.indexOf(boundary, pos) - 4;
            //附件结束位置
            int end = dataString.substring(0, pos).getBytes().length;
            //以下找出filename
            int fileNameBegin = dataString.indexOf("filename") + 10;
            int fileNameEnd = dataString.indexOf("/n", fileNameBegin);
            String fileName = dataString.substring(fileNameBegin, fileNameEnd);
            /**
             * 有时候上传的文件显示完整的文件名路径,比如c:/my file/somedir/project.doc
             * 但有时候只显示文件的名字，比如myphoto.jpg.
             * 所以需要做一个判断。
            */
            if(fileName.lastIndexOf("//")!=-1){
                fileName = fileName.substring(fileName.lastIndexOf("//") + 1);
            }
            fileName = fileName.substring(0, fileName.length()-2);
            OutputStream fileOut = new FileOutputStream("c://" + fileName);
            fileOut.write(buf, start, end-start);
            fileOut.close();
            fileOut.close();
        }
        String response = "";
        response += "HTTP/1.1 200 OK/n";
        response += "Server: Sunpache 1.0/n";
        response += "Content-Type: text/html/n";
        response += "Last-Modified: Mon, 11 Jan 1998 13:23:42 GMT/n";
        response += "Accept-ranges: bytes";
        response += "/n";
        out.write("<html><head><title>test server</title></head><body><p>Post is ok</p></body></html>".getBytes());
        out.flush();
        reader.close();
        System.out.println("request complete.");
    }

    public void service() throws Exception {
        ServerSocket serverSocket = new ServerSocket(this.port);
        System.out.println("server is ok.");
        //开启serverSocket等待用户请求到来，然后根据请求的类别作处理
        //在这里我只针对GET和POST作了处理
        //其中POST具有解析单个附件的能力
        while (true) {
            Socket socket = serverSocket.accept();
            System.out.println("new request coming.");
            DataInputStream reader = new DataInputStream((socket.getInputStream()));
            String line = reader.readLine();
            String method = line.substring(0, 4).trim();
            OutputStream out = socket.getOutputStream();
            this.requestPath = line.split(" ")[1];
            System.out.println(method);
            if ("GET".equalsIgnoreCase(method)) {
                System.out.println("do get......");
                this.doGet(reader, out);
            } else if ("POST".equalsIgnoreCase(method)) {
                System.out.println("do post......");
                this.doPost(reader, out);
            }
            socket.close();
            System.out.println("socket closed.");
        }
    }
    public static void main(String args[]) throws Exception {
        MyHttpServer server = new MyHttpServer("c:/root", 8080);
        server.service();
    }
}

 

测试文件post.html, upload.html都放在上面程序定义的WEB_ROOT下面。

post.html:处理普通的post请求

<html> 
<head> 
<title>test my server</title> 
<meta http-equiv="Content-Type" content="text/html; charset=utf-8"> 
</head> 
<body> 
<p>upload</p> 
来自http://blog.csdn.net/sunxing007<br>
<form name="UploadForm" method="post" action="http://localhost:8080/">
<input type="text" name="myname" /><br>
<select name="myage">
  <option value="18">18</option>
  <option value="20">20</option>
  <option value="22">22</option>
</select><br>
<input type="submit"value="Sutmit">
</form>
</body> 
</html>

 upload.html:测试带附件的post请求

<head>
<title>my page</title>
<style>
  table{
    border-collapse: collapse;
  }
</style>
</head>
<body>
来自http://blog.csdn.net/sunxing007<br>
    <form action='http://localhost:8080/' method='post' enctype='multipart/form-data'>
    file: <input type='file' name='myfile' /><br>
    <input type='submit' />
    </form>
</body>
</html>

 一切准备妥当,并且MyHttpServer运行之后, 在浏览器输入http://localhost:8080/post.html和http://localhost:8080/upload.html即可进行测试.

分享到：
| 警告：不能读取 AppletViewer 的属性文件：
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    用java实现的http服务器端例程

    用java实现的http服务器端例程

    用java实现的http服务器端例程java

    总的来说，通过Java实现HTTP服务器是一个很好的学习和实践网络编程技能的机会。这涉及到理解TCP/IP通信、HTTP协议以及Java的I/O操作。通过分析提供的代码和相关资源，开发者可以深入了解网络服务的构建，并为更复杂...

    Java实现的Http服务器

    首先，我们关注的是Java语言在实现HTTP服务器中的应用。Java SE（标准版）提供了丰富的API，使得开发人员可以便捷地创建网络应用程序。在这个项目中，`java.net.ServerSocket` 和 `java.net.Socket` 类被用于监听和...

    用java实现的http服务器端例程.rar

    用java实现的http服务器端例程.rar 用java实现的http服务器端例程.rar

    计算机网络实验一 Windows环境下用java实现web服务器

    总的来说，"计算机网络实验一：Windows环境下用Java实现web服务器"是一次综合性的学习体验，涵盖了HTTP协议、网络编程、Java编程以及服务器与前端的交互等多个重要知识点。通过实践，学生将能够更全面地理解Web服务...

    Java实现环信服务器端接口

    环信（Easemob）是一款流行的即时...综上所述，Java实现环信服务器端接口涉及的技术面较广，需要对HTTP通信、JSON处理、异常处理等有深入理解，同时要遵循环信的API文档和最佳实践，以确保功能的完整性和系统的稳定性。

    java代码实现coap 协议请求 服务器端+客户端

    我们将关注服务器端和客户端的Java实现，并提及所需的jar包资源。 首先，CoAP协议是基于UDP的，它简化了消息结构，以适应低功耗、带宽有限的设备。它的主要特点包括资源发现、请求/响应模式、可靠传输选项以及DTLS...

    java实现的http服务器

    Java实现的HTTP服务器是一个基础的网络编程项目，它利用了Java的Socket编程和HTTP协议的知识。这个简单的HTTP服务器能够处理浏览器发起的GET请求，将指定的静态资源（如HTML、CSS、JavaScript文件）发送回客户端，...

    java的客户端和服务器端通信代码，适合初学者

    要实现Java客户端和服务器端的通信，我们需要使用Socket编程。Socket是Java提供的API，允许两个网络应用程序通过TCP/IP协议进行通信。TCP（传输控制协议）是一种面向连接的、可靠的通信协议，确保了数据的正确传输。...

    java视频服务器和客户端

    Java视频服务器和客户端是计算机网络通信中的一个重要领域，主要涉及如何通过Java技术实现在服务器端与客户端之间进行视频数据的传输、存储和播放。在这个系统中，服务器端通常负责视频数据的管理和分发，而客户端则...

    java实现利用HTTP基于servlet上传文件至服务器.pdf

    Servlet 是 Java 语言中的一种服务器端组件，用于处理客户端的请求。Servlet 可以与 HTTP 协议结合，处理 HTTP 请求和响应。在文件上传中，Servlet 可以处理客户端上传的文件，并将其保存到服务器端。 文件上传实现...

    用Java实现Web服务器

    HTTP（HyperText Transfer Protocol）协议是互联网上应用最为广泛的一种网络协议，它定义了客户端（通常是Web浏览器）与服务器端（Web服务器）之间的通信规则。HTTP协议是基于TCP/IP协议之上的应用层协议，其主要...

    java BBS论坛服务器端

    Java BBS论坛服务器端开发是构建在线社区的重要一环，它负责处理用户的登录、发帖、回帖等操作，以及管理论坛的数据存储和检索。在这个项目中，我们有四个主要的文件：BBSServer.java（服务器端代码）、BBSClient....

    JAVA实现简单的http静态网页服务器

    要实现HTTP服务器，首先需要熟悉Java的基本语法、类库和异常处理。 2. **Socket编程**：在Java中，实现网络通信的基础是Socket编程。`java.net.Socket` 和 `java.net.ServerSocket` 类用于创建客户端和服务器之间的...

    iphone 推送通知 服务器端java 实现

    在iOS应用开发中，为了实现在用户...以上就是关于“iPhone推送通知服务器端Java实现”的详细说明，希望对你理解并实际操作APNs推送有所帮助。在实际开发中，记得遵循苹果的开发者指南，确保推送通知的合规性和有效性。

    JAVA服务器]用Java实现Web

    这个过程基于客户机/服务器计算模型，即Web浏览器作为客户端，Web服务器作为服务器端。客户端通过HTTP协议向服务器发送请求，服务器解析请求，处理业务逻辑，然后将响应数据回传给客户端。整个通信过程包括以下四个...

    HTTP1.1 服务器端及servlet引擎 java实现

    在Java中，实现HTTP服务器通常可以借助于Java的Socket编程。服务器启动后，创建一个ServerSocket监听指定端口，等待客户端的连接。当接收到请求时，通过Socket读取请求数据，解析出HTTP报文的各个部分，如方法（GET...

    Java实现Web服务器和客户端

    你可以通过阅读和运行这些代码来加深对Java Socket编程和HTTP协议的理解，同时也可以学习如何构建支持并发的HTTP服务器。通过实践，你可以更好地掌握这些核心技术，并为未来更复杂的网络应用开发打下坚实的基础。

Magicbox
Global site tag (gtag.js) - Google Analytics