二郎SSL无阻塞平行受体

我建立了一个很幼稚的并行SSL受体。二郎SSL无阻塞平行受体

-module(multiserver). 
-export([start/0,client/1]). 

%% This is a dummy SSL Erlang server/client example 

start() -> 
    spawn_link(fun() -> init([]) end). 

init([]) -> 
    ssl:start(), 
    {ok, ListenSocket} = ssl:listen(9990, [{certfile, "cert.pem"}, {keyfile, "privkey.pem"} ,{reuseaddr, true},{active, true}, binary]), 
    Pid = self(), 
    spawn_link(fun() -> listener(ListenSocket, Pid, 1) end), 
    spawn_link(fun() -> listener(ListenSocket, Pid, 2) end), 

    loop(). 

loop() -> 
    receive 
     {new, _Pid} -> 
      %% Do stuff here 
      loop() 
    end. 

listener(ListenSocket, Pid, Num) -> 
    {ok, ClientSocket} = ssl:transport_accept(ListenSocket), 
    ok = ssl:ssl_accept(ClientSocket), 
    io:format("listener ~p accepted ~n", [Num]), 

    ok = ssl:send(ClientSocket, "server"), 
    io:format("listener ~p sent~n", [Num]), 

    receive 
     X -> io:format("listener ~p: ~p ~n", [Num, X]) 
    after 5000 -> 
      io:format("listener ~p timeout ~n", [Num]), 
      timeout 
    end, 
    ssl:close(ClientSocket), 

    listener(ListenSocket, Pid, Num). 

client(Message) -> 
    ssl:start(), 
    {ok, Socket} = ssl:connect("localhost", 9990, [binary, {active,true}], infinity), 

    receive 
     X -> io:format("~p ~n", [X]) 
    after 2000 -> 
      timeout 
    end, 
    ok = ssl:send(Socket, Message),  

    ssl:close(Socket), 
    io:format("client closed~n").

我有的问题是听众2似乎不能接收任何消息。该程序的运行示例如下：

1> multiserver:start(). 
<0.34.0>

然后我调用客户端/ 1三次从不同的外壳：

首先，我在外壳1 壳牌1启动服务器。 Shell 2：

2> multiserver:client("client"). 
{ssl,{sslsocket,new_ssl,<0.51.0>},<<"server">>} 
client closed 
ok 
3> multiserver:client("client"). 
{ssl,{sslsocket,new_ssl,<0.54.0>},<<"server">>} 
client closed 
ok 
4> multiserver:client("client"). 
{ssl,{sslsocket,new_ssl,<0.56.0>},<<"server">>} 
client closed 
ok

这是打印输出到服务器shell。壳牌1：

listener 1 accepted 
listener 1 sent 
listener 1: {ssl,{sslsocket,new_ssl,<0.51.0>},<<"client">>} 
listener 2 accepted 
listener 2 sent 
listener 1 accepted 
listener 1 sent 
listener 1: {ssl,{sslsocket,new_ssl,<0.54.0>},<<"client">>} 
listener 2 timedout 
2>

我花了一些时间与这一点，我无法理解为什么它是不可能的听众2接收任何数据。如果我编辑代码以使用gen_tcp，它按预期工作。有什么我失踪？可以用当前的ssl模块做到这一点吗？

来源

2012-03-08 christofferp

看来，我运行到同样的问题...你有关于它的任何信息吗？ – TheSquad 2012-04-10 09:35:52

不，解决方法是在不同的shell中运行客户端。但我想知道发生了什么，为什么使用SSL不可能，而gen_tcp没有问题。 – christofferp 2012-04-26 06:27:24

的原因超时是，在第二过程使用套接字选项{活性，FALSE}，即接收将永远不会得到任何消息。

的erlang docs for the ssl module指出插座通过调用transport_accept/1应该继承监听套接字设置的选项创建的。第一个进程在transport_accept/3时继承这些选项，但由于某些原因，第二个进程没有。您可以检查选项与

ssl:getopts(ClientSocket,[mode, active])

我不知道为什么会这样，但一个解决方法是明确设置新接受的套接字上的选项

ssl:setopts(ClientSocket, [{active,true}, {mode,binary}])

来源

2012-05-08 21:27:17 johlo

二郎SSL无阻塞平行受体

回答

相关问题