Prοblem écriture sur le port série de Java

Question

en double de Implementation of Xmodem Protocol in Java

---

Salut, je dois mettre en œuvre le protocole XMODEM pour recevoir un fichier à partir d'un périphérique cible. Pour cela, je dois demander le fichier, puis pour chaque paquet de 128 octets reçu, je dois envoyer un accusé de réception. Mon problème est quand j'ouvre un flux de sortie pour demander le dossier, il écrira mais après que je ne peux pas écrire encore au flux de sortie. Quel est le problème que je ne reçois pas? S'il vous plaît aidez-moi; J'ai des problèmes.

merci pour la réponse. package writeToPort;

import java.awt.Toolkit; import java.io. ; import java.util.;

import javax.comm. *; import javax.swing.JOptionPane;

constantes d'importation.Constantes;

classe publique Flashwriter implémente Runnable, SerialPortEventListener { Enumeration portList; CommPortIdentifier portId; Chaîne messageString = "\ r \ nFLASH \ r \ n"; SerialPort serialPort; OutputStream outputStream, outputStream2; InputStream inputStream; // Thread readThread; Chaîne un, deux; String test = "ONLINE"; Chaîne [] dispArray = new Chaîne 1; int i = 0;

Thread readThread; 

byte[] readBufferArray; 
int numBytes; 
String response; 
FileOutputStream out; 
final int FLASH = 1, FILENAME = 2; 
int number; 

File winFile; 

public static void main(String[] args) throws IOException { 
    Flashwriter sm = new Flashwriter(); 
    sm.FlashWriteMethod(); 
} 

public void FlashWriteMethod() throws IOException { 

    portList = CommPortIdentifier.getPortIdentifiers(); 
    winFile = new File("D:\\testing\\out.FLS"); 

    while (portList.hasMoreElements()) { 
     portId = (CommPortIdentifier) portList.nextElement(); 
     if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) { 
      if (portId.getName().equals("COM2")) { 
       // if (portId.getName().equals("/dev/term/a")) { 
       try { 
        serialPort = (SerialPort) portId.open("SimpleWriteApp", 
          1000); 
       } catch (PortInUseException e) { 
       } 

       try { 
        outputStream = serialPort.getOutputStream(); 
        inputStream = serialPort.getInputStream(); 

        System.out.println(" Input Stream... " + inputStream); 
       } catch (IOException e) { 
        System.out.println("IO Exception"); 
       } 
       try { 
        serialPort.addEventListener(this); 

       } catch (TooManyListenersException e) { 
        System.out.println("Tooo many Listener exception"); 
       } 
       serialPort.notifyOnDataAvailable(true); 


       try { 
        serialPort.setSerialPortParams(9600, 
          SerialPort.DATABITS_8, SerialPort.STOPBITS_1, 
          SerialPort.PARITY_NONE); 
        serialPort 
          .setFlowControlMode(SerialPort.FLOWCONTROL_NONE); 
        // serialPort.disableReceiveTimeout(); 

        // outputStream.write(messageString.getBytes()); 

        // sendRequest("/r/n26-02-08.FLS/r/n"); 
        number = FLASH; 
        sendRequest(number); 

       } catch (UnsupportedCommOperationException e) { 
       } 

      } 
     } 
    } 
} 

public void serialEvent(SerialPortEvent event) { 
    SerialPort port = (SerialPort) event.getSource(); 

    switch (event.getEventType()) { 
    case SerialPortEvent.DATA_AVAILABLE: 
     try { 
      while (inputStream.available() > 0) { 
       numBytes = inputStream.available(); 
       readBufferArray = new byte[numBytes]; 
       // int readtheBytes = (int) inputStream.skip(2); 
       int readBytes = inputStream.read(readBufferArray); 

       one = new String(readBufferArray); 
       System.out.println("readBytes " + one); 

      if (one.indexOf("FLASH_") > -1 & !(one.indexOf("FLASH_F") > -1)) { 
       System.out.println("got message"); 
       response = "FLASH_OK"; 
       // JOptionPane.showMessageDialog(null, 
       // "ONLINE", 
       // "Online Dump", 
       // JOptionPane.INFORMATION_MESSAGE); 
       // Toolkit.getDefaultToolkit().beep(); 
       // outputStream.write("\r\nONLINEr\n".getBytes()); 
       // outputStream.flush(); 
       // outputStream.write("/r/n26-02-08.FLS/r/n".getBytes()); 

       number = FILENAME; 
       sendRequest(number); 
      } 

      out = new FileOutputStream(winFile, true); 
      out.write(readBufferArray); 
      out.close(); 

      } 
     } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
     readBufferArray = null; 
     // break; 
    } 

    // try { 
    // int c; 
    // while((c = inputStream.read()) != -1) { 
    // out.write(c); 
    // } 
    // } catch (IOException e) { 
    // // TODO Auto-generated catch block 
    // e.printStackTrace(); 
    // } 
    // // readBufferArray=null; 
    // break; 
    // } 
    // if (inputStream != null) 
    // try { 
    // inputStream.close(); 
    // if (port != null) port.close(); 
    // } catch (IOException e) { 
    // // TODO Auto-generated catch block 
    // e.printStackTrace(); 
    // } 
    //  
    // 
    readThread = new Thread(this); 
    readThread.start(); 

} 

public void run() { 
    try { 
     System.out.println("In run() function "); 
     Thread.sleep(1000); 

    } catch (InterruptedException e) { 
     System.out.println("Interrupted Exception in run() method"); 
    } 
} 

public void dispPacket(String packet) { 
    if (response == "FLASH_OK") { 
     System.out.println("disppacket " + packet); 
    } else { 
     System.out.println("No resust"); 
    } 
} 

public void sendRequest(int num) { 
    switch (num) { 
    case FLASH: 
     try { 
     // outputStream = serialPort.getOutputStream(); 
      outputStream.write("AT".getBytes()); 
     // outputStream.write("\r\n26-02-08.FLS\r\n".getBytes()); 

      System.out.println("Flash switch"); 
     // outputStream.close(); 
      outputStream.flush(); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
     break; 
    case FILENAME: 
     try { 
      //outputStream =(serialPort.getOutputStream()); 
      outputStream.write("\r\nSUNSHINE\\06-03-09.FLS\r\n".getBytes()); 

      System.out.println("File name"); 
      outputStream.flush(); 

     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
     break; 

    } 
} 

}

Answer 1

Peut-être que les cours d'eau bloquent.

Java nio a des canaux qui ne bloquent pas. Essayez d'en utiliser un. Il s'agit d'un sample of reading a file with nio. Je ne suis pas sûr si la même chose s'applique pour vous ou non.

J'espère que ça aide.