socketlisten_z.java

经过反编译和部分代码修改后的ultraimpro java源代码。可在netbean环境下成功编译。供学习和分析用。

// Decompiled by DJ v3.9.9.91 Copyright 2005 Atanas Neshkov  Date: 2006-5-1 19:31:39
// Home Page : http://members.fortunecity.com/neshkov/dj.html  - Check often for new version!
// Decompiler options: packimports(3) 

import java.util.Hashtable;

public final class SocketListen_z extends Thread
{

    public SocketListen_z(SocketManage_bp bp1)
    {
        a_bp_SocketManage_fld = bp1;
    }

    public final void run()
    {
        InputStreamUtil_p p1;
        Object obj = null;
        p1 = new InputStreamUtil_p(a_bp_SocketManage_fld.a_java_io_InputStream_fld, "UTF8");
//_L2:
        while(true) {
        InputCommandProcess_be be1;
        if(!a_bp_SocketManage_fld.blSocketOpen)
            break; /* Loop/switch isn't completed */
        String s;
        try
        {
            if(a_bp_SocketManage_fld.b)
                Thread.sleep(500L);
            if((s = p1.ReadLine()) == null)
                continue; //break; /* Loop/switch isn't completed */
        }
        catch(Exception _ex)
        {
            continue; /* Loop/switch isn't completed */
        }
        if(s.equals("err"))
            continue; /* Loop/switch isn't completed */
        try
        {
        be1 = new InputCommandProcess_be(s);
        }
        catch (Exception _ex) {continue;}
        int j;
        int k;
        if((j = be1.b()) > 0)
            try
            {
                if((k = be1.e_mod_toi()) > 0)
                    be1.a_byte_array1d_fld = p1.ReadBytes(k);
            }
            catch(Exception _ex) { continue;}
        String s1 = null;
        int i;
        if((i = be1.GetTraceId()) >= 0 && be1.CommandIndex == 2)
            s1 = (String)a_bp_SocketManage_fld.a_java_util_Hashtable_fld.remove(new Integer(i));
        a_bp_SocketManage_fld.a_ar_fld.a(be1, s1);
        //if(true) goto _L2; else goto _L1
        }
//_L1:
        if(a_bp_SocketManage_fld.blSocketOpen)
            a_bp_SocketManage_fld.CloseSocket();
        return;
    }

    private final SocketManage_bp a_bp_SocketManage_fld;
}