Onnowpurbo: /* Client side */

2018-11-24T00:59:43Z

Client side

← Older revision		Revision as of 00:59, 24 November 2018
Line 51:		Line 51:



			==Pranala Menarik==

			* https://docs.python.org/3/library/socketserver.html

	==Pranala Menarik==		==Pranala Menarik==

	* [[Python3]]		* [[Python3]]

Onnowpurbo: /* Client side */

2018-11-24T00:56:06Z

Client side

← Older revision		Revision as of 00:56, 24 November 2018
Line 49:		Line 49:

	python ThreadedTCPServer.py		python ThreadedTCPServer.py



			==Pranala Menarik==

			* [[Python3]]

Onnowpurbo: Created page with "==Server side== import socket import threading import socketserver class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler): def handle(self):..."

2018-11-24T00:51:09Z

Created page with "==Server side== import socket import threading import socketserver class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler): def handle(self):..."

New page

==Server side==

import socket
import threading
import socketserver

class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler):

def handle(self):
data = str(self.request.recv(1024), 'ascii')
cur_thread = threading.current_thread()
response = bytes("{}: {}".format(cur_thread.name, data), 'ascii')
self.request.sendall(response)

class ThreadedTCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
pass

def client(ip, port, message):
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
sock.connect((ip, port))
sock.sendall(bytes(message, 'ascii'))
response = str(sock.recv(1024), 'ascii')
print("Received: {}".format(response))

if __name__ == "__main__":
# Port 0 means to select an arbitrary unused port
HOST, PORT = "localhost", 0

server = ThreadedTCPServer((HOST, PORT), ThreadedTCPRequestHandler)
with server:
ip, port = server.server_address

# Start a thread with the server -- that thread will then start one
# more thread for each request
server_thread = threading.Thread(target=server.serve_forever)
# Exit the server thread when the main thread terminates
server_thread.daemon = True
server_thread.start()
print("Server loop running in thread:", server_thread.name)

client(ip, port, "Hello World 1")
client(ip, port, "Hello World 2")
client(ip, port, "Hello World 3")

server.shutdown()

==Client side==

python ThreadedTCPServer.py

Python3: Asynchronous Mixins - Revision history

Onnowpurbo: /* Client side */

Onnowpurbo: /* Client side */

Onnowpurbo: Created page with "==Server side== import socket import threading import socketserver class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler): def handle(self):..."