巡检计划调整为cmd模式

java110

2022-07-19 b311c0d7aad6f77659e39fb4f7900d1f0ef9de93

 service-api/src/main/java/com/java110/api/kafka/FrontServiceKafka.java

@@ -1,11 +1,13 @@
package com.java110.api.kafka;

import com.alibaba.fastjson.JSONObject;
import com.java110.core.base.controller.BaseController;
import com.java110.api.websocket.MessageWebsocket;
import com.java110.api.websocket.ParkingAreaWebsocket;
import com.java110.core.base.controller.BaseController;
import com.java110.utils.constant.KafkaConstant;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.java110.core.log.LoggerFactory;
import org.springframework.kafka.annotation.KafkaListener;

/**
@@ -17,7 +19,12 @@
    private final static Logger logger = LoggerFactory.getLogger(FrontServiceKafka.class);


    @KafkaListener(topics = {"webSentMessageTopic"})
    /**
     * 像前段返回内容
     *
     * @param record
     */
    @KafkaListener(topics = {KafkaConstant.TOPIC_API_SEND_WEB})
    public void listen(ConsumerRecord<?, ?> record) {
        logger.info("kafka的key: " + record.key());
        logger.info("kafka的value: " + record.value().toString());
@@ -33,5 +40,26 @@
        }
    }

    /**
     * 像前段返回内容
     *
     * @param record
     */
    @KafkaListener(topics = {KafkaConstant.TOPIC_API_SEND_PARKING_AREA_WEB})
    public void listenParkingArea(ConsumerRecord<?, ?> record) {
        logger.info("kafka的key: " + record.key());
        logger.info("kafka的value: " + record.value().toString());

        JSONObject param = null;
        try {
            param = JSONObject.parseObject(record.value().toString());
            ParkingAreaWebsocket.sendInfo(param.toJSONString(), param.getString("extBoxId"));
        } catch (Exception e) {
            logger.error("发送消息失败", e);
        } finally {

        }
    }


}