Java 클래스 라이브러리-Guava-EventBus

EventBus는 Guava의 이벤트 처리 메커니즘이며 디자인 패턴에서 관찰자 패턴(생산자/소비자 프로그래밍 모델)을 우아하게 구현한 것입니다. EventBus는 이벤트 수신 및 게시-구독 패턴을 위한 매우 우아하고 간단한 솔루션입니다. 복잡한 클래스 및 인터페이스 계층을 만들 필요가 없습니다.

Observer 패턴은 흔히 사용되는 디자인 패턴 중 하나입니다. 특정 코드에서는 반드시 이 이름으로 부르지 않을 때도 있지만, 예를 들어 Listener라고 하는데 패턴이 바로 이 패턴입니다. Observer를 수동으로 구현하는 것은 복잡한 문제가 아닙니다. 이 디자인 패턴이 매우 일반적으로 사용되기 때문에 Java에서는 JDK 1.0부터 Observable과 Observer를 사용했습니다. 어느 정도까지는 Observer 패턴 개발이 단순화됩니다. 적어도 더 이상 자체 Observer 목록을 수동으로 유지 관리할 필요가 없습니다. 그러나 앞서 언급했듯이 JDK의 Observer는 1.0부터 존재했으며 Java 7까지는 알림 매개변수조차 여전히 Object 유형으로 변경되지 않았습니다. 아시다시피 Java 5에는 이미 제네릭이 있습니다. Java 5는 대대적인 구문 점검이었으며 그 이후로 많은 라이브러리가 API를 더 간단하고 사용하기 쉽게 만들기 위해 다시 설계했습니다. 물론 응답하지 않는 라이브러리는 아마도 쓸모 없게 될 것입니다. 이것이 바로 지식 업데이트가 여기서 논의되는 이유입니다. 오늘날 일반 애플리케이션에서 Observer 패턴을 사용하려면 어떻게 해야 할까요? 대답은 Guava의 EventBus입니다.

EventBus의 기본 사용법:

Guava를 사용한 후 메시지를 구독하려면 더 이상 지정된 인터페이스를 상속할 필요가 없습니다. 지정된 방법. 코드는 다음과 같습니다.

메시지 캡슐화 클래스:

[code]public class TestEvent {
    private final int message;
    public TestEvent(int message) {        
        this.message = message;
        System.out.println("event message:"+message);
    }
    public int getMessage() {
        return message;
    }
}

메시지 승인 클래스:

[code]public class EventListener {
    public int lastMessage = 0;

    @Subscribe
    public void listen(TestEvent event) {
        lastMessage = event.getMessage();
        System.out.println("Message:"+lastMessage);
    }

    public int getLastMessage() {      
        return lastMessage;
    }
}

테스트 클래스 및 출력 결과:

[code]public class TestEventBus {
    @Test
    public void testReceiveEvent() throws Exception {

        EventBus eventBus = new EventBus("test");
        EventListener listener = new EventListener();

        eventBus.register(listener);

        eventBus.post(new TestEvent(200));
        eventBus.post(new TestEvent(300));
        eventBus.post(new TestEvent(400));

        System.out.println("LastMessage:"+listener.getLastMessage());
        ;
    }
}

//输出信息
event message:200
Message:200
event message:300
Message:300
event message:400
Message:400
LastMessage:400

MultiListener 사용:

여러 메시지를 구독하려면 메시지를 구독하는 메서드에 @Subscribe 주석만 추가하면 됩니다. 코드는 다음과 같습니다.

[code]public class MultipleListener {
    public Integer lastInteger;  
    public Long lastLong;  

    @Subscribe  
    public void listenInteger(Integer event) {  
        lastInteger = event; 
        System.out.println("event Integer:"+lastInteger);
    }  

    @Subscribe  
    public void listenLong(Long event) {  
        lastLong = event; 
        System.out.println("event Long:"+lastLong);
    }  

    public Integer getLastInteger() {  
        return lastInteger;  
    }  

    public Long getLastLong() {  
        return lastLong;  
    }  
}

[code]public class TestMultipleEvents {
    @Test  
    public void testMultipleEvents() throws Exception {  

        EventBus eventBus = new EventBus("test");  
        MultipleListener multiListener = new MultipleListener();  

        eventBus.register(multiListener);  

        eventBus.post(new Integer(100));
        eventBus.post(new Integer(200));  
        eventBus.post(new Integer(300));  
        eventBus.post(new Long(800)); 
        eventBus.post(new Long(800990));  
        eventBus.post(new Long(800882934));  

        System.out.println("LastInteger:"+multiListener.getLastInteger());
        System.out.println("LastLong:"+multiListener.getLastLong());
    }   
}

//输出信息
event Integer:100
event Integer:200
event Integer:300
event Long:800
event Long:800990
event Long:800882934
LastInteger:300
LastLong:800882934

