Proyecto escáner: Como comunicarse por serie con Arduino desde Java. Parte 2

Publicado en, octubre 29th, 2010 por Draft Ideader

Pues ya estoy de vuelta con el código en Java y una miniaplicacion para Arduino para mostrar como comunicaros con Arduino desde Java.

Al final he decidido utilizar un código que encontré en la pagina web de Arduino en el que muestran como mantener una conversación con Arduino desde Java. Me ha gustado sobre todo porque viene bien explicado y porque hace posible utilizar ese mismo código en diferentes plataformas comentando un par de líneas. La única pega es que esta en inglés, pero no creo que os de problemas, es sencillo de comprender. LINK AL CODIGO

Con este código voy a hacer un sencillísimo programa de Eco (le envío un mensaje a Arduino, este me lo devuelve y lo imprimo por pantalla).

Antes de nada quiero explicar un poco por encima como está implementado y que métodos tiene.

La clase se llama SerialTest, la cual hereda la clase abstracta SerialPortEventListener de gnu.io (RxTx) por lo tanto, como es abstracta, debemos implementar sus métodos. La clase solo tiene un método abstracto, serialEvent(SerialPortEvent ev) en cual se implementa como tratar un evento de ese tipo, en el ejemplo de la web de Arduino simplemente lo lee y lo imprime por pantalla, yo le añadiré un par más de lineas de código para poder distinguir cuando recibimos un mensaje desde Arduino.

Pero claro, solo con ese método no vamos a ningún sitio, así que en el ejemplo codifican también un método para iniciar y parar la conexión, con esto ya tenemos todo lo necesario para recibir datos desde Arduino y manejarlos.

Para enviar datos implementé un sencillísimo método que utiliza output que es un objeto de la clase OutputStream preparado para escribir por el puerto serie, y que se define al inicializar el puerto serie.

A continuación os voy a mostrar mi código modificado. Está preparado para funcionar en distribuciones GNU/Linux, pero podeis hacerlo compatible con Windows o Mac solo comentando y descomentando las siguientes líneas y sabiendo a que puerto se va a conectar el Arduino:

Compatible con windows:

	private static final String PORT_NAMES[] = {
			//"/dev/tty.usbserial-A9007UX1", // Mac OS X
			//"/dev/ttyUSB0", // Linux
                                      // "/dev/ttyUSB1",
			"COM3", // Windows
			};

private static final String PORT_NAMES[] = {

//"/dev/tty.usbserial-A9007UX1", // Mac OS X

//"/dev/ttyUSB0", // Linux

// "/dev/ttyUSB1",

"COM3", // Windows

};

Compatible con Mac:

	private static final String PORT_NAMES[] = {
			"/dev/tty.usbserial-A9007UX1", // Mac OS X
			//"/dev/ttyUSB0", // Linux
                                       //"/dev/ttyUSB1",
			//"COM3", // Windows
			};

private static final String PORT_NAMES[] = {

"/dev/tty.usbserial-A9007UX1", // Mac OS X

//"/dev/ttyUSB0", // Linux

//"/dev/ttyUSB1",

//"COM3", // Windows

};

package Serie;

//import para la entrada por teclado:
import java.io.BufferedReader;
import java.io.InputStreamReader;

// Imports necesarios para conectarnos por serie conb esta clase
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import gnu.io.CommPortIdentifier;
import gnu.io.SerialPort;
import gnu.io.SerialPortEvent;
import gnu.io.SerialPortEventListener;
import java.util.Enumeration;
import java.util.logging.Level;
import java.util.logging.Logger;

public class SerialTest implements SerialPortEventListener {

        boolean Conectado=false;

	SerialPort serialPort;
        /** The port we're normally going to use. */
	private static final String PORT_NAMES[] = {
			//"/dev/tty.usbserial-A9007UX1", // Mac OS X
			"/dev/ttyUSB0", // Linux
                        "/dev/ttyUSB1",
			//"COM3", // Windows
			};
	/** Buffered input stream from the port */
	private InputStream input;
	/** The output stream to the port */
	private OutputStream output;
	/** Milliseconds to block while waiting for port open */
	private static final int TIME_OUT = 2000;
	/** Default bits per second for COM port. */
	private static final int DATA_RATE = 9600;

