首页 / PHP / erlang连接php-fpm
erlang连接php-fpm
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了erlang连接php-fpm,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含4412字,纯文字阅读大概需要7分钟。
内容图文
前端时间在网上看见erlang 连接php-fpm的例子,自己跟到弄了一下,下面给我调试后的代码贴出来我修正了原来代码的2处bug:
1、参数超过128字符出错
2、当php返回超过1024字节时候出错
文件名fastcgi.erl
输出内容长度 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 >> .- 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, %% 计算
在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}").
文笔不好,请大家多多包含
内容总结
以上是互联网集市为您收集整理的erlang连接php-fpm全部内容,希望文章能够帮你解决erlang连接php-fpm所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。