Apache ActiveMQ এর বেসিক কনসেপ্ট

অ্যাপাচি অ্যাকটিভএমকিউ হলো একটি ওপেন সোর্স মেসেজ ব্রোকার সিস্টেম যা বিভিন্ন অ্যাপ্লিকেশন ও সিস্টেমের মধ্যে মেসেজ আদান-প্রদানকে সহজ এবং নিরাপদ করে। এটি মূলত মেসেজিং সিস্টেমের জন্য ব্যবহৃত হয়, যেখানে এক বা একাধিক প্রোডিউসার এবং কনসিউমার মেসেজ আদান-প্রদান করতে পারে। অ্যাপাচি অ্যাকটিভএমকিউ এর বেসিক কনসেপ্টগুলো বুঝে নেওয়া খুবই গুরুত্বপূর্ণ, যাতে আপনি সিস্টেমটি সঠিকভাবে ব্যবহার করতে পারেন।

অ্যাপাচি অ্যাকটিভএমকিউ এর মূল কনসেপ্ট

১. মেসেজ (Message)

মেসেজ হল অ্যাপাচি অ্যাকটিভএমকিউ এর মধ্যে ডেটার একক এক্সচেঞ্জ। মেসেজ সাধারণত তিনটি প্রধান উপাদান নিয়ে গঠিত:

• হেডার (Header): মেসেজ সম্পর্কিত মেটাডেটা ধারণ করে যেমন প্রেরক, গন্তব্য, টাইমস্ট্যাম্প ইত্যাদি।
• বডি (Body): মেসেজের আসল ডেটা বা কনটেন্ট থাকে এখানে।
• প্রপার্টিজ (Properties): অতিরিক্ত তথ্য বা কাস্টম প্রপার্টি থাকে যা মেসেজের প্রসেসিং বা রাউটিংকে সাহায্য করতে পারে।

২. কিউ (Queue)

কিউ হলো একটি FIFO (First In, First Out) ডেটা স্ট্রাকচার যেখানে মেসেজগুলো রাখা হয়। এটি পয়েন্ট-টু-পয়েন্ট মেসেজিং মডেল (Point-to-Point Messaging Model) এর জন্য ব্যবহৃত হয়, যেখানে এক প্রোডিউসার মেসেজ তৈরি করে এবং এক বা একাধিক কনসিউমার সেই মেসেজ গ্রহণ করে। কিউতে যে মেসেজ প্রথমে পৌঁছায়, সেটি প্রথমে কনসিউম করা হবে।

৩. টপিক (Topic)

টপিক হলো একটি পাবলিশ-অ্যান্ড-সাবস্ক্রাইব মেসেজিং মডেল (Publish-and-Subscribe Messaging Model) এর অংশ, যেখানে প্রোডিউসার একটি মেসেজ একাধিক সাবস্ক্রাইবারকে পাঠাতে পারে। এখানে, একাধিক কনসিউমার একই মেসেজ গ্রহণ করতে পারে। এটি সাধারণত ব্রডকাস্ট মেসেজিং ব্যবহারের জন্য ব্যবহৃত হয়।

৪. পোস্টিং (Producer)

পোস্টিং বা প্রোডিউসার (Producer) হলো সেই কম্পোনেন্ট যা মেসেজ তৈরি করে এবং এটি অ্যাকটিভএমকিউ ব্রোকারে পাঠায়। একটি প্রোডিউসার এক বা একাধিক কিউ বা টপিকে মেসেজ পোষ্ট করতে পারে।

৫. সাবস্ক্রাইবার (Consumer)

সাবস্ক্রাইবার (Consumer) হলো সেই কম্পোনেন্ট যা মেসেজ গ্রহণ করে। এটি এমন একটি অ্যাপ্লিকেশন হতে পারে যা মেসেজ কনসিউম বা প্রক্রিয়া করে। সাবস্ক্রাইবার একাধিক কিউ বা টপিক থেকে মেসেজ গ্রহণ করতে পারে।

৬. ব্রোকার (Broker)

ব্রোকার হলো অ্যাপাচি অ্যাকটিভএমকিউ এর কেন্দ্রীয় কম্পোনেন্ট, যা মেসেজ গ্রহণ এবং রাউটিং করার কাজ করে। এটি কিউ বা টপিকের মাধ্যমে মেসেজগুলিকে প্রোডিউসার থেকে কনসিউমারের কাছে পাঠায়। ব্রোকার ক্লায়েন্টদের মধ্যে মেসেজ আদান-প্রদান নিশ্চিত করে।

