UDP — connectionless-এর সরলতা

লক্ষ্য: দেখানো যে UDP-র উপর reliability বানানো সহজ — শুধু তা transport-এ না রেখে application-এ রাখতে হয়। পুরো protocol: client "TIME <seq>" পাঠায়, server "OK <seq> <unix-time>" ফেরত দেয়।

Server (time_server.py):

import socket, time, random

DROP_EVERY = 0          # 3 দিলে প্রতি ৩-তম reply ইচ্ছাকৃত drop (demo)

def main():
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    s.bind(("0.0.0.0", 3777))
    print("UDP time-server on :3777 — কোনো connection, শুধু datagram")
    n = 0
    while True:
        data, addr = s.recvfrom(512)
        parts = data.decode(errors="replace").split()
        # খারাপ/অজানা request-ও এক datagram-এই এসেছে — ব্যর্থতা একাই সীমাবদ্ধ
        if len(parts) != 2 or parts[0] != "TIME":
            continue
        seq = parts[1]
        n += 1
        if DROP_EVERY and n % DROP_EVERY == 0:
            print(f"{seq}: ইচ্ছাকৃত drop (demo)")
            continue
        reply = f"OK {seq} {time.time():.6f}"
        s.sendto(reply.encode(), addr)

if __name__ == "__main__":
    main()

Client (time_client.py):

import socket, sys, time

def query(sock, seq, retries=3):
    msg = f"TIME {seq}".encode()
    for attempt in range(1, retries + 1):
        sock.sendto(msg, ("127.0.0.1", 3777))
        try:
            data, _ = sock.recvfrom(512)
            return data.decode(), attempt
        except socket.timeout:
            print(f"  seq={seq}: timeout, retry {attempt}/{retries}")
    return None, retries

def main():
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    s.settimeout(0.7)
    for seq in range(1, 6):
        t0 = time.monotonic()
        reply, tries = query(s, seq)
        if reply is None:
            print(f"seq={seq}: FAILED — server কাছে নেই বা সব reply হারাল")
            continue
        rtt = (time.monotonic() - t0) * 1000
        print(f"seq={seq}: {reply}  (rtt={rtt:.1f} ms, tries={tries})")
        time.sleep(0.3)

if __name__ == "__main__":
    main()

চালান:

python3 time_server.py        # এক terminal-এ
python3 time_client.py        # আরেকটায়

এবার server-এ DROP_EVERY = 3 করে দুটোই আবার চালান — client- এর timeout-retry লাইনগুলো দেখবেন। প্রতিটা reply-তে নিজের পাঠানো seq ফিরে আসছে দেখে client নিশ্চিত হয় উত্তরটা তারই প্রশ্নের — এই ছোট ট্রিকটাই আজকের ICMP লেসনের identifier+sequence প্যাটার্নের প্রতিধ্বনি, এবং পরের লেসনের TCP seq/ack-র ভূতুড়ে পূর্বাভাস।

নিজে বাড়ান:

1. Client-এ পরপর দ্রুত ৫টা request পাঠিয়ে reply গুলোর ক্রম উল্টে গেলে ধরুন (loopback-এ কষ্ট, কিন্তু delay যোগ করে সম্ভব)
2. Server-এ প্রতি request-এ নতুন socket-এ reply দিয়ে দেখুন source port বদলালে client-এর কী হয়
3. Broadcast যোগ করুন — SO_BROADCAST সেট করে 255.255.255.255-এ এক request, LAN-এর সব time-server একসাথে উত্তর দেবে