📅 最后修改于: 2020-11-04 05:59:25 🧑 作者: Mango
在Erlang中，端口用于不同程序之间的通信。套接字是一个通信端点，允许计算机使用Internet协议(IP)在Internet上进行通信。
有2种类型的协议可用于通信。一个是UDP，另一个是TCP。 UDP允许应用程序相互发送短消息(称为数据报)，但是不能保证这些消息的传递。他们也可能无秩序到达。另一方面，TCP提供可靠的字节流，只要建立连接就按顺序传递字节。
让我们看一个使用UDP打开端口的简单示例。
-module(helloworld).
-export([start/0]).
start() ->
{ok, Socket} = gen_udp:open(8789),
io:fwrite("~p",[Socket]).
关于上述程序，需要注意以下几点
gen_udp包含Erlang中用于UDP通信的模块。
8789是在Erlang中打开的端口号。您需要确保此端口号可用并且可以使用。
上面程序的输出是-
#Port<0.376>
打开端口后，可以在该端口上发送一条消息。这是通过send方法完成的。让我们看一下语法和以下示例。
send(Socket, Address, Port, Packet)
套接字-这是使用gen_udp：open命令创建的套接字。
地址-这是必须将消息发送到的机器地址。
端口-这是需要在其上发送消息的端口号。
数据包-这是需要发送的数据包或消息详细信息。
如果消息发送正确，则返回确定消息。
-module(helloworld).
-export([start/0]).
start() ->
{ok, Socket} = gen_udp:open(8789),
io:fwrite("~p",[Socket]),
io:fwrite("~p",[gen_udp:send
(Socket,"localhost",8789,"Hello")]).
上述程序的输出如下。
#Port<0.376>ok
打开端口后，也可以在该端口上收到一条消息。这是通过recv方法完成的。让我们看一下语法和以下示例。
recv(Socket, length)
套接字-这是使用gen_udp：open命令创建的套接字。
长度-这是需要接收的消息的长度。
如果消息发送正确，则返回确定消息。
-module(helloworld).
-export([start/0]).
start() ->
{ok, Socket} = gen_udp:open(8789),
io:fwrite("~p",[Socket]),
io:fwrite("~p",[gen_udp:send(Socket,"localhost",8789,"Hello")]),
io:fwrite("~p",[gen_udp:recv(Socket, 20)]).
现在显然我们不能在同一程序中具有相同的发送和接收消息。您需要在不同的程序中定义它们。因此，让我们创建以下代码，该代码创建一个侦听消息的服务器组件和一个发送消息的客户端组件。
-module(helloworld).
-export([start/0,client/1]).
start() ->
spawn(fun() -> server(4000) end).
server(Port) ->
{ok, Socket} = gen_udp:open(Port, [binary, {active, false}]),
io:format("server opened socket:~p~n",[Socket]),
loop(Socket).
loop(Socket) ->
inet:setopts(Socket, [{active, once}]),
receive
{udp, Socket, Host, Port, Bin} ->
io:format("server received:~p~n",[Bin]),
gen_udp:send(Socket, Host, Port, Bin),
loop(Socket)
end.
client(N) ->
{ok, Socket} = gen_udp:open(0, [binary]),
io:format("client opened socket=~p~n",[Socket]),
ok = gen_udp:send(Socket, "localhost", 4000, N), Value = receive
{udp, Socket, _, _, Bin} ->
io:format("client received:~p~n",[Bin]) after 2000 ->
0
end,
gen_udp:close(Socket),
Value.
关于上述程序，需要注意以下几点。
我们定义2个功能，第一个是服务器。这将用于侦听端口4000。第二个是客户端，用于将消息“ Hello”发送到服务器组件。
接收循环用于读取在定义循环内发送的消息。
现在您需要从2个窗口中运行该程序。通过在erl命令行窗口中运行以下代码，第一个窗口将用于运行服务器组件。
helloworld:start().
这将在命令行窗口中显示以下输出。
server opened socket:#Port<0.2314>
现在，在第二个erl命令行窗口中，运行以下命令。
Helloworld:client(“<>”).
发出此命令时，以下输出将显示在第一个命令行窗口中。
server received:<>