Guava Eventbus 예제 코드에 대한 자세한 설명-java지도 시간-php.cn

Guava Eventbus 예제 코드에 대한 자세한 설명

PHP中文网

풀어 주다： 2017-06-21 09:25:33

원래의

2001명이 탐색했습니다.

guava eventbus를 분석하기 전에 전통적인 관찰자 패턴이 어떻게 작성되는지 살펴보겠습니다.

주제 인터페이스는 관찰자와 동일한 추상 테마이며, 연결 방법은 다음과 같습니다. 이 List Listener에 등록된 경우 detach 메소드는 리스너를 로그아웃시키며, Notify 메소드는 이벤트 발생 시 리스트에 있는 리스너에게 알리는 데 사용됩니다. 일반적으로 알림 구현 메소드에서는 리스너의 update 메소드를 호출합니다.

Observer는 업데이트 메소드가 있는 추상 관찰자이며, 업데이트 메소드는 특정 테마의 알림 메소드에 의해 호출됩니다.

이것은 인터페이스에 대한 전통적인 프로그래밍 방법입니다. 차이점은 이벤트버스가 Java Annotation을 기반으로 한 프로그래밍 방법인 "암시적 인터페이스"를 사용한다는 것입니다. 차이점은 이 "암시적 인터페이스" 간의 대응은 프로그램이 실행될 때 생성되며 실제 이벤트 간의 해당 관계를 기반으로 한다는 것입니다. 의미 있는 인터페이스와 구현은 컴파일 타임에 설정됩니다. 대조적으로, 암시적 인터페이스와 구현이 바인딩 관계를 설정하는 방법을 분석해 보겠습니다.

 1 ##SubscriberRegistry类的register方法 2 void register(Object listener) { 3     Multimap<Class<?>, Subscriber> listenerMethods = findAllSubscribers(listener); 4  5     for (Map.Entry<Class<?>, Collection<Subscriber>> entry : listenerMethods.asMap().entrySet()) { 6       Class<?> eventType = entry.getKey(); 7       Collection<Subscriber> eventMethodsInListener = entry.getValue(); 8  9       CopyOnWriteArraySet<Subscriber> eventSubscribers = subscribers.get(eventType);10 11       if (eventSubscribers == null) {12         CopyOnWriteArraySet<Subscriber> newSet = new CopyOnWriteArraySet<Subscriber>();13         eventSubscribers = MoreObjects.firstNonNull(14             subscribers.putIfAbsent(eventType, newSet), newSet);15       }16 17       eventSubscribers.addAll(eventMethodsInListener);18     }19   }

로그인 후 복사

유용한 점 이 방법은 세 번째 줄입니다. 코드의 나머지 부분에 대한 대략적인 분석은 이 Mutimap을 용이하게 하고 현재 이벤트 유형의 구독자 세트가 다음과 같은 경우 동일한 이벤트 유형의 리스너 구독자를 추가하는 것입니다.

위의 3번째 줄에 있는 메서드를 따르세요.

 1 /** 2    * Returns all subscribers for the given listener grouped by the type of event they subscribe to. 3    */ 4   private Multimap<Class<?>, Subscriber> findAllSubscribers(Object listener) { 5     Multimap<Class<?>, Subscriber> methodsInListener = HashMultimap.create(); 6     Class<?> clazz = listener.getClass(); 7     for (Method method : getAnnotatedMethods(clazz)) { 8       Class<?>[] parameterTypes = method.getParameterTypes(); 9       Class<?> eventType = parameterTypes[0];10       methodsInListener.put(eventType, Subscriber.create(bus, listener, method));11     }12     return methodsInListener;13   }

로그인 후 복사

이 메서드의 핵심 메서드는 특정 클래스의 Subscribe 주석이 포함된 모든 메서드를 가져오는 7번째 줄입니다. 코드의 의미는 이러한 메소드를 가져와 다중 값 맵에 넣은 다음 반환하는 것입니다.

위 7행의 메소드를 따르세요.

1 private static ImmutableList<Method> getAnnotatedMethods(Class<?> clazz) {2     return subscriberMethodsCache.getUnchecked(clazz);3   }

로그인 후 복사

이를 따른 후에는 Eclipse가 따라갈 방법이 없습니다. . 내부적인 것으로 의심됩니다. 익명 클래스가 특정 메소드 호출과 연관되어 있습니다(eclipse도 내부 익명 클래스에 대한 모든 호출 링크를 표시하지 않습니다)

이것을 살펴보겠습니다

subscriberMethodsCache

로그인 후 복사

1 private static final LoadingCache<Class<?>, ImmutableList<Method>> subscriberMethodsCache =2       CacheBuilder.newBuilder()3           .weakKeys()4           .build(new CacheLoader<Class<?>, ImmutableList<Method>>() {5             @Override6             public ImmutableList<Method> load(Class<?> concreteClass) throws Exception {7               return getAnnotatedMethodsNotCached(concreteClass);8             }9           });

로그인 후 복사

호출되면 현재 클래스의 getAnnotatedMethodsNOtCached 메서드가 호출됩니다. 다음 메서드를 따르세요.

 1 private static ImmutableList<Method> getAnnotatedMethodsNotCached(Class<?> clazz) { 2     Set<? extends Class<?>> supertypes = TypeToken.of(clazz).getTypes().rawTypes(); 3     Map<MethodIdentifier, Method> identifiers = Maps.newHashMap(); 4     for (Class<?> supertype : supertypes) { 5       for (Method method : supertype.getDeclaredMethods()) { 6         if (method.isAnnotationPresent(Subscribe.class) && !method.isSynthetic()) { 7           // TODO(cgdecker): Should check for a generic parameter type and error out 8           Class<?>[] parameterTypes = method.getParameterTypes(); 9           checkArgument(parameterTypes.length == 1,10               "Method %s has @Subscribe annotation but has %s parameters."11                   + "Subscriber methods must have exactly 1 parameter.",12               method, parameterTypes.length);13 14           MethodIdentifier ident = new MethodIdentifier(method);15           if (!identifiers.containsKey(ident)) {16             identifiers.put(ident, method);17           }18         }19       }20     }21     return ImmutableList.copyOf(identifiers.values());22   }

로그인 후 복사

2행은 현재 클래스 자체의 모든 클래스 + 현재 클래스의 상위 클래스와 인터페이스를 가져와서 여기에 넣는 것을 의미합니다. a Set

4행은 이 Set를 탐색합니다.

5행 라인은 각 클래스의 모든 메서드를 탐색합니다.

Line 6은 메서드의 isAnnotationPresent 메서드를 호출하여 대상 메서드에 @Subscribe 주석이 있고 해당 메서드가 "복합 메서드"가 될 수 없음을 확인합니다.

라인 16은 복합 조건부 메소드를 맵에 넣습니다. 21번째 라인으로 가서 돌아오세요

위 내용은 Guava Eventbus 예제 코드에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!