Proksi, balanslovchi, CDN va P2P

import socket
import threading

ORQA_PORT = 9970      # haqiqiy ilova
PROKSI_PORT = 9971    # mijoz shu yerga ulanadi

# --- orqadagi ilova
orqa = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
orqa.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
orqa.bind(("127.0.0.1", ORQA_PORT))
orqa.listen(4)


def ilova():
    u, _ = orqa.accept()
    sorov = u.recv(4096).decode()
    yol = sorov.split(" ")[1]
    tana = f"ilova javobi, yo'l: {yol}".encode()
    u.sendall(b"HTTP/1.1 200 OK\r\nContent-Length: "
              + str(len(tana)).encode() + b"\r\n\r\n" + tana)
    u.close()


# --- proksi
proksi = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
proksi.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
proksi.bind(("127.0.0.1", PROKSI_PORT))
proksi.listen(4)

jurnal = []


def proksi_ishla():
    mijoz_ulanishi, kim = proksi.accept()
    sorov = mijoz_ulanishi.recv(4096)
    jurnal.append(sorov.split(b"\r\n")[0].decode())

    # Orqadagi ilovaga uzatamiz - va o'zimiz haqimizda sarlavha qo'shamiz
    qoshimcha = b"X-Forwarded-For: 127.0.0.1\r\n"
    uzatiladigan = sorov.replace(b"\r\n\r\n", b"\r\n" + qoshimcha + b"\r\n")

    orqaga = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    orqaga.connect(("127.0.0.1", ORQA_PORT))
    orqaga.sendall(uzatiladigan)

    javob = b""
    while True:
        b_ = orqaga.recv(4096)
        if not b_:
            break
        javob += b_
    orqaga.close()

    mijoz_ulanishi.sendall(javob)
    mijoz_ulanishi.close()


t1 = threading.Thread(target=ilova, daemon=True)
t2 = threading.Thread(target=proksi_ishla, daemon=True)
t1.start()
t2.start()

# --- mijoz PROKSIga ulanadi, ilovani umuman bilmaydi
m = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
m.settimeout(5)
m.connect(("127.0.0.1", PROKSI_PORT))
m.sendall(b"GET /darslik HTTP/1.1\r\nHost: sayt.uz\r\n\r\n")

javob = b""
while True:
    b_ = m.recv(4096)
    if not b_:
        break
    javob += b_
m.close()

t1.join()
t2.join()
orqa.close()
proksi.close()

sarlavhalar, tana = javob.decode().split("\r\n\r\n", 1)
print("mijoz ulangan port:", PROKSI_PORT)
print("javob birinchi qatori:", sarlavhalar.split("\r\n")[0])
print("javob tanasi:", tana)
print()
print("proksi jurnali:", jurnal)
print("mijoz orqadagi port", ORQA_PORT, "ni bilmaydi ham")

class Balanslovchi:
    def __init__(self, serverlar):
        self.serverlar = serverlar
        self.joriy = 0
        self.ulanishlar = {s: 0 for s in serverlar}

    def navbat_bilan(self):
        s = self.serverlar[self.joriy % len(self.serverlar)]
        self.joriy += 1
        return s

    def eng_bosh(self):
        return min(self.serverlar, key=lambda s: self.ulanishlar[s])


SERVERLAR = ["server-1", "server-2", "server-3"]

b = Balanslovchi(SERVERLAR)
print("navbat bilan (round-robin):")
for i in range(1, 7):
    print(f"  {i}-so'rov -> {b.navbat_bilan()}")

print()
print("eng bo'sh serverga (least connections):")
b2 = Balanslovchi(SERVERLAR)
# server-1 ga uchta uzoq ulanish osilib qolgan
b2.ulanishlar["server-1"] = 3
b2.ulanishlar["server-2"] = 1
b2.ulanishlar["server-3"] = 0

for i in range(1, 7):
    s = b2.eng_bosh()
    b2.ulanishlar[s] += 1
    holat = " ".join(f"{k.split('-')[1]}:{v}"
                     for k, v in b2.ulanishlar.items())
    print(f"  {i}-so'rov -> {s}   yuk: {holat}")

print()
print("navbat bilan usuli yukni HISOBGA OLMAYDI")
print("eng bo'sh usuli esa band serverni chetlab o'tadi")