Socket সংযোগ এবং Disconnect প্রক্রিয়া

Socket সংযোগ এবং Disconnect প্রক্রিয়া ZeroMQ-এর মাধ্যমে ডিস্ট্রিবিউটেড সিস্টেম এবং মেসেজিং অ্যাপ্লিকেশনের মধ্যে গুরুত্বপূর্ণ ভূমিকা পালন করে। ZeroMQ বিভিন্ন ধরনের সকার মডেল সাপোর্ট করে, যেমন REQ/REP, PUB/SUB, PUSH/PULL ইত্যাদি, এবং প্রতিটি সকারের সংযোগ এবং ডিসকানেক্ট প্রক্রিয়া কিছুটা ভিন্ন হতে পারে। তবে মূল সংযোগ প্রক্রিয়া এবং সকারের ব্যবহারের কৌশলগুলো সাধারণত একইরকম থাকে। নিচে ZeroMQ-এর Socket সংযোগ এবং Disconnect প্রক্রিয়া বিস্তারিতভাবে আলোচনা করা হলো:

১. Socket সংযোগ প্রক্রিয়া

ZeroMQ-তে Socket সংযোগ স্থাপনের জন্য কিছু নির্দিষ্ট ধাপ রয়েছে, যা বিভিন্ন সকার টাইপের ক্ষেত্রে প্রযোজ্য।

ধাপসমূহ:

Context তৈরি করা:

• ZeroMQ ব্যবহার করতে হলে প্রথমে একটি Context তৈরি করতে হয়। Context হলো ZeroMQ-এর জন্য একটি পরিবেশ, যা Socket তৈরি ও পরিচালনার জন্য ব্যবহৃত হয়।
• উদাহরণ:

import zmq
context = zmq.Context()

Socket তৈরি করা:

• Context তৈরি হওয়ার পরে, একটি Socket তৈরি করতে হয়। ZeroMQ বিভিন্ন ধরনের Socket প্রদান করে (যেমন REQ, REP, PUB, SUB, PUSH, PULL), যা নির্দিষ্ট মেসেজিং প্যাটার্নের জন্য ব্যবহৃত হয়।
• উদাহরণ:

socket = context.socket(zmq.REQ)  # REQ সকার তৈরি করা

Socket bind বা connect করা:

• একটি সকার সংযোগ করার সময় সেটিকে bind অথবা connect করতে হয়।
  • bind: সার্ভার বা মেসেজ প্রকাশকের ক্ষেত্রে সকারে bind করা হয়। এটি একটি নির্দিষ্ট পোর্ট এবং প্রোটোকলে সংযোগ তৈরি করে।
  • connect: ক্লায়েন্ট বা সাবস্ক্রাইবারের ক্ষেত্রে connect করা হয়, যা একটি নির্দিষ্ট পোর্টে সংযুক্ত হয়।
• উদাহরণ:

# সার্ভার বা পাবলিশারের জন্য
socket.bind("tcp://*:5555")  # 5555 পোর্টে bind করা

# ক্লায়েন্ট বা সাবস্ক্রাইবারের জন্য
socket.connect("tcp://localhost:5555")  # 5555 পোর্টে connect করা

একটি পূর্ণ উদাহরণ (REQ/REP):

# সার্ভার (REP)
import zmq

context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://*:5555")

while True:
    message = socket.recv_string()
    print(f"Received request: {message}")
    socket.send_string("Response from server")

# ক্লায়েন্ট (REQ)
import zmq

context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://localhost:5555")

socket.send_string("Hello from client")
reply = socket.recv_string()
print(f"Received reply: {reply}")

২. Disconnect প্রক্রিয়া

ZeroMQ সকারের সংযোগ বন্ধ করার জন্য কিছু নির্দিষ্ট ধাপ অনুসরণ করতে হয়। Disconnect প্রক্রিয়া নিশ্চিত করে যে সিস্টেমের মধ্যে কোন টাস্ক অসম্পূর্ণ থাকে না এবং সঠিকভাবে সংযোগ বন্ধ হয়।

ধাপসমূহ:

Socket বন্ধ করা:

• সকার সংযোগ বন্ধ করার জন্য close() মেথড ব্যবহার করা হয়। এটি সকারকে নিরাপদে বন্ধ করে এবং আর কোনো মেসেজ গ্রহণ বা প্রেরণ করে না।
• উদাহরণ:

socket.close()

Context বন্ধ করা:

• ZeroMQ Context বন্ধ করার জন্য terminate() মেথড ব্যবহার করা হয়। Context বন্ধ করা হলে, এটি সমস্ত সক্রিয় সকার এবং সংযোগও বন্ধ করে দেয়।
• উদাহরণ:

context.term()

একটি পূর্ণ Disconnect উদাহরণ:

import zmq

# Context এবং সকার তৈরি করা
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://localhost:5555")

# মেসেজ পাঠানো এবং গ্রহণ করা
socket.send_string("Hello from client")
reply = socket.recv_string()
print(f"Received reply: {reply}")

# সকার এবং Context বন্ধ করা
socket.close()
context.term()

সংযোগ এবং Disconnect-এর মধ্যে সতর্কতা:

• সঠিকভাবে Disconnect নিশ্চিত করা: একটি সকার বন্ধ করার সময় নিশ্চিত করতে হবে যে এটি সমস্ত মেসেজ প্রক্রিয়াকরণ শেষ করেছে। তা না হলে মেসেজ লস হতে পারে।
• শাটডাউন পরিকল্পনা: যদি সার্ভার বন্ধ করতে হয়, তবে মেসেজিং চ্যানেলের সকল ক্লায়েন্টকে সেটি আগে জানানো উচিত।
• Timeout এবং Poller ব্যবহার: ক্লায়েন্ট বা সার্ভারের সংযোগে সময়সীমা (Timeout) সেট করা উচিত, যাতে সংযোগ সমস্যা হলে এটি দ্রুত সাড়া দিতে পারে। ZeroMQ-তে Poller ব্যবহার করে সক্রিয় সকার পর্যবেক্ষণ করা যায়।

সংক্ষেপে:

ZeroMQ-তে Socket সংযোগ এবং Disconnect প্রক্রিয়া একটি নির্দিষ্ট ধাপ অনুসরণ করে সম্পন্ন করা হয়। Context তৈরি, Socket তৈরি, bind/connect করা, এবং সঠিকভাবে close ও terminate করা নিশ্চিত করতে হবে। REQ/REP, PUB/SUB, এবং PUSH/PULL এর মতো প্যাটার্নে সঠিক সংযোগ এবং Disconnect প্রক্রিয়া ব্যবহার করে ZeroMQ-এর মাধ্যমে কার্যকরী মেসেজিং সিস্টেম তৈরি করা সম্ভব।