Pythonでクライアントとサーバーのシステムを作っていて、複数回メッセージを送ることができないです。

Question

前提・実現したいこと

初めて質問します。
クライアントとサーバーのシステムを作っていて、何回もクライアント側からメッセージを送れるようにしたいです

発生している問題・エラーメッセージ

2回目に文字を打つと

client.py", line 24, in <module>
    receive_msg = sock.recv(BUFSIZE)

ConnectionAbortedError: [WinError 10053] 確立された接続がホスト コンピューターのソウトウェアによって中止されました。
と出てしまいます。

24行目はreceive_msg = sock.recv(BUFSIZE)です。

該当のソースコード

クライアント側
# -*- coding: utf-8 -*-

import socket

#接続先ホストの名前(あるいはIPアドレス) ローカルホスト
HOST='127.0.0.1'
#接続先ホストのポート番号
PORT = 50001
#ソケットから受信するデータのバッファサイズ
BUFSIZE = 4096

#ソケットの作成
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
try:
    #サーバへの接続
    sock.connect((HOST,PORT))
    flag = True
    while flag:
        #メッセージを入力
        mesg=input('input message :')#この行を加えた
        #バイトコード化してデータ送信
        sock.send(mesg.encode())
        #データを受信
        receive_msg = sock.recv(BUFSIZE)
        print(receive_msg)
        if mesg=='end':
            flag = False
finally:
    #接続のクローズ
    sock.close()
print('end')


サーバー側
# -*- coding: utf-8 -*-

import socket

#サーバのホスト名(あるいはIPアドレス)
HOST='127.0.0.1'
#ポート番号
PORT = 50001
#接続の最大数
BACKLOG = 10
#ソケットから受信するデータのバッファサイズ
BUFSIZE = 4096

print('try socket')
#ソケットを作成する
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
print('try connect')

try:
    #作成したソケットにアドレスとポート番号を設定
    sock.bind((HOST , PORT))
    sock.listen(BACKLOG)
    while True:
    #clientからの接続を開始
        conn, address  = sock.accept()
        try:
            #recv:ソケットからデータを受信
            b_msg = conn.recv(BUFSIZE)
            #バイトコードが送られてくるのでデコードする
            msg = b_msg.decode('utf-8')
            print('receive msg:'+ msg)
            #ソケットにデートを送信
            conn.send(b'you sent"' + b_msg + b'"')
        finally:
            #接続のクローズ
            conn.close()
finally:
    #接続のクローズ
    sock.close()
print('end')

試したこと

ここに問題に対して試したことを記載してください。

補足情報（FW/ツールのバージョンなど）

ここにより詳細な情報を記載してください。

Answer 1

原因: サーバー側で、一回受信・返信した後に接続を閉じてます。
処理を追ってみてください。

    while True:
    #clientからの接続を開始
        conn, address  = sock.accept()
        try:
            #recv:ソケットからデータを受信
            b_msg = conn.recv(BUFSIZE)
            #バイトコードが送られてくるのでデコードする
            msg = b_msg.decode('utf-8')
            print('receive msg:'+ msg)
            #ソケットにデートを送信
            conn.send(b'you sent"' + b_msg + b'"')
        finally:
            #接続のクローズ
            conn.close()

- clientからの接続を開始
- recv:ソケットからデータを受信
- バイトコードが送られてくるのでデコードする
- ソケットにデートを送信
- 接続のクローズ <-- 原因

---

解決策: close の前に読出～返信のループを組む。

- clientからの接続を開始
　　(ここを繰り返す)
    - recv:ソケットからデータを受信
    - バイトコードが送られてくるのでデコードする
    - ソケットにデートを送信
- 接続のクローズ

接続の最大数は10 となっていますが、現在のコードで扱える接続は一つのみです。
同時接続を考える場合は、スレッドを使う等の方法を別途検討してください。

---

追記: send/recv ですが、これらはデータの送受信を保証しない為、問題になる事があります。
例えば send() の説明ではこのように説明されてます。(recv()も同様)

戻り値として、送信したバイト数を返します。アプリケーションでは、必ず戻り値をチェックし、全てのデータが送られた事を確認する必要があります。データの一部だけが送信された場合、アプリケーションで残りのデータを再送信してください。 ソケットプログラミング HOWTO に、さらに詳しい情報があります。

実際にはこのような処理を自分で書くことは稀で、
より高水準なライブラリやフレームワークを使います。

• socketモジュールの sendall や makefileとread について調べてみてください。
• 他: socketserver フレームワーク 同時接続の場合についてもサンプルコードあり。

Comments

[sadfa]

できました。ありがとうございます

[sadfa]

ベストアンサーした後で申し訳ないのですが、サーバー側はアナコンダプロンプトで、クライアント側はspyderで実行していて、
両方をspyderで実行しようとすると、サーバー側を起動した後にクライアント側を実行できないのですが、何か方法はありますでしょうか？

[teamikl]

生憎と spyder はあまり使ったことがないので、実行環境についてはわかりません。

IDEであれば実行時の設定で複数のバックグランドジョブを実行できるか、
対応していなければ、プラグインの管轄になりますね。

サーバーをプロンプトで実行しておくのが無難だと思います。

スクリプトで対応できること、
毎回サーバーを起動・終了してもよいのなら、一回の実行操作により
サーバー起動 → クライアントの実行を行う事は可能です。(そのようにコードを書く必要はあります)

[sadfa]

分かりました。ありがとうございます。

Answer 2

クライアント側の Socket を毎回接続し閉じるようにすると良いのではないでしょうか？

ソケットプログラミング HOWTO — Python 3.8.3 ドキュメント

だが、以降の転送にもそのソケットを使い回すつもりなら、ソケットに EOT など 存在しない ことを認識する必要がある。もう一度言おう: ソケットの send や recv が 0 バイト処理で返ってきたなら、その接続は終わっている。終わって いない なら、いつまで recv を待てばいいかは分からない。

それが嫌であれば、もう少し、工夫が必要そうです。