通過線程池實(shí)現(xiàn)一個(gè)簡單的Web服務(wù)器

測試步驟:

  • 執(zhí)行HttpServerMain.java
  • 瀏覽器訪問http://127.0.0.1:8181/test.html

SimpleHttpServer.java

該類定義了對端口的監(jiān)聽描融,對每一個(gè)請求的具體處理拦盹,和開啟服務(wù)器宇挫。

package com.httpServerTest;

import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.Closeable;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

import com.threadpooltest.DefaultThreadPool;
import com.threadpooltest.ThreadPool;

public class SimpleHttpServer {
    //處理HttpRequest的線程池
    static ThreadPool<HttpRequestHandler> threadPool = new DefaultThreadPool<HttpRequestHandler>(1);
    static String basePath;
    static ServerSocket serverSocket;
    //服務(wù)監(jiān)聽端口
    static int port = 8181;
    
    public static void setPort(int port){
        if(port>0){
            SimpleHttpServer.port = port;
        }
    }
    public static void setBasePath(String basePath){
        if(basePath != null && new File(basePath).exists() && new File(basePath).isDirectory()){
            SimpleHttpServer.basePath = basePath;
        }
    }
    //啟動(dòng)SimpleHttpServer
    public static void start() throws Exception{
        serverSocket = new ServerSocket(port);
        Socket socket = null;
        while((socket=serverSocket.accept()) != null){
            //接收一個(gè)客戶端Socket件豌,生成一個(gè)HttpRequestHandler袱蚓,放入線程池中執(zhí)行
            threadPool.execute(new HttpRequestHandler(socket));
        }
        serverSocket.close();
    }
    
    static class HttpRequestHandler implements Runnable{
        private Socket socket;
        public HttpRequestHandler(Socket socket) {
            this.socket = socket;
        }
        @Override
        public void run() {
            String line = null;
            BufferedReader br = null;
            BufferedReader reader = null;//讀socket的輸入
            PrintWriter out = null;//讀socket的輸出
            InputStream in = null;//讀圖片文件
            try{
                reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                String header = reader.readLine();
                System.out.println("收到header=" + header);
                //由相對路徑計(jì)算出絕對路徑
                String filePath = basePath + header.split(" ")[1];
                out = new PrintWriter(socket.getOutputStream());
                if(! new File(filePath).exists()){
                    out.flush();
                    return;
                }
                //如果有請求資源的后綴是.jpg或者.ico,則讀取資源并輸出
                if(filePath.endsWith(".jpg")){
                    in = new FileInputStream(filePath);
                    ByteArrayOutputStream baos = new ByteArrayOutputStream();
                    int i = 0;
                    while((i = in.read()) != -1){
                        baos.write(i);
                    }
                    byte[] array = baos.toByteArray();
                    out.println("HTTP/1.1 200 OK");
                    out.println("Server: Molly");
                    out.println("Content-Type:image/jpeg");
                    out.println("Content-Length:" + array.length);
                    out.println("");
                    socket.getOutputStream().write(array, 0, array.length);
                }else{
                    br = new BufferedReader(new InputStreamReader(new FileInputStream(filePath)));
                    out.println("HTTP/1.1 200 OK");
                    out.println("Server: Molly");
                    out.println("Content-Type:text/html;charset=UTF-8");
                    out.println("");
                    while((line = br.readLine()) != null){
                        out.println(line);
                    }
                }
                out.flush();
            }catch(Exception e){
                e.printStackTrace();
                out.println("HTTP/1.1 500");
                out.println("");
                out.flush();
            }finally{
                close(br, in, reader, out, socket);
            }
        }
        //關(guān)閉流或者socket
        private static void close(Closeable... closeables){
            if(closeables != null){
                for(Closeable closeable : closeables){
                    try {
                        if(closeable!=null){
                            closeable.close();
                        }
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }           
            }
        }
    }
}

HttpServerMain.java

package com.httpServerTest;

public class HttpServerMain {

