Socket

import java.io.*;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
 
public class IPAServer {
 
    private class ClientThread extends Thread {
 
        public ClientThread() {
        }
 
        @Override
        public void run() {
            try {
                mySocket = serverSocket.accept();
                while (!stop_server) {
                    InputStream is = mySocket.getInputStream();
                    int r = is.available();//тут у меня проблема так как для сокетов нельзя использовать available сейчас 
//борюсь как можно поправить. Моя проблема в том что я не знаю сколько байт принимаю от клиента. Если у тя свой ///протокол то можно все упростить если тебе интересно.
                    if (r != 0) {
                        MainFrame.StartIPACleint();
                        byte[] buf =new byte[r];
                        mySocket.getInputStream().read(buf);
                        IPAClient.SendByteToClient(buf);
                        MainFrame.SetTextLog("[S]IPA [" + String.valueOf(port)
                                + "] : " + bytesToHex(buf) + "\n");
                    }
                }
            } catch (IOException ex) {
                System.out.println(ex);
            }
        }
    }
    private int port;
    private ServerSocket serverSocket;
    private boolean stop_server = false;
    private ClientThread clientthread;
    private static Socket mySocket;
    final protected static char[] hexArray = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F'};
 
    public IPAServer(int _port, String _ipadress) {
        try {
            this.port = _port;
            this.serverSocket = new ServerSocket(port, 0, InetAddress.getByName(_ipadress));
            clientthread = new ClientThread();
            clientthread.start();
        } catch (IOException ex) {
            System.out.println(ex);
        }
    }
 
    public void SendDataFromServer(String _data) {
        try {
            OutputStream os = mySocket.getOutputStream();
            os.write(_data.getBytes());
        } catch (Exception ex) {
            System.out.println(ex);
        }
    }
 
    public static void SendByteToServer(byte _buf[]) {
        OutputStream os;
        try {
            if (mySocket != null) {
                os = mySocket.getOutputStream();
                os.write(_buf);
            }
        } catch (Exception ex) {
            System.out.println(ex);
        }
    }
 
    public String bytesToHex(byte[] bytes) {
        char[] hexChars = new char[bytes.length * 2];
        int v;
        for (int j = 0; j < bytes.length; j++) {
            v = bytes[j] & 0xFF;
            hexChars[j * 2] = hexArray[v >>> 4];
            hexChars[j * 2 + 1] = hexArray[v & 0x0F];
        }
        return new String(hexChars);
    }
}

import java.io.*;
import java.net.Socket;
 
public class IPAClient {
 
    private class DataListener extends Thread {
 
        public DataListener() {
        }
 
        public void run() {
            try {
                clSocket = new Socket(IPadress, port);
                while (!stoprun) {
                    InputStream is = clSocket.getInputStream();
                    int r = is.available();//Тут тоже available не канает. 
                    if (r > 0) {
                        byte[] buf = new byte[r];
                        clSocket.getInputStream().read(buf);
                        if (!OMLClient.getSock()) {
                            buf = ConvertByteBuffer(buf);
                        }
                        IPAServer.SendByteToServer(buf);
//Вывод сообщения в текстовое поле у андроида такого неу :) 
                        MainFrame.SetTextLog("[C]IPA [" + String.valueOf(port) + "] : " + bytesToHex(buf) + "\n");
                    }
                }
            } catch (Exception ex) {
                System.out.println(ex);
            }
        }
    }
    private int port;
    private String IPadress;
    private static Socket clSocket = null;
    private DataListener datalistener;
    public boolean stoprun = false;
    final protected static char[] hexArray = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F'};
 
    public IPAClient(int _port, String _ipadress) {
        this.port = _port;
        this.IPadress = _ipadress;
        datalistener = new DataListener();
        datalistener.start();
    }
 
    public static boolean getSock() {
        if (clSocket != null) {
            return true;
        }
        return false;
    }
 
    public static void SendByteToClient(byte _buf[]) {
        OutputStream os;
        try {
            if (clSocket != null) {
                os = clSocket.getOutputStream();
                os.write(_buf);
            }
        } catch (Exception ex) {
            System.out.println(ex);
        }
    }
 
    public String bytesToHex(byte[] bytes) {
        char[] hexChars = new char[bytes.length * 2];
        int v;
        for (int j = 0; j < bytes.length; j++) {
            v = bytes[j] & 0xFF;
            hexChars[j * 2] = hexArray[v >>> 4];
            hexChars[j * 2 + 1] = hexArray[v & 0x0F];
        }
        return new String(hexChars);
    }
 
    private byte[] ConvertByteBuffer(byte[] buff) {
        for (int i = 0; i < buff.length; i++) {
            if ((buff[i] == (byte) 0x0B) && (buff[i + 1] == (byte) 0xBB)) {
                buff[i] = (byte) 0x0F;
                buff[i + 1] = (byte) 0xA3;
                break;
            }
        }
        return buff;
    }
 
    public void StopClient() {
        stoprun = false;
    }
}