৭. ট্রান্সপোর্ট (Transport)

অ্যাপাচি অ্যাকটিভএমকিউ বিভিন্ন ট্রান্সপোর্ট প্রোটোকল যেমন TCP, SSL, HTTP, UDP ইত্যাদি সমর্থন করে। ট্রান্সপোর্ট প্রোটোকলগুলি মেসেজের আদান-প্রদান নিশ্চিত করতে ক্লায়েন্ট এবং ব্রোকারের মধ্যে যোগাযোগ স্থাপন করে।

অ্যাপাচি অ্যাকটিভএমকিউ মেসেজিং মডেল

অ্যাপাচি অ্যাকটিভএমকিউ দুটি প্রধান মেসেজিং মডেল ব্যবহার করে:

১. পয়েন্ট-টু-পয়েন্ট মডেল (Point-to-Point Model)

এই মডেলে, একটি প্রোডিউসার একটি মেসেজ একটি কিউতে পোষ্ট করে এবং শুধুমাত্র এক বা একাধিক কনসিউমার সেই মেসেজ গ্রহণ করে। এটি "কিউ" ভিত্তিক সিস্টেম যেখানে মেসেজ একবার কনসিউম হলে, তা আর পুনরায় প্রক্রিয়া করা যায় না।

২. পাবলিশ-অ্যান্ড-সাবস্ক্রাইব মডেল (Publish-and-Subscribe Model)

এই মডেলে, একটি প্রোডিউসার একটি টপিকের মাধ্যমে একাধিক কনসিউমারকে একই মেসেজ পাঠায়। এটি "টপিক" ভিত্তিক সিস্টেম যেখানে একাধিক কনসিউমার একই মেসেজ গ্রহণ করতে পারে। এটি ব্রডকাস্ট মেসেজিং এর জন্য ব্যবহার করা হয়।

সারাংশ

অ্যাপাচি অ্যাকটিভএমকিউ এর বেসিক কনসেপ্টগুলো মেসেজিং সিস্টেমের কার্যপ্রণালীকে সহজ এবং কার্যকরী করে তোলে। এখানে প্রোডিউসার মেসেজ তৈরি করে এবং ব্রোকারের মাধ্যমে কিউ বা টপিকের মাধ্যমে কনসিউমারের কাছে পৌঁছায়। কিউ এবং টপিক দুটি মেসেজিং মডেল দ্বারা মেসেজ আদান-প্রদান নিশ্চিত হয়। এর মাধ্যমে বিভিন্ন ডিস্ট্রিবিউটেড সিস্টেম এবং অ্যাপ্লিকেশনগুলির মধ্যে নিরাপদ এবং দ্রুত ডেটা শেয়ার করা সম্ভব হয়।

অ্যাপাচি অ্যাকটিভএমকিউ (Apache ActiveMQ) দুটি প্রধান মেসেজিং মডেল সাপোর্ট করে: Queue এবং Topic। এই দুটি মডেল ডিস্ট্রিবিউটেড সিস্টেমে মেসেজিং সিস্টেমের মধ্যে যোগাযোগের জন্য ব্যবহৃত হয়। তবে, Queue এবং Topic এর মধ্যে কিছু মৌলিক পার্থক্য রয়েছে, যা তাদের ব্যবহার এবং কার্যকারিতাকে পৃথক করে।

Queue (কিউ)

Queue মেসেজিং মডেল Point-to-Point (P2P) মডেল নামে পরিচিত। এটি একক প্রযোজক (Producer) এবং একক ভোক্তা (Consumer) এর মধ্যে মেসেজের আদান-প্রদান নিশ্চিত করে।

বৈশিষ্ট্য:

• একক কনজিউমার: একটি কিউতে যেসব মেসেজ আসে, সেগুলি কেবলমাত্র এক কনজিউমার (Consumer) গ্রহণ করতে পারে। অর্থাৎ, মেসেজগুলো একাধিক কনজিউমারের মধ্যে ভাগ করা হয় না।
• মেসেজ সিকোয়েন্স: কিউ মেসেজের সিকোয়েন্স এবং অর্ডার সঠিকভাবে রক্ষা করে, যাতে মেসেজগুলো সঠিকভাবে প্রসেস করা যায়।
• ডুরেবিলিটি (Durability): কিউ মেসেজগুলো স্থায়ী হতে পারে (যদি ডুরেবল কিউ ব্যবহৃত হয়), যা নিশ্চিত করে যে, মেসেজ সিস্টেম পুনরায় চালু হলে মেসেজগুলো হারাবে না।

