47921_it-IT

liliconcom

Comunicazione socket per ottenere e registrare messaggi da script JMP, R e python

A volte è utile raccogliere messaggi o dati in una posizione centrale da script di lunga durata o script in esecuzione su computer remoti.In allegato sono quattro file che lo dimostrano:

 

1. Un "server" che raccoglie i messaggi da altre macchine o processi e li inserisce in una tabella di dati. Eseguilo in un'istanza separata di JMP da qualsiasi altro script o tabella.
2. Uno script JSL "client" che invia messaggi al server, incorporalo negli script.
3. Uno script R "client" che invia messaggi al server
4. Uno script python "client" che invia messaggi al server

 

Ecco un esempio di come potrebbe apparire, i client sulla destra possono trovarsi su computer diversi o copie separate di JMP sullo stesso computer.

Il codice importante si presenta così:

 

server

//Create a socket
con = Socket();

//Use a specific address and port on this computer
con << Bind( "10.0.0.2", "12345" );

//Tell this socket to be ready for other sockets to connect to it
con << Listen();

//Verify that the connection is active
con << getsockname;

//When something connects to this socket, call a function to handle
//the connection.  Accept connections for the next 5 minutes.
con << Accept(callbackfn, 300);

//Now messages can be sent to this connection.

//When all done, close the connection
con << close();

 

Dove la funzione di callback sarebbe simile a questa (la funzione effettiva è più complessa, vedi sotto):

//Simplified function to handle communication with the client, do not use as is
callbackfn = function( {x}, 
 
 If( x[2] == "ok", 
  //Get data
  r = x[4] << recv( 1000 );
  
  //While data was received
  While( r[2] == "ok",
  
   //Write it to the log
   write( Blob to Char( r[3] ) );
   
   //try to get more data
   r = x[4] << recv( 1000 );
  );
 );
 
 //close the connection to the client
 x[4] << Close;
);

Ecco una funzione di callback leggermente più complessa che gestisce il blocco (comune):

Visualizza di più...

Ecco un esempio di un codice server completo:

 

Visualizza di più...

 

 

Cliente JSL

Names default to here( 1 );

//function to send a message to a waiting connection
SendMessage = Function( {message},

 //Create a socket
 con = Socket();
 
 //Connect to a socket that is already bound to, listening on, and accepting
 //connections on a port.  This is the server IP address, not the client.
 con << Connect( "10.0.0.2", "12345" );
 
 //Send data
 r = con << Send( Char To Blob( message ) );
 
 ///check that the data was sent
 if(r[2] == "ok", result = "sent", result = "fail" );
 
 //close the connection
 con << Close;
 return( result );
);

//send messages
Write( SendMessage( "Hi" ) );

 

Cliente R

sendmessage = function( message ) {
  con <- socketConnection(host="10.0.0.2", port = 12345, blocking=FALSE,
                          server=FALSE, open="r+")
  
  write_resp <- write(message, con)
  close(con)
}

sendmessage("Hi from R")

 

Cliente Python

import socket
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect(("10.0.0.2", 12345))
client_socket.send("Hello from Python")
client_socket.close()
break;

 

Cliente Powershell

$socket = new-object System.Net.Sockets.TcpClient( "10.0.0.2", 12345)
$stream = $socket.GetStream()
$writer = new-object System.IO.StreamWriter $stream
$writer.WriteLine( "Hello from Powershell`n" )
$writer.Flush()
$writer.Close()

 

Questo vuole essere più un'introduzione alla comunicazione socket per chiunque cerchi codice di esempio che un meccanismo di registrazione funzionale, ma accolgo con favore i tuoi commenti e suggerimenti!

Un'introduzione alla comunicazione socket e un modo per ricevere messaggi da script di lunga durata o macchine remote.

Sviluppo di applicazioni analiticheUtilità