windows - 在 Windows 中使用 ZeroMQ 的 Erlang

Question

是否可以在 Windows 中使用 Erlang 和 ZeroMQ？我需要制作 rep/req 客户端。我在网站上尝试了 Erlang 的所有绑定：zeromq.org，但没有任何效果。我只能在 Chumak 绑定中运行对客户端/服务器。但我需要代表/请求。当我尝试运行 req/rep 客户端和服务器时，我得到了这个：

req_client:main().
** exception exit: {noproc,
                    {gen_server,call,
                     [chumak_sup,
                      {start_child,
                       #{id => 'chumak_socket_my-req',restart => transient,
                         start => {chumak_socket,start_link,[req,"my-req"]}}},
                      infinity]}}
     in function  gen_server:call/3 (gen_server.erl, line 223)
     in call from chumak_sup:start_socket/2 (chumak_sup.erl, line 30)
     in call from req_client:main/0 (req_client.erl, line 9)

这是来自模块的代码：chumak_sup：

-spec start_socket(Type::socket_type(), Identity::string()) -> {ok, SocketPid::pid()} | {error, Reason::atom()}.
start_socket(Type, Identity) ->
    ProcessId = get_child_id(Identity), %% generate an atom ?
    case supervisor:start_child(?MODULE, #{
                             id=>ProcessId,
                             restart=> transient,
                             start=>{?SOCKET, start_link, [Type, Identity]}
                            }) of
        {error, already_present} ->
            supervisor:restart_child(?MODULE, ProcessId); 
        Res ->
            Res
    end.

start_socket(Type) ->
    %% socket without identity not use supervisor because the identity
    %% is used to localize process inside supervisor.
    ?SOCKET:start_link(Type, "").

这是客户端的代码：

%% This Source Code Form is subject to the terms of the Mozilla Public
%% License, v. 2.0. If a copy of the MPL was not distributed with this
%% file, You can obtain one at http://mozilla.org/MPL/2.0/.
-module(req_client).
-export([main/0]).

    main() ->
        application:start(chumak),
        {ok, Socket} = chumak:socket(req, "my-req"),

        case chumak:connect(Socket, tcp, "localhost", 5555) of
            {ok, Pid} ->
                send_messages(Socket, [
                                       <<"Hello my dear friend">>,
                                       <<"Hello my old friend">>,
                                       <<"Hello all the things">>
                                      ]);
            {error, Reason} ->
                io:format("Connection Failed for this reason: ~p\n", [Reason]);
            Reply ->
                io:format("Unhandled reply for connect ~p \n", [Reply])
        end.

    send_messages(Socket, []) ->
        send_messages(Socket, [
                               <<"Hello my dear friend">>,
                               <<"Hello my old friend">>,
                               <<"Hello all the things">>
                              ]);

    send_messages(Socket, [Message|Messages]) ->
        case chumak:send(Socket, Message) of
            ok ->
                io:format("Send message: ~p\n", [Message]);
            {error, Reason} ->
                io:format("Failed to send message: ~p, reason: ~p\n", [Message, Reason])
        end,
        case chumak:recv(Socket) of
            {ok, RecvMessage} ->
                io:format("Recv message: ~p\n", [RecvMessage]);
            {error, RecvReason} ->
                io:format("Failed to recv, reason: ~p\n", [RecvReason])
        end,
        timer:sleep(1000),
        send_messages(Socket, Messages).

我是编程新手。我不明白如何解决这个任务。

标签： windowserlangzeromq