带有python客户端的Erlang echo服务器未回显,python客户端未正确接收响应

q7solyqu  于 2022-12-08  发布在  Erlang
关注(0)|答案(1)|浏览(209)

So I'm trying to get an erlang server started, which will echo back from my python client. I can see the connection is made, however the echo doesn't actually happen. Can anybody point me to the right solution?
I'm using python3 as my client driver.
Here is my erlang server: I start it with 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.

here is my python client:

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()

I think the problem is it just hangs after sending, and now it's waiting for a response, I think I might not be receiving the string in the right way.

zsbz8rwp

zsbz8rwp1#

一个问题是您有{packet, line},并且消息不包含新行,因此echo服务器在将消息发送到处理程序之前一直等待消息完成。
此外,您应该小心使用active选项,因为在controlling_process/2调用期间接收到的任何数据都将保留在先前的处理程序中。您应该使用{active, false}启动接受的套接字,然后在套接字由处理程序管理时将其设置为true | pos_integer()

相关问题