Erlang与Python通过端口通信实现互通详解

晚来风

发布时间：2026-10-13| 5人浏览过

原创

本文详解Erlang通过open_port调用Python脚本实现字符串处理的方法。利用gen_server管理端口生命周期，Erlang发送指令至Python进程，Python解析输入并返回结果后退出。该方案解决了Erlang字符串处理能力的不足，为构建混合语言分布式系统提供了可行路径。

Erlang与Python互通背景

近期在进行Erlang开发时，深感其原生字符串处理能力的局限，因此决定将Erlang与Python结合，构建一个功能强大的分布式系统。未来若涉及更底层的系统级开发，计划进一步引入C++或C语言进行组合优化。

在实施过程中，主要参考了Erlang官方文档、新浪博客的相关Erlang标签文章以及kazmier.net发布的端口通信指南。

经过约24小时的深入研究，最终完全解决了技术难题。该项目被命名为“town”，寓意集市，象征不同编程语言在此交汇与互动。

Erlang端实现细节


-module(town).
-behaviour(gen_server).
 
%% API
-export([start/0,combine/1]).
 
%% gen_server callbacks
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
terminate/2, code_change/3]).
-record(state, {port}).
 
start() -&gt;
 gen_server:start_link({global, ?MODULE}, ?MODULE, [], []).
stop() -&gt;
 gen_server:cast(?SERVER, stop).
init([]) -&gt;
 process_flag(trap_exit, true),
 Port = open_port({spawn, "python -u /home/freefis/Desktop/town.py"},[stream,{line, 1024}]),
 {ok, #state{port = Port}}.
 
handle_call({combine,String}, _From, #state{port = Port} = State) -&gt;
 port_command(Port,String),
 receive
 {Port,{data,{_Flag,Data}}} -&gt;
  io:format("receiving:~p~n",[Data]),
  sleep(2000),
  {reply, Data, Port}
 end.
handle_cast(stop, State) -&gt;
 {stop, normal, State};
handle_cast(_Msg, State) -&gt;
 {noreply, State}.
 
handle_info(Info, State) -&gt;
 {noreply,State}.
 
terminate(_Reason, Port) -&gt;
 ok.
 
code_change(_OldVsn, State, _Extra) -&gt;
 {ok, State}.
 
%%--------------------------------------------------------------------
%%% Internal ---------------------------------------------------------
combine(_String) -&gt;
 start(),
 String = list_to_binary("combine|"++_String++"\n"),
 gen_server:call(?SERVER,{combine,String},infinity),
 stop().

Python脚本处理逻辑

核心机制在于Python脚本的后台执行。当Erlang代码执行town:combine(“sentence1+sentence2”)时，系统会在后台启动对应的Python脚本。脚本处理完成后，将拼接后的结果sentence1sentence2返回给Erlang，随后进程自动退出。


import sys
def handle(_string):
 if _string.startswith("combine|"):
  string = "".join( _string[8:].split(","))
  return string
 
"""waiting for input """
while 1:
 # Recv. Binary Stream as Standard IN
 _stream = sys.stdin.readline()
 
if not _stream: break
 # Scheme, Turn into Formal String
 inString = _stream.strip("\r\n")
 # handle String
 outString = handle(inString)
 # send to port as Standart OUT
 sys.stdout.write("%s\n" % (outString,))
 sys.exit(0)

以上内容涵盖了Erlang与Python互通的核心实现逻辑，希望能为相关技术学习者提供参考，欢迎继续支持本站获取更多技术资讯。