socket通信中にプラグラムが停止してしまう（終了はしない）

Question

pythonのsocketライブラリでtcp通信プログラムを作成しました。
サーバーから毎秒データを送っているのですが、突然何のエラーもなくclient.pyのif not rcv_dataでプログラムが停止してしまいます。
try exceptでもエラーが出ていないため、原因が全く分からないのですが、何か原因としてありそうなことを教えていただきたいです。

環境はAWS EC2 AmazonLinux2でcloud9で動かしています。
AWS EC2のモニタリングでCPU使用率を確認してみましたが、停止時間中でもそれ以外の時間より高いというわけではなく10~20%程度でした。

# client.py
socket_client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
socket_client.connect(("localhost", 8080))
while True:
	try:
		rcv_data = socket_client.recv(1024)
		logger.info("{} recv {}".format(datetime.utcnow(), rcv_data.decode()))
		if not rcv_data:
			logger.info("Disconnect")
			break
		else:
			logger.info("{} {}".format(datetime.utcnow(), "send ok"))
           socket_client.send("ok".encode())
	except:
		traceback.print_exc()


# 実際に動かすと数時間後に下記のようにif not rcvの処理で4時間以上停止している
2022-06-03 00:03:00.621 recv test
2022-06-03 00:03:00.848 send ok
...
2022-06-03 02:03:05.621 recv test
2022-06-03 06:42:57.848 send ok

#server.py
sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
sock.bind(("localhost", 8080))
sock.listen()
client,remote_addr = sock.accept()
while True:
    client.send("test".encode())
    rcv_data = client.recv(1024)
    time.sleep(1)

このほかにthreadingでwhile Trueの無限ループで３秒ごとにログを出力する関数も動かしているのですが、そちらも止まっていました。
プログラム全体が止まってしまっていると思うのですが、これはsocketライブラリによって引き起こされているのでしょうか?

Answer 1

クライアント側のwhileが一重ループなので、一度受信が完了するとbreakでwhileを抜けて終わってしまいます。client.pyでは処理が終わっただけで、ソケットの切断はされていません。

続けてデータを処理するにはtryの後にもう一つwhileがいります。
ただし、これだと間髪入れずに次の処理をするので、何か条件分岐を加えた方がよいです。

補足：ソケットは切断するとめんどくさいので、プログラムの（異常）終了時だけ切断し、それまでは同じソケットを使い回した方がよいと考えます。

Comments

[ramin]

回答ありがとうございます。
client.pyのbreakですが、if not recv_dataなのでサーバー側でソケットをクローズされない限りはelseを通って無限ループになるはずです。

[fourteenlength]

手元で確認していないのでうろ覚えの経験の話ですが、
クライアントの処理は
if not rcv_data:
　　一回のパケット(1024)の中身が空の場合
else:
　　何かのデータが送られた場合
です。

サーバの送信命令は、
client.send("test".encode())
が一回の通信分のデータです。2バイト=16ビットしかなく、一回のパケット(1024)に収まります。クライアントのrcv_dataはサーバが一回のソケット通信で送ろうとしたデータ("test")が送り終わったらNoneかFalseか""のようなデータがclientに届きます。（もし送ろうとしたデータが画像のような大きいものでしたら、一回のソケット通信で何回もパケットを送り、else側の処理を何度も繰り返して受信したデータを結合し続け、サーバが送り終わったらnot rcv_dataの方に流れてbreak、という流れになります、）ですので、今回のような小さいデータをサーバから送った場合、一度パケットを受信したら直ちにクライアントのelseに流れ、breakするだろうという考えです。
ただし、本当にそうかはprint("else")みたいなものを挟んでトレースしないとわかりません💦

補足：パケットはソケット通信で何度もやり取りする最大容量の決まったバケツ(ここではサイズを1024と定義)のようなイメージです。ソケット通信は、パケットを何度もやり取りする通信手法の名前、と理解しています。
---
https://qiita.com/shino_312/items/3c81ed8d8dfd0d53f25a
にあるように、私も過去にサーバクライアントの継続した通信をする際にはSO_REUSEADDRを使ったような気がします。