|
@@ -1,58 +0,0 @@
|
|
-package com.fdkankan.modeling.receiver;
|
|
|
|
-
|
|
|
|
-import com.fdkankan.mq.util.RocketMQProducer;
|
|
|
|
-import lombok.extern.slf4j.Slf4j;
|
|
|
|
-import org.apache.rocketmq.spring.annotation.ConsumeMode;
|
|
|
|
-import org.apache.rocketmq.spring.annotation.MessageModel;
|
|
|
|
-import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
|
|
|
-import org.apache.rocketmq.spring.core.RocketMQListener;
|
|
|
|
-import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
-import org.springframework.stereotype.Component;
|
|
|
|
-
|
|
|
|
-import java.util.concurrent.*;
|
|
|
|
-
|
|
|
|
-
|
|
|
|
-@Slf4j
|
|
|
|
-@Component
|
|
|
|
-@RocketMQMessageListener(
|
|
|
|
- consumerGroup = "test_model_order",
|
|
|
|
- topic = "test_model_order",
|
|
|
|
- messageModel = MessageModel.CLUSTERING,consumeMode = ConsumeMode.ORDERLY)
|
|
|
|
-public class BuildSceneMQListenerTest implements RocketMQListener<String> {
|
|
|
|
-
|
|
|
|
- private String consumerGroup ="test_model_order";
|
|
|
|
-
|
|
|
|
- private String topicName = "test_model_order";
|
|
|
|
-
|
|
|
|
- @Autowired
|
|
|
|
- RocketMQProducer rocketMQProducer;
|
|
|
|
-
|
|
|
|
- @Override
|
|
|
|
- public void onMessage(String message) {
|
|
|
|
- log.info("开始处理消息,消费者组:{},主题名:{}, 消息内容:{}", consumerGroup, topicName, message);
|
|
|
|
- System.out.println(1);
|
|
|
|
- process2();
|
|
|
|
- System.out.println(2);
|
|
|
|
- }
|
|
|
|
- public void process2() {
|
|
|
|
- Long startTime = System.currentTimeMillis();
|
|
|
|
- final ExecutorService exec = Executors.newFixedThreadPool(1);
|
|
|
|
- Callable<String> call = (Callable<String>) () -> {
|
|
|
|
- while (System.currentTimeMillis() - startTime <=1000 * 60 ){
|
|
|
|
-
|
|
|
|
- }
|
|
|
|
- return "success";
|
|
|
|
- };
|
|
|
|
- Future<String> future = exec.submit(call);
|
|
|
|
- try {
|
|
|
|
- future.get(1, TimeUnit.HOURS); //任务处理超时时间设为 24个小时
|
|
|
|
- } catch (InterruptedException e) {
|
|
|
|
- e.printStackTrace();
|
|
|
|
- } catch (ExecutionException e) {
|
|
|
|
- e.printStackTrace();
|
|
|
|
- } catch (TimeoutException e) {
|
|
|
|
- e.printStackTrace();
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
-}
|
|
|