উদাহরণ:

• একটি অর্ডার প্রক্রিয়াকরণ সিস্টেম, যেখানে একটি কিউতে গ্রাহকের অর্ডারগুলো রাখা হয় এবং একক প্রক্রিয়া (যেমন পেমেন্ট) করা হয়।

Topic (টপিক)

Topic মেসেজিং মডেল Publish-Subscribe (Pub-Sub) মডেল নামে পরিচিত। এটি একাধিক প্রযোজক এবং একাধিক ভোক্তার মধ্যে মেসেজের আদান-প্রদান নিশ্চিত করে।

বৈশিষ্ট্য:

• বহু কনজিউমার: একাধিক কনজিউমার একই মেসেজ গ্রহণ করতে পারে। অর্থাৎ, এক প্রযোজক (Producer) একই মেসেজ একাধিক কনজিউমারকে পাঠাতে পারে।
• ব্রডকাস্টিং (Broadcasting): মেসেজটি প্রকাশ (Publish) করার পর, এটি সমস্ত সাবস্ক্রাইবারদের (Subscribers) কাছে পৌঁছায়।
• নন-ডুরেবল (Non-Durable): সাধারণত টপিকের মেসেজগুলো ডুরেবল নয়, তবে এটি ডুরেবল সাবস্ক্রিপশন সাপোর্ট করে, যা মেসেজগুলো সাবস্ক্রাইবারদের না পাওয়ার পরে আবার পাঠাতে সাহায্য করে।

উদাহরণ:

• একটি স্টক মার্কেট অ্যাপ্লিকেশন, যেখানে একাধিক কনজিউমার (যেমন ট্রেডাররা) একই স্টকের দাম সম্পর্কিত তথ্য গ্রহণ করতে পারে।

Queue এবং Topic এর মধ্যে পার্থক্য

সারাংশ

Queue এবং Topic এর মধ্যে মূল পার্থক্য হল মেসেজের প্রসেসিং এবং মেসেজের গ্রহণকারী। Queue মডেল একক কনজিউমারের জন্য মেসেজ প্রসেসিং নিশ্চিত করে, যেখানে মেসেজগুলি একে একে গ্রহণ করা হয়। অন্যদিকে, Topic মডেল একাধিক কনজিউমারের মধ্যে মেসেজ ভাগ করে দেয়, এবং এটি মূলত Publish-Subscribe মডেল অনুসরণ করে, যেখানে একাধিক সাবস্ক্রাইবার একই মেসেজ গ্রহণ করে।

অ্যাপাচি অ্যাকটিভএমকিউ দুটি মূল মেসেজিং মডেল সমর্থন করে: Point-to-Point (P2P) এবং Publish/Subscribe। এই দুটি মডেল মেসেজিং সিস্টেমের মাধ্যমে তথ্য আদান-প্রদান করার আলাদা পদ্ধতি এবং সুবিধা প্রদান করে। প্রতিটি মডেল বিভিন্ন পরিস্থিতিতে ব্যবহৃত হয় এবং এর নিজস্ব কার্যকারিতা ও সুবিধা রয়েছে।

Point-to-Point (P2P) মেসেজিং মডেল

Point-to-Point মডেল হল একটি সরল মেসেজিং প্যাটার্ন যেখানে এক প্রোডিউসার (Producer) থেকে মেসেজ সরাসরি একটি কিউ (Queue) তে পাঠানো হয় এবং এক কনজিউমার (Consumer) সেই মেসেজ গ্রহণ করে। এই মডেলটি FIFO (First In, First Out) পদ্ধতিতে কাজ করে, অর্থাৎ প্রথমে যে মেসেজ আসবে সেটি প্রথমে কনজিউমার দ্বারা প্রক্রিয়া করা হবে।

P2P মডেলের বৈশিষ্ট্য:

