47921_de-DE

liliconcom

Socket-Kommunikation zum Abrufen und Protokollieren von Nachrichten von JMP-, R- und Python-Skripten

Manchmal ist es hilfreich, Nachrichten oder Daten von Skripts mit langer Laufzeit oder Skripts, die auf Remotecomputern ausgeführt werden, an einem zentralen Ort zu sammeln.Im Anhang sind vier Dateien, die dies demonstrieren:

 

1. Ein „Server“, der Nachrichten von anderen Maschinen oder Prozessen sammelt und sie in eine Datentabelle einfügt. Führen Sie dies in einer von anderen Skripten oder Tabellen getrennten Instanz von JMP aus.
2. Ein 'Client'-JSL-Skript, das Nachrichten an den Server sendet, betten Sie dies in Skripte ein.
3. Ein „Client“-R-Skript, das Nachrichten an den Server sendet
4. Ein „Client“-Python-Skript, das Nachrichten an den Server sendet

 

Hier ist ein Beispiel dafür, wie dies aussehen könnte: Die Clients auf der rechten Seite können sich auf verschiedenen Computern oder separate Kopien von JMP auf demselben Computer befinden.

Der wichtige Code sieht so aus:

 

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();

 

Wobei die Callback-Funktion etwa so aussehen würde (die eigentliche Funktion ist komplexer, siehe unten):

//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;
);

Hier ist eine etwas komplexere Callback-Funktion, die das Blockieren behandelt (häufig):

Mehr sehen...

Hier ist ein Beispiel für einen vollständigen Servercode:

 

Mehr sehen...

 

 

JSL-Client

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" ) );

 

R-Client

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")

 

Python-Client

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;

 

Powershell-Client

$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()

 

Dies soll eher eine Einführung in die Socket-Kommunikation für alle sein, die nach Beispielcode suchen, als nach einem funktionalen Protokollierungsmechanismus, aber ich freue mich über Ihre Kommentare und Vorschläge!

Eine Einführung in die Socket-Kommunikation und eine Möglichkeit, Nachrichten von lange laufenden Skripten oder Remote-Computern zu erhalten.

Analytische AnwendungsentwicklungDienstprogramme