Shulou(Shulou.com)06/02 Report--

How to implement a delay message component in Redisson? aiming at this problem, this article introduces the corresponding analysis and solution in detail, hoping to help more partners who want to solve this problem to find a more simple and feasible method.

Define topic queue comments

@ Target ({ElementType.TYPE}) @ Retention (RetentionPolicy.RUNTIME) @ Documented@Componentpublic @ interface RMessage {/ * message queue * @ return * / String queue (); / * * topic * @ return * / String topic () default "system";}

Springboot starts listening to initialize task queues and message topics, and consumers subscribe to topics

@ Slf4j@Componentpublic class RMessageListener implements ApplicationListener {/ * consumer monitoringMethod monitorMessage * / private final static String METHOD_MONITOR_MESSAGE = "monitorMessage"; / * redisson topic name * / private final static String ATTRIBUTE_NAME_TOPIC = "topic"; / * redisson messageQueue name * / private final static String ATTRIBUTE_NAME_QUEUE = "queue"; / * redisson queue map * / public static Map

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.