스프링 환경에서 Reactive Redis pub/sub 을 이용할때 구독을 중단하는 방법이 있나요?

Question

Redis pub/sub 를 사용하면 RedisMessageListenerContainer 를 통해서 리스너를 제거(removeMessageListener)하면 채널 구독수가 줄어드는데 (redis-cli 에서 PUBSUB NUMSUB {CHANNEL} 로 확인) reactive redis는 ReactiveRedisTemplate.listenToChannel 아니면 ReactiveRedisMessageListenerContainer 를 이용해서 어떻게 풀어야 할지 모르겠습니다..

Clickin · Answer

return을 Flux 타입으로 받을텐데 리액터 패턴에 따라서 subscription을 cancel 하시면 되겠습니다.스프링 소스 코드에도 Subscribe가 cancel되면 취소된다고 주석이 적혀있네요/** * Subscribe to one or more {@link PatternTopic}s and receive a stream of {@link PatternMessage}. Messages, pattern, * and channel names are treated as {@link String}. The message stream subscribes lazily to the Redis channels and * unsubscribes if the {@link org.reactivestreams.Subscription} is {@link org.reactivestreams.Subscription#cancel() * cancelled}. * * @param patternTopics the channels to subscribe. * @return the message stream. * @throws InvalidDataAccessApiUsageException if {@code patternTopics} is empty. * @see #receive(Iterable, SerializationPair, SerializationPair) */https://github.com/spring-projects/spring-data-redis/blob/main/src/main/java/org/springframework/data/redis/listener/ReactiveRedisMessageListenerContainer.java#L194cancel하는 여러가지 방법https://www.baeldung.com/spring-webflux-cancel-flux

스프링 환경에서 Reactive Redis pub/sub 을 이용할때 구독을 중단하는 방법이 있나요?

1개의 답변

#reactive-redis 목록