মাইক্রোসার্ভিসেস আর্কিটেকচারে নেটওয়ার্ক ব্যর্থতা বা ক্ষণস্থায়ী ত্রুটি (transient failure) খুবই সাধারণ। একটি সার্ভিস যখন অস্থায়ীভাবে ডাউন থাকে বা রেসপন্স দিতে দেরি করে, তখন ক্লায়েন্ট অ্যাপ্লিকেশন বারবার রিকোয়েস্ট পাঠিয়ে ব্যর্থ হতে পারে। এই সমস্যা সমাধানের জন্য রিট্রাই স্ট্র্যাটেজি (retry strategy) একটি অপরিহার্য প্যাটার্ন। এই টিউটোরিয়ালে আমরা রিট্রাই কীভাবে কাজ করে, বিভিন্ন ধরনের রিট্রাই কৌশল, এবং সেগুলো জাভা মাইক্রোসার্ভিসে বাস্তবায়নের পদ্ধতি শিখব।

ভূমিকা (Background)

রিট্রাই স্ট্র্যাটেজি হলো একটি ফল্ট টলারেন্স (fault tolerance) প্যাটার্ন যা কোনো অপারেশন ব্যর্থ হলে স্বয়ংক্রিয়ভাবে পুনরায় চেষ্টা করে। এটি বিশেষ করে নেটওয়ার্ক কল, ডেটাবেস কানেকশন, বা থার্ড-পার্টি API কলের জন্য কার্যকর। রিট্রাই করার সময় সঠিক কৌশল নির্বাচন না করলে সার্ভিসের উপর অতিরিক্ত লোড পড়তে পারে বা ডিস্ট্রিবিউটেড সিস্টেমে ক্যাসকেডিং ফেইলিওর (cascading failure) তৈরি হতে পারে।

রিট্রাই স্ট্র্যাটেজির মূল উপাদানগুলো হলো:

  • রিট্রাই কাউন্ট (retry count): কতবার পুনরায় চেষ্টা করবে
  • ডেলে (delay): প্রতিটি রিট্রাইয়ের মধ্যে কত সময় অপেক্ষা করবে
  • ব্যাক-অফ (back-off): ডেলের সময় ক্রমান্বয়ে বাড়ানো বা কমানোর কৌশল
  • এক্সপোনেনশিয়াল ব্যাক-অফ (exponential back-off): প্রতিটি রিট্রাইয়ের সাথে ডেলের সময় দ্বিগুণ করা

পূর্বশর্ত (Prerequisites)

এই টিউটোরিয়াল অনুসরণ করতে আপনার প্রয়োজন হবে:

  1. জাভা ডেভেলপমেন্ট এনভায়রনমেন্ট (JDK 8 বা তার উপরে)
  2. মাইক্রোসার্ভিস ফ্রেমওয়ার্ক - আমরা স্প্রিং বুট ব্যবহার করবো
  3. ম্যাভেন বা গ্রেডল - বিল্ড টুল
  4. রিট্রাই লাইব্রেরি - আমরা Spring Retry এবং Resilience4j ব্যবহার করবো
  5. বেসিক স্প্রিং বুট নলেজ - @RestController, @Service অ্যানোটেশন সম্পর্কে ধারণা

আপনার pom.xml-এ নিচের ডিপেন্ডেন্সি যোগ করুন:

<dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
</dependency>

ধাপে ধাপে বাস্তবায়ন (Step-by-step Implementation)

১. Spring Retry কনফিগারেশন

প্রথমে স্প্রিং বুট অ্যাপ্লিকেশনে @EnableRetry অ্যানোটেশন যোগ করতে হবে। এটি স্প্রিং কনটেক্সটে রিট্রাই ইন্টারসেপ্টর সক্রিয় করে।

@SpringBootApplication
@EnableRetry
public class RetryApplication {
    public static void main(String[] args) {
        SpringApplication.run(RetryApplication.class, args);
    }
}

এই অ্যানোটেশনটি স্প্রিং এওপি (AOP) ব্যবহার করে রিট্রাই লজিক প্রয়োগ করে। এর মানে হলো, যেকোনো মেথডে @Retryable অ্যানোটেশন দিলে স্বয়ংক্রিয়ভাবে রিট্রাই হবে।