• একটি মেসেজ এক কনজিউমার পায়: P2P মডেলে একটি কিউতে পাঠানো মেসেজটি শুধুমাত্র একটি কনজিউমার গ্রহণ করে।
• লোড ব্যালান্সিং: যদি একাধিক কনজিউমার থাকে, তবে মেসেজগুলো সমানভাবে বিতরণ হয়। কিউতে থাকা মেসেজগুলো সবার মধ্যে ব্যালান্স হয়ে প্রক্রিয়া করা হয়।
• অ্যাসিঙ্ক্রোনাস কমিউনিকেশন: প্রোডিউসার এবং কনজিউমার একে অপরের অপেক্ষায় থাকে না। কনজিউমার যখন প্রস্তুত হবে তখন মেসেজটি গ্রহণ করবে।
• মেসেজের গ্যারান্টেড ডেলিভারি: P2P মডেলে মেসেজগুলো স্থায়ীভাবে কিউতে রাখা হয়, তাই মেসেজ হারানোর ভয় থাকে না।

ব্যবহার ক্ষেত্র:

• অর্ডার প্রসেসিং: যেমন একটি সিস্টেম থেকে অর্ডার ডেটা পাঠানো এবং প্রক্রিয়া করা।
• ব্যাংকিং ট্রানজ্যাকশন: যেখানে এক একটি ট্রানজ্যাকশন প্রক্রিয়াকরণের জন্য একটি নির্দিষ্ট কনজিউমার প্রয়োজন।

Publish/Subscribe মেসেজিং মডেল

Publish/Subscribe মডেলটি একটি পাবলিশ-সাবস্ক্রাইব প্যাটার্ন অনুসরণ করে, যেখানে একটি প্রোডিউসার (Publisher) মেসেজ একটি টপিক (Topic) তে পাঠায়, এবং একাধিক কনজিউমার (Subscriber) সেই টপিককে সাবস্ক্রাইব করে মেসেজ গ্রহণ করে। এই মডেলটি একাধিক কনজিউমারকে একই মেসেজ প্রেরণের সুবিধা দেয়।

Publish/Subscribe মডেলের বৈশিষ্ট্য:

• একাধিক কনজিউমার মেসেজ গ্রহণ করে: একটি মেসেজ একাধিক কনজিউমারকে পাঠানো হয়। সবাই একই মেসেজ গ্রহণ করে।
• ডাটা ব্রডকাস্টিং: এটি ব্রডকাস্টিংয়ের মতো কাজ করে, যেখানে একই মেসেজ একাধিক ডিভাইস বা কনজিউমারে পৌঁছায়।
• বৃহৎ স্কেল অ্যাপ্লিকেশন: এই মডেলটি বিশেষভাবে উপযুক্ত যখন সিস্টেমে একাধিক কনজিউমার একে অপরের সাথে যোগাযোগ করতে চাইছে বা একাধিক ডিভাইসে একই ডেটা পাঠানো প্রয়োজন।
• দ্বৈত ভিউ: প্রোডিউসার এবং কনজিউমার একে অপরের অবস্থার জন্য অপেক্ষা করে না, এটি অ্যাসিঙ্ক্রোনাস মেসেজিংয়ের সুবিধা দেয়।

ব্যবহার ক্ষেত্র:

• নিউজ ফিড সিস্টেম: যেখানে একাধিক সাবস্ক্রাইবার একই নিউজ আপডেট বা মেসেজ গ্রহণ করে।
• লাইভ স্ট্রিমিং: যখন একাধিক সাবস্ক্রাইবার একটি লাইভ ভিডিও বা অডিও স্ট্রিম গ্রহণ করে।

সারাংশ

• Point-to-Point (P2P): একটি প্রোডিউসার এক কিউতে মেসেজ পাঠায় এবং এক কনজিউমার সেই মেসেজ গ্রহণ করে। এটি লোড ব্যালান্সিং এবং অ্যাসিঙ্ক্রোনাস কমিউনিকেশনের জন্য উপযুক্ত।
• Publish/Subscribe: একটি প্রোডিউসার টপিকে মেসেজ পাঠায় এবং একাধিক কনজিউমার সেই টপিককে সাবস্ক্রাইব করে একই মেসেজ গ্রহণ করে। এটি ডাটা ব্রডকাস্টিং এবং বড় স্কেল অ্যাপ্লিকেশনগুলির জন্য উপযুক্ত।

এই দুটি মডেল মেসেজিং সিস্টেমের মধ্যে যোগাযোগের সঠিক উপায় নির্বাচন করতে সাহায্য করে, যেহেতু প্রতিটি মডেল বিভিন্ন প্রকারের ব্যবহারের জন্য উপযুক্ত।

