我有一些问题。
我想将进程与一个用户关联(来自用户的所有请求都接收一个进程,在 HTTP 1.1 中默认保持活动状态,所有请求都通过一个套接字发送。)
我有以下代码:
loop(Sock, Reg_pid) ->
{ok, Conn} = gen_tcp:accept(Sock),
Pid = spawn(fun () -> client_socket(Conn,Reg_pid) end),
gen_tcp:controlling_process(Conn, Pid),
Pid ! {take, Conn}, %% race condition
loop(Sock, Reg_pid).
client_socket(S,Reg_pid) ->
io:format("in~n"),
receive
{take, So} ->
inet:setopts(So, [{active, once}]),
client_socket(So, Reg_pid);
{http, Socket, {http_request, _Method, {abs_path, _Path}, _Vers}} ->
case http_uri2:parse_path_query(_Path) of
{"/",[]} ->
io:format("Main pid - ~p ~n", [self()]),
gen_tcp:send(Socket, response("<a href='http://127.0.0.1:8080/register?name=Max'>Click</a>"));
{"/register",[{"name", Player_name}]} ->
io:format("Register pid - ~p ~n", [self()]);
_-> ok
end,
inet:setopts(Socket, [{active, once}]),
client_socket(Socket, Reg_pid);
{tcp_closed, Socket} ->
io:format("Socket ~w closed [~w]~n",[Socket,self()]);
% gen_tcp:close(Socket);
{tcp_error, Socket, Reason} ->
io:format("Error ~w closed [~w]~n",[Socket,self()]);
_-> ok
end.
当我通过浏览器连接到服务器(索引页面)然后单击返回服务器的链接时,我有下一个结果:
3> server:start(8080).
<0.43.0>
in
Main pid - <0.45.0>
in
in
Register pid - <0.46.0>
in
我不明白为什么我的下一个请求(点击链接)会收到其他进程(注册 pid - <0.46.0>)?
这样,来自一个用户的所有请求都会产生新进程,我希望来自一个用户的所有请求都处理一个进程,我该如何实现呢?
谢谢!