serielle Schnittstelle

[MQue]

Hallo,

ich hätte eine Frage zu der seriellen schnittstelle und zwar habe ich eine GUI und mit dieser GUI verbinde ich mich mit einer anderen GUI.
Mein Problem ist jetzt folgendes: damit ich auf meiner GUI noch was machen kann, wenn ich mit der seriellen Schnittstelle verbunden bin, habe ich die Verbindung in eine Run- Methode gegeben. Jetzt implementiere ich das Interface SerialPortEventListener und muss daher die Methode serialEvent überschreiben. Diese Methode soll aber innerhalb der run- Methode stehen, damit meine GUI nicht blockiert wird.

Hat da vielleicht jemand eine Idee, wie ich da elegant lösen könnte, innerhalb der run- Methode die serialEvent- Methode implementieren geht ja nicht.

vielen Dank für die Hilfe!!

lg
Michl

public class ComListener implements SerialPortEventListener{       
     
       public ComListener() {}
         
//die Methode serialEvent soll in der run- Methode stehen, da sonst meine GUI blockiert wird
  
        public void serialEvent(SerialPortEvent event) {
       
            if(event.getEventType()==SerialPortEvent.DATA_AVAILABLE){         
                String sNachricht = "";

                byte[] readBuffer = new byte[120];
                try {
                    //System.out.println("in SerialEvent");
                    while (ins.available() > 0) {int numBytes = ins.read(readBuffer);}
                    String nachricht = new String(readBuffer);         
                    char c = (char)0;
                    System.out.println("Nachricht: " + sNachricht);
                }
                    catch (IOException e) {System.out.println("Fehler: "+e);
                }     
            }
        } 
    }

 

[Rock Lobster]

Eigentlich müßte das doch so funktionieren, da der Listener ja zurückgerufen wird, sobald ein Event kommt. Dieses wird kurz ausgegeben, aber danach geht's ja gleich weiter. Da dürfte eigentlich nix blockieren.

Falls doch, müßtest Du vielleicht ein bißchen mehr Code zeigen, damit man verstehen kann, wieso da was blockieren sollte.

 

[MQue]

Mein code schaut momentan so wei unten angeführt aus, Ich empange sehr viele Daten und die Methode serialEvent würde dann sehr oft (bis andauern) aufgerufen werden, daher möchte ich die Kommunikation in einem eigenen Thread laufen lassen´. Unten im code habe ich momentan die 2 Methoden "serialEvent" und die "run" - Methode extra.

Vielleicht hättet ihr noch eine Idee, wie ich diese beiden Methoden verbinden könnte oder iwe ich das machen könnte, das während der Kommunikation (die ja fast andauernd statfindet) meine GUI- Oberfläche nicht blockiert.

vielen Dank auf jeden Fall für Eure Hilfe

lg Michl

public class SerielleSchnittstelle extends Thread implements SerialPortEventListener /* implements SerialPortEventListener */  {
     private Enumeration portList;		    /* Variablen für das Schreiben und Lesen über die serielle Schnittstelle */
     private CommPortIdentifier portId;
     private SerialPort serialPort;
     private OutputStream outs;    
     private InputStream ins;       
     
     public SerielleSchnittstelle()
	{
	try { 
	    portList = CommPortIdentifier.getPortIdentifiers();
	    while (portList.hasMoreElements()) 
		{
		portId = (CommPortIdentifier) portList.nextElement();
		if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) 
		    {
		    if (portId.getName().equals("COM1")) 
			{
			try {serialPort = (SerialPort) portId.open("COM1Application", 5000);} 
			catch (PortInUseException e) {System.out.println("Fehler bei open");}
			try {ins = serialPort.getInputStream();
			     outs = serialPort.getOutputStream();} 
			catch (IOException e) {System.out.println("Fehler bei Output Stream öffnen");}
			serialPort.notifyOnDataAvailable(true);
			try {serialPort.setSerialPortParams(57600, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);} 
			catch (UnsupportedCommOperationException e) {System.out.println("Fehler bei der Initialisierung der seriellen Schnittstelle");}   
			}
		    }	    
		}		
	    }
	catch (Exception ex) 
	    {
	    
	    }
	}
     
     public void run()
	{
	try {	    
	    byte[] readBuf = new byte[643];
	    byte[] writeBuf = new byte[643];
	    boolean hasData = true;
            int len = 0;
	    try {
		while (hasData)
		    {
		    System.out.println("Available: " + ins.available());
                    len = ins.read(readBuf);                        //lesen	
                    outs.write("das zu schreibende".getBytes());    //schreiben				
		    }
		} 
	    catch (IOException e) {System.out.println("Fehler beim Lesen: " + e);}
	    } 
	catch (Exception e) {}
	} 
     
     public void serialEvent(SerialPortEvent event) 
        {      
        if(event.getEventType()==SerialPortEvent.DATA_AVAILABLE){         
            String sNachricht = "";
        byte[] readBuffer = new byte[120];
        try {
            while (ins.available() > 0) 
                {
                int numBytes = ins.read(readBuffer);
                }
            String nachricht = new String(readBuffer);         
            char c = (char)0;
            System.out.println("Nachricht: " + sNachricht);
            }
        catch (IOException e) {System.out.println("Fehler: "+e);}     
            }
        }  
 }