الجلسات والكوكيز والمرشّحات

مستمعو الويب

18 دقيقة الدرس 8 من 13

مستمعو الويب

تعترض مرشّحات (Filters) الـ Servlet الطلبات الفردية. لكنّ كثيرًا من المخاوف المتقاطعة — تهيئة بدء التشغيل، وإحماء تجمّع الاتصالات، وعدّادات المقاييس، ومسارات التدقيق — لا علاقة لها بأي طلب بعينه. إنها تهتم بـ أحداث دورة الحياة: بدأ التطبيق، أُنشئت جلسة، أُزيل سمة من طلب. هذا بالضبط ما تُتيحه مستمعات الويب (Web Listeners).

تعرّف مواصفة Servlet (Jakarta EE 10، الحزمة jakarta.servlet) ثمانية واجهات مستمع منظَّمة في ثلاثة نطاقات: السياق (context) أي التطبيق بأكمله، والجلسة (session)، والطلب (request). تُنفّذ الواجهة وتُزيّن الفئة بـ @WebListener، فيستدعي الحاوي (container) أساليبك في اللحظات المناسبة — دون تمديد (wiring) ودون XML (ما لم تُفضّل ذلك).

مستمعات السياق — نطاق التطبيق

ServletContextListener هي أهم مستمع ستكتبه. أسلوباه يحيطان بعمر تطبيق الويب بالكامل:

contextInitialized(ServletContextEvent) — يُستدعى مرة واحدة بعد أن ينتهي الحاوي من تحميل التطبيق، لكن قبل معالجة أي طلب. استخدمه للأعمال التي تُنجز مرة واحدة عند البدء.
contextDestroyed(ServletContextEvent) — يُستدعى مرة واحدة حين يُغلق الحاوي التطبيق (إلغاء النشر، إعادة تشغيل الخادم). استخدمه لتحرير الموارد بصورة رشيقة.

import jakarta.servlet.ServletContext;
import jakarta.servlet.ServletContextEvent;
import jakarta.servlet.ServletContextListener;
import jakarta.servlet.annotation.WebListener;
import javax.sql.DataSource;
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;

@WebListener
public class AppLifecycleListener implements ServletContextListener {

    private HikariDataSource pool;

    @Override
    public void contextInitialized(ServletContextEvent sce) {
        // بناء تجمّع الاتصالات مرة واحدة عند البدء
        HikariConfig cfg = new HikariConfig();
        cfg.setJdbcUrl(System.getenv("DB_URL"));
        cfg.setUsername(System.getenv("DB_USER"));
        cfg.setPassword(System.getenv("DB_PASS"));
        cfg.setMaximumPoolSize(10);

        pool = new HikariDataSource(cfg);

        // تخزينه في السياق ليتمكّن كل Servlet من الوصول إليه
        ServletContext ctx = sce.getServletContext();
        ctx.setAttribute("dataSource", pool);

        ctx.log("تجمّع الاتصالات جاهز: " + pool.getPoolName());
    }

    @Override
    public void contextDestroyed(ServletContextEvent sce) {
        if (pool != null && !pool.isClosed()) {
            pool.close();   // يُعيد كل الاتصالات ويوقف خيوط التجمّع
            sce.getServletContext().log("تجمّع الاتصالات مغلق.");
        }
    }
}

يمكن لأي Servlet الآن استرداد التجمّع بـ (DataSource) request.getServletContext().getAttribute("dataSource") — دون حاجة لـ static singletons أو إطار حقن تبعيات.

لماذا لا نستخدم static singleton؟ تخزين التجمّع في ServletContext يربط دورة حياته بالتطبيق لا بـ JVM. عند إعادة نشر التطبيق دون إعادة تشغيل الخادم، يعمل contextDestroyed أولًا فيُغلق التجمّع نظيفًا. أما الحقل الـ static فسيظل حيًّا بعد انتهاء السياق ويُسرّب اتصالات للـ class loader القديم.

