erlang连接php-fpm

前端时间在网上看见erlang 连接php-fpm的例子，自己跟到弄了一下，下面给我调试后的代码贴出来

我修正了原来代码的2处bug:

1、参数超过128字符出错

2、当php返回超过1024字节时候出错

文件名fastcgi.erl

                  
                 -     module(fastcgi).     -     compile(export_all).do_request(Argv)      ->       Env      =      [ {     "     SCRIPT_FILENAME     "     ,     "     E:/phpGame/game/gateway.php     "     }, {     "     websocket     "     ,Argv} ], io:format(     "     Argv msg: ~ts~n     "     , [Argv]), {ok, Socket}     =     gen_tcp:connect(     "     127.0.0.1     "     ,     9000     ,[binary, {packet, 0}, {active,true}],     10000     ), fcgi_send_record(Socket,     1     ,     1     ,     <<     1     :     16     ,0:     8     ,0:     40     >>     ), fcgi_send_record(Socket,      4     ,     1     , Env),  fcgi_send_record(Socket,      4     ,     1     , []),  Bin      =      phpRespone(Socket,[]), gen_tcp:close(Socket),      %%     原报文     <<     Version:     8     , Type:     8     , RequestId:     16     , ContentLength:     16     ,PaddingLength:     8     , Reserved:     8     ,Str     /     binary      >>           =      Bin,       <<     _:     32     ,ContentLength:     16     ,_:     16     ,Str     /     binary      >>           =      Bin,       %%     计算

输出内容长度 Dlen = ContentLength - 52 , %% 获取内容 << _H: 52 / binary,Data:Dlen / binary,_Other / binary >> = Str, io:fwrite( " rs:~p~n " ,[Data]), {ok,Data}.recv_msg(Sock) -> receive {tcp, Sock, Bin} -> io:format( " Bin msg: ~p~n " , [Bin]), %% 原报文 << Version: 8 , Type: 8 , RequestId: 16 , ContentLength: 16 ,PaddingLength: 8 , Reserved: 8 ,Str / binary >> = Bin, << _: 32 ,ContentLength: 16 ,_: 16 ,Str / binary >> = Bin, %% 计算输出内容长度 Dlen = ContentLength - 52 , %% 获取内容 << _H: 52 / binary,Data:Dlen / binary,_Other / binary >> = Str, io:fwrite( " rs:~p~n " ,[Data]), {ok,Data}; {tcp_closed,Sock} -> io:format( " socket close: ~p~n " , [Sock]); _Other -> io:format( " Other msg: ~p~n " , [_Other]), recv_msg(Sock) after 3000 -> io:format( " Time out.~n " ) end. phpRespone(Sock,SoFar) -> receive {tcp, Sock, Bin} -> phpRespone(Sock,[Bin | SoFar]); {tcp_closed,Sock} -> list_to_binary(lists:reverse(SoFar)); _Other -> io:format( " Other msg: ~p~n " , [_Other]), phpRespone(Sock,SoFar) after 3000 -> io:format( " Time out.~n " ) end. %% 发送选项 fcgi_send_record(Socket, Type, RequestId, NameValueList) -> EncodedRecord = fcgi_encode_record(Type, RequestId,NameValueList), gen_tcp:send(Socket, EncodedRecord). %% 组包 fcgi_encode_record(Type, RequestId, NameValueList) when is_list(NameValueList) -> fcgi_encode_record(Type, RequestId,fcgi_encode_name_value_list(NameValueList)); %% 判断ContentData是否满8字节,否则填充 fcgi_encode_record(Type, RequestId, ContentData) when is_binary(ContentData) -> ContentLength = size(ContentData), PaddingLength = if ContentLength rem 8 == 0 -> 0; true -> 8 - (ContentLength rem 8 ) end, %% 填充数据,每8字节组包 不足用0填充 PaddingData = << 0:(PaddingLength * 8 ) >> , Version = 1 , Reserved = 0, << Version: 8 , Type: 8 , RequestId: 16 , ContentLength: 16 , PaddingLength: 8 , Reserved: 8 , ContentData / binary, PaddingData / binary >> . %% 将环境变量组成binary fcgi_encode_name_value_list(_NameValueList = []) -> << >> ; fcgi_encode_name_value_list(_NameValueList = [{Name, Value} | Tail]) -> << (fcgi_encode_name_value(Name,Value)) / binary,(fcgi_encode_name_value_list(Tail)) / binary >> . fcgi_encode_name_value(Name, _Value = undefined) -> fcgi_encode_name_value(Name, "" ); fcgi_encode_name_value(Name, Value) when is_list(Name) and is_list(Value) -> NameSize = length(Name), NameSizeData = << NameSize: 8 >> , ValueSize = length(Value), if ValueSize < 128 -> ValueSizeData = << ValueSize: 8 >> ; ValueSize > 127 -> ValueSizeData = << (ValueSize bor 16 # 80000000):32>> end, << NameSizeData / binary,ValueSizeData / binary,(list_to_binary(Name)) / binary,(list_to_binary(Value)) / binary >> .

在windows 下启动php cgi可以这样做

php-cgi.exe -b 127.0.0.1:9000

在erlang shell中调用：

2> c(fastcgi).
{ok,fastcgi}
3> fastcgi:do_request("{'uid':1}").

文笔不好，请大家多多包含