২. বেসিক রিট্রাই মেথড তৈরি

একটি সিম্পল সার্ভিস ক্লাস তৈরি করি যা এক্সটার্নাল API কল করবে। ধরুন, কখনো কখনো API 500 বা 503 এরর দেয়।

@Service
public class ExternalService {
    
    @Retryable(
        value = {RuntimeException.class},
        maxAttempts = 3,
        backoff = @Backoff(delay = 2000)
    )
    public String callExternalApi() {
        // সিমুলেটেড ব্যর্থতা
        if (Math.random() > 0.5) {
            throw new RuntimeException("Service temporarily unavailable");
        }
        return "Success response";
    }
}

এখানে maxAttempts = 3 মানে সর্বোচ্চ ৩ বার চেষ্টা করবে। backoff.delay = 2000 মানে প্রতিটি চেষ্টার মধ্যে ২ সেকেন্ড অপেক্ষা করবে। যদি সব চেষ্টা ব্যর্থ হয়, তাহলে RuntimeException থ্রো হবে।

৩. এক্সপোনেনশিয়াল ব্যাক-অফ কনফিগারেশন

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

@Retryable(
    value = {RuntimeException.class},
    maxAttempts = 5,
    backoff = @Backoff(
        delay = 1000,
        multiplier = 2.0,
        maxDelay = 10000
    )
)
public String callExternalApiWithExponentialBackoff() {
    // API কল লজিক
    if (someCondition) {
        throw new RuntimeException("Temporary error");
    }
    return "Success";
}

প্রথম চেষ্টায় ১ সেকেন্ড, দ্বিতীয় চেষ্টায় ২ সেকেন্ড (মাল্টিপ্লায়ার 2.0), তৃতীয় চেষ্টায় ৪ সেকেন্ড, এবং সর্বোচ্চ ১০ সেকেন্ড পর্যন্ত অপেক্ষা করবে।

৪. রিট্রাই ফেইলিওর হ্যান্ডলিং

যদি সব রিট্রাই ব্যর্থ হয়, তাহলে @Recover অ্যানোটেশন ব্যবহার করে একটি ফলব্যাক (fallback) মেথড ডিফাইন করতে পারি।

@Retryable(
    value = {RuntimeException.class, IOException.class},
    maxAttempts = 3
)
public String processData(String input) {
    // প্রসেসিং লজিক
    if (input == null) {
        throw new IllegalArgumentException("Invalid input");
    }
    return "Processed: " + input;
}

@Recover
public String recover(RuntimeException e, String input) {
    return "Fallback response for: " + input;
}

@Recover মেথডের প্যারামিটার সিগনেচার অবশ্যই মূল মেথডের সাথে মিলতে হবে। এখানে প্রথম প্যারামিটার হলো এক্সেপশন টাইপ, বাকি প্যারামিটারগুলো মূল মেথডের মতো।

সম্পূর্ণ উদাহরণ (Complete Example)

নিচে একটি সম্পূর্ণ স্প্রিং বুট কন্ট্রোলার এবং সার্ভিস উদাহরণ দেওয়া হলো যা আপনি কপি করে রান করতে পারেন।

ExternalService.java - সার্ভিস ক্লাস:

package com.example.retry;

import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Service;
import java.io.IOException;

@Service
public class ExternalService {

    @Retryable(
        value = {IOException.class, RuntimeException.class},
        maxAttempts = 4,
        backoff = @Backoff(delay = 1000, multiplier = 2.0)
    )
    public String fetchData(String url) throws IOException {
        // সিমুলেটেড নেটওয়ার্ক ব্যর্থতা
        if (Math.random() < 0.7) {
            throw new IOException("Connection timeout for " + url);
        }
        return "Data from " + url;
    }

    @Retryable(
        value = {RuntimeException.class},
        maxAttempts = 3,
        backoff = @Backoff(delay = 500)
    )
    public String processRequest(String request) {
        if (request.length() > 10) {
            throw new RuntimeException("Request too long");
        }
        return "Processed: " + request;
    }
}

RetryController.java - REST কন্ট্রোলার:

