ইভেন্ট-ড্রিভেন আর্কিটেকচার

১ · রিকোয়েস্ট-রেসপন্স বনাম ইভেন্ট-ড্রিভেন

এতদিন আমরা যে যোগাযোগ মডেল দেখেছি (HTTP/REST, gRPC — L06, L07) সেটি রিকোয়েস্ট-রেসপন্সRequest-Responseক্যালার একটি নির্দিষ্ট সার্ভিসকে সরাসরি কল করে এবং তার রেসপন্সের জন্য অপেক্ষা করে — সিঙ্ক্রোনাস, টাইট কাপলড। — ক্যালার জানে ঠিক কাকে কল করছে, এবং রেসপন্সের জন্য অপেক্ষা করে। এটি সিঙ্ক্রোনাস এবং টাইটলি কাপলড — যদি Service B ডাউন থাকে, Service A-এর কলও ব্যর্থ হয়।

ইভেন্ট-ড্রিভেন আর্কিটেকচারে Service A শুধু একটি ইভেন্ট প্রকাশ করে ("এই ঘটনাটি ঘটেছে") এবং জানেই না কে বা কতজন তা শুনছে। প্রতিটি আগ্রহী সার্ভিস স্বাধীনভাবে সেই ইভেন্টে প্রতিক্রিয়া জানায়, নিজের সময়ে, নিজের গতিতে।

২ · Worked Example — "OrderPlaced" ইভেন্ট

একটি ই-কমার্স সিস্টেমে একজন গ্রাহক অর্ডার প্লেস করার সাথে সাথে "OrderPlaced" নামে একটি ইভেন্ট প্রকাশিত হয়। তিনটি সম্পূর্ণ স্বাধীন সার্ভিস এই ইভেন্টে প্রতিক্রিয়া জানায় — কেউ একে অপরকে সরাসরি কল করে না, সবাই শুধু একই ইভেন্ট শোনে।

৩ · Python-এ একটি ছোট ইভেন্ট বাস

নিচে একটি সাধারণ event bus বানানো হলো — একটি ডিকশনারি যা ইভেন্টের নামকে হ্যান্ডলার ফাংশনের তালিকার সাথে ম্যাপ করে। emit() কল করলে সেই ইভেন্টের সব রেজিস্টার্ড হ্যান্ডলার একে একে চলে।

event_handlers = {}

def on(event_name, handler):
    event_handlers.setdefault(event_name, []).append(handler)

def emit(event_name, data):
    print(f"ইভেন্ট emit হলো: {event_name} | data={data}")
    for handler in event_handlers.get(event_name, []):
        handler(data)

def inventory_handler(data):
    print(f"  [Inventory] স্টক কমানো হচ্ছে: {data['item']} x{data['qty']}")

def notification_handler(data):
    print(f"  [Notification] ইমেইল পাঠানো হচ্ছে গ্রাহক {data['customer']}-কে")

def analytics_handler(data):
    print(f"  [Analytics] বিক্রয় লগ করা হলো: order #{data['order_id']}")

# তিনটি স্বাধীন হ্যান্ডলার একই ইভেন্টে রেজিস্টার — কেউ কাউকে চেনে না
on("OrderPlaced", inventory_handler)
on("OrderPlaced", notification_handler)
on("OrderPlaced", analytics_handler)

emit("OrderPlaced", {"order_id": 501, "item": "Book", "qty": 2, "customer": "Rahim"})

print(f"\nমোট {len(event_handlers['OrderPlaced'])}টি হ্যান্ডলার independently fire করলো — কেউ একে অপরকে ডাকেনি")

৪ · ট্রেড-অফ — সবকিছু ইভেন্ট-ড্রিভেন করা ঠিক নয়

ইভেন্ট-ড্রিভেন আর্কিটেকচারের একটি বাস্তব খরচ আছে — ডিবাগিং কঠিন হয় (একটি ইভেন্ট ঠিক কোন কোন হ্যান্ডলার ট্রিগার করলো তা ট্রেস করা সরাসরি ফাংশন কলের মতো সহজ নয়, তাই L41-এর ডিস্ট্রিবিউটেড ট্রেসিং এখানে বিশেষভাবে দরকারি হয়ে ওঠে), এবং eventual consistency মেনে নিতে হয় — ইভেন্ট emit হওয়ার সাথে সাথে সব হ্যান্ডলার সম্পন্ন হয়ে যাবে এই গ্যারান্টি নেই। যেখানে ইউজারকে সাথে সাথে একটি নির্দিষ্ট ফলাফল (যেমন "পেমেন্ট সফল হয়েছে কি না") জানাতে হয়, সেখানে সিঙ্ক্রোনাস রিকোয়েস্ট-রেসপন্সই সঠিক পছন্দ থেকে যায়।