隨筆 - 40, 文章 - 0, 評論 - 20, 引用 - 0

          導(dǎo)航

          <2006年3月>
          2627281234
          567891011
          12131415161718
          19202122232425
          2627282930311
          2345678

          常用鏈接

          留言簿(2)

          隨筆檔案

          相冊

          收藏夾

          我的鏈接

          搜索

          •  

          最新評論

          閱讀排行榜

          評論排行榜

          用Java實現(xiàn)的Html web服務(wù)器

          ? 馬上就要開始轉(zhuǎn)到新的項目組,做一個全新的項目了,對于HTTP協(xié)議需要一定的了解,所以周末自己用Java寫了一個簡單的web服務(wù)器試試,只能實現(xiàn)簡單的html文件瀏覽。

          主要包括三個類:WebServer(監(jiān)聽瀏覽器請求),SocketThread(處理瀏覽器請求的進(jìn)程),StringUtil(實現(xiàn)一些公共的操作),下面是三個類的代碼.


          ----WebServer----
          import java.io.IOException;
          import java.net.ServerSocket;
          import java.net.Socket;

          public class WebServer {
          ?
          ?public static void main(String[] argv) throws IOException {
          ??ServerSocket servSocket = new ServerSocket(StringUtil.LISTENING_PORT);
          ??try {
          ???while (true) {
          ????Socket socket = servSocket.accept();
          ????new SocketThread(socket).start();
          ???}
          ??} finally {
          ???servSocket.close();
          ??}
          ?}
          }

          ---SocketThread------
          import java.io.BufferedReader;
          import java.io.BufferedWriter;
          import java.io.File;
          import java.io.InputStreamReader;
          import java.io.OutputStreamWriter;
          import java.io.PrintStream;
          import java.io.Writer;
          import java.net.Socket;

          public class SocketThread extends Thread {
          ?private Socket socket = null;

          ?public SocketThread(Socket s) {
          ??this.socket = s;
          ?}

          ?public void run() {
          ??try {
          ???if (socket == null) {
          ????throw new Exception("==>SOCKET為空<==");
          ???}
          ???BufferedReader reader = new BufferedReader(new InputStreamReader(
          ?????socket.getInputStream()));
          ???String fileName = "";
          ???while (true) {
          ????String str = reader.readLine();
          ????if (str == null || str.length() <= 0) {
          ?????break;
          ????}
          ????//System.out.println("===>"+str);
          ????if (StringUtil.isGetRequestInfo(str)) {
          ?????fileName = StringUtil.getFileName(str);
          ?????break;
          ????}
          ???}
          ???//System.out.println("===>客戶機(jī)IP==>"+socket.getInetAddress().toString());
          ???//System.out.println("===>客戶機(jī)端口==>"+socket.getPort());???
          ???/*
          ??? BufferedWriter writer = new BufferedWriter(new
          ??? OutputStreamWriter(socket.getOutputStream()));
          ??? */
          ???PrintStream outputStream = new PrintStream(socket.getOutputStream());
          ???File file = new File(StringUtil.WEBPATH + fileName);
          ???if (file.exists()) { //如果文件存在
          ????StringUtil.sendHttpHead(outputStream, file);
          ????StringUtil.sendFile(outputStream, file);
          ????outputStream.flush();
          ???} else { //文件沒找到,返回404頁面
          ????StringUtil.send404Page(outputStream);
          ????outputStream.flush();
          ???}
          ??} catch (Exception e) {
          ???e.printStackTrace();
          ??} finally {
          ???try {
          ????socket.close();
          ???} catch (Exception e) {
          ???}
          ??}
          ?}

          }



          ---StringUtil-----
          import java.io.DataInputStream;
          import java.io.File;
          import java.io.FileInputStream;
          import java.io.PrintStream;

          /**
          ?* @author xiaoliang
          ?*/
          public class StringUtil {

          ?// 服務(wù)器監(jiān)聽的端口
          ?public static final int LISTENING_PORT = 8080;

          ?// 服務(wù)器文件的位置
          ?public static final String WEBPATH = "E:";

          ?/**
          ? * 判斷該字符串是不是瀏覽器發(fā)送過來的請求頭信息
          ? * @param str
          ? * @return
          ? */
          ?public static boolean isGetRequestInfo(String str) {
          ??if (str == null || str.length() <= 0)
          ???return false;
          ??boolean isGetStr = true;
          ??if (str.indexOf("GET") != 0) {
          ???isGetStr = false;
          ??}
          ??if (str.indexOf("HTTP/") <= 0) {
          ???isGetStr = false;
          ??}
          ??return isGetStr;
          ?}

          ?/**
          ? * 獲得請求信息中的文件名,默認(rèn)為index.html
          ? *
          ? * @param str
          ? * @return
          ? */
          ?public static String getFileName(String str) {
          ??String fileName = "index.html", s;
          ??int httpIndex = str.lastIndexOf("HTTP/");
          ??s = str.substring(3, httpIndex);
          ??s = s.trim();
          ??if (s != null && s.length() > 0 && s.indexOf(".") > 0) {
          ???fileName = s;
          ??}
          ??return fileName;
          ?}

          ?/**
          ? * 發(fā)送文件到客戶端
          ? *
          ? * @param out
          ? * @param file
          ? */
          ?public static void sendFile(PrintStream out, File file) {
          ??try {
          ???DataInputStream in = new DataInputStream(new FileInputStream(file));
          ???int length = (int) file.length();
          ???byte[] buffer = new byte[length];
          ???in.readFully(buffer);
          ???out.write(buffer, 0, length);
          ???in.close();
          ??} catch (Exception e) {
          ???e.printStackTrace();
          ??}
          ?}

          ?/**
          ? * 發(fā)送返回的頭部信息
          ? * @param out
          ? */
          ?public static void sendHttpHead(PrintStream outputStream, File file) {
          ??try {
          ???outputStream.println("HTTP/1.0200OK");
          ???outputStream.println("Content_Type:text/htm1");
          ???outputStream.println("Content_Length:" + file.length());
          ???outputStream.println("Server:moon webserver 1.0");
          ???outputStream.println("");
          ??} catch (Exception e) {
          ???e.printStackTrace();
          ??}
          ?}

          ?/**
          ? * 返回404頁面
          ? * @param out
          ? */
          ?public static void send404Page(PrintStream out) {
          ??try {
          ???out.println("HTTP /1.0 404 no found");
          ???out.println("Content_type:text/html");
          ???out.println("");
          ???out.println("Error404:file not found!");
          ??} catch (Exception e) {
          ???e.printStackTrace();
          ??}
          ?}
          ?
          ?public static void main(String[] argv) {
          ??String str = "GET /11.html HTTP/1.1";
          ??str = StringUtil.getFileName(str);
          ??System.out.println("==>" + str + "<==");
          ??File file = new File(StringUtil.WEBPATH + str);
          ??if (file.exists()) {
          ???System.out.println("exists");
          ??} else {
          ???System.out.println("not exists");
          ??}
          ?}

          }

          posted on 2006-03-28 13:55 月亮 閱讀(456) 評論(0)  編輯  收藏


          只有注冊用戶登錄后才能發(fā)表評論。


          網(wǎng)站導(dǎo)航:
           
          主站蜘蛛池模板: 资阳市| 永定县| 庆云县| 沙坪坝区| 印江| 宜都市| 忻州市| 莒南县| 剑川县| 丘北县| 东丽区| 桐乡市| 济南市| 宜春市| 清水河县| 都江堰市| 吉木乃县| 合水县| 石柱| 中方县| 井冈山市| 大庆市| 宝山区| 东至县| 汤原县| 金塔县| 河南省| 井陉县| 阳江市| 闻喜县| 茶陵县| 巴林左旗| 安西县| 蚌埠市| 峨眉山市| 无极县| 任丘市| 蒙城县| 邵武市| 三台县| 阆中市|