package comunication;
import gnu.io.CommPortIdentifier;
import gnu.io.PortInUseException;
import gnu.io.SerialPort;
import gnu.io.SerialPortEvent;
import gnu.io.SerialPortEventListener;
import gnu.io.UnsupportedCommOperationException;
import java.io.*;
import java.util.*;
/**
* Este es un ejemplo de uso del API de Comunicaciones Java que permite la
* lectura de información a través de uno de los puertos serie de la
* máquina en que se ejecuta.
* El ejemplo se ha probado en Windows y Solaris, utilizando la línea
* de código que identifica el puerto a utilizar correspondiente
*/
public class Comunication implements Runnable,SerialPortEventListener {
static CommPortIdentifier idPuerto;
static Enumeration listaPuertos;
InputStream entrada;
SerialPort puertoSerie;
Thread tLectura;
// En este ejemplo implementa un thread que es el que se encarga de
// que la aplicación se quede esperando en el puerto que se haya
// abierto a que se reciban datos.
// Primero abre el puerto y luego le fija los parámetros
public Comunication() {
// Si el puerto no está en uso, se intenta abrir
try {
puertoSerie = (SerialPort)idPuerto.open( "AplLectura",2000 );
} catch( PortInUseException e ) {
System.out.println(e);
}
// Se obtiene un canal de entrada
try {
entrada = puertoSerie.getInputStream();
} catch( IOException e ) {
System.out.println(e);
}
// Añadimos un receptor de eventos para estar informados de lo
// que suceda en el puerto
try {
puertoSerie.addEventListener( this );
} catch( TooManyListenersException e ) {
System.out.println("Peso : ");
System.out.println(e);
}
// Hacemos que se nos notifique cuando haya datos disponibles
// para lectura en el buffer de la puerta
puertoSerie.notifyOnDataAvailable( true );
// Se fijan los parámetros de comunicación del puerto
try {
puertoSerie.setSerialPortParams( 9600,
SerialPort.DATABITS_8,
SerialPort.STOPBITS_1,
SerialPort.PARITY_NONE );
} catch( UnsupportedCommOperationException e ) {
System.out.println(e);
}
// Se crea y lanza el thread que se va a encargar de quedarse
// esperando en la puerta a que haya datos disponibles
tLectura = new Thread( this );
tLectura.start();
}
@Override
public void run() {
try {
// En los threads, hay que procurar siempre que haya algún
// método de escape, para que no se queden continuamente
// bloqueados, en este caso, la comprobación de si hay datos
// o no disponibles en el buffer de la puerta, se hace
// intermitentemente
System.out.println("Entra hilo");
Thread.sleep( 2000 );
} catch( InterruptedException e )
{
System.out.println(e);
}
}
@Override
public void serialEvent( SerialPortEvent _ev ) {
System.out.println("Entra evento serial");
switch( _ev.getEventType() ) {
// La mayoría de los eventos no se trata, éstos son los
// que se producen por cambios en las líneas de control del
// puerto que se está monitorizando
case SerialPortEvent.BI:
case SerialPortEvent.OE:
case SerialPortEvent.FE:
case SerialPortEvent.PE:
case SerialPortEvent.CD:
case SerialPortEvent.CTS:
case SerialPortEvent.DSR:
case SerialPortEvent.RI:
case SerialPortEvent.OUTPUT_BUFFER_EMPTY:
break;
// Cuando haya datos disponibles se leen y luego se
// imprime lo recibido en la consola
case SerialPortEvent.DATA_AVAILABLE:
byte[] bufferLectura = new byte[20];
try {
while( entrada.available() > 0 ) {
int nBytes = entrada.read( bufferLectura );
}
System.out.print( new String(bufferLectura) );
} catch( IOException e ) {
System.out.println(e);
}
break;
};
//System.out.println("validar datos leídos y si son validos salir del app : ");
//System.exit(-1);
}
public static void main( String[] args ) {
// Lista de los puertos disponibles en la máquina. Se carga en el
// mimo momento en que se inicia la JVM de Java
listaPuertos = CommPortIdentifier.getPortIdentifiers();
while( listaPuertos.hasMoreElements() ) {
idPuerto = (CommPortIdentifier)listaPuertos.nextElement();
if( idPuerto.getPortType() == CommPortIdentifier.PORT_SERIAL ) {
if( idPuerto.getName().equals("COM4") ) { // WINDOWS
// Lector del puerto, se quedará esperando a que llegue algo
// al puerto
Comunication lector = new Comunication();
}
}
}
}
}
#include "FiveWin.ch"
LeerSerial()
function LeerSerial()
local oDlg, nComm := InitComm() , nStatus := "ok"
alerta("entro")
BytesAtPort( nComm, nStatus )
CloseComm( nComm )
alerta("salio")
return nil
function InitCOMM()
local cDcb, nError, nBytes
local nComm := OpenComm( "COM4", 1024, 128 )
if ! BuildCommDcb( "COM4:9600,n,8,1", @cDcb )
MsgStop( "Error BUILD!" )
return .f.
endif
#ifdef __CLIPPER__
if ! SetCommState( cDcb )
#else
if ! SetCommState( nComm, cDcb )
#endif
MsgStop( "Error SETCOMM!" )
return .f.
endif
return nComm
function BytesAtPort( nComm, nStatus )
local cBuffer := Space(20 ), x := 0, nBytes := 0
// n := ReadComm( nComm, @cBuffer) // <<<<---- program will lock here
for x := 1 to 20
n := ReadComm( nComm, @cBuffer) // <<<<---- program will lock here
if n > 0
exit
endif
next x
Msginfo( AllTrim( cBuffer ))
return nil
n := ReadComm( nComm, @cBuffer)
alert( GetCommError( nComm ) ) // = 0.00 valor retornado
alert(n) // = 0.00 valor retornado
alert(cBuffer) // retorno vacio
for x := 1 to 20
n := ReadComm( nComm, @cBuffer) // <<<<---- program will lock here
if n > 0
exit
endif
SysRefresh()
next x
Return to FiveWin para Harbour/xHarbour
Users browsing this forum: No registered users and 79 guests