|
@@ -0,0 +1,28 @@
|
|
|
|
|
+package com.caimei365.tools.listener;
|
|
|
|
|
+
|
|
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
|
|
|
|
+import org.apache.rocketmq.spring.core.RocketMQListener;
|
|
|
|
|
+import org.springframework.stereotype.Component;
|
|
|
|
|
+
|
|
|
|
|
+/**
|
|
|
|
|
+ * 测试消息监听
|
|
|
|
|
+ *
|
|
|
|
|
+ * @author : Charles
|
|
|
|
|
+ * @date : 2021/6/17
|
|
|
|
|
+ */
|
|
|
|
|
+@Slf4j
|
|
|
|
|
+@Component
|
|
|
|
|
+@RocketMQMessageListener(
|
|
|
|
|
+ topic = "IpSave",
|
|
|
|
|
+ // messageModel = MessageModel.BROADCASTING,//指定为广播消费
|
|
|
|
|
+ // consumeMode = ConsumeMode.ORDERLY, // 指定消费模式为顺序消费，消费的顺序也和发送顺序一致
|
|
|
|
|
+ // selectorType = SelectorType.TAG,// 如果我们的生产者指定了Tag，但是消费者的selectorExpression没有设置，即用默认的“*”,那么这个消费者也会消费到
|
|
|
|
|
+ // selectorExpression = "tag", // 指定了tag后，发送的消息如果不带tag，将会消费不到
|
|
|
|
|
+ consumerGroup = "Ip_group")
|
|
|
|
|
+public class IpSaveListener implements RocketMQListener<String> {
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public void onMessage(String message) {
|
|
|
|
|
+ log.info("{}收到消息：{}", this.getClass().getSimpleName(), message);
|
|
|
|
|
+ }
|
|
|
|
|
+}
|
