ERLANG和PYTHON互通實現(xiàn)過程詳解
更新時間：2019年07月05日 10:55:14 作者：Free.Wang
這篇文章主要介紹了ERLANG和PYTHON互通過程詳解,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
最近開發(fā) Erlang ,對其字符串處理能力無言至極,于是決定把它和python聯(lián)合起來,打造一個強(qiáng)力的分布式系統(tǒng),等將來需要系統(tǒng)級開發(fā)時,我再把 C++/C組合進(jìn)來.
首先參考了 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的腳本 當(dāng)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)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了opencv?python模糊影像檢測,本文只使用cv2和shutil庫，若想直接使用該腳本需安裝這兩個庫，通過實例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-03-03
這篇文章主要介紹了Apache,wsgi,django 程序部署配置方法,結(jié)合實例形式詳細(xì)分析了Linux環(huán)境下Apache,wsgi,django程序部署配置的相關(guān)操作技巧與注意事項,需要的朋友可以參考下2019-07-07
這篇文章主要介紹了Python的自動化部署模塊Fabric的安裝及使用指南,文中以Debian系統(tǒng)為環(huán)境進(jìn)行了實例演示,需要的朋友可以參考下2016-01-01
這篇文章主要介紹了簡單了解pytest測試框架setup和tearDown,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-04-04
Pycharm學(xué)習(xí)教程（3） 代碼運行調(diào)試
這篇文章主要為大家詳細(xì)介紹了最全的Pycharm學(xué)習(xí)教程第三篇代碼運行調(diào)試，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-05-05
Python實現(xiàn)發(fā)票自動校核微信機(jī)器人的方法
這篇文章主要介紹了Python實現(xiàn)發(fā)票自動校核微信機(jī)器人的方法，本文通過實例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-05-05
這篇文章主要介紹了在Python中處理字符串之isdigit()方法的使用,是Python入門學(xué)習(xí)中的基礎(chǔ)知識,需要的朋友可以參考下2015-05-05
這篇文章主要介紹了python 使用pandas讀取csv文件的方法,本文結(jié)合示例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-12-12
pandas使用QGraphicsView自動排列項目的實現(xiàn)
本文主要介紹了pandas使用QGraphicsView自動排列項目的實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2025-04-04
Python Process創(chuàng)建進(jìn)程的2種方法詳解
這篇文章主要介紹了Python Process創(chuàng)建進(jìn)程的2種方法詳解,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-01-01