引进镜屏

security-protection-service/pom.xml

            <version>2.6.12</version>
        </dependency>
        <!--  IPU 镜屏 -->
        <dependency>
            <groupId>com.ai.ipu.server</groupId>
            <artifactId>iot-stomp-server</artifactId>
            <version>3.1-SNAPSHOT</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.logging.log4j</groupId>
                    <artifactId>log4j-slf4j-impl</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>
    <repositories>

security-protection-service/src/main/java/com/ai/bss/security/protection/SecurityProtectionApp.java

package com.ai.bss.security.protection;
import com.ai.ipu.server.connect.ConnectServerStart;
import com.ai.ipu.server.connect.util.ConnectServerManager;
import com.ai.ipu.server.stomp.WebSocketStompServer;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.domain.EntityScan;
@SpringBootApplication
public class SecurityProtectionApp {
    public static void main(String[] args) throws Exception {
        System.setProperty("websocket.port", "7200");
        //注册镜屏服务
        ConnectServerManager.registerServer("websocket.port", new WebSocketStompServer("/stomp"));
        //镜屏服务启动
        ConnectServerStart.start(args, false);
        SpringApplication.run(SecurityProtectionApp.class, args);
    }
}

security-protection-service/src/main/java/com/ai/bss/security/protection/service/task/AiResultRecordKafkaTask.java

	@KafkaListener(containerFactory = "kafkaBatchListener6", topics = "${kafka.topic.aitask:topic_ai_task}", groupId = "ai_group")
	public void AiResultRecordListener(ConsumerRecord<String, String> records, Acknowledgment ack) throws Throwable {
	/*@KafkaListener(containerFactory = "kafkaBatchListener6", topics = "${kafka.topic.aitask:topicTaskTest}", groupId = "ai_group")
	public void AiResultRecordListener(ConsumerRecord<String, String> records, Acknowledgment ack) throws Throwable {*/
		try {
			log.debug("----------------AI任务执行结果信息消费开始---------------------------");