ServletContextAttributeListener هي الواجهة المرافقة: تُطلق أحداث attributeAdded وattributeReplaced وattributeRemoved كلما نادى أحد setAttribute / removeAttribute على السياق. مفيدة للتدقيق أو الاستجابة لتغييرات الإعداد في وقت التشغيل.

مستمعات الجلسة — نطاق الجلسة

تتتبع HttpSessionListener ولادة الجلسات وانتهاءها عبر جميع المستخدمين:

sessionCreated(HttpSessionEvent) — تُطلق حين تنشئ request.getSession(true) جلسة جديدة تمامًا.
sessionDestroyed(HttpSessionEvent) — تُطلق حين تُبطل الجلسة (session.invalidate()) أو تنتهي صلاحيتها.

import jakarta.servlet.annotation.WebListener;
import jakarta.servlet.http.HttpSessionEvent;
import jakarta.servlet.http.HttpSessionListener;
import java.util.concurrent.atomic.AtomicInteger;

@WebListener
public class ActiveSessionCounter implements HttpSessionListener {

    // عداد آمن للخيوط مشترك بين جميع الطلبات
    private static final AtomicInteger ACTIVE = new AtomicInteger(0);

    @Override
    public void sessionCreated(HttpSessionEvent se) {
        int count = ACTIVE.incrementAndGet();
        se.getSession().getServletContext()
          .log("جلسة أُنشئت. الجلسات النشطة: " + count);
    }

    @Override
    public void sessionDestroyed(HttpSessionEvent se) {
        int count = ACTIVE.decrementAndGet();
        se.getSession().getServletContext()
          .log("جلسة دُمّرت. الجلسات النشطة: " + count);
    }

    public static int getActiveCount() { return ACTIVE.get(); }
}

لا تقرأ سمات الجلسة في sessionDestroyed حين تنتهي الجلسة بالتوقيت. بحلول الوقت الذي يستدعي فيه الحاوي sessionDestroyed لجلسة انتهت صلاحيتها، ربما يكون قد أزال سماتها بالفعل. اقرأ السمات التي تحتاجها في sessionCreated أو خزّنها في مكان آخر إذا أردت استخدامها لاحقًا. حين يُستدعى session.invalidate() صراحةً تظل السمات موجودة في لحظة الاستدعاء.

تُطلق HttpSessionAttributeListener أحداثًا عند تغيير السمات داخل أي جلسة — مفيدة لتتبّع وضع كائن المستخدم في الجلسة أو إزالته منها (مسار تدقيق تسجيل الدخول والخروج).

HttpSessionBindingListener مختلفة: تُنفَّذ على كائن القيمة نفسه (مثل فئة User الخاصة بك)، لا على فئة مستمع منفصلة. حين يُعيَّن كائن ينفّذ هذه الواجهة كسمة جلسة يستدعي الحاوي valueBound عليه؛ وحين يُزال يستدعي valueUnbound. هذا يتيح للكائن إدارة تنظيف نفسه دون مستمع عالمي يفحص كل جلسة.

تدعم HttpSessionActivationListener عملية المرور (passivation)، أي تسلسل الجلسات إلى القرص أو عقدة أخرى. sessionWillPassivate يُستدعى قبل التسلسل؛ وsessionDidActivate بعد إلغاء التسلسل. نفّذ هذه الواجهة على أي سمة جلسة تحمل موردًا غير قابل للتسلسل (مثل اتصال مباشر) كي تُحرّره وتُعيد اقتناءه بصواب.

مستمعات الطلب — نطاق الطلب

ServletRequestListener هو المقابل على مستوى الطلب لـ ServletContextListener. أسلوباه يُحيطان بكل طلب HTTP فردي يدخل التطبيق:

import jakarta.servlet.ServletRequest;
import jakarta.servlet.ServletRequestEvent;
import jakarta.servlet.ServletRequestListener;
import jakarta.servlet.annotation.WebListener;
import jakarta.servlet.http.HttpServletRequest;

@WebListener
public class RequestTimingListener implements ServletRequestListener {

