zoukankan      html  css  js  c++  java
  • [置顶] java web 动态服务器

    写了一个java web 动态服务器,主要通过内部类来实现,动态类使用了外部类,采用了

    classforname 实例化,动态类的构造方法不能带参数, 效果都出来了,分享给有需要的

    朋友。判断做的不够多,

    写得不够好,感谢指出缺点。以下是代码:

    静态文件index.html:

                 <html>
                        <head>
                                 <title>简单的web服务器</title>
                        </head>
                        <body>
                                  <div align="center">简单的web静态服务器</div>
                         </body>
                  </html>

    主要核心代码:

                 

    import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileNotFoundException;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.io.PrintWriter;
    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    import java.net.MalformedURLException;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.net.URL;
    import java.net.URLClassLoader;

    /**
     * web处理类
     */
    class WebProcess{
     private Request request;
     private Response response;
     public WebProcess(Request request, Response response) {
      // TODO Auto-generated constructor stub
      this.request=request;
      this.response=response;
      this.process();
     }
     private void process() {
      // TODO Auto-generated method stub
      String uri=request.getUri();
      System.out.println("uri---------------------------"+uri);
      String uriSuffix=uri.substring(uri.indexOf('.')+1);
      System.out.println("uriSuffix------------"+uriSuffix);
      if("htmlxmlhtm".indexOf(uriSuffix)>-1){
       System.out.println("静态文件");
       File fileToSend=new File(uri);
       if(fileToSend.exists()){
        System.out.println("存在文件");
        try {
         FileInputStream fis=new FileInputStream(fileToSend);
         byte[] data=new byte[fis.available()];
         fis.read(data);
         //System.out.println(data.length);
         response.out(new String(data));
        } catch (FileNotFoundException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
        } catch (IOException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
        }
       }else{
        System.out.println("不存在文件");
        response.out("您要访问的网页不存在");
       }
      }else{
       System.out.println("动态文件");
       //Visit v=new Visit(response,request);
       File fileToSend1=new File(uri);
       System.out.println("fileToSend----------------"+fileToSend1);
      /* if(fileToSend1.exists()){*/
        //System.out.println("类文件存在");
        try {
         //获取需要的的类的路径
         URL url=new URL("file:\D:\Users\Administrator\Workspaces\MyEclipse 8.6\2013-08-21\src");
         String classname=uri;
         System.out.println("url-----------------"+url);
         ClassLoader cl=new URLClassLoader(new URL[]{url});
         Class d=cl.loadClass(classname);
         System.out.println(d);
         //System.out.println("cl-----------------------"+cl);
         Object c=Class.forName(uri).newInstance();
         Method method=c.getClass().getMethod("process", Response.class,Request.class);
         method.invoke(c,response,request);
        } catch (MalformedURLException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
        } catch (ClassNotFoundException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
        } catch (InstantiationException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
        } catch (IllegalAccessException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
        } catch (SecurityException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
        } catch (NoSuchMethodException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
        } catch (IllegalArgumentException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
        } catch (InvocationTargetException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
        }
       /*}else{
        System.out.println("类文件不存在");
       }*/
       
      }
     }
     
    }


    /**
     * 响应类
     */
    class Response{
     private PrintWriter writer;
     public Response(OutputStream outputStream) {
      // TODO Auto-generated constructor stub
      this.writer=new PrintWriter(outputStream,true);
      //this.out(data);
     }
     public void out(String data) {
      // TODO Auto-generated method stub
      System.out.println("out()-----------------start");
      writer.println(data);
      
     }
     
    }

    /**
     * 请求类
     */
    class Request{
     private InputStream input;
     public Request(InputStream inputStream) {
      // TODO Auto-generated constructor stub
      this.input=inputStream;
      //this.getUri();
     }
     public String getUri(){
      String resource=null;
      System.out.println("getUri()-------------------start--");
      BufferedReader in=new BufferedReader(new InputStreamReader(input));
      try {
       String line=in.readLine();
       resource=line.substring(line.indexOf('/')+1, line.lastIndexOf('/')-5);
       System.out.println("resource-----------"+resource);
       
      } catch (IOException e) {
       // TODO Auto-generated catch block
       e.printStackTrace();
      }
      return resource;
     }
     
    }


    /**
     * @author Administrator
     *采用了线程
     */
    public class ServerWeb implements Runnable {

     private static final int port = 8085;
     ServerSocket serversocket;


     /**
      * @param args
      */
     public ServerWeb(){
      new Thread(this).start();      //把当前类设置为一个线程
     }
     
     @Override
     public void run() {
      // TODO Auto-generated method stub
      System.out.println("run()---------------------start-----");
      try {
       serversocket=new ServerSocket(port);
       System.out.println("serversocket--------------------"+serversocket.getLocalPort());
       while(true){
        Socket socket=serversocket.accept();
        System.out.println("socket----------------------"+socket.getLocalPort());
        Request request=new Request(socket.getInputStream());
        Response response=new Response(socket.getOutputStream());
        WebProcess webprocess=new WebProcess(request,response);
        socket.close();
       }
      } catch (IOException e) {
       // TODO Auto-generated catch block
       e.printStackTrace();
      }
     }
     
     
     
     public static void main(String[] args) {
      // TODO Auto-generated method stub
      new ServerWeb();
     }

    }

    独立动态类的代码:

    import java.util.Date;


    public class Visit {
     public Visit(/*Response response, Request request*/) {
      // TODO Auto-generated constructor stub
      /*this.request=request;
      this.response=response;*/
      //this.process();
     }
     
     public void process(Response response, Request request){
      response.out("动态网页"+new Date().toString());
      System.out.println("process------------start");
     }
    }

             

  • 相关阅读:
    (转)乐观的并发策略——基于CAS的自旋
    mysql避免插入重复数据
    Java_Web使用简单的批处理操作
    Java中jar命令详解
    使用文档注释(javadoc)
    APP和WEB元素定位方法
    RF(二)RF常用库介绍
    RF(一)RF的安装步骤
    javascript匿名函数及闭包深入理解及应用
    javascript简介
  • 原文地址:https://www.cnblogs.com/pangblog/p/3275529.html
Copyright © 2011-2022 走看看