Notes

package tr.com.solvia.weigherbridge.socket.impl;

import tr.com.solvia.weigherbridge.socket.SocketAlgorithm;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class SocketAlgorithmImpl implements SocketAlgorithm {

ServerSocket serverSocket;
Socket socket;
@Override
public void runningSocketServer(int socketPort) {
try {
serverSocket = new ServerSocket(socketPort);
socket = serverSocket.accept();
System.out.println("The Solvia Socket Server is running...");
} catch (IOException e) {
e.printStackTrace();
}
}

@Override
public void stopSocketServer(int socketPort) {
try {

ObjectInputStream input = new ObjectInputStream(socket.getInputStream());
while(true)
{
Object object = input.readObject();
if(object instanceof String)
{
String command = ((String) object).trim();
if(command.equals("stop"))
break;
}
}
socket.close();
}
catch (IOException e) { System.err.println(e); }
catch (ClassNotFoundException e) { e.printStackTrace(); }
}

public void socketServer(Object writeToClient, int socketPort) throws IOException {
serverSocket = new ServerSocket(socketPort);

try {
while (true) {
socket = serverSocket.accept();
try {
InputStreamReader in = new InputStreamReader(socket.getInputStream());
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
out.println(writeToClient);
} catch (Exception e) {
e.printStackTrace();
}
}
} catch (Exception e) {
e.printStackTrace();
}
}

@Override
public void socketClient(Object writeToServer, int socketPort) throws IOException {
socket = new Socket("localhost",socketPort);
PrintWriter pr = new PrintWriter(socket.getOutputStream(), true);
pr.println(writeToServer);
pr.flush();

}
}