	public void initialize() {
		CommPortIdentifier portId = null;
		Enumeration portEnum = CommPortIdentifier.getPortIdentifiers();

		// iterate through, looking for the port
		while (portEnum.hasMoreElements()) {
			CommPortIdentifier currPortId = (CommPortIdentifier) portEnum.nextElement();
			for (String portName : PORT_NAMES) {
				if (currPortId.getName().equals(portName)) {
					portId = currPortId;
					break;
				}
			}
		}

		if (portId == null) {
                        Conectado=false;
			System.out.println("Could not find COM port.");
			return;
		}

		try {
			// open serial port, and use class name for the appName.
			serialPort = (SerialPort) portId.open(this.getClass().getName(),
					TIME_OUT);

			// set port parameters
			serialPort.setSerialPortParams(DATA_RATE,
					SerialPort.DATABITS_8,
					SerialPort.STOPBITS_1,
					SerialPort.PARITY_NONE);

			// open the streams
			input = serialPort.getInputStream();
			output = serialPort.getOutputStream();

			// add event listeners
			serialPort.addEventListener(this);
			serialPort.notifyOnDataAvailable(true);
                        Conectado=true;
		} catch (Exception e) {
			System.err.println(e.toString());
		}
	}

	/**
	 * This should be called when you stop using the port.
	 * This will prevent port locking on platforms like Linux.
	 */
	public synchronized void close() {
		if (serialPort != null) {
			serialPort.removeEventListener();
			serialPort.close();
		}
	}

        public synchronized boolean conectado() {
            if (Conectado) { // puedo sustituirlo por serialPort !=null
                return true;
            } else {
                return false;
            }
        }

	/**
	 * Handle an event on the serial port. Read the data and print it.
	 */
	public synchronized void serialEvent(SerialPortEvent oEvent) {
		if (oEvent.getEventType() == SerialPortEvent.DATA_AVAILABLE) {
			try {
				int available = input.available();
				byte chunk[] = new byte[available];
				input.read(chunk, 0, available);

				// Displayed results are codepage dependent
                                System.out.println("");
				System.out.println("Arduino dice: "+new String(chunk));
              		} catch (Exception e) {
				System.err.println(e.toString());
			}
		}
		// Ignore all the other eventTypes, but you should consider the other ones.
	}

        public synchronized void sendMessage(String cadena) {

            byte[] asd;
            asd=cadena.getBytes();
            try {
                output.write(asd);
            } catch (IOException ex) {
                Logger.getLogger(SerialTest.class.getName()).log(Level.SEVERE, null, ex);
            }
	}

