| | |
| | | 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 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; |
| | | } |
| | | |
| | | } |