erlang - Elixir/Erlang : Communication with external process

Question

假设我有一个简单的 python 脚本，它使用 subprocess 执行 elixir/erlang 脚本模块。

假设 python 脚本的 OS PID 是 P1运行的生成的 elixir/erlang 脚本是 P2 .

我想知道P1之间的通讯是否和 P2是可能的。更具体地说，P1写一些东西到stdin的 P2 , 和 P2从 P1 读取接收到的输入并将一些相应的输出写入它自己的stdout和 P1从 stdout 读取的 P2并再次向 stdin 写入内容的 P2等等。

我知道另一种方法是可能的，即从 elixir/erlang 内部产生外部进程，然后与进程通信。任何帮助表示赞赏，谢谢。

Answer 1

是的，这种跨语言的 IPC 是完全可能的。绝大多数文档和博客文章等(以及迄今为止在 StackOverflow 上的回复!)假设与您似乎在问的相反 - 也就是说，他们假设 Erlang/Elixir 正在产生 Python 子进程，而不是Python 产生一个 Erlang/Elixir 子进程。如果没问题(即你的 Erlang 或 Elixir 应用程序启动 Python 进程没问题)，那就太好了! Badu 的回答将帮助您做到这一点，您也可以访问 the documentation for Elixir's Port module供额外引用。

但这似乎不是您寻求的答案，而且不那么有趣。世界需要更多关于如何反其道而行之的文档，所以让我们深入了解将 Erlang 作为 Python 脚本的子进程运行的美妙世界!

首先，我们的 Python 脚本(eip.py):

#!/usr/bin/env python
from subprocess import Popen, PIPE

erl = Popen(['escript', 'eip.escript'],
            stdin=PIPE, stdout=PIPE, stderr=PIPE)
ping = input('Ping: ')

outs, errs = erl.communicate(input=ping.encode('utf-8'),
                                 timeout=15)

print(outs.decode('utf-8'))

在 Erlang 方面(正如您可能已经在 Python 代码中注意到的那样)，一个非常简单的方法是使用 escript程序，它允许我们编写或多或少独立的 Erlang 脚本，就像这里 eip.escript :

#!/usr/bin/env escript

main(_Args) ->
  Ping = io:get_line(""),
  io:format("Pong: ~ts", [Ping]).

现在，当你运行 python3 eip.py并输入 asdf在 Ping:提示，您应该返回 Pong: asdf .

用 Elixir 做同样的事情只是稍微复杂一点:我们需要创建一个带有一些额外配置的 Mix 项目，比如告诉 Mix 组合一个 escript 文件。那么让我们从项目开始:

$ mix new eip
* creating README.md
* creating .formatter.exs
* creating .gitignore
* creating mix.exs
* creating lib
* creating lib/eip.ex
* creating test
* creating test/test_helper.exs
* creating test/eip_test.exs

Your Mix project was created successfully.
You can use "mix" to compile it, test it, and more:

    cd eip
    mix test

Run "mix help" for more commands.

(对于这个简单的例子，甚至使用 Mix 可能有点过头了，但我假设你最终会想做一些比这个例子更高级的事情)

接下来，您需要添加一个 escript mix.exs 的选项，像这样:

defmodule Eip.MixProject do
  use Mix.Project

  def project, do: [
    app: :eip,
    version: "0.1.0",
    elixir: "~> 1.9",
    start_permanent: Mix.env() == :prod,
    deps: deps(),
    escript: escript()
  ]

  def application, do: [extra_applications: [:logger]]

  defp deps, do: []
  defp escript, do: [main_module: Eip]
end

最后，您的 lib/eip.ex模块:

defmodule Eip do
  def main(_argv) do
    ping = IO.gets("")
    IO.puts("Pong: #{ping}")
  end
end

现在我们只需要构建它:

$ mix escript.build
Compiling 1 file (.ex)
Generated eip app
Generated escript eip with MIX_ENV=dev

eip.py需要稍作调整才能指向这个新的 Elixirified ping/pong IPC thingamabob:

#!/usr/bin/env python
from subprocess import Popen, PIPE, TimeoutExpired

erl = Popen(['escript', 'eip/eip'],
            stdin=PIPE, stdout=PIPE, stderr=PIPE)
ping = input('Ping: ')

outs, errs = erl.communicate(input=ping.encode('utf-8'))

print(outs.decode('utf-8'))

不幸的是，这并不完全有效:

$ python3 eip.py
Ping: asdf
Pong: eof

即使使用 Erlang 版本的更直接端口(即将 IO.gets("") 替换为 :io.get_line("") 和 IO.puts("Pong: #{ping}") 替换为 :io.fwrite("Pong: ~ts", [ping]) ，也会发生相同的结果，这意味着 Elixir 的 STDIN 处理通常会导致它过早地相信它已到达文件末尾。但是，嘿，至少一个方向有效!