如何使用gen_tcp在Elixir的活动套接字上检测TCP超时？

Question

我有一个GenServer通过gen_tcp连接到远程TCP连接。

opts = [:binary, active: true, packet: :line] {:ok, socket} = :gen_tcp.connect('remote-url', 8000, opts}

我处理消息有：

def handle_info({:tcp, socket, msg}, stage) do IO.inspect msg {:noreply, state} end

伟大的工程。但是，TCP服务器很容易超时。如果我使用gen_tcp.recv，我可以指定超时。但是，我正在使用active: true来接收带有handle_info的消息，而不必循环并呼叫recv。所以，GenServer高兴地等待下一条消息，即使服务器超时。

如何让GenServer在X秒后没有收到来自TCP连接的消息时触发一个函数？我坚持使用recv？

Answer 1

如果TCP连接本身已超时，那么您应该收到一封闭的套接字消息{tcp_closed, Socket}。与handle_info匹配就是这样。至于在连接上建立你自己的超时，我通常用erlang:send_after/3给自己发送一条消息 - 有效地添加一个超时消息语义，我可以在handle_info或任何可能存在的receive服务循环中收到。

erlang:send_after(?IDLE_TIMEOUT, self(), {tcp_timeout, Socket})

这必须是每次接收到交通定时器的取消配对。这可能看起来像这样：

handle_info({tcp, Socket, Bin}, State = #s{timer = T, socket = Socket}) -> 
    _ = erlang:cancel_timer(T), 
    {Messages, NewState} = interpret(Bin, State), 
    ok = handle(Messages), 
    NewT = erlang:send_after(?IDLE_TIMEOUT, self(), {tcp_timeout, Socket}) 
    {noreply, NewState#s{timer = NewT}}; 
handle_info({tcp_closed, Socket}, State = #s{timer = T, socket = Socket}) -> 
    _ = erlang:cancel_timer(T), 
    NewState = handle_close(State), 
    {noreply, NewState}; 
handle_info({tcp_timeout, Socket}, State = #s{socket = Socket}) -> 
    NewState = handle_timeout(State), 
    {noreply, NewState}; 
handle_info(Unexpected, State) -> 
    ok = log(warning, "Received unexpected message: ~tp", [Unexpected]), 
    {noreply, State}.