ERLANG和PYTHON互通實現(xiàn)過程詳解

更新時間：2019年07月05日 10:55:14 作者：Free.Wang

這篇文章主要介紹了ERLANG和PYTHON互通過程詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

最近開發(fā) Erlang ,對其字符串處理能力無言至極,于是決定把它和python聯(lián)合起來,打造一個強力的分布式系統(tǒng),等將來需要系統(tǒng)級開發(fā)時,我再把 C++/C組合進來.

首先參考了 Erlang 官方文檔和 http://blog.developers.api.sina.com.cn/?tag=erlang 以及 http://kazmier.net/computer/port-howto/ .

研讀了將近24個小時, 才終于完全把問題解決. 起名為town，town在英文里表示集市，也就是代表各種語言在這里的交流與互動。) )

-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的腳本當erlang中town:combine(“sentence1+sentence2”)執(zhí)行時，會在后臺啟動python的腳本，處理完畢后返回給Erlang結(jié)果:sentence1sentence2，然后退出。

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)

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: