Erlang与PHP通信

dreamxyp

e2p.erl

1. %% Author: [email protected]
   
2. %% Created: 2011-5-5
   
3. %% Description: TODO: Add description to e2p
   
4. -module(e2p). % 定义模块名
   
5. 
   
6. 
   
7. %% 对外公开的方法,要用列表[MethodName1/ArgNum,MethodName2/ArgNum,...]的形式。
   
8. %% MethodName1为方法名
   
9. %% /ArgNum 为方法要几个参数
   
10. -export([request_url/0, request_url/3, request_url/5]).
    
11. 
    
12. % -compile(export_all). %向外公布所有方法
    
13. 
    
14. %% 发送请求
    
15. request_url() ->
    
16.         Url = "/phperlang/gateway.php",
    
17.         SendMethod = "GET",
    
18.         %Argument = [{"username","zengfeng"},{"password", "123456"},{"hello","yes"}],
    
19.         %Argument = [{"username","zengfeng"}],
    
20.         %Argument = [],
    
21.         %Argument = ["user=aaaaa", "arg=bbbbbbbbbb","b=111111" ],
    
22.         Argument = ["msg=ok&username=zengfeng&password=123456"]
    
23. 
    
24.         request_url(Url, SendMethod, Argument).
    
25. 
    
26. %% 发送请求
    
27. %% @param Url 请求Url
    
28. %% @param SendMethod 发送方式
    
29. %% @param Argument 参数
    
30. request_url(Url, SendMethod, Argument) ->
    
31.         Host = "127.0.0.1",
    
32.         Port = 80,
    
33.         request_url(Host, Port, Url, SendMethod,Argument).
    
34. 
    
35. %% 发送请求
    
36. %% @param Host 服务器地址http://erlide.sourceforge.net/update
    
37. %% @param Port 服务器端口
    
38. %% @param Url 请求Url
    
39. %% @param SendMethod 发送方式
    
40. %% @param Argument 参数
    
41. request_url(Host, Port, Url, SendMethod, Argument) ->
    
42.         {ok, Socket} = gen_tcp:connect(Host, Port, [binary, {packet, 0}]), %连接服务器,如果Port是80就表示访问一个网站
    
43. 
    
44.         %取得请求头内容
    
45.         RequestHead = get_request_head(Url, SendMethod, Argument),
    
46.         %RequestHead = "POST /phperlang/gateway.php?a=1&a2=2 HTTP/1.0\r\nContent-Type:application/x-www-form-urlencoded\r\nContent-Length:84\r\nConnection:close\r\n\r\narr=array('key1' => 'value1', 'key2' = 'value2')&username=zengfeng75&password=123456",
    
47. 
    
48.         ok = gen_tcp:send(Socket, list_to_binary(RequestHead)),  %向服务器发送请求
    
49.         receive_data(Socket, []). %接收服务器返回的数据
    
50. 
    
51. %% 取得请求头内容, 如果不带参数
    
52. %% @param Url 请求Url
    
53. %% @param SendMethod 发送方式
    
54. %% @param Argument 参数
    
55. get_request_head_method(Url, SendMethod, []) ->
    
56.         %第一行,请求方式和协议
    
57.         HeadLine_1 = string:join([SendMethod, Url, "HTTP/1.0\r\n"], " "),
    
58.         [HeadLine_1,"\r\n"];
    
59. 
    
60. %% 取得请求头内容, 带参数,如果是以GET方式发送
    
61. %% @param Url 请求Url
    
62. %% @param SendMethod 发送方式
    
63. %% @param Argument 参数
    
64. get_request_head_method(Url, "GET", Argument) ->
    
65.         ArgumentStr = arguments_join(Argument),
    
66.         UrlAndArgs = string:join([Url, ArgumentStr], "?"),
    
67.         %第一行,请求方式和协议
    
68.         HeadLine_1 = string:join(["GET", UrlAndArgs, "HTTP/1.0\r\n"], " "),
    
69.         [HeadLine_1, "\r\n"];
    
70. 
    
71. %% 取得请求头内容, 带参数,如果是以POST方式发送
    
72. %% @param Url 请求Url
    
73. %% @param SendMethod 发送方式
    
74. %% @param Argument 参数
    
75. get_request_head_method(Url, "POST", Argument) ->
    
76.         %第一行,请求方式和协议
    
77.         HeadLine_1 = string:join(["POST", Url, "HTTP/1.0\r\n"], " "),
    
78.         ArgumentStr = arguments_join(Argument), %处理参数为一个字符串
    
79.         ArgumentStrLength = size(list_to_binary(ArgumentStr)), %取得要发送参数的总长度,如果是POST就要向服务说明发送的内容有多长Content-Length
    
80. 
    
81. 
    
82.         [HeadLine_1,
    
83.         "Content-Type:application/x-www-form-urlencoded\r\n",
    
84.         string:join(["Content-Length:",integer_to_list(ArgumentStrLength),"\r\n"],""),
    
85.         "Connection:close\r\n\r\n",
    
86.         ArgumentStr
    
87.         ].
    
88. 
    
89. %% 取得请求头内容
    
90. %% @param Url 请求Url
    
91. %% @param SendMethod 发送方式
    
92. %% @param Argument 参数
    
93. get_request_head(Url, SendMethod, Argument) ->
    
94.         get_request_head_method(Url, SendMethod, Argument).
    
95. 
    
96. %% 合并参数
    
97. arguments_join([]) -> [];
    
98. %% 合并参数, 当参数是元组时如[{"username","zengfeng"}, {"passowrd", "123455"}]
    
99. arguments_join([Head | _T] = L) when is_tuple(Head) ->
    
100.         List = argument_join_key_value(L, []),  %合并参数的key和value
     
101.         %io:format("arguments_join's List:~p~n", [List]),
     
102.         arguments_join(List); %继续进行合并
     
103. 
     
104. 
     
105. %% 合并参数, 当参数是列表时如["username=zengfeng", "password=1234"]
     
106. %% 将会返回这种方试 "username=zengfeng&password=1234"
     
107. arguments_join([Head | T] = L) ->
     
108.         %io:format("arguments_join's T:~p~n", [T]),
     
109.         case T of
     
110.                 [] -> Head;
     
111.                 _Other ->
     
112.                         io:format("========================~n"),
     
113.                                string:join(L, "&")
     
114.         end.
     
115. 
     
116. 
     
117. %合并参数的key和value 如[{"username","zengfeng"}, {"passowrd", "123455"}]
     
118. %% 将会返回这种方试 ["username=zengfeng", "password=1234"]
     
119. argument_join_key_value([{Key, Value} | T], Result) ->
     
120.         %io:format("Result= ~p~n",[Result]),
     
121.         case T of
     
122.                 [] ->
     
123.                         io:format("[]------------~n"),
     
124.                         [(string:join([Key, Value], "="))| Result];               
     
125.                 [{_Key, _Value} | _T] ->
     
126.                         io:format("true----------~n"),
     
127.                                argument_join_key_value(T, [(string:join([Key, Value], "=")) | Result])
     
128.         end.
     
129. 
     
130. 
     
131. 
     
132. 
     
133. 
     
134. 
     
135. %%接收数据
     
136. receive_data(Socket, SoFar) ->
     
137.         receive
     
138.                 {tcp, Socket, Bin} ->
     
139.                         receive_data(Socket, [Bin | SoFar]);
     
140.                 {tcp_closed, Socket} ->
     
141.                         Content = list_to_binary(lists:reverse(SoFar)), %此时的内容会包含PHP服务器发来的一些头
     
142.                         %io:format("~p~n", [Content]),
     
143.                         %<<_Head:1480, Data/binary>> = Content,
     
144.                         get_content(Content) %将会把头去掉，得到PHP返回的输出
     
145.         after 5000 -> %如果超时5秒就结束
     
146.                         io:format("over time5000"),
     
147.                         receive_data_over_time5000
     
148.         end.
     
149. 
     
150. %% 取得去掉头的数据
     
151. get_content(Data) ->
     
152.         %% 取得去掉头的数据,先试着头长度为165.为会如果正文内容长度超过8000时，头内容就不会变
     
153.         split_content(Data, 165).
     
154. 
     
155. %% 取得去掉头的数据
     
156. split_content(Data, StartLength) when StartLength =:= 165 ->
     
157.         {B1, B2} = split_binary(Data, StartLength),
     
158.         {_B1_1, B1_2} = split_binary(B1, (StartLength - 27)),
     
159.         HeadEnd = <<"Content-Type: text/html\r\n\r\n">>,
     
160.         if
     
161.                 B1_2 =:= HeadEnd ->
     
162.                         B2;
     
163.                 B1_2 =/= HeadEnd ->
     
164.                         split_content(Data, 180)
     
165.         end;
     
166. %% 取得去掉头的数据
     
167. split_content(Data, StartLength) ->
     
168.         {B1, B2} = split_binary(Data, StartLength),
     
169.         {_B1_1, B1_2} = split_binary(B1, (StartLength - 27)),
     
170.         HeadEnd = <<"Content-Type: text/html\r\n\r\n">>,
     
171.         if
     
172.                 B1_2 =:= HeadEnd ->
     
173.                         B2;
     
174.                 B1_2 =/= HeadEnd ->
     
175.                         split_content(Data, (StartLength + 1))
     
176.         end.

复制代码

lfh

httpc:request 可以直接支持 erlang对外的http请求，OTP 21开始， 新加的模块 http_uri:encode 很方便的解决了uri 里 需要转义的部分, 例如参数带中文等。

dreamxyp

哈哈，这个是13年的方法，那时的老方法