Dead Event:

EventBus에서 보낸 메시지가 구독자와 관련이 없는 경우 이를 데드 이벤트라고 합니다.

[code]public class DeadEventListener {
    boolean notDelivered = false;  

    @Subscribe  
    public void listen(DeadEvent event) {  

        notDelivered = true;  
    }  

    public boolean isNotDelivered() {  
        return notDelivered;  
    }  
}

[code]public class DeadEventListener {
    boolean notDelivered = false;  

    @Subscribe  
    public void listen(DeadEvent event) {  

        notDelivered = true;  
    }  

    public boolean isNotDelivered() {  
        return notDelivered;  
    }  
}

설명: 메시지를 듣고 있는 메시지 구독자가 없으면 EventBus는 DeadEvent 메시지를 보냅니다. 이 상태를 로그에 기록할 수 있습니다.

이벤트 상속:

리스너 A가 이벤트 A를 수신하고 이벤트 A에 하위 클래스 이벤트 B가 있는 경우 리스너 A는 이벤트 A와 B 메시지를 동시에 수신합니다.

리스너 클래스:

[code]public class NumberListener {  

    private Number lastMessage;  

    @Subscribe  
    public void listen(Number integer) {  
        lastMessage = integer; 
        System.out.println("Message:"+lastMessage);
    }  

    public Number getLastMessage() {  
        return lastMessage;  
    }  
}  

public class IntegerListener {  

    private Integer lastMessage;  

    @Subscribe  
    public void listen(Integer integer) {  
        lastMessage = integer; 
        System.out.println("Message:"+lastMessage);
    }  

    public Integer getLastMessage() {  
        return lastMessage;  
    }  
}

[code]public class TestEventsFromSubclass {
    @Test  
    public void testEventsFromSubclass() throws Exception {  

        EventBus eventBus = new EventBus("test");  
        IntegerListener integerListener = new IntegerListener();  
        NumberListener numberListener = new NumberListener();  
        eventBus.register(integerListener);  
        eventBus.register(numberListener);  

        eventBus.post(new Integer(100));  

        System.out.println("integerListener message:"+integerListener.getLastMessage());
        System.out.println("numberListener message:"+numberListener.getLastMessage());

        eventBus.post(new Long(200L));  

        System.out.println("integerListener message:"+integerListener.getLastMessage());
        System.out.println("numberListener message:"+numberListener.getLastMessage());        
    }  
}

//输出类
Message:100
Message:100
integerListener message:100
numberListener message:100
Message:200
integerListener message:100
numberListener message:200

설명: 이 방법에서는 첫 번째 이벤트(새 정수(100))가 두 리스너에 의해 수신되지만 두 번째 이벤트(new long(200l))은 NumberListener에 의해 정수로만 도달할 수 있습니다. 이 유형에 대해 생성된 이벤트가 없습니다. 이 기능을 사용하면 광범위한 이벤트 세트를 수신하는 보다 일반적인 리스너와 특정 특수 이벤트를 수신하는 보다 자세한 리스너를 생성할 수 있습니다.

포괄적인 인스턴스:

[code]public class UserThread extends Thread {
    private Socket connection;
    private EventBus channel;
    private BufferedReader in;
    private PrintWriter out;

    public UserThread(Socket connection, EventBus channel) {
        this.connection = connection;
        this.channel = channel;
        try {
            in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
            out = new PrintWriter(connection.getOutputStream(), true);
        } catch (IOException e) {
            e.printStackTrace();
            System.exit(1);
        }
    }

    @Subscribe
    public void recieveMessage(String message) {
        if (out != null) {
            out.println(message);
            System.out.println("recieveMessage:"+message);
        }
    }

    @Override
    public void run() {
        try {
            String input;
            while ((input = in.readLine()) != null) {
                channel.post(input);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }

        //reached eof
        channel.unregister(this);
        try {
            connection.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
        in = null;
        out = null;
    }
}

[code]mport java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

import com.google.common.eventbus.EventBus;

public class EventBusChat {
    public static void main(String[] args) {
        EventBus channel = new EventBus();
        ServerSocket socket;
        try {
            socket = new ServerSocket(4444);
            while (true) {
                Socket connection = socket.accept();
                UserThread newUser = new UserThread(connection, channel);
                channel.register(newUser);
                newUser.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

지침: telnet 명령으로 로그인: telnet 127.0.0.1 4444, 여러 인스턴스에 연결하면 전송된 모든 메시지가 다른 인스턴스로 전달되는 것을 볼 수 있습니다

위 내용은 Java-Class Library-Guava-EventBus 내용입니다. 더 많은 관련 내용은 PHP 중국어 홈페이지(www.php.cn)를 참고해주세요!