SocketHttpServer无法启动，需要在maven中怎么配置

Z时代
2024-01-10
分类：IT


package com.socket;
import java.net.Socket;
public class SocketHttpServer implements Runnable {
    private final static int PORT = 28081;
    private ServerSocket server = null;
    public static void main(String[] args) {
        new SocketHttpServer();
    }
    public SocketHttpServer() {
        try {
            server = new ServerSocket(PORT);
            if (server == null)
                System.exit(1);
            new Thread(this).start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    @Override
    public void run() {
        while (true) {
            try {
                Socket client = null;
                client = server.accept();
                if (client != null) {
                    try {
                        System.out.println("连接服务器成功！！...");
                        BufferedReader reader = new BufferedReader(
                                new InputStreamReader(client.getInputStream()));
                        // GET /test.jpg /HTTP1.1
                        String line = reader.readLine();
                        System.out.println("line: " + line);
                        String resource = line.substring(line.indexOf('/'),
                                line.lastIndexOf('/') - 5);
                        System.out.println("the resource you request is: "
                                + resource);
                        resource = URLDecoder.decode(resource, "UTF-8");
                        String method = new StringTokenizer(line).nextElement()
                                .toString();
                        System.out.println("the request method you send is: "
                                + method);
                        while ((line = reader.readLine()) != null) {
                            if (line.equals("")) {
                                break;
                            }
                            System.out.println("the Http Header is : " + line);
                        }
                        if ("post".equals(method.toLowerCase())) {
                            System.out.println("the post request body is: "
                                    + reader.readLine());
                        }
                        if (resource.endsWith(".mkv")) {
                            transferFileHandle("videos/test.mkv", client);
                            closeSocket(client);
                            continue;
                        } else if (resource.endsWith(".jpg")) {
                            transferFileHandle("images/test.jpg", client);
                            closeSocket(client);
                            continue;
                        } else if (resource.endsWith(".rmvb")) {
                            transferFileHandle("videos/test.rmvb", client);
                            closeSocket(client);
                            continue;
                        } else {
                            PrintStream writer = new PrintStream(
                                    client.getOutputStream(), true);
                            writer.println("HTTP/1.0 404 Not found");// 返回应答消息,并结束应答
                            writer.println();// 根据 HTTP 协议, 空行将结束头信息
                            writer.close();
                            closeSocket(client);
                            continue;
                        }
                    } catch (Exception e) {
                        System.out.println("HTTP服务器错误:"
                                + e.getLocalizedMessage());
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
    private void closeSocket(Socket socket) {
        try {
            socket.close();
        } catch (IOException ex) {
            ex.printStackTrace();
        }
        System.out.println(socket + "离开了HTTP服务器");
    }
    private void transferFileHandle(String path, Socket client) {
        File fileToSend = new File(path);
        if (fileToSend.exists() && !fileToSend.isDirectory()) {
            try {
                PrintStream writer = new PrintStream(client.getOutputStream());
                writer.println("HTTP/1.0 200 OK");// 返回应答消息,并结束应答
                writer.println("Content-Type:application/binary");
                writer.println("Content-Length:" + fileToSend.length());// 返回内容字节数
                writer.println();// 根据 HTTP 协议, 空行将结束头信息
                FileInputStream fis = new FileInputStream(fileToSend);
                byte[] buf = new byte[fis.available()];
                fis.read(buf);
                writer.write(buf);
                writer.close();
                fis.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}