package com.ruoyi;
|
|
import com.ruoyi.task.DataAssembleUtil;
|
import com.ruoyi.utils.CameraUtils;
|
import org.springframework.boot.SpringApplication;
|
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
|
import org.springframework.jms.config.JmsListenerContainerFactory;
|
|
import javax.jms.ConnectionFactory;
|
|
/**
|
* 启动程序
|
*
|
* @author ruoyi
|
*/
|
@SpringBootApplication(exclude = { DataSourceAutoConfiguration.class })
|
public class RuoYiApplication
|
{
|
public static void main(String[] args){
|
// System.setProperty("spring.devtools.restart.enabled", "false");
|
SpringApplication.run(RuoYiApplication.class, args);
|
System.out.println("(♥◠‿◠)ﾉﾞ AI智能视频监控系统启动成功 ლ(´ڡ`ლ)ﾞ \n");
|
|
DataAssembleUtil.AssembleBDZSBJBXX();//设备信息
|
DataAssembleUtil.AssembleBDZSBJCSJ();//测点信息
|
|
//启动1个线程进行数据发送处理
|
new DataTransmissionThread("DataAssemble").start();
|
new DataTransmissionThread("CameraAssemble").start();
|
|
CameraUtils.startCamera();
|
|
|
|
}
|
|
//需要给topic定义独立的JmsListenerContainer
|
//发布-订阅模式的ListenerContainer
|
@Bean
|
public JmsListenerContainerFactory<?> jmsListenerContainerTopic(ConnectionFactory activeMQConnectionFactory) {
|
DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();
|
bean.setPubSubDomain(true);
|
bean.setConnectionFactory(activeMQConnectionFactory);
|
return bean;
|
}
|
|
}
|
