package com.thhy.screen.config;
|
|
import com.thhy.general.common.enums.TopicConstant;
|
import com.thhy.general.config.mq.MqConfig;
|
import com.thhy.screen.modules.biz.bigscreen.controller.ExecProListener;
|
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
|
import org.apache.rocketmq.spring.core.RocketMQTemplate;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.boot.ApplicationArguments;
|
import org.springframework.boot.ApplicationRunner;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.core.env.ConfigurableEnvironment;
|
|
@Configuration
|
public class AddAnno implements ApplicationRunner {
|
|
@Autowired
|
private ConfigurableEnvironment environment;
|
|
private Logger logger = LoggerFactory.getLogger(AddAnno.class);
|
|
@Autowired
|
private MqConfig mqConfig;
|
|
@Autowired
|
private RocketMQTemplate rocketMQTemplate;
|
|
@Value("${server.port}")
|
private String serverPort;
|
|
@Override
|
public void run(ApplicationArguments args) throws Exception {
|
String addr = NetUtils.getIp();
|
DefaultMQPushConsumer defaultMQPushConsumer = new DefaultMQPushConsumer();
|
defaultMQPushConsumer.setNamesrvAddr(mqConfig.getNameServer());
|
defaultMQPushConsumer.setConsumerGroup(TopicConstant.PROLISTENEXC_GROUP);
|
defaultMQPushConsumer.subscribe(TopicConstant.PROLISTENEXC,addr+"-"+serverPort);
|
defaultMQPushConsumer.registerMessageListener(new ExecProListener());
|
defaultMQPushConsumer.start();
|
logger.info("生产监控消息监听注册成功,标识："+addr+"-"+serverPort);
|
}
|
}
|
