Untitled

public class MainActivity extends AppCompatActivity {

​

    private Button mAddButton;

    private Button mConnectButton;

    TCPWorker UniTimer;

    @Override

    protected void onCreate(Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);

        setContentView(R.layout.activity_main);

​

        mAddButton = (Button) findViewById(R.id.butt_add);

        mAddButton.setOnClickListener(new View.OnClickListener() {

            @Override

            public void onClick(View v) {

                Toast.makeText( MainActivity.this, R.string.jpa, Toast.LENGTH_LONG).show();

            }

        });

        mConnectButton = (Button) findViewById(R.id.butt_connect);

        mConnectButton.setOnClickListener(new View.OnClickListener()  {

            @Override

            public void onClick(View v) {

                Toast.makeText( MainActivity.this, R.string.pcd, Toast.LENGTH_LONG).show();

                try {

                    Thread.sleep(1000);

                } catch (InterruptedException e) {

                    e.printStackTrace();

                }

                UniTimer.run();

​

            }

        });

​

    }

}

class TCPWorker extends Thread {

​

    Thread TCP_Sock_Thread;

​

    private BlockingDeque<byte []> deque;

​

    public void run() {

        TCP_Sock_Thread = new Thread(new Runnable() {

            public void run() {

                try {

                    for (; ; ) {

                        if (true) {//isNetworkRun) {

                               GetTCPProtoBuf();

                        } else {

                            Thread.sleep(100);

                        }

                    }

                } catch (InterruptedException e) {

                }

            }

        });

        TCP_Sock_Thread.start();

​

        for (;;) {

            try {

                //byte[] bit = queue.take();

                byte[] bit = deque.takeLast(); deque.clear();

                final Bitmap new_jpg = BitmapFactory.decodeByteArray(bit, 0, bit.length);

                /*MainActivity.this.runOnUiThread(new Runnable() {

                    @Override

                    public void run() {

                       // mFinalbitmap = new_jpg;

                    }

                });*/

            } catch (InterruptedException e) {

            }

        }

    }

​

    void GetTCPProtoBuf() {

        Socket socket = null;

        try {

       //     connect_status = "try connect";

            InetAddress serverAddr = InetAddress.getByName("192.168.4.74"); //InetAddress.getByName(888);

            //Log.e("TCP Client", "C: Connecting...");

            socket = new Socket(serverAddr, 8888);

            OutputStream wrt = socket.getOutputStream();

            DataInputStream rdt = new DataInputStream(socket.getInputStream());

            socket.setSoTimeout(300 * 1000);

            socket.setReceiveBufferSize(500000);

            socket.setSendBufferSize(1000);

            try {

                byte [] init_string = new byte [] { (byte)'?', (byte)'?', (byte)'?', (byte)'?', (byte)'?', (byte)'?', (byte)'1', (byte)'2', (byte)'3', (byte)0x0D };

                wrt.write(init_string);

                wrt.flush();

       //         connect_status = "wait other";

                if (rdt.readByte() != (byte)'#') {

                    socket.close();

                    return;

                }

        //        connect_status = "";

                int k = 0;

                //byte [] hdr = new byte[4];

                ByteBuffer hdr_buf = ByteBuffer.allocate(4);

                hdr_buf.order(ByteOrder.LITTLE_ENDIAN);

                //float [] local_angles = new float[3];

                socket.setSoTimeout(60 * 1000);

                while (true) {//isNetworkRun) {

                    // rdt.readFully(hdr); k = 0; k |= (hdr[0] & 0xff); k |= (hdr[1] & 0xff) << 8; k |= (hdr[2] & 0xff) << 16; k |= (hdr[3] & 0xff) << 24;

                    rdt.readFully(hdr_buf.array()); k = hdr_buf.getInt(0);

​

                    if ((k < 0) || (k > 10000000)) {

                        socket.close();

                        return;

                    }

                    if (k == 0) {

                        continue;

                    }

                    byte [] bit = new byte[k];

                    rdt.readFully(bit);

​

                    //updateConversationHandler.post(new updateUIThread(bit));

                    //picture_worker.queue.clear(); worker.queue.put(bit);

                    //picture_worker.deque.putLast(bit);

​

​

/*

                        byte [] out_data = pos_worker.outque.pollLast();

                        if (out_data != null) {

                            pos_worker.outque.clear();

                            wrt.write(out_data);

                        }

                        */

                    //float[] local_angles = pos_worker.get_mean_angles();

                    /*if (local_angles.length == 3) {

                        ByteBuffer out_buf = ByteBuffer.allocate(4 + 4 * 3);

                        out_buf.order(ByteOrder.LITTLE_ENDIAN);

                        out_buf.putInt(4 * 3);

                        out_buf.putFloat(local_angles[0]);

                        out_buf.putFloat(local_angles[1]);

                        out_buf.putFloat(local_angles[2]);

                        wrt.write(out_buf.array());

                    }*/

                }

            } catch (Exception e) {

            } finally {

                try {

                    socket.close();

                } catch (Exception e) {

                }

            }

        } catch (Exception e) {

            try {

                if (socket != null) {

                    socket.close();

                }

            } catch (Exception ef) {

            }

        }

        //connect_status = "close connection";

    }

}