Server is running as nc -l 1234
Below is the client that is not blocked on recv() using event loop's select() call.
client.py
import socket
import sys
from eventloop import EventLoop
class Connection():
def __init__(self):
self.sock = socket.socket()
self.sock.connect(('localhost', 1234))
def fileno(self):
return self.sock.fileno()
def onRead(self):
msg = self.sock.recv(1000).decode('utf-8')
print(msg)
def send(self, msg):
self.sock.send(msg)
class Input():
def __init__(self, sock):
self.sock = sock
def fileno(self):
return sys.stdin.fileno()
def onRead(self):
msg = sys.stdin.readline().encode('utf-8')
self.sock.send(msg)
sock = Connection()
inputReader = Input(sock)
eventLoop = EventLoop()
eventLoop.addReader(sock)
eventLoop.addReader(inputReader)
eventLoop.runForever()
eventloop.py
import select
class EventLoop():
def __init__(self):
self.readers = []
def addReader(self, reader):
self.readers.append(reader)
def runForever(self):
while True:
readers, _, _ = select.select(self.readers, [], [])
for reader in readers:
reader.onRead()
But self.sock.send(msg) call can get blocked for different reasons:
1) server is crashed
2) Remote server(not localhost) is not reachable, due to broken network cable
How to make send() call not blocked? by just throwing the message and continue with rest of the functionality... without using asyncio
