ERLANG和PYTHON互通實現(xiàn)過程詳解
最近開發(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() -> gen_server:start_link({global, ?MODULE}, ?MODULE, [], []). stop() -> gen_server:cast(?SERVER, stop). init([]) -> 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) -> port_command(Port,String), receive {Port,{data,{_Flag,Data}}} -> io:format("receiving:~p~n",[Data]), sleep(2000), {reply, Data, Port} end. handle_cast(stop, State) -> {stop, normal, State}; handle_cast(_Msg, State) -> {noreply, State}. handle_info(Info, State) -> {noreply,State}. terminate(_Reason, Port) -> ok. code_change(_OldVsn, State, _Extra) -> {ok, State}. %%-------------------------------------------------------------------- %%% Internal --------------------------------------------------------- combine(_String) -> 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結果: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)
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關文章
pandas中的DataFrame按指定順序輸出所有列的方法
下面小編就為大家分享一篇pandas中的DataFrame按指定順序輸出所有列的方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2018-04-04python實現(xiàn)數獨游戲 java簡單實現(xiàn)數獨游戲
這篇文章主要為大家詳細介紹了python實現(xiàn)數獨游戲和java實現(xiàn)數獨游戲的相關代碼,比較兩種語言實現(xiàn)數獨游戲的區(qū)別2018-03-03