java Socket 实现多线程静态文件服务器

关于静态文件服务器,我觉得博文共赏:Node.js静态文件服务器实战写的不错,简单易懂,思路清晰,不过使用Nodejs写的。我本人更熟悉Java,所以就用Java写了一个简易版本。
此版本主要实现以下功能:
1 . 对于请求的资源,若处理成功,返回200
2 . 对于请求的资源,若服务器上不存在,返回404
3 . 多线程处理浏览器发出的请求
4 . MIME类型支持
此项目的完整代码,可以到java-staticfile中download.
先贴项目工程图

Handler.java

对请求头进行处理

public class Handler implements Runnable {
    Functions functions = new Functions();
    MIME mime = new MIME();
    HashMap<String, String> type = mime.getMime();
    String contentType = null;
    public String encoding = "UTF-8";
    private Socket client;
    PrintWriter out = null;

    public Handler(Socket client) {
        this.client = client;
    }

    public void run() {
        if (client != null) {
            try {
                BufferedReader reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
                String header = reader.readLine();
                System.out.println("客户端发送的请求信息: >>>>>>>>>>>>>>>>>>>>>>>>>");
                System.out.println(header);// 读取所有浏览器发送过来的请求参数头部的所有信息
                String resource = (String) header.split(" ")[1];// 获得请求的资源的地址
                System.out.println("客户端发送的请求信息结束 <<<<<<<<<<<<<<<<<<<<<<<<<<");
                System.out.println("用户请求的资源resource是:" + resource);
                System.out.println();
                String suffix = null;
                if (resource.equals("/")) {
                    resource = "/index.html";
                    String[] names = resource.split("\\.");
                    suffix = names[names.length - 1];
                    contentType = type.get(suffix);
                } else {
                    String[] names = resource.split("\\.");
                    suffix = names[names.length - 1];
                    contentType = type.get(suffix);
                }
                String path = "/home/sunyan/code/public/" + resource;
                File file = new File(path);
                if (file.exists()) {
                    if (suffix.equals("png") || suffix.equals("jpg") || suffix.equals("jpeg")) {
                        functions.readImg(file, client, contentType);
                    } else {
                        functions.readFile(file, client, contentType);
                    }
                } else {
                    PrintWriter out = new PrintWriter(client.getOutputStream(), true);
                    out.println("HTTP/1.0 404 NOTFOUND");// 返回应答消息,并结束应答
                    out.println("Content-Type:text/html;charset=UTF-8");
                    out.println();// 根据 HTTP 协议, 空行将结束头信息
                    out.println("对不起,您寻找的资源在本服务器上不存在");
                    out.close();
                    functions.closeSocket(client);
                } // file.exists
            } catch (Exception e) {
                System.out.println("HTTP服务器错误:" + e.getLocalizedMessage());
            }
        }
    }
}

Functions.java

包括三个函数

  1. closeSocket():用于关闭socket
  2. readImg() readFile():用于读取静态文件
    若文件存在,则调用方法读取文件,正常状态下则发送读取到的文件给客户端,并返回200状态。
    若服务器读取文件出错,则返回500状态。
    若文件不存在,则返回404状态。
public class Functions {
    public void closeSocket(Socket socket) {
        try {
            socket.close();
            System.out.println(socket + "离开了HTTP服务器");
            System.out.println();
            System.out.println();
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

    public void readImg(File file, Socket client, String contentType) {
        PrintStream out = null;
        FileInputStream fis = null;
        try {
            out = new PrintStream(client.getOutputStream(), true);
            fis = new FileInputStream(file);
            byte data[] = new byte[fis.available()];
            out.println("HTTP/1.0 200 OK");// 返回应答消息,并结束应答
            out.println("Content-Type:" + contentType + ";charset=UTF-8");
            out.println("Content-Length: " + file.length());
            out.println();// 根据 HTTP 协议, 空行将结束头信息
            fis.read(data);
            out.write(data);
            fis.close();
        } catch (Exception e) {
            out.println("HTTP/1.0 500");// 返回应答消息,并结束应答
            out.println("");
            out.flush();
        } finally {
            out.close();
            closeSocket(client);
        }
    }

    public void readFile(File file, Socket client, String contentType) {
        PrintWriter out = null;
        try {
            out = new PrintWriter(client.getOutputStream(), true);
            FileReader in = new FileReader(file);
            BufferedReader breader = new BufferedReader(in);
            String s = null;
            StringBuffer sbu = new StringBuffer();
            out.println("HTTP/1.0 200 OK");// 返回应答消息,并结束应答
            out.println("Content-Type:" + contentType + ";charset=UTF-8");
            out.println();// 根据 HTTP 协议, 空行将结束头信息
            while ((s = breader.readLine()) != null) {
                out.println(s);
            }

        } catch (Exception e) {
            out.println("HTTP/1.0 500");// 返回应答消息,并结束应答
            out.println("");
            out.flush();
        } finally {
            out.close();
            closeSocket(client);
        }
    }

}

MIME.java

MIME类型支持
因为服务器同时要存放html, css, js, png, gif, jpg等等文件。并非每一种文件的MIME类型都是text/html的。因此需要支持MIME。
支持MIME的话,就需要一张映射表。

public class MIME {
    HashMap<String, String> mime = new HashMap<String, String>();

    public MIME() {
        mime.put("css", "text/css");
        mime.put("gif", "image/gif");
        mime.put("html", "text/html;charset=utf-8");
        mime.put("ico", "image/x-icon");
        mime.put("jpeg", "image/jpeg");
        mime.put("jpg", "image/jpeg");
        mime.put("js", "text/javascript");
        mime.put("json", "application/json");
        mime.put("pdf", "application/pdf");
        mime.put("png", "image/png");
        mime.put("svg", "image/svg+xml");
        mime.put("swf", "application/x-shockwave-flash");
        mime.put("tiff", "image/tiff");
        mime.put("txt", "text/plain;charset=utf-8");
        mime.put("wav", "audio/x-wav");
        mime.put("wma", "audio/x-ms-wma");
        mime.put("wmv", "video/x-ms-wmv");
        mime.put("xml", "text/xml");
    }

    public HashMap<String, String> getMime() {
        return mime;
    }
}

MultiThreadServer.java

监听客户端发出的请求,并创建线程对其进行处理

public class MultiThreadServer {
    public static void main(String[] args) throws Exception {
        int port = 20012;// 标准HTTP端口
        ServerSocket server = new ServerSocket(20012);
        Socket client = null;
        System.out.println("静态文件服务器正在运行,端口:" + port);
        System.out.println();
        while (true) {
            client = server.accept();
            System.out.println(client + "连接到HTTP服务器");
            Handler handler = new Handler(client);
            new Thread(handler).start();
        }
    }
}

测试过程

  1. 默认路径
    在地址栏输入http://localhost:20012/ 或者 http://localhost:20012/index.html
    后显示如下页面:

    服务器端运行日志如下:
  2. 在地址栏输入http://localhost:20012/2.png

    服务器端运行日志如下:
  3. 在地址栏输入http://localhost:20012/a.txt

    4 . 在地址栏输入http://localhost:20012/b.txt, 此文件在服务器上是不存在的
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 199,636评论 5 468
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 83,890评论 2 376
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 146,680评论 0 330
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 53,766评论 1 271
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 62,665评论 5 359
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,045评论 1 276
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,515评论 3 390
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,182评论 0 254
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,334评论 1 294
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,274评论 2 317
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,319评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,002评论 3 315
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,599评论 3 303
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,675评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,917评论 1 255
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,309评论 2 345
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 41,885评论 2 341

推荐阅读更多精彩内容