    public static void main(String[] args) {
        SimpleHttpServer shs = new SimpleHttpServer();
        shs.setBasePath("D:/testDir"); //將根目錄定義到html所在的目錄
        try {
            shs.start();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

一個(gè)簡易的html頁面test.html

將該頁面和任意三個(gè)命名為1.jpg/2.jpg/3.jpg的圖片放到d:\testDir文件夾芥吟。

<html>
    <head>
        <title>測試頁面</title>
        <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
    </head>
    <body align="center">
        <h1>第一張圖片</h1>
        <img src="1.jpg" alt="" align="middle"/>
        <h1>第二張圖片</h1>
        <img src="2.jpg" alt="" align="middle"/>
        <h1>第三張圖片</h1>
        <img src="3.jpg" alt="" align="middle"/>
    </body>
</html>
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末蛹头,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子遮晚,更是在濱河造成了極大的恐慌性昭,老刑警劉巖,帶你破解...
    沈念sama閱讀 218,284評論 6 506
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件县遣,死亡現(xiàn)場離奇詭異糜颠,居然都是意外死亡,警方通過查閱死者的電腦和手機(jī)萧求,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,115評論 3 395
  • 文/潘曉璐 我一進(jìn)店門其兴,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人夸政,你說我怎么就攤上這事元旬。” “怎么了守问?”我有些...
    開封第一講書人閱讀 164,614評論 0 354
  • 文/不壞的土叔 我叫張陵匀归,是天一觀的道長。 經(jīng)常有香客問我酪碘,道長朋譬,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,671評論 1 293
  • 正文 為了忘掉前任兴垦,我火速辦了婚禮,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘探越。我一直安慰自己狡赐,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,699評論 6 392
  • 文/花漫 我一把揭開白布钦幔。 她就那樣靜靜地躺著枕屉,像睡著了一般。 火紅的嫁衣襯著肌膚如雪鲤氢。 梳的紋絲不亂的頭發(fā)上搀擂,一...
    開封第一講書人閱讀 51,562評論 1 305
  • 那天,我揣著相機(jī)與錄音卷玉,去河邊找鬼哨颂。 笑死,一個(gè)胖子當(dāng)著我的面吹牛相种,可吹牛的內(nèi)容都是我干的威恼。 我是一名探鬼主播,決...
    沈念sama閱讀 40,309評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼寝并,長吁一口氣:“原來是場噩夢啊……” “哼箫措!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起衬潦,我...
    開封第一講書人閱讀 39,223評論 0 276
  • 序言:老撾萬榮一對情侶失蹤斤蔓,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后镀岛,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體弦牡,經(jīng)...
    沈念sama閱讀 45,668評論 1 314
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,859評論 3 336
  • 正文 我和宋清朗相戀三年哎媚,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了喇伯。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,981評論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡拨与,死狀恐怖稻据,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情买喧,我是刑警寧澤捻悯,帶...
    沈念sama閱讀 35,705評論 5 347
  • 正文 年R本政府宣布,位于F島的核電站淤毛,受9級特大地震影響今缚,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜低淡,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,310評論 3 330
  • 文/蒙蒙 一姓言、第九天 我趴在偏房一處隱蔽的房頂上張望瞬项。 院中可真熱鬧,春花似錦何荚、人聲如沸囱淋。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,904評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽妥衣。三九已至,卻和暖如春戒傻,著一層夾襖步出監(jiān)牢的瞬間税手,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,023評論 1 270
  • 我被黑心中介騙來泰國打工需纳, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留芦倒,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 48,146評論 3 370
  • 正文 我出身青樓候齿,卻偏偏與公主長得像熙暴,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個(gè)殘疾皇子慌盯,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,933評論 2 355

推薦閱讀更多精彩內(nèi)容

  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理周霉,服務(wù)發(fā)現(xiàn),斷路器亚皂,智...
    卡卡羅2017閱讀 134,657評論 18 139
  • 1. Java基礎(chǔ)部分 基礎(chǔ)部分的順序:基本語法俱箱,類相關(guān)的語法,內(nèi)部類的語法灭必,繼承相關(guān)的語法狞谱,異常的語法,線程的語...
    子非魚_t_閱讀 31,632評論 18 399
  • 1 Redis介紹1.1 什么是NoSql為了解決高并發(fā)、高可擴(kuò)展播歼、高可用伶跷、大數(shù)據(jù)存儲(chǔ)問題而產(chǎn)生的數(shù)據(jù)庫解決方...
    克魯?shù)吕?/span>閱讀 5,291評論 0 36
  • 我盼望著一場火山的爆發(fā) 我等待著一場海嘯的顫栗 如果痛苦能讓人放棄思考 我愿重生十次 再重生十次 我將行走在黑暗里...
    小木土水閱讀 173評論 0 2
  • 我似乎嘗試了很多,想講好英文又沒有在一件事或者說一個(gè)方向堅(jiān)持下來過秘狞。對叭莫,我確實(shí)不想僅僅因?yàn)榭妓牧墸佳腥W(xué)習(xí)英文...
    追咪閱讀 603評論 19 1