trasferimento doppio tra java e simulink usando udp

Question

Ho bisogno di trasferire valori decimali tra il programma Java e un modello Simulink, per farlo uso i socket UDP, non sono un problema nel lato java. In Simulink sono in grado di inviare i valori usando il blocco 'Stream Output', ma il problema si presenta durante la ricezione da java! il blocco 'Stream input' non riceve nulla. Sto usando il protocollo standard UDP, con la porta UDP locale corretta e l'indirizzo è 'localhost'. Per favore dimmi come ricevere correttamente un doppio in simulink con udp, o anche con altri metodi, che importa trasferire i dati. grazie in anticipo. qui sono un certo codice:

localSocket = new DatagramSocket(9010); 

...

public static void localSend(String msg,int PORT) throws Exception{ 
    DatagramPacket sendPacket = null,encPacket=null; 
    try { 
     sendPacket = new DatagramPacket(msg.getBytes(), msg.getBytes().length, InetAddress.getLocalHost(), PORT); 
    } catch (Exception e) { 
     System.out.printf("Error!"); 
    } 
    localSocket.send(sendPacket); 
} 

e nel metodo principale:

localSend(myMessage, 9005); 

'setup Board' del blocco del 'Input flusso' è Simulink è come qui sotto:

ecco come ricevo d ata da Simulink ins Java (il metodo):

public static String localReceive() throws Exception{      
    DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length); 
    int count=0; 
     try { 
      localSocket.receive(receivePacket); 
      return new String(receivePacket.getData(),receivePacket.getOffset(),receivePacket.getLength()); 
      } catch (SocketTimeoutException socketTimeoutException) { 
       return defaultValue; 
      } 
} 

e la configurazione di blocco "Uscita Stream" in Simulink:

Answer 1

ho fatto un trucco. 'Packet Input' blocco Simulink, e 'decodifica ASCII',

i regolare i parametri di questi 2 blocchi come segue:

e nel lato java , ho riformattato il doppio con questo metodo:

public static String reformat(String str){ 
    double d = 0; 
    DecimalFormat df=null; 
    try { 
     d = Double.parseDouble(str); 
    } catch (NumberFormatException numberFormatException) { 
     return "0.00000"; 
    } 
    if(d>=0){ 
    String[] sp=str.split("\\."); 
    if(sp[0].length()==0) 
    df= new DecimalFormat("0.00000"); 
    if(sp[0].length()==1) 
    df= new DecimalFormat("0.00000"); 
    if(sp[0].length()==2) 
     df= new DecimalFormat("00.0000"); 
    if(sp[0].length()==3) 
     df= new DecimalFormat("000.000"); 
    if(sp[0].length()==4) 
     df= new DecimalFormat("0000.00"); 
    if(sp[0].length()==5) 
     df= new DecimalFormat("00000.0"); 
    } 
    else{ 
    String[] sp=str.split("\\."); 
    if(sp[0].length()==1) 
    df= new DecimalFormat("0.0000"); 
    if(sp[0].length()==2) 
    df= new DecimalFormat("0.0000"); 
    if(sp[0].length()==3) 
     df= new DecimalFormat("00.000"); 
    if(sp[0].length()==4) 
     df= new DecimalFormat("000.00"); 
    if(sp[0].length()==5) 
     df= new DecimalFormat("0000.0"); 
    if(sp[0].length()==6) 
     df= new DecimalFormat("000000"); 
    } 

    try { 
     return df.format(d); 
    } catch (Exception e) { 
     return "0.00000"; 
    } 
} 

brevemente: il blocco di input del pacchetto riceve 7 ASCII ogni volta, e in java i riformatta il doppio da combinare di 7 caratteri (compreso il punto e il meno).

Spero che questo aiuti qualcuno.

aggiornamento:

some self explanatory extra code: 

//somewhere before: 
//Global variables 
    String defaultValue="0",ip="xxx.xx.xx.xx"; 
    DatagramSocket remoteSocket,localSocket; 
    byte[] receiveArray,receiveKey,receiveSig,sendSig; 
    int remoteSendPort=xxx,localSendport=xxx, 
     remoteReceivePort=xxx,localReceivePort=xxx;  
    String feedback,control_val,ReceivedTimeStamp; 
    InetAddress IPAddress;  
... 
//receive message from the other java program in pc2 
    public void remoteMsgSend(byte[] msg,InetAddress IPAddress, int PORT) {  
     try {  
      DatagramPacket sendPacket = null; 
      try { 
       sendPacket = new DatagramPacket(msg, msg.length, IPAddress, PORT); 
      } catch (Exception e) { 
       System.out.printf("Error! check ports"); 
      } 
      remoteSocket.send(sendPacket); 
     } catch (IOException ex) { 
      System.out.println("IOException! remote send"); 
     } 
    } 
    //receive message from the other java program in pc2 
    public String remoteMsgReceive() {      
     DatagramPacket receivePacket = new DatagramPacket(receiveArray, receiveArray.length); 
     byte[] r1; 
     int count=0,len,offset; 
      try { 
       remoteSocket.receive(receivePacket); 
       r1=receivePacket.getData(); 
       len=receivePacket.getLength(); 
       offset=receivePacket.getOffset(); 
       r1=Arrays.copyOfRange(r1, offset, len); 
       remoteOk=true; 
       return new String(r1); 
       } catch (Exception ex) { 
//     System.out.println("remote receive time out: " +ex.getMessage()); 
        remoteOk=false; 
        return defaultValue; 
       } 
    } 

    //send data to matlab on this pc 
    public void localSend(String msg,int PORT) { 
     DatagramPacket sendPacket = null; 
     try { 
      sendPacket = new DatagramPacket(msg.getBytes(), msg.getBytes().length, InetAddress.getLocalHost(), PORT); 
     } catch (Exception e) { 
      System.out.printf("Error! check ports"); 
     } 
     try { 
      localSocket.send(sendPacket); 
     } catch (IOException ex) { 
      System.out.println("localsend error"); 
     } 
    } 
    //receive data from Matlab on this pc 
    public String localReceive() {      
     DatagramPacket receivePacket = new DatagramPacket(receiveArray, receiveArray.length); 

     String rec; 
      try { 
       localSocket.receive(receivePacket); 
       rec=new String(receivePacket.getData(),receivePacket.getOffset(),receivePacket.getLength()); 
       localOk=true; 
       return rec; 
       } catch (Exception ex) { 
//       System.out.println("local receive time out " +ex.getMessage()); 
          localOk=false; 
          return defaultValue; 
       } 
    } 

Answer 2

Un'altra soluzione, con l'ingresso flusso in Simulink. Basta aggiungere un terminatore "\ n" a ciascun messaggio da java.