ServerWorker

package ispitna;

import scenarioKostadin.Server;

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

public class ServerWorker extends Thread {
    Socket socket;
    String filePath;

    public ServerWorker(Socket socket, String filePath) {
        this.socket = socket;
        this.filePath = filePath;
    }

    @Override
    public void run() {
        File dataFile = new File(filePath);

        try {
            DataInputStream inputStream = new DataInputStream(socket.getInputStream());
            BufferedWriter bw = new BufferedWriter(new FileWriter(dataFile, true));
            String message = inputStream.readUTF();
            String [] info = message.split(",");

            synchronized (ServerWorker.class) {
                bw.write(String.format("%s %d %s %s\n", socket.getInetAddress().getHostAddress(), socket.getPort(), info[0], info[1]));

                bw.flush();
                bw.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}