recv сообщение и запись в файл - PullRequest
0 голосов
/ 19 августа 2011

Я сделал сервер здесь, который получает сообщения от терминала.Я хочу, чтобы сервер получал сообщения от терминала и записывал их в файл.Но я не знаю, как мне это сделать.Я думал о написании файловых методов file:open, file:write в функциях приема, но это не сработало, как я думал.

-module(tcp).

-behaviour(gen_server).

-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3, start/0, stop/0, connect/0, send/1, recv/0]).

-export([start_link/0]).

%% =============================================================================
%% EXPORTED GEN_SERVER CALLBACKS
%% =============================================================================

init([]) -> {ok, {}}.

handle_call({send, Packet}, _From, State) ->
    gen_tcp:send(State, Packet),
    io:format("Send Working\n"),
    {reply, ok, State};

handle_call(recv, _From, State) ->
     Message = gen_tcp:recv(State, 0),
    io:format("~w~n", [Message]),
    {reply, Message, State}.

handle_cast(connect, _) ->
    case gen_tcp:listen(6888, [binary]) of
    {ok, LSocket}->
        io:format("~w~n", [LSocket]),
        case gen_tcp:accept(LSocket) of 
        {ok, Socket} ->
            inet:setopts(Socket, [{active, false}]),
            io:format("accepted\n"),
            {noreply, Socket};
        Other ->
            error_logger:error_report(["An error occurred which is",Other,"in line",?LINE,"of module",?MODULE])

        end;
    {error, Reason} ->
        error_logger:error_report("An error occurred", Reason, [?LINE,?MODULE])
    end;

handle_cast(stop, State) -> {stop, normal, State}.

handle_info(_Info, State) -> {noreply, State}.

terminate(_Reason, _State) -> ok.

code_change(_OldVsn, State, _Extra) -> {ok, State}.


%% =============================================================================
%% EXPORTED CONVENIENCE FUNCTIONS TO START AND STOP THE SERVER
%% =============================================================================

start() ->
    case gen_server:start({local, ?MODULE}, ?MODULE, [], []) of
        {ok, Pid} ->
            Pid;
        Reason ->
            error_logger:error_report("An error occurred", Reason, [?LINE,?MODULE])
    end.

stop() ->
    case gen_server:cast(?MODULE, stop) of
        ok ->
            ok;
        _ ->
            {error, stop_error}
    end.


%% =============================================================================
%% PUBLIC API FUNCTIONS
%% =============================================================================

connect() -> gen_server:cast(?MODULE, connect).

send(Packet) -> gen_server:call(?MODULE, {send, Packet}).

recv() -> gen_server:call(?MODULE, recv).

write_file(Filename) ->
    {ok, IoDevice} = file:open(test.txt, [write, append]),
    ok.

start_link() -> gen_server:start_link({local, ?MODULE}, ?MODULE, [], []).


%% =============================================================================
%% LOCAL FUNCTIONS
%% =============================================================================

Я сделал, как вы предложили, и реализовал его как handle_call но когда я запускаюсь, я получаю ошибку,

функция handle_call / 3 уже определила ошибку

Я совершенно не понимаю, почему я получаю эту ошибку, так как у меня есть 3 аргументадля handle_call, и он должен работать.

handle_call(write_file, Filename, S) ->
    {ok, File} = file:open(Filename, [append]),
    ok = file:write(File, S),
    ok = file:close(File).

Моя функция API

write_file() -> gen_server:call(?MODULE, write_file).

Ответы [ 2 ]

3 голосов
/ 30 августа 2011

Ваш вызов дескриптора не работает, потому что у вас есть два его определения. Вы написали:

 handle_call(...) ->
   do_something.

 handle_call(M, F, S) ->
   do_some_other_thing.

Вы должны превратить их в одну и ту же функцию, изменив:

   do_something.

в

   do_something;
handle_call(M, F, S) ->
   do_some_other_thing.
2 голосов
/ 19 августа 2011

write_file должен сделать что-то вроде:

write_file(Fname, S) ->
    ok = file:write_file(Fname, S, [append]).

или

write_file(Fname, S) ->
    {ok, File} = file:open(Fname, [append]),
    ok = file:write(File, S),
    ok = file:close(File).
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...