Il est parfois utile de collecter des messages ou des données dans un emplacement central à partir de scripts de longue durée ou de scripts exécutés sur des ordinateurs distants.Ci-joint quatre fichiers qui le démontrent :
- Un "serveur" qui collecte les messages d'autres machines ou processus et les place dans une table de données. Exécutez ceci dans une instance distincte de JMP à partir de tout autre script ou table.
- Un script JSL "client" qui envoie des messages au serveur, intégrez-le dans les scripts.
- Un script R 'client' qui envoie des messages au serveur
- Un script python 'client' qui envoie des messages au serveur
Voici un exemple de ce à quoi cela pourrait ressembler, les clients sur la droite peuvent être sur des ordinateurs différents, ou des copies distinctes de JMP sur le même ordinateur.
Le code important ressemble à ceci :
Serveur
//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();
Où la fonction de rappel ressemblerait à ceci (la fonction réelle est plus complexe, voir ci-dessous) :
//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;
);
Voici une fonction de rappel légèrement plus complexe qui gère le blocage (commun) :
Voir plus...
Voici un exemple de code serveur complet :
Voir plus...
Client 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" ) );
Client 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")
Client 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;
Client 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()
Il s'agit plus d'une introduction à la communication par socket pour tous ceux qui recherchent un exemple de code qu'un mécanisme de journalisation fonctionnel, mais vos commentaires et suggestions sont les bienvenus !
