Java web服务器webServer

刺骨的言语ヽ痛彻心扉 2023-09-26 11:02 51阅读 0赞

package com;
    
    import java.net.ServerSocket;
    import java.net.Socket;
     
     
    public class WebServer {
        
    	public static void main(String[] args) {
        
    		int Port = 8081;//端口号，由于这里是测试，所以不要使用常用端口
    		//创建两个套接字
    		ServerSocket server = null;
    		Socket client = null;
    		try{
        
    			server = new ServerSocket(Port);
    			//服务器开始监听
    			System.out.println("The WebServer is listening on port "+server.getLocalPort());
    			while(true){
        
    				client = server.accept();
    //				//多线程运行
    				new CommunicateThread(client).start();
    			}
    		}catch(Exception e){
        
    			System.out.println(e.getMessage());
    		}
    	}
    
    }```
    
    
    
    
    ```java
    package com;
    
    import java.io.DataInputStream;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.PrintStream;
    import java.net.Socket;
    
    
    //每有一个连接建立时，服务器分出一个通信的线程
    public class CommunicateThread extends Thread {
        
        //与客户端通信的套接字
        Socket client;
    
        public CommunicateThread(Socket s) {
        
            client = s;
        }
    
        //获取浏览器请求资源的路径
        public String getResourcePath(String s) {
        
            // 一般的HTTP请求报文的第一行是“GET /index.html HTTP/1.1”
            // 我们要获取的就是中间的"/indext.apsx"
    
            //获取资源的位置
            String s1 = s.substring(s.indexOf(' ') + 1);
            s1 = s1.substring(1, s1.indexOf(' '));
    
            //默认资源为index.html
            if (s1.equals(""))
                s1 = "index.html";
    
            return s1;
        }
    
        public void sendFile(PrintStream out, File file) {
        
            try {
        
                DataInputStream in = new DataInputStream(new FileInputStream(file));
                int len = (int) file.length();
                byte buf[] = new byte[len];
                in.readFully(buf);//读取文内容到buf数组中
                out.write(buf, 0, len);
    
                out.flush();
                in.close();
            } catch (Exception e) {
        
                System.out.println(e.getMessage());
                System.exit(1);
            }
        }
    
        public void run() {
        
            try {
        
                //获取用户的IP地址和端口号
                String clientIP = client.getInetAddress().toString();
                int clientPort = client.getPort();
                //创建输出流对象
                PrintStream out = new PrintStream(client.getOutputStream());
                //创建输入流对象
                DataInputStream in = new DataInputStream(client.getInputStream());
                //读取浏览器提交的请求
                String msg = in.readLine();
    
                //获取文件路径
                String fileName = getResourcePath(msg);
    //            System.out.println("The user asked for resource: " + fileName);
                File file = new File(fileName);
    
                if (file.exists()) {
        
                    //根据响应报文格式设置
                    System.out.println(fileName + " start send");
                    out.println("HTTP/1.0 200 OK");
                    out.println("MIME_version:1.0");
                    out.println("Content_Type:text/html");
                    int len = (int) file.length();
                    out.println("Content_Length:" + len);
                    out.println("");//报文头和信息之间要空一行
    
                    //发送文件
                    sendFile(out, file);
                    out.flush();
                }
                else {
        
                    StringBuffer error2 = new StringBuffer();
                    error2.append("HTTP/1.1 404 file not found \r\n");
                    error2.append("Content-Type:text/html \r\n");
                    error2.append("Content-Length:20 \r\n").append("\r\n");
                    error2.append("<h1 >404 no find</h1>");
                    try {
        
                        out.write(error2.toString().getBytes());
                        out.flush();
                        out.close();
                    } catch (IOException e) {
        
                        e.printStackTrace();
                    }
    
                }
                client.close();
            } catch (Exception e) {
        
                System.out.println(e.getMessage());
            }
        }
    
    
    }