『ゼロから作る暗号通貨』P38-40あたりの質問です

Question

client.pyとserver.pyファイルを作って、server.pyをrunningしたんですが、うまく行かないです。

以下が見本のコマンドです

python3 server.py
my ip address is now ... 10.1.1.27 ← ※1 Waiting for the connection ...
Connected by .. ('10.1.1.27', 55017)
Waiting for the connection ...
Hello! This is test message from my sample client!

以下が自分のパソコンで、コマンドの操作が途中で止まってしまいます。何がまずいのか知りたいです。

python server.py
my ip address is now ... 192.168.100.101
Waiting for the connection ...

以下が作ったファイルです

#client.py
#coding:utf-8
import socket

my_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#ここは環境に合わせた接続先を入れる
my_socket.connect(('10.1.1.27', 50030))
my_text = "Hello! This is test message from my sample client!"
my_socket.sendall(my_text.encode('utf-8'))

#server.py
#coding:utf-8
from concurrent.futures import ThreadPoolExecutor
import socket
import os

def __handle_message(args_tuple):

    conn, addr, data_sum = args_tuple
    while True:
        data = conn.recv(1024)
        data_sum = data_sum + data.decode('utf-8')

        if not data:
            break

        if data_sum != '':
            print(data_sum)

def __get_myip():
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    s.connect(('8.8.8.8', 80))
    return s.getsockname()[0]

def main():

    #AF_INET : IPv4ベースのアドレス体系を使うということ

    #SOCK_STREAM : TCP/IPを使うということ
    my_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

    #多重接続になってもいいようにスレッドで処理するようにする
    executor = ThreadPoolExecutor(max_workers=os.cpu_count())

    #開くポート番号は適当に選んだだけ
    myhost = __get_myip()
    print('my ip address is now ...', myhost)
    my_socket.bind((myhost, 50030))
    #同時に接続してくる相手の数。今回はテストなのでとりあえず1
    my_socket.listen(1)

    while True:
        #接続があるまで待機
        print('Waiting for the connection ...')
        conn, addr = my_socket.accept()
        print('Connected by ..', addr)
        data_sum = ''
        executor.submit(__handle_message, (conn, addr, data_sum))

if __name__ == '__main__':
    main()

Comments

[maisumakun]

「うまくいかない」というのは、具体的にどんな状況になっていますか？エラーメッセージなどが出ているなら、実際のものを書き込んでください。

Answer 1

実行手順は書籍に記載されているものと思われますが…

まずclient.pyの以下の接続先IPを、自身の環境に合わせて書き換える必要があります。

#client.py
#ここは環境に合わせた接続先を入れる
#my_socket.connect(('10.1.1.27', 50030))
my_socket.connect(('192.168.100.101', 50030))

その後client.pyを実行してください。
サーバに接続しメッセージ送信されてターミナル上にメッセージが表示されるはずです。

Answer 2

#ここは環境に合わせた接続先を入れる
my_socket.connect(('10.1.1.27', 50030))

ここのv4が違うのでは？
環境に合わせた接続先と書かれているためその環境設定等を調べるページぐらい存在するはずですよ。
もう一度その本を読みましょう。

Answer 3

以下が自分のパソコンで、コマンドの操作が途中で止まってしまいます。何がまずいのか知りたいです。

特に問題ないのではないかと思います。サーバは接続を待つのが仕事なので、接続されていない状態では何も表示されません。