অ্যাপাচি অ্যাকটিভএমকিউ (Apache ActiveMQ) মেসেজ ব্রোকারের মাধ্যমে মেসেজের প্রেরণ এবং গ্রহণের সময়, মেসেজের দীর্ঘস্থায়িতা (Persistence) একটি গুরুত্বপূর্ণ বিষয়। এটি নির্ধারণ করে যে মেসেজগুলি ডিফল্টভাবে কিউ বা টপিকে কতদিন থাকবে এবং সিস্টেম বন্ধ হওয়ার পরও সেগুলি কি সংরক্ষিত থাকবে। অ্যাকটিভএমকিউ মেসেজ ডেলিভারি দুইটি প্রধান মোডে পরিচালনা করে: Persistent এবং Non-persistent।

Persistent Message Delivery Mode

Persistent মেসেজ ডেলিভারি মোড নিশ্চিত করে যে মেসেজটি একবার পাঠানো হলে, সেটি ডাটাবেস বা ফাইল সিস্টেমে সেভ হয়ে যাবে এবং ব্রোকারের রিস্টার্ট বা সিস্টেম ক্র্যাশের পরও মেসেজটি হারিয়ে যাবে না। এই মোডে পাঠানো মেসেজগুলি দীর্ঘস্থায়ী (Persistent) হয়ে থাকে এবং তাদের ডেটা সিস্টেম বন্ধ বা ক্র্যাশ হওয়ার পরও পুনরুদ্ধার করা যায়।

Persistent মেসেজের বৈশিষ্ট্য:

• ডাটাবেস বা ফাইল সিস্টেমে সংরক্ষণ: মেসেজগুলি সিস্টেমের স্থায়ী স্টোরেজে (যেমন, ডাটাবেস বা ফাইল সিস্টেম) সংরক্ষিত হয়।
• নির্ভরযোগ্যতা: সিস্টেম যদি ক্র্যাশ হয় বা পুনরায় চালু হয়, তবুও মেসেজগুলো ফিরে পাওয়া সম্ভব।
• কম পারফরম্যান্স: মেসেজকে স্টোরেজে সেভ করার কারণে এটি কিছুটা বেশি সময় নিতে পারে, যার ফলে পারফরম্যান্সে কিছুটা প্রভাব পড়ে।

উদাহরণ

import javax.jms.*;

public class PersistentMessageProducer {
    public static void main(String[] args) throws JMSException {
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection connection = connectionFactory.createConnection();
        connection.start();

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue("TEST_QUEUE");

        MessageProducer producer = session.createProducer(destination);
        producer.setDeliveryMode(DeliveryMode.PERSISTENT);  // Persistent Delivery Mode

        TextMessage message = session.createTextMessage("This is a persistent message.");
        producer.send(message);

        System.out.println("Persistent message sent: " + message.getText());

        connection.close();
    }
}

উপরের কোডে, মেসেজটির ডেলিভারি মোড Persistent হিসেবে সেট করা হয়েছে, যার ফলে মেসেজটি ডাটাবেসে বা ফাইল সিস্টেমে সংরক্ষিত হবে।

Non-persistent Message Delivery Mode

Non-persistent মেসেজ ডেলিভারি মোডে, মেসেজটি পাঠানোর পর তা কোন স্থায়ী স্টোরেজে সংরক্ষিত হয় না। এটি শুধুমাত্র মেমরি বা টেম্পোরারি স্টোরেজে রক্ষা পায় এবং সিস্টেম বন্ধ বা ক্র্যাশ হলে মেসেজটি হারিয়ে যায়। এই মোডটি সাধারণত পারফরম্যান্স বৃদ্ধি করতে ব্যবহৃত হয়, কারণ এতে ডেটা স্টোরেজের জন্য অতিরিক্ত সময় লাগে না।

Non-persistent মেসেজের বৈশিষ্ট্য:

• মেমরিতে সংরক্ষণ: মেসেজগুলি মেমরি বা অন্যান্য টেম্পোরারি স্টোরেজে সংরক্ষিত থাকে।
• নির্ভরযোগ্যতা কম: সিস্টেম ক্র্যাশ হলে মেসেজগুলি হারিয়ে যাবে।
• উচ্চ পারফরম্যান্স: মেসেজটি দ্রুত পাঠানো হয় কারণ এটি ডাটাবেস বা স্থায়ী স্টোরেজে সেভ করা হয় না।

উদাহরণ

import javax.jms.*;