package com.example.retry;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class RetryController {

    @Autowired
    private ExternalService externalService;

    @GetMapping("/fetch")
    public String fetchData(@RequestParam(defaultValue = "http://example.com") String url) {
        try {
            return externalService.fetchData(url);
        } catch (Exception e) {
            return "Error: " + e.getMessage();
        }
    }

    @GetMapping("/process")
    public String processRequest(@RequestParam(defaultValue = "test") String request) {
        return externalService.processRequest(request);
    }
}

RetryApplication.java - মেইন ক্লাস:

package com.example.retry;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.retry.annotation.EnableRetry;

@SpringBootApplication
@EnableRetry
public class RetryApplication {
    public static void main(String[] args) {
        SpringApplication.run(RetryApplication.class, args);
    }
}

এই উদাহরণটি http://localhost:8080/fetch?url=test এবং http://localhost:8080/process?request=mydata এন্ডপয়েন্টে রান করলে আপনি রিট্রাই লজিকের আউটপুট দেখতে পাবেন।

সাধারণ সমস্যা ও সমাধান (Common Issues)

১. রিট্রাই লুপে আটকে যাওয়া (Infinite Loop)

যদি maxAttempts না দেন, তাহলে ডিফল্ট মান ৩ ব্যবহার করে। কিন্তু কিছু ক্ষেত্রে আপনি যদি value প্যারামিটার ভুলভাবে সেট করেন, তাহলে রিট্রাই কাজ নাও করতে পারে।

সমাধান: সবসময় maxAttempts এবং backoff প্যারামিটার স্পষ্টভাবে ডিফাইন করুন।

২. থ্রেড সেফটি ইস্যু (Thread Safety)

রিট্রাই মেথড যদি স্টেটফুল (stateful) হয়, তাহলে থ্রেড সেফটি সমস্যা হতে পারে। যেমন, কাউন্টার ভেরিয়েবল ব্যবহার করলে।

সমাধান: রিট্রাই মেথডকে স্টেটলেস (stateless) রাখুন। যদি স্টেট প্রয়োজন হয়, তাহলে ThreadLocal ব্যবহার করুন।

৩. সার্কিট ব্রেকার (Circuit Breaker) ছাড়া রিট্রাই

শুধু রিট্রাই ব্যবহার করলে সার্ভিস ডাউন থাকলে বারবার চেষ্টা করে রিসোর্স নষ্ট হবে। সার্কিট ব্রেকার প্যাটার্নের সাথে রিট্রাই ব্যবহার করা ভালো।

সমাধান: Resilience4j বা Hystrix এর মতো লাইব্রেরি ব্যবহার করে সার্কিট ব্রেকার যুক্ত করুন।

// Resilience4j সার্কিট ব্রেকারের সাথে রিট্রাই
@CircuitBreaker(name = "externalService", fallbackMethod = "fallback")
@Retry(name = "externalService", fallbackMethod = "fallback")
public String callService() {
    // API কল
}

সারসংক্ষেপ (Summary)

এই টিউটোরিয়ালে আমরা রিট্রাই স্ট্র্যাটেজির মূল ধারণা এবং জাভা মাইক্রোসার্ভিসে বাস্তবায়নের পদ্ধতি শিখেছি। Spring Retry লাইব্রেরি ব্যবহার করে আমরা সহজেই @Retryable এবং @Recover অ্যানোটেশন দিয়ে রিট্রাই লজিক যোগ করতে পারি। মনে রাখবেন:

  • এক্সপোনেনশিয়াল ব্যাক-অফ ব্যবহার করলে সার্ভিসের উপর চাপ কমে
  • সার্কিট ব্রেকার এর সাথে রিট্রাই ব্যবহার করলে সিস্টেম আরো রেজিলিয়েন্ট হয়
  • লগিং (logging) যুক্ত করলে ডিবাগিং সহজ হয়
  • ফলব্যাক মেথড (fallback method) ব্যবহার করে ইউজার এক্সপেরিয়েন্স উন্নত হয়

রিট্রাই স্ট্র্যাটেজি মাইক্রোসার্ভিসেস আর্কিটেকচারের একটি গুরুত্বপূর্ণ অংশ। সঠিকভাবে কনফিগার করলে আপনার অ্যাপ্লিকেশন নেটওয়ার্ক ব্যর্থতা এবং অস্থায়ী ত্রুটির বিরুদ্ধে আরো শক্তিশালী হবে।

Share