長時間実行されるスクリプトやリモート コンピューターで実行されるスクリプトからメッセージやデータを中央の場所に収集すると便利な場合があります。これを示す 4 つのファイルが添付されています。
- 他のマシンまたはプロセスからメッセージを収集し、それらをデータ テーブルに入れる「サーバー」。 これを、他のスクリプトやテーブルとは別の JMP インスタンスで実行します。
- サーバーにメッセージを送信する「クライアント」JSL スクリプト。これをスクリプトに埋め込みます。
- サーバーにメッセージを送信する「クライアント」R スクリプト
- メッセージをサーバーに送信する「クライアント」python スクリプト
これがどのように表示されるかの例を次に示します。右側のクライアントは、異なるコンピューター上にある場合もあれば、同じコンピューター上に別の JMP のコピーがある場合もあります。
重要なコードは次のようになります。
サーバ
//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();
コールバック関数は次のようになります (実際の関数はもっと複雑です。以下を参照してください)。
//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;
);
ブロッキングを処理するもう少し複雑なコールバック関数を次に示します (共通):
もっと見る...
完全なサーバー コードの例を次に示します。
もっと見る...
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" ) );
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")
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;
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()
これは、機能的なロギング メカニズムよりもサンプル コードを探している人のためのソケット通信の紹介を目的としていますが、コメントや提案を歓迎します!