public class NonPersistentMessageProducer {
    public static void main(String[] args) throws JMSException {
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection connection = connectionFactory.createConnection();
        connection.start();

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue("TEST_QUEUE");

        MessageProducer producer = session.createProducer(destination);
        producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);  // Non-persistent Delivery Mode

        TextMessage message = session.createTextMessage("This is a non-persistent message.");
        producer.send(message);

        System.out.println("Non-persistent message sent: " + message.getText());

        connection.close();
    }
}

উপরের কোডে, মেসেজটির ডেলিভারি মোড Non-persistent হিসেবে সেট করা হয়েছে, যার ফলে মেসেজটি মেমরিতে সংরক্ষিত হবে এবং সিস্টেম বন্ধ হলে তা হারিয়ে যাবে।

Persistent এবং Non-persistent মেসেজের তুলনা

সারাংশ

অ্যাপাচি অ্যাকটিভএমকিউ মেসেজ ডেলিভারি মোড দুটি প্রদান করে: Persistent এবং Non-persistent। Persistent মোড মেসেজগুলো স্থায়ীভাবে সংরক্ষণ করে এবং সিস্টেমের রিস্টার্টের পরও তা পুনরুদ্ধার করা যায়, তবে এতে কিছুটা কম পারফরম্যান্স পাওয়া যায়। অপরদিকে, Non-persistent মোডে মেসেজগুলি দ্রুত প্রেরিত হয়, কিন্তু সিস্টেম বন্ধ হলে তা হারিয়ে যায়। অ্যাপ্লিকেশন বা সিস্টেমের প্রয়োজন অনুযায়ী মেসেজ ডেলিভারি মোড নির্বাচন করা উচিত।

অ্যাপাচি অ্যাকটিভএমকিউ একটি শক্তিশালী মেসেজ ব্রোকার যা মেসেজ প্রেরণ এবং গ্রহণের জন্য বিভিন্ন মেসেজ অ্যাকনলেজমেন্ট (Acknowledgment) মোড সমর্থন করে। Message Acknowledgment হচ্ছে একটি প্রক্রিয়া যা নিশ্চিত করে যে মেসেজ সফলভাবে গ্রহণ করা হয়েছে। অ্যাকনলেজমেন্ট মোড নির্ধারণ করে কিভাবে একটি মেসেজ কনজিউমার (Consumer) কর্তৃক অ্যাকনলেজ করা হবে এবং কবে তা মেসেজ ব্রোকার থেকে মুছে ফেলা হবে। অ্যাকনলেজমেন্ট মোডের সঠিক নির্বাচন মেসেজের প্রক্রিয়াকরণ এবং সিস্টেমের নির্ভরযোগ্যতা নিশ্চিত করতে সাহায্য করে।

ActiveMQ-তে Message Acknowledgment Modes

অ্যাপাচি অ্যাকটিভএমকিউ বিভিন্ন ধরনের মেসেজ অ্যাকনলেজমেন্ট মোড সরবরাহ করে, যার মধ্যে কিছু নিচে আলোচনা করা হলো:

১. AUTO_ACKNOWLEDGE

AUTO_ACKNOWLEDGE মোডে, যখন একটি মেসেজ কনজিউমার দ্বারা গ্রহণ করা হয়, তখন তা স্বয়ংক্রিয়ভাবে অ্যাকনলেজ হয়ে যায়। অর্থাৎ, কনজিউমার মেসেজ গ্রহণ করার পর, ActiveMQ মেসেজটি কনজিউমারের কাছে সফলভাবে পৌঁছানোর পরে অ্যাকনলেজ করে।

বৈশিষ্ট্য:

• সহজ এবং স্বয়ংক্রিয়ভাবে কাজ করে।
• কনজিউমার কেবল মেসেজ গ্রহণ করলে, অ্যাকনলেজমেন্ট কার্যকর হয়।
• কনজিউমারের মেসেজ প্রসেসিং শেষ হওয়ার পরেই অ্যাকনলেজমেন্ট পাঠানো হয়।

উদাহরণ:

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

২. CLIENT_ACKNOWLEDGE

CLIENT_ACKNOWLEDGE মোডে, কনজিউমারকে ম্যানুয়ালি মেসেজ অ্যাকনলেজ করতে হয়। অর্থাৎ, কনজিউমার যখন মেসেজ প্রক্রিয়া সম্পন্ন করবে, তখন সে নিজেই অ্যাকনলেজমেন্ট পাঠাবে। এই মোডটি মেসেজ প্রসেসিং এর উপর আরও নিয়ন্ত্রণ দেয় এবং ডেলিভারি নিশ্চিত করার জন্য সহায়ক।

