Erlang、Julia、Elixir の接続
これは、Erlang/Elixir と Julia の異なる世界を接続するための私の野心的な小さなプロジェクトです。
Erlang プロセスと Elixir プロセスは同じ BEAM プラットフォーム上で実行され、PID を共有するため、相互にメッセージを送信できるようになりました。しかし、メッセージを Julia に送信して Erlang/Elixir に返すのはどうでしょうか?
Julia REPL では、 pServer
タスクを開始します。これにより、オンデマンドで独自のモジュール名前空間を持つEvalServer
タスクが生成されます。
julia > using Erjulix, Sockets
julia > pServer ( 6000 )
Task (runnable) @ 0x0000000110b30ab0
Elixir REPL では、Julia EvalServer
をリクエストし、それを使用して Julia 式を評価したり、Julia 関数を呼び出したりします。
iex ( 1 ) > { :ok , jl , _ } = :ejx_udp . srv ( 6000 ) # get an eval server from Julia
{ :ok , { { 127 , 0 , 0 , 1 } , 54465 } , "Main.##esm#257" }
iex ( 2 ) > :ejx_udp . eval ( jl , "using .Threads" )
{ :ok , [ ] }
iex ( 3 ) > :ejx_udp . call ( jl , :threadid )
{ :ok , 3 }
iex ( 4 ) > :ejx_udp . call ( jl , :factorial , [ 50 ] )
{ :error ,
"OverflowError( " 50 is too large to look up in the table; consider using `factorial(big(50))` instead " )" }
iex ( 5 ) > :ejx_udp . eval ( jl , """ # define a function on the Julia server
...(5)> function fact(x)
...(5)> factorial(big(x))
...(5)> end
...(5)> """)
{:ok, "Main.##esm#257.fact"}
iex(6)> :ejx_udp.call(jl, :fact, [50])
{:ok, 30414093201713378043612608166064768844377641568960512000000000000}
iex(7)> :timer.tc(:ejx_udp, :call, [jl, :fact, [55]])
{527,
{:ok,
12696403353658275925965100847566516959580321051449436762275840000000000000}}
最後のタイミングは、同じマシン (MacBook Pro) で両方のセッションが実行されている場合、作成された Julia fact
関数を Elixir からのデータで呼び出して結果を取得するためのピンポンに約 500 μs かかることを示しています。
iex ( 8 ) > a = Enum . map ( 1 .. 10 , fn _ -> :rand . uniform ( ) end )
[ 0.9414436609049482 , 0.08244595999142224 , 0.6727398779368937 ,
0.18612089183158875 , 0.7414592106015152 , 0.7340558985797445 ,
0.9511971092470349 , 0.7139960750204088 , 0.31514816254491884 , 0.94168140313657 ]
iex ( 9 ) > :ejx_udp . set ( jl , :a , a ) # create variable a on the Julia server
{ :ok , [ ] }
Julia REPL に戻ります。
julia > exmod = Erjulix . _ESM[ 1 ] # get access to the server module
Main. # #esm#257
julia > exmod . a # and to the created variable a
10 - element Vector{Any} :
0.9414436609049482
0.08244595999142224
0.6727398779368937
0.18612089183158875
⋮
0.9511971092470349
0.7139960750204088
0.31514816254491884
0.94168140313657
julia > using Plots ....
マシンの IP アドレスとキーを使用してpServer
起動すると、リモート クライアントとの通信が SHA-256 で暗号化されます。
julia > getipaddr ()
ip " 192.168.2.113 "
julia > key = Erjulix . genpasswd ( 12 )
" 1XQeFem2NUNw "
julia > pServer ( getipaddr (), 6000 , key)
Task (runnable) @ 0x00000001110e7b90
マシンの IP アドレスとそのキーを使用して、ローカル ネットワーク内の Raspberry Pi からpServer
にアクセスします。
iex ( 1 ) > :inet . gethostname ( )
{ :ok , 'raspberrypi' }
iex ( 2 ) > key = "1XQeFem2NUNw"
"1XQeFem2NUNw"
iex ( 3 ) > { :ok , jl , _ } = :ejx_udp . srv ( { { 192 , 168 , 2 , 113 } , 6000 , key } )
{ :ok , { { 192 , 168 , 2 , 113 } , 55052 , "j8Gh3G6dPfJm28UpthL0dXew" } , "Main.##esm#258" }
iex ( 4 ) > :ejx_udp . call ( jl , :factorial , [ 20 ] )
{ :ok , 2432902008176640000 }
iex ( 5 ) > :timer . tc ( :ejx_udp , :call , [ jl , :factorial , [ 20 ] ] )
{ 86620 , { :ok , 2432902008176640000 } }
pServer
Julia EvalServer
への暗号化されたネットワーク アクセス用の新しいキーを生成しました。タイミングは、2 台のマシン間でのネットワーク ピンポンにかかった時間が 100 ミリ秒未満であることを示しています (暗号化を使用しない場合は約 70 ミリ秒かかります)。
iex ( 9 ) > :ejx_udp . client ( jl , :exit )
{ :ok , :done }
これは、UDP 上の Erlang の Term Format に基づく相互運用性のプロトタイプです。
スレッドセーフ:もちろん、示されているようにサーバー モジュールにアクセスすることはスレッドセーフではないため、同時に実行すべきではありません。
セキュリティ: UDP サーバーのアドレスとポートを共有すると、リモート クライアントがファイル システムにアクセスできるようになります。 pServer
にキーを指定すると、データ送信には SHA-256 暗号化が使用されます。
ErlangTerm.jl
に依存しています。jwerl
のフォークに依存しています。メイン リポジトリの更新に問題があります。 Julia レジストリで利用可能な場合は、次のコマンドを使用してパッケージをインストールできます。
pkg > add Erjulix
Hex で利用可能な場合は、 mix.exs
の依存関係のリストにerjulix
追加することで、パッケージを Elixir にインストールできます。
def deps do
[
{ :erjulix , "~> 0.1.0" }
]
end
ドキュメントは ExDoc で生成し、HexDocs で公開できます。公開されると、ドキュメントは https://hexdocs.pm/erjulix で見つけることができます。