Tag: tcp

I have created a TCP server thread that I want to continue running and saved in the IOT device listener, that is, the RFID reader.
Since I only have one client
Please check my code and give your help.

the public class TcpServerThread extends the thread {

static static end String TAG = "TcpServerThread";


private boolean run_ = true;
Flow of DataInputStream;
ServerSocket serverSocket;
Socket ClientSocket;


public TcpServerThread () {
super();
Start(); // start the thread
}


@Cancel
public void run () {


Long loop_count = Long.valueOf (0);


byte[] inBytes = new byte[200];
int a = 1025;
Chain IP = MiscUtilities.getIpAccess ();
Log.d (TAG, "IP" + IP);
// creating a socket to listen to on a given port
Log.d (TAG, "SUCCESSFUL OPEN PORT in" + a);
try {
serverSocket = new ServerSocket (a);

} capture (IOException e) {
Log.d (TAG, "execute: [exception occured in creating the socket]"+ e.getLocalizedMessage ());
}

int input = 0;
while (run_) {

Log.d (TAG, "run (): start");
loop_count ++;
try {
while (serverSocket! = null) {
Log.d (TAG, "run (): running");
try {
// accepting the incoming socket connection request
long start = System.currentTimeMillis ();
clientSocket = serverSocket.accept ();
clientSocket.setKeepAlive (true);

if (clientSocket! = null) {
long established = (System.currentTimeMillis () - started);
Log.d (TAG, "[Connection made at]: "+ clientSocket.getRemoteSocketAddress () +" in mills: "+ established);

DataInputStream stream = new DataInputStream (clientSocket.getInputStream ());
DataOutputStream outToServer = new DataOutputStream (clientSocket.getOutputStream ());

while ((input = stream.read (inBytes))! = -1) {
Log.d (TAG, "Read size is" + entry);
Log.d (TAG, "Data is" + MiscUtilities.bytesToHex (inBytes));

outToServer.writeByte (10);

}

}

} capture (IOException e) {
Log.d (TAG, "IOexception occurred:" + e.getLocalizedMessage ());
continue;

} catch (exception e) {
Log.d (TAG, "EXCEPTION occurred:" + e.getLocalizedMessage ());
continue;
}

}

} catch (exception e) {
// we have to pay attention to the IllegalStateException cases
Log.d (TAG, "[Exception occured] : "+ e.getLocalizedMessage ());
MiscUtilities.handleSilentException (e);
continue;

}

}
try {
throw a new exception RuntimeException (TAG + "Crashed !!");
} catch (RuntimeException e) {
MiscUtilities.handleSilentException (e);
}
}

abort the public vacuum () {
run_ = false;
closeServer ();
interrupt();
}

public void closeServer () {

try {
serverSocket.close ();
clientSocket.close ();
stream.close ();
} catch (exception e) {
Log.d (TAG, "closeServer:" + e.getLocalizedMessage ());
} Finally {
Start();
}
}

Can anyone review my code and provide comments please?