0

だから私は、Pythonクライアントからエコーバックするerlangサーバーを起動しようとしています。接続が確立されていることがわかりますが、エコーは実際には発生しません。誰でも正しい解決策を教えてもらえますか?

クライアントドライバーとしてpython3を使用しています。

これが私の erlang サーバーです。echo:accept(6000) で開始します。

-module(echo).
-export([accept/1]).

%% Starts an echo server listening for incoming connections on
%% the given Port.
accept(Port) ->
    {ok, Socket} = gen_tcp:listen(Port, [binary, {active, true}, {packet, line}, {reuseaddr, true}]),
    io:format("Echo server listening on port ~p~n", [Port]),
    server_loop(Socket).

%% Accepts incoming socket connections and passes then off to a separate Handler process
server_loop(Socket) ->
    {ok, Connection} = gen_tcp:accept(Socket),
    Handler = spawn(fun () -> echo_loop(Connection) end),
    gen_tcp:controlling_process(Connection, Handler),
    io:format("New connection ~p~n", [Connection]),
    server_loop(Socket).

%% Echoes the incoming lines from the given connected client socket
echo_loop(Connection) ->
    receive
        {tcp, Connection, Data} ->
        gen_tcp:send(Connection, Data),
        echo_loop(Connection);
    {tcp_closed, Connection} ->
        io:format("Connection closed ~p~n", [Connection])
    end.

ここに私のpythonクライアントがあります：

import socket
import sys

# Create a TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# Connect the socket to the port where the server is listening
server_address = ('localhost', 6000)
print(sys.stderr, 'connecting to %s port %s' % server_address)
sock.connect(server_address)
try:
    
    # Send data
    message = 'This is the message.  It will be repeated.'
    convertedString = message.encode('utf-8')
    print(sys.stderr, 'sending "%s"' % message)
    sock.sendall(convertedString)

    # Look for the response
    amount_received = 0
    amount_expected = len(message)
    
    while amount_received < amount_expected:
        data = sock.recv(16).decode('utf-8')
        amount_received += len(data)
        print(sys.stderr, 'received "%s"' % data)

finally:
    print(sys.stderr, 'closing socket')
    sock.close()

問題は、送信後にハングするだけで、応答を待っていることだと思います。文字列を正しい方法で受信していない可能性があります。

4

1 に答える 1

1

1 つの問題は{packet, line}、メッセージに改行が含まれていないため、エコー サーバーはメッセージが完了するのを待ってからハンドラーに送信することです。

activeまた、呼び出し中に受信したデータはcontrolling_process/2前のハンドラーに残るため、このオプションには注意が必要です。受け入れられたソケットを で開始し、ソケットがハンドラーによって管理されている場合に{active, false}設定する必要があります。true | pos_integer()

于 2021-04-11T01:17:57.477 に答える