En Python se ha creado un script que me abre un puerto a demanda en mi máquina linux, la recepción, respuesta, cierre de sesión y almacén de datos anda bien, pero cada cierto tiempo el socket se bloquea y por ende deja de recibir datos. He leido que mientras haya una sesión establecida el socket se bloquea e impide nuevas conexiones. ¿Hay alguna forma de impedir el bloqueo del puerto? de forma que al haber una sesión establecida aún pueda recibir mensajes por el mismo puerto?
El código es el siguiente:
De antemano agradezco la ayuda
import os
from datetime import datetime
import socket
from threading import Thread
import threading
import time
import argparse
import multiprocessing as mp
import thread
import subprocess
import codecs
import traceback
print_lock = threading.Lock()
class SocketServer():
'''
This class creates a socket server and listens to messages on a specific ip and port.
'''
clients = []
def __init__(self, ip='127.0.0.1', port='8080', folder_path='data', timer=60):
'''
Parameters
ip: int
Ip to receive messages with web socket.
port: int
Port to receive messages with web socket.
folder_path: string
Path to save messages received with web socket.
timer: int
Timer to wait to last messages or close connection with client.
'''
self.ip = ip
self.port = port
self.folder_path = folder_path
self.timer = timer
self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
#self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
self.socket.bind((self.ip, self.port))
self.socket.listen(5)
def run(self):
print ("Server started")
try:
self.accept_clients()
except Exception as ex:
print (ex)
finally:
print ("Server closed")
for client in self.clients:
client.close()
self.socket.close()
def accept_clients(self):
'''
Accet client to connect this and create thread to process client.
'''
while 1:
print("Multithreaded Python server : Waiting for connections in IP:", self.ip, " PORT:",self.port)
print_lock.acquire()
(clientsocket, address) = self.socket.accept()
clientsocket.settimeout(self.timer)
#Adding client to clients list
self.clients.append(clientsocket)
#Client Connected
self.onopen(clientsocket, address)
#Receiving data from client
thread.start_new_thread(self.receive, (clientsocket,address))
def receive(self, client, address):
'''
Receive messages from client trough onmessage and onclose
'''
data_brute=''
max_buffer_size = 1024
try:
while 1:
data_brute, port = client.recvfrom(max_buffer_size)
if not data_brute:
break
else:
#Message Received
self.onmessage(client, data_brute, address)
self.onclose(client,address, data_brute)
except Exception:
traceback.print_exc()
#Client Disconnected
self.onclose(client,address, data_brute)
def onopen(self, client, address):
'''
Trigger when new client connected.
'''
print ("[+] New server socket thread started for " + str(address))
def onmessage(self, client, message, address):
'''
Trigger when response to client with a message.
'''
self.save_data(address[0], message)
MESSAGE = b'\nMessage received by server\n'
client.send(MESSAGE) # echo
def onclose(self, client, address, data):
'''
Trigger to print close connection with client.
'''
print("Close connection",address, data)
print_lock.release()
#Removing client from clients list
self.clients.remove(client)
#Closing connection with client
client.close()
#Closing thread
thread.exit()
def save_data(self, addr, data):
'''
Save in txt and call php function when receive data from client.
Parameters
----------
addr: tuple int (ip,port)
Address from connected client
data: bytes
Data send from client to server.
'''
#Save data in txt and log adding lines to document.
file_path = os.path.join(self.folder_path,'data.txt')
log_path = os.path.join('log','log.txt')
data_decode = data
if not os.path.isdir(self.folder_path):
os.makedirs(self.folder_path)
if not os.path.isdir('log'):
os.makedirs('log')
now = datetime.now()
dt_string = now.strftime("%d/%m/%Y %H:%M:%S")
with open(file_path, 'w') as file:
file.write('#'+data_decode+'\n')
with open(log_path, 'a') as file:
file.write(dt_string +','+data_decode+'\n')
subprocess.call(["php", "thingsend.php"])
def main(ip='127.0.0.1',port=18003, folder_path='data'):
'''
Funtion principal to create object SocketServer from websocket.
'''
# Multithreaded Python server : TCP Server Socket Program Stub
SocketServer(ip, port, folder_path)
if __name__ == "__main__":
parser = argparse.ArgumentParser()
parser.add_argument('parameters',
type=str, nargs=3,
help='host, port and folder')
args = parser.parse_args()
ip = args.parameters[0]
port = int(args.parameters[1])
folder_path = os.path.abspath(args.parameters[2])
server_process = mp.Process(name="{server_socket}",
args=(ip, port, folder_path),
target=main)
server_process.start()