বৈশিষ্ট্য:

• কনজিউমারের প্রক্রিয়া শেষ হওয়ার পর মেসেজটি ম্যানুয়ালি অ্যাকনলেজ করতে হয়।
• অ্যাকনলেজমেন্ট কনজিউমারের হাতে থাকে, যাতে সে তার মেসেজ প্রক্রিয়াকরণের পরে মেসেজটি অ্যাকনলেজ করতে পারে।

উদাহরণ:

Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);

৩. DUPS_OK_ACKNOWLEDGE

DUPS_OK_ACKNOWLEDGE মোডে, অ্যাকনলেজমেন্ট প্রক্রিয়াটি একটু ধীরভাবে কাজ করে এবং এটি কিছুটা কম নির্ভরযোগ্য। এই মোডটি তখন ব্যবহৃত হয় যখন মেসেজ কনজিউমারের কাছে পুনরায় ডেলিভারির চেষ্টা হতে পারে, তবে এটি দখল করতে একটু বেশি সময় নেয়। কিছু পরিস্থিতিতে এটি মেসেজ ডুপ্লিকেট হওয়ার সম্ভাবনা তৈরি করতে পারে, তবে এটি উচ্চ পারফরম্যান্সের জন্য উপযুক্ত।

বৈশিষ্ট্য:

• মেসেজ ডুপ্লিকেট হওয়ার সম্ভাবনা থাকে, তবে পারফরম্যান্সের ক্ষেত্রে সুবিধা প্রদান করে।
• যদি মেসেজ অপ্রত্যাশিতভাবে হারিয়ে যায়, তবে এটি পুনরায় ডেলিভারি করতে পারে।

উদাহরণ:

Session session = connection.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);

৪. SESSION_TRANSACTED

SESSION_TRANSACTED মোডে, মেসেজের প্রক্রিয়া ট্রানজেকশন হিসেবে পরিচালিত হয়। এটি মেসেজ প্রক্রিয়ার জন্য একাধিক মেসেজকে একত্রে প্রসেস করার সুযোগ দেয় এবং যদি কোনো মেসেজ প্রক্রিয়া ব্যর্থ হয়, তবে পূর্ববর্তী সমস্ত মেসেজকে রোলব্যাক করা হয়। এই মোডে, কনজিউমার ট্রানজেকশনের মাধ্যমে একাধিক মেসেজ অ্যাকনলেজ করতে পারে।

বৈশিষ্ট্য:

• ট্রানজেকশন ব্যবস্থাপনা সহ, একাধিক মেসেজ প্রসেস করা হয়।
• যদি এক বা একাধিক মেসেজের প্রক্রিয়া ব্যর্থ হয়, তবে পুরো ট্রানজেকশনটি রোলব্যাক করা হয়।
• উচ্চ নির্ভরযোগ্যতা এবং অ্যাটমিক অপারেশন নিশ্চিত করে।

উদাহরণ:

Session session = connection.createSession(true, Session.SESSION_TRANSACTED);

বিভিন্ন অ্যাকনলেজমেন্ট মোডের তুলনা

সারাংশ

অ্যাপাচি অ্যাকটিভএমকিউ-এর মেসেজ অ্যাকনলেজমেন্ট মোডগুলি বিভিন্ন পরিস্থিতির জন্য উপযুক্ত, এবং এগুলির সঠিক ব্যবহার সিস্টেমের পারফরম্যান্স, নির্ভরযোগ্যতা, এবং অ্যাটমিক অপারেশন নিশ্চিত করতে সহায়তা করে। AUTO_ACKNOWLEDGE সাধারণ অ্যাপ্লিকেশনগুলির জন্য সহজ এবং স্বয়ংক্রিয়, CLIENT_ACKNOWLEDGE কনজিউমারের মেসেজ প্রক্রিয়া নিয়ন্ত্রণে আনে, DUPS_OK_ACKNOWLEDGE উচ্চ পারফরম্যান্স প্রদান করে, এবং SESSION_TRANSACTED একটি ট্রানজেকশনাল সিস্টেমে নিরাপত্তা এবং ডেটা অখণ্ডতা নিশ্চিত করে।