The aprendizadorepo from alzemiro

aprendizadorepo's People

Contributors

Watchers

aprendizadorepo's Issues

Info

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.logging.Level;
import java.util.logging.Logger;

public class CommandExecutor {

private static final Logger LOGGER = Logger.getLogger(CommandExecutor.class.getName());

private final String ipAddress;
private final int port;

public CommandExecutor(String ipAddress, int port) {
    this.ipAddress = ipAddress;
    this.port = port;
}

public void executeCommands(List<String> commands) {
    ExecutorService executor = Executors.newSingleThreadExecutor();
    executor.submit(() -> {
        try (Socket socket = new Socket(ipAddress, port)) {
            OutputStream outputStream = socket.getOutputStream();
            BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            for (String command : commands) {
                LOGGER.log(Level.INFO, "Enviando comando: {0}", command);
                outputStream.write(command.getBytes());
                outputStream.flush();

                String response = reader.readLine();
                LOGGER.log(Level.INFO, "Resposta: {0}", response);
            }
        } catch (IOException e) {
            LOGGER.log(Level.SEVERE, "Erro ao executar comando", e);
        }
    });
}

public static void main(String[] args) {
    String ipAddress = "endereco_ip";
    int port = 1234;
    List<String> commands = Arrays.asList("root", "digicon", "reboot", "exit");

    CommandExecutor commandExecutor = new CommandExecutor(ipAddress, port);
    commandExecutor.executeCommands(commands);
}

}

Recommend Projects