interruptor - Mantener la comunicación entre Arduino y el programa Java

interruptor wifi arduino

Question

Obtuve un proyecto en la escuela que consiste en un auto de RC que se controla con WiFi. Funciona muy bien durante unos segundos, pero luego simplemente detiene la conexión e intenta volver a conectarse. La cosa es que si estoy haciendo un automóvil que depende de esa conexión inestable, puede causar accidentes. Ya sea a sí mismo o a una persona.

Quizás estoy haciendo algo mal? Mi pregunta es, ¿cómo mantengo esa conexión activa todo el tiempo? Aquí está mi programa hasta ahora:

Cliente Arduino:

#include <SPI.h>
#include <WiFi.h>

int status = WL_IDLE_STATUS;
char ssid[] = "mynet";
char pass[] = "password";

IPAddress remoteIp(192,168,80,165);
int port = 37899;

String message = "";

WiFiClient client;

void setup()
{
    // start the serial for debugging
    Serial.begin(9600);
    pinMode(9, OUTPUT);
    digitalWrite(9, LOW);

    //check if the wifi shield is present
    if(WiFi.status() == WL_NO_SHIELD){
        Serial.println("WiFi shield not present! Press reset to try again.");
        while(true); //stops the program
    }

    connectWiFi();
    printWifiStatus();
    connectClient(3);
}

void loop(){

    if(client){
        if(client.available()){

            char c = client.read();

            if(c != ''/n''){
                message += c;
            }
            else{
                Serial.println("Received message: "+message);
                checkMessage();
                sendMessage(message);
                message = "";
            }
        }
    }
}

void printWifiStatus() {
    // print the SSID of the network you''re attached to:
    Serial.print("SSID: ");
    Serial.println(WiFi.SSID());

    // print your WiFi shield''s IP address:
    IPAddress ip = WiFi.localIP();
    Serial.print("IP Address: ");
    Serial.println(ip);
}

void connectWiFi(){

    if( status != WL_CONNECTED){
        while(status != WL_CONNECTED){

            Serial.print("Attempting connection to network...");

            status = WiFi.begin(ssid, pass);
            delay(3000);

            if(status == WL_CONNECTED){
                Serial.println(" SUCSESS");
            }
            else{
                Serial.println(" FAILED");
                delay(3000);
                connectWiFi();
            }
        }
    }   
}

void connectClient(int retries){

    //Attempt connection to server

    if(retries <= 0){
        Serial.println("FAILED");
        Serial.println("Connection to server failed.");
        while(true);
    }

    Serial.print("Attempting conenction to server... ");

    if(client.connect(remoteIp, port)){
        Serial.println("SUCSESS");
        sendMessage("Hello server!");
    }
    else if(retries > 0){
        Serial.println("FAILED");
        connectClient(retries - 1);
    }

}

void checkMessage(){

    if(message == "on"){
        digitalWrite(9, HIGH);
    }

    if(message == "off"){
        digitalWrite(9, LOW);
    }
}

void sendMessage(String toSend){

    if(client){
        client.println(toSend+''/n'');
        client.flush();
        Serial.println("Sendt message: "+toSend);
    }
    else{
        Serial.println("Could not send message; Not connected.");
    }
}

Servidor Java:

import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;

public class Car_Client extends JFrame {

    private JTextField userText;
    private JTextArea chatWindow;

    private static final int serverPort = 37899;

    private ServerSocket server;
    private Socket connection;
    private BufferedWriter output;
    private BufferedReader input;

    private String message = "";

    public Car_Client() {

        userText = new JTextField();
        userText.setEditable(false);
        userText.addActionListener(
                new ActionListener() {
                    public void actionPerformed(ActionEvent event) {
                        sendMessage(event.getActionCommand());
                        userText.setText("");
                    }
                }
        );
        add(userText, BorderLayout.NORTH);
        chatWindow = new JTextArea();
        add(new JScrollPane(chatWindow), BorderLayout.CENTER);
        setSize(400, 300);
        setVisible(true);

    }

    public void startRunning() {
        try {

            server = new ServerSocket(serverPort, 100);
            while (true) {
                try {
                    waitForConnection();
                    setupStreams();
                    whileConnected();
                } catch (EOFException eofException) {
                    showMessage("Client terminated connection");
                } catch (IOException ioException) {
                    showMessage("Could not connect...");
                } finally {
                    closeStreams();
                }
            }

        } catch (IOException ioException) {
            ioException.printStackTrace();
        }

    }

    private void waitForConnection() throws IOException {

        showMessage("Waiting for someone to connect...");
        connection = server.accept(); //once someone asks to connect, it accepts the connection to the socket this gets repeated fast
        showMessage("Now connected to " + connection.getInetAddress().getHostName()); //shows IP adress of client

    }

    private void setupStreams() throws IOException {

        showMessage("creating streams...");
        output = new BufferedWriter(new OutputStreamWriter(connection.getOutputStream()));
        output.flush();
        input = new BufferedReader(new InputStreamReader(connection.getInputStream()));
        showMessage("Streams are setup!");

    }

    private void whileConnected() throws IOException {

        ableToType(true); //makes the user able to type

        do {

            char x = (char) input.read();
            while (x != ''/n'') {
                message += x;
                x = (char) input.read();
            }
            showMessage(message);
            message = "";

        } while (!message.equals("END")); //if the user has not disconnected, by sending "END"

    }

    private void closeStreams() {

        ableToType(false);

        showMessage("Closing streams...");
        try {
            output.close();
            input.close();
            connection.close();
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

    private void sendMessage(String message) {
        try {
            output.write(message + ''/n'');
            output.flush();
            showMessage("Sent: " + message);
        } catch (IOException ex) {
            chatWindow.append("/nSomething messed up whilst sending messages...");
        }

    }

    private void showMessage(final String message) {
        SwingUtilities.invokeLater(
                new Runnable() {
                    public void run() {
                        chatWindow.append(''/n'' + message);
                    }
                }
        );

    }

    private void ableToType(final boolean tof) {
        SwingUtilities.invokeLater(
                new Runnable() {
                    public void run() {
                        userText.setEditable(tof);
                    }
                }
        );
    }

}

¡Aclamaciones!
-kad

Answer 1

Lo resolví, lo hice para que el Arduino envíe datos al programa Java cada 15 segundos. Todo lo que necesitó fueron algunas líneas en el programa Arduino:

Variables:

long lastSendt;

Función de bucle:

void loop(){

    if(client){

        if(millis() >= (lastSendt + 15000)){
            sendCharacter(''*'')
        }

        if(client.available()){

            char c = client.read();

            if(c != ''/n''){
                message += c;
            }
            else{
                Serial.println("Received message: "+message);
                checkMessage();
                sendMessage(message);
                message = "";
            }
        }
    }
}

Función sendCharacter:

void sendCharacter(char toSend){

    if(client){
        client.println(toSend){
        lastSendt = millis();
    }else{
        Serial.println("Could not send character!");
    }
}