|
|
@@ -1,6 +1,6 @@
|
|
1
|
1
|
package com.chinaitop.depot.intelligent.rocketMQ.listenerMQ;
|
|
2
|
2
|
|
|
3
|
|
-import com.alibaba.fastjson.JSON;
|
|
|
3
|
+/*import com.alibaba.fastjson.JSON;
|
|
4
|
4
|
import com.chinaitop.depot.intelligent.grainsituation.mapper.TTestdataLayerMapper;
|
|
5
|
5
|
import com.chinaitop.depot.intelligent.grainsituation.model.TTestdata;
|
|
6
|
6
|
import com.chinaitop.depot.intelligent.grainsituation.model.TTestdataLayer;
|
|
|
@@ -12,21 +12,21 @@ import org.springframework.stereotype.Component;
|
|
12
|
12
|
import org.springframework.stereotype.Service;
|
|
13
|
13
|
|
|
14
|
14
|
import javax.annotation.Resource;
|
|
15
|
|
-import java.util.ArrayList;
|
|
|
15
|
+import java.util.ArrayList;*/
|
|
16
|
16
|
|
|
17
|
|
-@Slf4j
|
|
|
17
|
+/*@Slf4j
|
|
18
|
18
|
@Component
|
|
19
|
19
|
public class MQConsumerService {
|
|
20
|
20
|
|
|
21
|
21
|
@Resource
|
|
22
|
22
|
private TemperatureRecordService temperatureRecordService;
|
|
23
|
23
|
@Resource
|
|
24
|
|
- private TTestdataLayerMapper tTestdataLayerMapper;
|
|
|
24
|
+ private TTestdataLayerMapper tTestdataLayerMapper;*/
|
|
25
|
25
|
|
|
26
|
26
|
|
|
27
|
27
|
// topic需要和生产者的topic一致,consumerGroup属性是必须指定的,内容可以随意
|
|
28
|
28
|
// selectorExpression的意思指的就是tag,默认为“*”,不设置的话会监听所有消息
|
|
29
|
|
- @Service
|
|
|
29
|
+ /*@Service
|
|
30
|
30
|
@RocketMQMessageListener(topic = "smart_grp_yn", selectorExpression = "t_testdata_c", consumerGroup = "t_testdata_c")
|
|
31
|
31
|
public class ConsumerSend implements RocketMQListener<ArrayList<TTestdata>> {
|
|
32
|
32
|
// 监听到消息就会执行此方法
|
|
|
@@ -48,31 +48,6 @@ public class MQConsumerService {
|
|
48
|
48
|
log.info("监听到消息:tTestdataLayerArrayList={}", JSON.toJSONString(tTestdataLayerArrayList));
|
|
49
|
49
|
tTestdataLayerMapper.insertBatch(tTestdataLayerArrayList);
|
|
50
|
50
|
}
|
|
51
|
|
- }
|
|
52
|
|
-
|
|
53
|
|
-
|
|
54
|
|
-
|
|
55
|
|
- // 注意:这个ConsumerSend2和上面ConsumerSend在没有添加tag做区分时,不能共存,
|
|
56
|
|
- // 不然生产者发送一条消息,这两个都会去消费,如果类型不同会有一个报错,所以实际运用中最好加上tag,写这只是让你看知道就行
|
|
57
|
|
-// @Service
|
|
58
|
|
-// @RocketMQMessageListener(topic = "smart_grp_yn", consumerGroup = "Con_Group_Two")
|
|
59
|
|
-// public class ConsumerSend2 implements RocketMQListener<String> {
|
|
60
|
|
-// @Override
|
|
61
|
|
-// public void onMessage(String str) {
|
|
62
|
|
-// log.info("监听到消息:555str={}", str);
|
|
63
|
|
-// }
|
|
64
|
|
-// }
|
|
65
|
|
-
|
|
66
|
|
- // MessageExt:是一个消息接收通配符,不管发送的是String还是对象,都可接收,当然也可以像上面明确指定类型(我建议还是指定类型较方便)
|
|
67
|
|
-// @Service
|
|
68
|
|
-// @RocketMQMessageListener(topic = "smart_grp_yn", selectorExpression = "tag2", consumerGroup = "Con_Group_Three")
|
|
69
|
|
-// public class Consumer implements RocketMQListener<MessageExt> {
|
|
70
|
|
-// @Override
|
|
71
|
|
-// public void onMessage(MessageExt messageExt) {
|
|
72
|
|
-// byte[] body = messageExt.getBody();
|
|
73
|
|
-// String msg = new String(body);
|
|
74
|
|
-// log.info("监听到消息:666msg={}", msg);
|
|
75
|
|
-// }
|
|
76
|
|
-// }
|
|
|
51
|
+ }*/
|
|
77
|
52
|
|
|
78
|
|
-}
|
|
|
53
|
+//}
|