Java笔记-使用ServerSocket构建HTTP服务器

左手的ㄟ右手 2022-09-04 01:55 37阅读 0赞

运行截图如下；

![20210810083742741.png][]

浏览器访问：

![20210810083750267.png][]

后端打印：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70][]

项目结构如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 1][]

HttpCallback.java

package cn.it1995.http;
    
    public interface HttpCallback {
    
        byte[] onResponse(String request);
    }

HttpServer.java

package cn.it1995.http;
    
    import java.io.IOException;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.concurrent.Executor;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class HttpServer {
    
        private boolean mRunning;
        private HttpCallback mCallback;
    
        public HttpServer(HttpCallback Callback) {
    
            this.mCallback = Callback;
        }
    
        public void startHttpServer(){
    
            if(mRunning){
    
                return;
            }
            mRunning = true;
    
            try {
    
                ServerSocket serverSocket = new ServerSocket(80);
                while (mRunning){
    
                    Socket accept = serverSocket.accept();
                    ExecutorService threadPool = Executors.newCachedThreadPool();
                    threadPool.execute(new HttpThread(accept, mCallback));
                }
            }
            catch (IOException e) {
    
                e.printStackTrace();
            }
        }
    }

HttpThread.java

package cn.it1995.http;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.net.Socket;
    
    public class HttpThread implements Runnable{
    
        private Socket mSocket;
        private HttpCallback mCallback;
    
        public HttpThread(Socket socket, HttpCallback httpCallback){
    
            mSocket = socket;
            mCallback = httpCallback;
        }
    
        @Override
        public void run() {
    
            try {
    
                BufferedReader reader = new BufferedReader(new InputStreamReader(mSocket.getInputStream()));
                String content;
                StringBuffer request = new StringBuffer();
    
                while((content = reader.readLine()) != null
                        && !content.trim().isEmpty()){
    
                    request.append(content).append("\n");
                }
    
                System.out.println("request:\n" + request);
                byte[] response = new byte[0];
                if(mCallback != null){
    
                    response = mCallback.onResponse(request.toString());
                }
    
                String responseFirstLine = "HTTP/1.1 200 OK \r\n";
                String responseHead = "Content-type:" + "text/html" + "\r\n";
                OutputStream outputStream = mSocket.getOutputStream();
                outputStream.write(responseFirstLine.getBytes());
                outputStream.write(responseHead.getBytes());
                outputStream.write("\r\n".getBytes());
                outputStream.write(response);
    
                mSocket.close();
            }
            catch (IOException e) {
    
                e.printStackTrace();
            }
        }
    }

Main.java

package cn.it1995;
    
    import cn.it1995.http.HttpCallback;
    import cn.it1995.http.HttpServer;
    
    public class Main {
    
        public static void main(String[] args) {
    
            System.out.println("start http server");
            HttpServer server = new HttpServer(new HttpCallback() {
                @Override
                public byte[] onResponse(String request) {
    
                    return "Hello World".getBytes();
                }
            });
    
            server.startHttpServer();
        }
    }

源码打包下载地址：

[https://github.com/fengfanchen/Java/tree/master/Server][https_github.com_fengfanchen_Java_tree_master_Server]

[20210810083742741.png]: /images/20220829/f8354f6bc4e64db59b409147e9b227a4.png
[20210810083750267.png]: /images/20220829/5e497e9e86434d3ca3a1d3f537217b49.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70]: /images/20220829/8e2ae9ffbe744b4c81525fd9513f3ccc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 1]: /images/20220829/8ae5cac7b686483196f1946484a0df5e.png
[https_github.com_fengfanchen_Java_tree_master_Server]: https://github.com/fengfanchen/Java/tree/master/Server