z.txt

手机QQ原代码,有喜欢的朋友可以大量的下载,我不要钱的哦

import java.io.*;
import java.util.Calendar;
import javax.microedition.io.ConnectionNotFoundException;
import javax.microedition.io.SocketConnection;

public class z extends Thread
{

    public InputStream a_java_io_InputStream_fld;
    public l a_l_fld;
    public byte a_byte_array1d_fld[];
    public boolean a_boolean_fld;

    public void a()
    {
        System.out.println("Want exit run");
        a_boolean_fld = true;
        try
        {
            if(a_java_io_InputStream_fld != null)
            {
                a_java_io_InputStream_fld.close();
                a_java_io_InputStream_fld = null;
            }
        }
        catch(Exception exception)
        {
            i.a("CR Exit exception:" + exception);
            i.a(exception);
        }
    }

    public z(l l1)
    {
        a_java_io_InputStream_fld = null;
        a_l_fld = null;
        a_byte_array1d_fld = null;
        a_boolean_fld = false;
        a_l_fld = l1;
        a_byte_array1d_fld = new byte[1024];
    }

    public boolean a()
    {
        a_java_io_InputStream_fld = a_l_fld.a_javax_microedition_io_SocketConnection_fld.openInputStream();
        start();
        return true;
        Object obj;
        obj;
        i.a("CR ConnectionNotFoundException: " + ((ConnectionNotFoundException) (obj)).getMessage());
        break MISSING_BLOCK_LABEL_86;
        obj;
        i.a("CR IOException: " + ((IOException) (obj)).getMessage());
        break MISSING_BLOCK_LABEL_86;
        obj;
        i.a("CR start recv exception");
        return false;
    }

    public void run()
    {
        ByteArrayOutputStream bytearrayoutputstream = new ByteArrayOutputStream();
        boolean flag = false;
        boolean flag1 = false;
        try
        {
            while(!a_boolean_fld) 
            {
                if(a_l_fld.e != l.c)
                {
                    synchronized(this)
                    {
                        wait();
                    }
                }
                for(; !a_boolean_fld && a_java_io_InputStream_fld.available() == 0; sleep(200L)) { }
                do
                {
                    int j;
                    if(a_boolean_fld || (j = a_java_io_InputStream_fld.read()) == -1)
                    {
                        break;
                    }
                    if(j == 13)
                    {
                        int k = a_java_io_InputStream_fld.read();
                        if(k == -1)
                        {
                            a(bytearrayoutputstream);
                            bytearrayoutputstream.reset();
                            break;
                        }
                        if(k == 10)
                        {
                            a(bytearrayoutputstream);
                            bytearrayoutputstream.reset();
                            break;
                        }
                        bytearrayoutputstream.write(j);
                        bytearrayoutputstream.write(k);
                    } else
                    {
                        bytearrayoutputstream.write(j);
                    }
                } while(true);
                i.a("read -1 or exit");
            }
        }
        catch(InterruptedException interruptedexception)
        {
            i.a("InterruptedException: " + interruptedexception.getMessage());
            i.a(interruptedexception);
            a_l_fld.c();
        }
        catch(ConnectionNotFoundException connectionnotfoundexception)
        {
            i.a("CR ConnectionNotFoundException: " + connectionnotfoundexception.getMessage());
            i.a(connectionnotfoundexception);
            a_l_fld.c();
        }
        catch(EOFException eofexception)
        {
            i.a("java.io.EOFException");
            i.a(eofexception);
            a_l_fld.c();
        }
        catch(IOException ioexception)
        {
            i.a("CR IOException1: " + ioexception.getMessage());
            i.a(ioexception);
            a_l_fld.c();
        }
        catch(Exception exception)
        {
            i.a("CR Exception: " + exception.getMessage());
            i.a(exception);
            a_l_fld.c();
        }
    }

    private void a(ByteArrayOutputStream bytearrayoutputstream)
    {
        boolean flag = false;
        String s = null;
        Object obj = null;
        byte abyte0[] = bytearrayoutputstream.toByteArray();
        int j = abyte0.length;
        byte abyte1[] = new byte[j + 2];
        abyte1[0] = (byte)(j >> 8);
        abyte1[1] = (byte)j;
        try
        {
            System.arraycopy(abyte0, 0, abyte1, 2, j);
            ByteArrayInputStream bytearrayinputstream = new ByteArrayInputStream(abyte1);
            DataInputStream datainputstream = new DataInputStream(bytearrayinputstream);
            s = datainputstream.readUTF();
            datainputstream.close();
            bytearrayinputstream.close();
        }
        catch(Exception exception)
        {
            i.a("CR.doReceive Exception: " + exception.getMessage());
            i.a(exception);
        }
        s = s.trim();
        i.a(Calendar.getInstance() + "\nreceive:" + s);
        a_l_fld.a_ad_fld.a(a_l_fld, s);
    }
}