0

我正在尝试让客户端（在 NAT 之后）将数据包发送到专用服务器。

这是我的代码：

-module(udp_test).

-export([start_client/3, listen/1, send/4, start_listen/1]).

start_client(Host, Port, Packet) ->
    {ok, Socket} = gen_udp:open(0, [{active, true}, binary]),
    io:format("client opened socket=~p~n",[Socket]),
    spawn(?MODULE, send, [Socket, Host, Port, Packet]).

start_listen(Port) ->
    {ok, Socket} = gen_udp:open(Port, [binary]),
    spawn(?MODULE, listen, [Socket]).

listen(Socket) ->
    inet:setopts(Socket, [{active, once}]),
    receive
    {udp, Socket , Host, Port, Bin} ->
        gen_udp:send(Socket, Host, Port, "Got Message"),
        io:format("server received:~p / ~p~n",[Socket, Bin]),
        listen(Socket)
    end.

send(Socket, Host, Port, Packet) ->
    timer:send_after(1000, tryToSend),
    receive
    tryToSend ->
        io:fwrite("Sending: ~p / to ~p / P: ~p~n", [Packet, Host, Port]),
        Val = gen_udp:send(Socket, Host, Port, Packet),
        io:fwrite("Value: ~p~n", [Val]),
        send(Socket, Host, Port, Packet);
    _ ->
        io:fwrite("???~n")
    end.

在专用服务器上，我启动了监听功能：

# erl -pa ebin
Erlang R15B01 (erts-5.9.1) [source] [64-bit] [smp:4:4] [async-threads:0] [kernel-poll:false]

Eshell V5.9.1  (abort with ^G)
1> udp_test:listen(4000).

在客户端我启动发送循环：

$ erl -pa ebin                                                      
Erlang R15B (erts-5.9) [source] [smp:2:2] [async-threads:0] [hipe] [kernel-poll:false]

Eshell V5.9  (abort with ^G)
1> udp_test:start_client("ip.of.my.server", 4000, "HELLO !!!").
client opened socket=#Port<0.737>
<0.33.0>
Sending: "HELLO !!!" / to "ip.of.my.server" / P: 4000
Value: ok
Sending: "HELLO !!!" / to "ip.of.my.server" / P: 4000
Value: ok
Sending: "HELLO !!!" / to "ip.of.my.server" / P: 4000
Value: ok

虽然gen_udp:send从客户端返回ok，但服务器似乎没有收到任何这些数据包，因为它应该在控制台上打印“服务器收到：”HELLO !!!“ ”。

任何人都会知道为什么这不起作用。

编辑 1：

  • 专用服务器上没有配置防火墙或 iptable。

  • 客户端和服务器之间的连接通过 TCP 工作正常，但不是 UDP。

  • 当我尝试在同一设备（不同的 erlang 节点）上同时运行服务器和客户端时，它也不起作用。

编辑 2 ： 更改了监听部分的代码，在每次收到消息时循环自己重新创建 Socket ......但仍然无法正常工作。

4

2 回答 2

2

您的start_client/3,send/4循环应该按预期工作，尽管它是一种稍微复杂的方式来获得 1 秒的延迟。

您listen/1不会按预期执行，最多应返回一条消息：

  • 对于每个循环，它都会打开一个新套接字，第一次它使用端口打开套接字，而在接下来的循环中，它使用套接字打开一个新套接字，这应该会产生错误。
  • 您将套接字设置为，{active,once}因此在将套接字重置为活动一次之前，您最多会在套接字上接收一个数据包。

为什么要在接收端尝试做一些简单的事情，比如：

Erlang R15B (erts-5.9) [source] [smp:4:4] [async-threads:0] [hipe] [kernel-poll:false]

Eshell V5.9  (abort with ^G)
1> {ok,S}=gen_udp:open(5555,[]).
{ok,#Port<0.582>}
2> flush().
Shell got {udp,#Port<0.582>,{127,0,0,1},4444,"hej"}
Shell got {udp,#Port<0.582>,{127,0,0,1},4444,"there"}
ok
3>

作为测试基本连接的第一步？

编辑：

在您调用的新版本中，start_listen/1它会打开一个 UDP 套接字，然后生成一个进程来坐下来监听它。打开端口的进程就是端口控制进程。当数据包到达时发送的消息被发送到控制进程，在这种情况下，控制进程不是控制进程。

有两种方法可以解决此问题：

  • 产生一个进程，它首先打开端口，然后进入一个循环，从套接字接收 UDP 消息。这就是您引用的示例中的完成方式：start生成一个正在运行的进程server，该进程打开端口，然后调用loop.

  • 用于gen_udp:controlling_process/2将套接字的控制权传递给循环进程，以便它接收数据包消息。

两者都工作并有自己的位置。您在原始代码中具有相同的结构，但我错过了它。

于 2012-09-07T13:07:37.840 回答
2

发现问题，我正在启动套接字，然后只产生循环......

要么将 control_process 更改为生成的 pid，要么打开生成的 pid 上的套接字。

希望它可以帮助某人。

于 2012-09-07T14:30:14.033 回答