    private static final String START_ATTR = "req.startNanos";

    @Override
    public void requestInitialized(ServletRequestEvent sre) {
        sre.getServletRequest().setAttribute(START_ATTR, System.nanoTime());
    }

    @Override
    public void requestDestroyed(ServletRequestEvent sre) {
        ServletRequest req = sre.getServletRequest();
        Long start = (Long) req.getAttribute(START_ATTR);
        if (start == null) return;

        long ms = (System.nanoTime() - start) / 1_000_000;
        String uri = ((HttpServletRequest) req).getRequestURI();
        req.getServletContext().log(uri + " اكتمل في " + ms + " مللي ثانية");
    }
}

على خلاف المرشح (Filter)، لا يجلس هذا المستمع في سلسلة المعالجة، لذا لا يستطيع حجب الطلب أو تعديله. دوره مراقبة بحتة — القياس عن بُعد (telemetry)، وإعداد سياق MDC لكل طلب من أجل التسجيل، ومخاوف متقاطعة مماثلة لا ينبغي أن تؤثر في الاستجابة.

اختيار المستمع المناسب

أعمال البدء والإيقاف (تهيئة التجمّع، إحماء الكاش، بدء/إيقاف الوظائف المجدولة) ← ServletContextListener
إحصاء المستخدمين النشطين، وتطبيق حدود تسجيل الدخول المتزامن ← HttpSessionListener
مسار تدقيق تسجيل الدخول والخروج ← HttpSessionAttributeListener أو HttpSessionBindingListener
تمرير الجلسات في البيئات المُجمَّعة (clustered) ← HttpSessionActivationListener
قياس الطلبات، وإعداد MDC ← ServletRequestListener

ترتيب المستمعات وسلامة الخيوط

يُستدعى المستمعون من النوع نفسه وفق الترتيب الذي يكتشفهم فيه الحاوي (ترتيب الاكتشاف المبني على التعليقات التوضيحية غير محدد؛ استخدم مدخلات <listener> في web.xml إن كان الترتيب مهمًا). يُستدعى contextInitialized وcontextDestroyed على خيط واحد؛ أما مستمعات الجلسة والطلب فقد تُستدعى بصورة متزامنة عبر خيوط متعددة. أي حالة قابلة للتغيير مشتركة بين استدعاءات المستمع يجب أن تكون آمنة للخيوط — استخدم AtomicInteger أو ConcurrentHashMap أو كتل synchronized وفقًا لذلك.

في Spring Boot لا تحتاج إلى @WebListener — سجّل المستمعين كـ Spring beans باستخدام أساليب @Bean التي تُعيد تسجيلات EventListener، أو نفّذ الواجهة المعنية وزيّنها بـ @Component. يُغلّف Spring أحداث حاوي Servlet في نظام أحداث التطبيق الخاص به، لذا يمكنك الاستماع لـ ApplicationReadyEvent أو ContextClosedEvent بدلًا من واجهات Servlet المباشرة. لكن حين تعمل مع حاويات Jakarta EE خالصة (Tomcat أو Jetty أو WildFly بدون Spring)، تكون واجهات المستمع الأصلية هي ما تلجأ إليه.

الخلاصة

تمنحك مستمعات الويب خطّافات دورة الحياة (lifecycle hooks) على ثلاثة نطاقات. استخدم ServletContextListener لتهيئة موارد التطبيق وتفكيكها عند البدء والإيقاف — تجمّعات الاتصالات والذواكر المؤقتة والخيوط الخلفية. استخدم HttpSessionListener لإحصاء الجلسات وتطبيق الحدود أو الاحتفاظ بسجل تدقيق لعمليات الدخول والخروج. استخدم ServletRequestListener للرصد (observability): القياس الزمني وسياق التسجيل لكل طلب والمقاييس التي لا ينبغي أن تُغيّر الاستجابة. المستمع الصحيح في النطاق الصحيح أنظف بكثير من تشتيت المنطق نفسه عبر كل Servlet أو Filter.