Вопросы по протоколу NMDC, Делаю программу

String key="";
            Socket sckServer1 = new Socket();
            try
            {
                sckServer1.connect(p2padrr);
                sckServer1.getInputStream().read(p2preq);
                key=new String(p2preq);
                key=key.substring(key.indexOf("$Lock ")+6, key.indexOf(" Pk="));
                sckServer1.getOutputStream().write(("$Supports UserCommand NoGetINFO NoHello UserIP2 TTHSearch ZPipe0|"+lockToKey(key)+"$ValidateNick Master256|").getBytes());
                sckServer1.getOutputStream().flush();
                sckServer1.getOutputStream().write(("$MyINFO $ALL Master256 <FlylinkDC++ V:17958,M:P,H:1/2/3,S:20>$ $1A$123@321.ru$50000000000$|").getBytes());
                sckServer1.getOutputStream().flush();
                sckServer1.getOutputStream().write(("$Search Hub:Master256 F?T?0?9?TTH:7FZEBBKAWID5QSOX5DQFDZS6CXPCBV63RPNUCTA|").getBytes());
                sckServer1.getOutputStream().flush();

p2padrr=new InetSocketAddress("dc.filimania.com", 411);
            
            String key="";
            Socket sckServer1 = new Socket();
            Socket sckServer2 = new Socket();
            try
            {
                sckServer1.connect(p2padrr);
                sckServer1.getInputStream().read(p2preq);
                key=new String(p2preq);
                key=key.substring(key.indexOf("$Lock ")+6, key.indexOf(" Pk="));
                sckServer1.getOutputStream().write(("$Supports UserCommand NoGetINFO NoHello UserIP2 TTHSearch|"+lockToKey(key)+"$ValidateNick Master256|").getBytes());
                sckServer1.getOutputStream().flush();
                sckServer1.getOutputStream().write(("$Version 1,0091|$MyINFO $ALL Master256 <FlylinkDC++ V:r502-x64,M:P,H:1/0/0,S:15>$ $100 $$500000000000$|").getBytes());
                sckServer1.getOutputStream().flush();
                p2preq=new byte[1024*100];

                int i8=10;
                while ((bytes_read = sckServer1.getInputStream().read(
                        p2preq)) != -1)
                        {
                key=new String(p2preq, "windows-1251");
                if ((key.contains("YQOU7P77AXP7FMKY6R5XJKCNYBHC46LZ2BXTZNI")==true) || (key.contains("$SR")==true)
                         || (key.contains("Master255")==true) || (key.contains("Master256")==true)
                         || (key.contains("77.241.32.197")==true)) {
                    Log.d("999", key.substring(0, bytes_read));
                } else {
                Log.d("999", key.substring(0, bytes_read));}
                
                if (i8==0){
                sckServer1.getOutputStream().write(("$Search Hub:Master256 F?T?0?9?TTH:YQOU7P77AXP7FMKY6R5XJKCNYBHC46LZ2BXTZNI|").getBytes());
                sckServer1.getOutputStream().flush();
                p2preq=new byte[1024*100];
                while ((bytes_read = sckServer1.getInputStream().read(
                        p2preq)) != -1)
                        {
                    key=new String(p2preq, "windows-1251");
                    Log.d("999", key.substring(0, bytes_read));
                    if (key.contains("$SR")) {break;}
                    p2preq=new byte[1024*100];
                        }
                sckServer1.getOutputStream().write(("$RevConnectToMe Master256 serpentarium1377|").getBytes());
                sckServer1.getOutputStream().flush();
                p2preq=new byte[1024*100];
                while ((bytes_read = sckServer1.getInputStream().read(
                        p2preq)) != -1)
                        {
                    key=new String(p2preq, "windows-1251");
                    Log.d("999", key.substring(0, bytes_read));
                    if (key.contains("$ConnectToMe Master256")) {
                        String hgf=key.substring(key.indexOf("$ConnectToMe Master256")+23, key.indexOf(":", key.indexOf("$ConnectToMe Master256")+23));
                        int u=Integer.parseInt(key.substring(key.indexOf(":", key.indexOf("$ConnectToMe Master256")+23)+1, key.indexOf("|", key.indexOf(":", key.indexOf("$ConnectToMe Master256")+23))));
                        InetSocketAddress p2padrr1=new InetSocketAddress(hgf, u);
                        sckServer2.connect(p2padrr1);
                        break;}
                    p2preq=new byte[1024*100];
                        }
                    sckServer2.getOutputStream().write(("$MyNick Master256|$Lock EXTENDEDPROTOCOLABCABCABCABCABCABC Pk=DCPLUSPLUS0.785ABCABCRef=dchub://dc.dcmagnets.ru|").getBytes());
                    sckServer2.getOutputStream().flush();
                    p2preq=new byte[1024*100];
                    bytes_read = sckServer2.getInputStream().read(p2preq);
                    
                        key=new String(p2preq, "windows-1251");
                        Log.d("999", key.substring(0, bytes_read));
                        p2preq=new byte[1024*100];
                    
                    sckServer2.getOutputStream().write(("$Supports MiniSlots XmlBZList ADCGet TTHL TTHF ZLIG|$Direction Download 2436|$Key СА° A С±±АА0Р0 0 0 0 0 0|").getBytes());
                    sckServer2.getOutputStream().flush();
                    p2preq=new byte[1024*100];
                    sckServer2.getOutputStream().write(("$ADCGET tthl TTH/YQOU7P77AXP7FMKY6R5XJKCNYBHC46LZ2BXTZNI 0 -1 ZL1|").getBytes());
                    sckServer2.getOutputStream().flush();
                    while ((bytes_read = sckServer2.getInputStream().read(
                            p2preq)) != -1)
                            {
                        key=new String(p2preq, "windows-1251");
                        Log.d("999", key.substring(0, bytes_read));
                        p2preq=new byte[1024*100];
                            }
                    i8=30000;
                }
                i8=i8-1;
                p2preq=new byte[1024*100];
                }
                
            } catch (IOException e3)
            {
                e3.printStackTrace();
            }

private boolean connectDC()
        {
            p2padrr = new InetSocketAddress(Hub, dcPort);
            p2pServer = new Socket();
            p2preq = new byte[1024 * 10];
            try
            {
                p2pServer.connect(p2padrr);
                p2pServer.getInputStream().read(p2preq);
                str = new String(p2preq, CHARENCODING);
                str = str.substring(str.indexOf("$Lock ") + 6,
                        str.indexOf(" Pk="));
                p2pServer
                        .getOutputStream()
                        .write(("$Supports UserCommand NoGetINFO NoHello UserIP2 TTHSearch|"
                                + lockToKey(str)
                                + "$ValidateNick "
                                + nick
                                + "|" + "$Version 1,0091|$MyINFO $ALL " + nick + " <FlylinkDC++ V:r502-x64,M:P,H:1/0/0,S:15>$ $100 $$600000000000$|")
                                .getBytes());
                p2pServer.getOutputStream().flush();
                p2preq = new byte[1024 * 10];
                while ((bytes_read = p2pServer.getInputStream().read(p2preq)) != -1)
                {
                    str = new String(p2preq, CHARENCODING);
                    if (str.contains("$ValidateDenide"))
                    {
                        nick = nick + Integer.toString(postFix);
                        postFix = postFix + 1;
                        if (postFix > 100)
                        {
                            errorDC = true;
                            return false;
                        } else
                        {
                            connectDC();
                        }
                    }
                    if (str.contains("$Search"))
                    {
                        errorDC = false;
                        return true;
                    }
                }
            } catch (Exception e)
            {}
            errorDC = true;
            return false;
        }

// Read from DC++ peering network!
            if ((useDC == true) && (errorDC == false))
            {
                try
                {
                    if ((p2pServer == null)
                            || (p2pServer.isConnected() != true))
                    {
                        if (connectDC() == false)
                        {
                            errorDC = true;
                            throw new NullPointerException("No connect");
                        }
                    }
                    try
                    {
                        os = new RandomAccessFile(file1, "rwd");
                        os.seek(request._rangePosition);
                    } catch (FileNotFoundException e2)
                    {
                        e2.printStackTrace();
                    }
                    if (nickUser.length() < 1)
                    {// then get nick user
                        p2pServer.getOutputStream()
                                .write(("$Search Hub:" + nick + " F?T?0?9?TTH:"
                                        + TTH + "|").getBytes());
                        p2pServer.getOutputStream().flush();
                        p2preq = new byte[1024 * 10];
                        retr = 40;// number of answers to searches
                        while ((bytes_read = p2pServer.getInputStream().read(
                                p2preq)) != -1)
                        {
                            str = new String(p2preq, CHARENCODING);
                            Log.d("999", str.substring(0, bytes_read));
                            if (str.contains("$SR"))
                            {
                                nickUser = str.substring(
                                        str.indexOf("$SR") + 4, str.indexOf(
                                                " ", str.indexOf("$SR") + 4));
                                urlsize = Integer
                                        .parseInt(str.substring(
                                                str.indexOf("",
                                                        str.indexOf("$SR")) + 1,
                                                str.indexOf(
                                                        " ",
                                                        str.indexOf("", str
                                                                .indexOf("$SR")) + 1)));
                                break;
                            }
                            retr = retr - 1;
                            if (retr == 0) { throw new NullPointerException(
                                    "No search result"); }
                            p2preq = new byte[1024 * 10];
                        }
                    }
                    p2pServer.getOutputStream().write(
                            ("$RevConnectToMe " + nick + " " + nickUser + "|")
                                    .getBytes());
                    p2pServer.getOutputStream().flush();
                    p2preq = new byte[1024 * 10];
                    retr = 40;// number of answers (user) to searches
                    while ((bytes_read = p2pServer.getInputStream()
                            .read(p2preq)) != -1)
                    {
                        str = new String(p2preq, CHARENCODING);
                        Log.d("999", str.substring(0, bytes_read));
                        if (str.contains("$ConnectToMe " + nick))
                        {
                            ipUser = str.substring(str.indexOf("$ConnectToMe "
                                    + nick) + ("$ConnectToMe "+ nick).length()+1, str.indexOf(":",
                                    str.indexOf("$ConnectToMe " + nick) + ("$ConnectToMe "+ nick).length()+1));
                            portUser = Integer
                                    .parseInt(str.substring(str
                                            .indexOf(
                                                    ":",
                                                    str.indexOf("$ConnectToMe "
                                                            + nick) + ("$ConnectToMe "+ nick).length()+1) + 1,
                                            str.indexOf("|", str.indexOf(
                                                    ":",
                                                    str.indexOf("$ConnectToMe "
                                                            + nick) + ("$ConnectToMe "+ nick).length()+1))));
                            break;
                        }
                        p2preq = new byte[1024 * 10];
                        retr = retr - 1;
                        if (retr == 0) { throw new NullPointerException(
                                "No answer from User"); }
                    }
                    sckUser = new Socket();
                    sckUser.setSoTimeout(1500);
                    InetSocketAddress p2padrr1 = new InetSocketAddress(ipUser,
                            portUser);
                    sckUser.connect(p2padrr1);
                    sckUser.getOutputStream()
                            .write(("$MyNick "
                                    + nick
                                    + "|$Lock EXTENDEDPROTOCOLABCABCABCABCABCABC Pk=DCPLUSPLUS0.785ABCABCRef=dchub://"
                                    + Hub
                                    + "|$Supports MiniSlots ADCGet TTHL TTHF|$Direction Download 7777|$Key СА° A С±±АА0Р0 0 0 0 0 0|"
                                    + "$ADCGET file TTH/" + TTH + " "
                                    + request._rangePosition + " -1|")
                                    .getBytes());
                    sckUser.getOutputStream().flush();
                    // header
                    if ((request._rangePosition > 0)
                            || (request._overRange == true))
                    {
                        header = "HTTP/1.1 206 Partial Content\r\nAccept-Ranges: bytes\r\nContent-Length: "
                                + Long.toString(urlsize
                                        - request._rangePosition)
                                + "\r\nContent-Range: bytes "
                                + Long.toString(request._rangePosition)
                                + "-"
                                + Long.toString(urlsize - 1)
                                + "/"
                                + urlsize
                                + "\r\nContent-Type: application/octet-stream\r\n\r\n";
                    } else
                    {
                        header = "HTTP/1.1 200 OK\r\nAccept-Ranges: bytes\r\nContent-Length: "
                                + Long.toString(urlsize)
                                + "\r\nContent-Disposition: attachment\r\nContent-Type: application/octet-stream\r\n\r\n";
                    }
                    sckPlayer.getOutputStream().write(header.getBytes(), 0,
                            header.length());
                    // removes $ADCSND
                    p2preq = new byte[1024 * 10];
                    bytes_read = sckUser.getInputStream().read(p2preq);
                    str = new String(p2preq, CHARENCODING);
                    if (str.contains("$ADCSND"))
                    {
                        str = str.substring(str.indexOf("$MyNick"),
                                str.indexOf("|", str.indexOf("$ADCSND")) + 1);
                        bytes_read = bytes_read - str.length();
                    } else
                    {
                        str = "";
                    }
                    sendByte = sendByte + bytes_read;
                    os.write(p2preq, str.length(), bytes_read);
                    sckPlayer.getOutputStream().write(p2preq, str.length(),
                            bytes_read);
                    while ((bytes_read = sckUser.getInputStream().read(p2preq)) != -1)
                    {
                        os.write(p2preq, 0, bytes_read);
                        sendByte = sendByte + bytes_read;
                        sckPlayer.getOutputStream()
                                .write(p2preq, 0, bytes_read);
                    }
                    sckPlayer.getOutputStream().flush();
                } catch (Exception e3)
                {
                    e3.printStackTrace();
                }
            }

str.contains("$ValidateDenide")

$oZshb6243dss34 $ValidateDenide|

public boolean startsWith(String prefix)

$SomeCommand|$OtherCommand command_parameters|$OtherCommand command_parameters|$OtherCommand command_parameters|