	public static void main(String[] args) throws Exception {
            boolean salir=false;
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            String linea="";
            SerialTest main = new SerialTest();

            while (salir==false) {
                main.initialize();
                if (main.conectado()) {
                    System.out.println("Prueba de ECO");
                    System.out.println("");
                    System.out.println("Aduino debe devolver lo que se le mande por aqui.");
                    System.out.println("");
                    System.out.println("Ahora puedes enviar tu tus mensajes para probar : )");

                    while (!linea.equals("fin")) {
                        try{
                            System.out.print("¿Qué le quieres decir a Arduino? :");linea = br.readLine();
                            if (linea.equals("fin")) {
                                main.close();
                                salir=true;
                            } else {
                                main.sendMessage(linea);
                            }

                        }catch(Exception e){}
                    }
                } else {
                    System.out.println("No se ha podido conectar.");
                    System.out.println(";¿Deseas volver a intentarlo? [s/n] :");linea =br.readLine();
                    if (linea.equals("s") || linea.equals("S")) {
                        salir=false;
                    } else {
                        salir=true;
                    }
                }
            }
	}
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

package Serie;

//import para la entrada por teclado:

import java.io.BufferedReader;

import java.io.InputStreamReader;

// Imports necesarios para conectarnos por serie conb esta clase

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import gnu.io.CommPortIdentifier;

import gnu.io.SerialPort;

import gnu.io.SerialPortEvent;

import gnu.io.SerialPortEventListener;

import java.util.Enumeration;

import java.util.logging.Level;

import java.util.logging.Logger;

public class SerialTest implements SerialPortEventListener {

boolean Conectado=false;

SerialPort serialPort;

/** The port we're normally going to use. */

private static final String PORT_NAMES[] = {

//"/dev/tty.usbserial-A9007UX1", // Mac OS X

"/dev/ttyUSB0", // Linux

"/dev/ttyUSB1",

//"COM3", // Windows

};

/** Buffered input stream from the port */

private InputStream input;

/** The output stream to the port */

private OutputStream output;

/** Milliseconds to block while waiting for port open */

private static final int TIME_OUT = 2000;

/** Default bits per second for COM port. */

private static final int DATA_RATE = 9600;

public void initialize() {

CommPortIdentifier portId = null;

Enumeration portEnum = CommPortIdentifier.getPortIdentifiers();

// iterate through, looking for the port

while (portEnum.hasMoreElements()) {

CommPortIdentifier currPortId = (CommPortIdentifier) portEnum.nextElement();

for (String portName : PORT_NAMES) {

if (currPortId.getName().equals(portName)) {

portId = currPortId;

break;

}

if (portId == null) {

Conectado=false;

System.out.println("Could not find COM port.");

return;

}

try {

// open serial port, and use class name for the appName.

serialPort = (SerialPort) portId.open(this.getClass().getName(),

TIME_OUT);

// set port parameters

serialPort.setSerialPortParams(DATA_RATE,

SerialPort.DATABITS_8,

SerialPort.STOPBITS_1,

SerialPort.PARITY_NONE);

// open the streams

input = serialPort.getInputStream();

output = serialPort.getOutputStream();

// add event listeners

serialPort.addEventListener(this);

serialPort.notifyOnDataAvailable(true);

Conectado=true;

} catch (Exception e) {

System.err.println(e.toString());

}

/**

* This should be called when you stop using the port.

* This will prevent port locking on platforms like Linux.

public synchronized void close() {

if (serialPort != null) {

serialPort.removeEventListener();

serialPort.close();

}

public synchronized boolean conectado() {

if (Conectado) { // puedo sustituirlo por serialPort !=null

return true;

} else {

return false;

}

/**

* Handle an event on the serial port. Read the data and print it.

public synchronized void serialEvent(SerialPortEvent oEvent) {

if (oEvent.getEventType() == SerialPortEvent.DATA_AVAILABLE) {

try {

int available = input.available();

byte chunk[] = new byte[available];

input.read(chunk, 0, available);

// Displayed results are codepage dependent

System.out.println("");

System.out.println("Arduino dice: "+new String(chunk));

} catch (Exception e) {

System.err.println(e.toString());

}

// Ignore all the other eventTypes, but you should consider the other ones.

}

public synchronized void sendMessage(String cadena) {

byte[] asd;

asd=cadena.getBytes();

try {

output.write(asd);

} catch (IOException ex) {

Logger.getLogger(SerialTest.class.getName()).log(Level.SEVERE, null, ex);

}

public static void main(String[] args) throws Exception {

boolean salir=false;

BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

String linea="";

SerialTest main = new SerialTest();

while (salir==false) {

main.initialize();

if (main.conectado()) {

System.out.println("Prueba de ECO");

System.out.println("");

System.out.println("Aduino debe devolver lo que se le mande por aqui.");

System.out.println("");

System.out.println("Ahora puedes enviar tu tus mensajes para probar : )");

while (!linea.equals("fin")) {

try{

System.out.print("¿Qué le quieres decir a Arduino? :");linea = br.readLine();

if (linea.equals("fin")) {

main.close();

salir=true;

} else {

main.sendMessage(linea);

}

}catch(Exception e){}

}

} else {

System.out.println("No se ha podido conectar.");

System.out.println(";¿Deseas volver a intentarlo? [s/n] :");linea =br.readLine();

if (linea.equals("s") || linea.equals("S")) {

salir=false;

} else {

salir=true;

}

En la siguiente entrada mostraré el código que necesita Arduino para que el eco funcione y pondré un vídeo mostrando su funcionamiento.

Si alguien detecta alguna errata, o sugiere mejoras, estas serán bienvenidas 🙂
PD: Arreglado error en el código.

Tags: Arduino, java, proyecto escaner, serie

Proyectos, ideas y demás :D

Proyecto escáner: Desarrollo del software de prueba del sensor. Parte 2

Proyecto escáner: Como comunicarse por serie con Arduino desde Java. Parte 3

Proyecto escáner: Como comunicarse por serie con Arduino desde Java. Parte 2

Páginas principales

Categorías