問題点
VMware上で動かしているDebian10において、TCP接続クライアントが動作しません。
TCPソケットサーバーは既存のもので、動作確認済みです。
1400番ポートを使用することにしています。
Windows上で、以下のソースコードは完全に動作しています。
Debian上での動作
Debian上で、当該ソースコードを実行すると、s = self.sock.send(msg)
を実行した時点で、サーバーからRST終了させられてしまいます。(パケットキャプチャで確認)
この原因が分かりません。
ソースコード
import logging
import ipaddress
from ipaddress import AddressValueError
from queue import Queue
import socket
from socket import AF_INET, SOCK_STREAM
import threading
import time
logging.basicConfig(level=logging.INFO, format=" %(asctime)s - %(levelname)s - %(message)s ")
class SocketClientError(Exception):
pass
class SocketClient():
def __init__(self,host,port):
self.host, self.port = None, None
self.is_recv_thread = False
self.recv_queue = Queue()
try:
ipchk = ipaddress.IPv4Address(host)
if ipchk.is_multicast:
msg = "マルチキャストアドレスは使用できません。"
logging.exception(msg)
raise SocketClientError(msg)
if ipchk.is_private:
pass
if ipchk.is_global:
pass
if ipchk.is_link_local:
pass
except AddressValueError as e:
raise e
if not isinstance(port,int):
msg = "portは整数値を指定してください。"
logging.exception(msg)
raise SocketClientError(msg)
else:
if port < 1:
msg = "portは0より上の整数値を指定してください。"
logging.exception(msg)
raise SocketClientError(msg)
self.sock = socket.socket(AF_INET,SOCK_STREAM)
self.sock.settimeout(1)
self.host = host
self.port = port
logging.info("socket生成")
def connect(self):
if not all(
[self.host,self.port]
):
msg = '接続先が正しく定義されていません。host:{},port:{}'.format(self.host,self.port)
raise SocketClientError(msg)
try:
self.sock.connect_ex((self.host,self.port))
logging.info("socket connect")
except ConnectionRefusedError as e:
msg = 'ソケットの接続を拒否された。接続先の指定が間違っているか、サーバーが停止している可能性があります。'
logging.exception(msg)
raise SocketClientError(msg)
try:
recv_thread = threading.Thread(target=recv,args=(self.sock,self.recv_queue))
recv_thread.start()
self.is_recv_thread = True
logging.info("socket receiver start!!")
except Exception as e:
logging.exception(e)
raise SocketClientError(e)
def send(self,msg):
if any(
[
isinstance(msg, bytes),
isinstance(msg, str),
]
):
is_bytes = isinstance(msg, bytes)
if not is_bytes:
msg = msg.encode()
s = self.sock.send(msg)
if s == 0:
msg = "送信できていません。socketが破棄されている可能性があります。"
logging.exception(msg)
raise SocketClientError(msg)
else:
logging.info("socket send :{}".format(msg))
else:
msg = '送信データがバイト列、文字列のどちらかではありません。'
logging.exception(msg)
raise SocketClientError(msg)
def recv(sock, recv_queue):
while True:
try:
data = sock.recv(1024)
logging.info("socket recv :{}".format(data))
if data == b"":
continue
else:
recv_queue.put(data.decode())
except ConnectionResetError:
break
except TimeoutError:
time.sleep(0.5)
continue
sock.shutdown(socket.SHUT_RDWR)
sock.close()
return
class command_terminal():
def __init__(self, instScoket):
self.instScoket = instScoket
self.recv_queue = instScoket.recv_queue
print('**** test ctr11 tcp socket command terminal ***')
while(True):
send_cmd = input("command > ")
send_cmd += "\r"
logging.info("send:{}".format(send_cmd))
self.instScoket.send(send_cmd)
time.sleep(0.3)
while not self.recv_queue.empty():
recv_data =self.recv_queue.get()
logging.info("recv data:{}".format(recv_data))
if __name__ == '__main__':
host = '192.168.1.3'
port = 1400
instScoket = SocketClient(host,port)
instScoket.connect()
time.sleep(1)
command_terminal(instScoket)