Notification

一個MBean提供的管理介面允許代理對其管理資源進行控制和配置。然而，對管理複雜的分散式系統來說，這些介面知識提供了一部分功能。通常，管理應用程式需要對狀態變化或者當特別情況發生變化時作出反映。Notification起到了MBean之間的溝通橋樑的作用。JMX Notification模型和Java Event模型類似，將一些重要的資訊，狀態的轉變，資料的變更傳遞給Notification Listener，以便資源的管理。
通知模型僅僅涉及了在同一個JMX代理中的管理構件之間的事件傳播。JMX通知模型依靠以下幾個部分：

1. Notification，一個通用的事件型別，該類標識事件的型別，可以被直接使用，也可以根據傳遞的事件的需要而被擴充套件。
2. NotificationListener介面，接受通知的物件需實現此介面。
3. NotificationFilter介面，作為通知過濾器的物件需實現此介面，為通知監聽者提供了一個過濾通知的過濾器。
4. NotificationBroadcaster介面，通知傳送者需實現此介面，該介面允許希望得到通知的監聽者註冊。

傳送一個通用型別的通知，任何一個監聽者都會得到該通知。因此，監聽者需提供過濾器來選擇所需要接受的通知。任何型別的MBean，標準的或動態的，都可以作為一個通知傳送者，也可以作為一個通知監聽者，或兩者都是。

這裡採用一個案例來說明，前面的Hello中有一個printHello(String whoName)方法，意思根據碰到的是誰來打招呼，比如：

小廝從對面走來，說：”hi”。我們回之以禮，說：“Hello, Xiaosi”.
首先這裡需要小廝先說一個“hi”(相應一個操作方法)，然後他說的話封裝成了聲波（Notification的訊息包）傳遞出去。然後我們要給Hello類裝上一個監聽器（NotificationListener）,這個監聽器將捕捉到小廝的Notification訊息包，然後回覆說：“Hello, Xiaosi”.

引入新的類XiaoSi.java和XiaosiMBean:

package com.test.jmx.notification;

import javax.management.Notification;
import
 
 javax.management.NotificationBroadcasterSupport;

public class XiaoSi extends NotificationBroadcasterSupport implements XiaoSiMBean {

    private int seq = 0;
    /*
    * 必需繼承NotificationBroadcasterSupport
    * 此類只有一個hi方法，方法只有兩句：建立一個Notification訊息包，然後將包發出去
    * 如果你還要在訊息包上附加其他資料，Notification還有一個setUserData方法可供使用
     */
    @Override
    public void hi() {
        Notification n = new Notification(//建立一個資訊包
                "xiaosi.hi",//給這個Notification起個名稱
                this,//由誰發出的Notification
                ++seq,//一系列通知中的序列號，可以設定任意數值
                System.currentTimeMillis(),//發出時間
                "Xiaosi"//發出資訊的訊息文字
        );

        sendNotification(n);
    }
}

package com.test.jmx.notification;

public interface XiaoSiMBean {
    public void hi();
}

接下去建立Hello類的Listener（HelloListener.java）,用於監聽Notification的訊息包並處理。

package com.test.jmx.notification;

import com.test.jmx.Hello;

import javax.management.Notification;
import javax.management.NotificationListener;

public class HelloListener implements NotificationListener {
    @Override
    public void handleNotification(Notification notification, Object handback) {
        System.out.println("----------HelloListener-Begin------------");
        System.out.println("\ttype = "+ notification.getType());
        System.out.println("\tsource = "+notification.getSource());
        System.out.println("\tseq = "+notification.getSequenceNumber());
        System.out.println("\tsend time = "+notification.getTimeStamp());
        System.out.println("\tmessage="+notification.getMessage());
        System.out.println("----------HelloListener-End------------");

        if (handback != null) {
            if (handback instanceof Hello) {
                Hello hello = (Hello)handback;
                hello.printHello(notification.getMessage());
            }
        }
    }
}

修改HelloAgent的程式碼：

package com.test.jmx.notification;

import com.sun.jdmk.comm.HtmlAdaptorServer;
import com.test.jmx.Hello;

import javax.management.*;
import java.lang.management.ManagementFactory;

public class HelloAgent {
    public static void main(String[] args) throws MalformedObjectNameException, NotCompliantMBeanException, 
InstanceAlreadyExistsException, MBeanRegistrationException {
        MBeanServer server = ManagementFactory.getPlatformMBeanServer();

        ObjectName helloName = new ObjectName("MyMBean:name=HelloWorld");
        Hello hello = new Hello();
        server.registerMBean(hello,helloName);

        ObjectName adapterName = new ObjectName("MyBean:name=htmladapter,port=8082");
        HtmlAdaptorServer adapter = new HtmlAdaptorServer();
        server.registerMBean(adapter,adapterName);

        XiaoSi xs = new XiaoSi();
        server.registerMBean(xs,new ObjectName("MyMBean:name=xiaosi"));
        xs.addNotificationListener(new HelloListener(),null,hello);
        adapter.start();
    }
}

執行HelloAgent，然後在瀏覽器中輸入localhost:8080, 點選“name=xiaosi”：

進入頁面：

點選“hi”按鈕，此時控制檯列印:
“`
———-HelloListener-Begin————
type = xiaosi.hi
source = [email protected]
seq = 1
send time = 1476184927551
message=Xiaosi
———-HelloListener-End————
Hello, Xiaosi

參考資料

歡迎支援《RabbitMQ實戰指南》以及關注微信公眾號：朱小廝的部落格。