1. package com.itcast.tomcateV2;<div class="blockcode"><blockquote>package com.itcast.tomcateV2;
   
2. 
   
3. import java.io.File;
   
4. import java.io.FileInputStream;
   
5. import java.io.IOException;
   
6. import java.io.InputStream;
   
7. import java.io.OutputStream;
   
8. import java.net.ServerSocket;
   
9. import java.net.Socket;
   
10. import java.util.HashMap;
    
11. import java.util.Iterator;
    
12. import java.util.Map;
    
13. import java.util.Properties;
    
14. import java.util.Set;
    
15. /*
    
16. * 接受客户端发送过来的请求,判断客户端要请求的是哪个资源,将这个资源发送到客户端
    
17. *
    
18. */
    
19. public class TestServer {
    
20. 
    
21.         public static final String WEB_ROOT =
    
22.                         System.getProperty("user.dir") +"\\"  + "webroot";
    
23.         // 代表客户端要请求资源的路径
    
24.         public static String url = "";
    
25. 
    
26.         //public static void startUp(String[] args) {
    
27.         public static void main(String[] args) {
    
28.                
    
29.                 try {
    
30.                        
    
31.                         // 建立不本机器的ServerSocket,监听本机器的80端口
    
32.                         ServerSocket serverSocket = new ServerSocket(9999);
    
33. 
    
34.                         boolean shutdown = false;
    
35. 
    
36.                         while (!shutdown) {
    
37.                                 Socket socket = serverSocket.accept();
    
38.                                 InputStream input = socket.getInputStream();
    
39.                                 OutputStream output = socket.getOutputStream();
    
40.                                 //localhost:9999/demo.html   localhost:9999/aa
    
41.                                 parse(input);
    
42.                                 //demo.html  demo.jpg   aa  GET /demo  http/1.1
    
43.                                 if(url.indexOf(".")!=-1){
    
44.                                         sendStaticResource(output);       
    
45.                                 }else{
    
46.                                         sendDynamicResource(output);
    
47.                                 }
    
48.                                
    
49.                                
    
50.                                 input.close();
    
51.                                 input=null;
    
52.                                
    
53.                                 output.close();
    
54.                                 output=null;
    
55.                                
    
56.                                 socket.close();
    
57.                                 socket=null;
    
58.                                
    
59.                                 //System.out.println("url.........."+url);
    
60.                                
    
61.                                 if(url.equals("/SHUTDOWN")){
    
62.                                         shutdown=true;
    
63.                                 }
    
64.                                
    
65.                                
    
66.                         }
    
67. 
    
68.                 } catch (Exception e) {
    
69.                         e.printStackTrace();
    
70.                 }
    
71. 
    
72.         }
    
73. 
    
74.         public static void parse(InputStream input) throws IOException {
    
75.                 StringBuffer content = new StringBuffer(2048);
    
76.                 int i;
    
77. 
    
78.                 byte[] buffer = new byte[2048];
    
79.                 // 读取客户端发送过来的数据,将数据读取到字节数组buffer中.i代表读取数据量的大小
    
80.                 i = input.read(buffer);
    
81.                 System.out.println(buffer);
    
82. 
    
83.                 for (int j = 0; j < i; j++) {
    
84.                         content.append((char) buffer[j]);
    
85.                 }
    
86.                 // 打印读取到的内容
    
87.                 System.out.print(content.toString());
    
88.                 // 截取客户端要请求的资源路径
    
89.                 String uri = parseUri(content.toString());
    
90.                
    
91.                 // 赋值给本类中静态成员
    
92.                 url = uri;
    
93.                 System.out.println("uri..............:"+uri);
    
94.         }
    
95. 
    
96.         // 截取客户端请求资源的路径
    
97.         public static String parseUri(String requestString) {
    
98.                 int index1, index2;
    
99.                 index1 = requestString.indexOf(' ');
    
100.                 if (index1 != -1) {
     
101.                         index2 = requestString.indexOf(' ', index1 + 1);
     
102.                         if (index2 > index1)
     
103.                                 return requestString.substring(index1+2, index2);
     
104.                 }
     
105.                 return null;
     
106.         }
     
107. 
     
108.         public static void sendStaticResource(OutputStream output)
     
109.                         throws IOException {
     
110. 
     
111.                 byte[] bytes = new byte[2048];
     
112.                 FileInputStream fis = null;
     
113.                 try {
     
114.                         File file = new File(TestServer.WEB_ROOT, url);
     
115.                         if (file.exists()) {
     
116.                                 output.write("HTTP/1.1 200 OK\n".getBytes());
     
117.                                 output.write("Server: Apache-Coyote/1.1\n".getBytes());
     
118.                                 output.write("Content-Type: text/html;charset=UTF-8\n"
     
119.                                                 .getBytes());
     
120.                                 output.write("\n".getBytes());
     
121. 
     
122.                                 fis = new FileInputStream(file);
     
123.                                 int ch = fis.read(bytes, 0, 2048);
     
124.                                 while (ch != -1) {
     
125.                                         output.write(bytes, 0, ch);
     
126.                                         ch = fis.read(bytes, 0, 2048);
     
127.                                 }
     
128.                         } else {
     
129.                                 // file not found
     
130.                                 String errorMessage = "HTTP/1.1 404 File Not Found\r\n"
     
131.                                                 + "Content-Type: text/html\r\n"
     
132.                                                 + "Content-Length: 23\r\n" + "\r\n"
     
133.                                                 + "<h1>File Not Found</h1>";
     
134.                                 output.write(errorMessage.getBytes());
     
135.                         }
     
136.                 } catch (Exception e) {
     
137.                         // thrown if cannot instantiate a File object
     
138.                         e.printStackTrace();
     
139.                         System.out.println(e.toString());
     
140.                 } finally {
     
141.                         if (fis != null)
     
142.                                 fis.close();
     
143.                 }
     
144.         }
     
145. 
     
146.         public static Map readConf() throws Exception{
     
147.                 Map m=new HashMap();
     
148.                
     
149.                 Properties p=new Properties();
     
150.                 p.load(new FileInputStream(TestServer.WEB_ROOT+"\\conf.properties"));
     
151.                
     
152.                 Set s=p.keySet();
     
153.                
     
154.                 Iterator ii=s.iterator();
     
155.                 while(ii.hasNext()){
     
156.                         String k=(String)ii.next();
     
157.                         String v=(String)p.get(k);
     
158.                         m.put(k, v);
     
159.                 }
     
160.                
     
161.                 return m;
     
162.         }
     
163.        
     
164.         public static void sendDynamicResource(OutputStream ops) throws Exception{
     
165.                 Map m=readConf();
     
166.                 if(m.size()>0){
     
167.                         Set s=m.keySet();
     
168.                         Iterator ii=s.iterator();
     
169.                         while(ii.hasNext()){
     
170.                                 String k=(String)ii.next();
     
171.                                 if(k.contains("url")){
     
172.                                         String k_v=(String)m.get(k);
     
173.                                         if(url.equals(k_v)){
     
174.                                                 String classStr=(String)m.get(k_v);
     
175.                                                 Class cc=Class.forName(classStr);
     
176.                                                 Server sss=(Server)cc.newInstance();
     
177.                                                 sss.server(ops);
     
178.                                         }
     
179.                                        
     
180.                                 }
     
181.                         }
     
182.                 }               
     
183.         }
     
184.        
     
185. }
     

复制代码

import java.io.IOException;
import java.io.OutputStream;

/*
* 抽取得能力
*/
public interface Server {
        public void init();
        public void server(OutputStream ops)throws IOException;
        public void destroy();
}

tomcat/     

superhs 发表于 2015-9-25 09:31
tomcat/

我们老师手速太快。。停不下来。。每次都会写成cate....{:3_65:}