如何优化婺源地区的网站以吸引玩家?
摘要:婺源网站建设wyjcwl,51游戏,启业网查询官网,腾讯企业邮箱电脑版文章目录 场景现象问题处理 场景现象 kafka作为消息队列,作为前端设备数据到后端消费的渠道,也被多个不同微
婺源网站建设wyjcwl,51游戏,启业网查询官网,腾讯企业邮箱电脑版文章目录 场景现象问题处理 场景现象
kafka作为消息队列#xff0c;作为前端设备数据到后端消费的渠道#xff0c;也被多个不同微服务消费一个服务与前端边缘计算设备建立socket消息#xff0c;接收实时交通事件推送#xff0c;再将事件发送到kafka里面。此处使用的是Spri… 文章目录 场景现象问题处理 场景现象
kafka作为消息队列作为前端设备数据到后端消费的渠道也被多个不同微服务消费一个服务与前端边缘计算设备建立socket消息接收实时交通事件推送再将事件发送到kafka里面。此处使用的是Spring Kafka普通的将事件列表数据转化为字符串后发送事件信息需要入库和实时推送也需要被第三方服务调用第三方也采取消费kafka的方式这个服务作为kafka的消费者读取事件数据发送短信给指定用户但此处使用的是Spring.cloud.stream函数式编程绑定kafka的topic此服务消费时加了一些打印。但是事件推送到kafka后看不到任何日志打印也没有报错。但是使用kafka命令查看却已经被该消费者消费掉了消费的源代码如下 Beanpublic ConsumerString boxEventTopicConsumer(HWTrafficEventManager hwTrafficEventManager) {log.info(Consumer Received (boxTopic): hwTrafficEventManager);return value - {log.info(Consumer Received (boxTopic): value);// todo : do somethings};}问题处理
消费某个多分区topic时发现只有其中一个分区数据有打印其他都没有但是查看却发现都消费掉了
2023-09-21 13:45:13.706 INFO 2184 --- [container-0-C-1] c.newatc.data.kafka.KafkaConfiguration : Consumer Received (boxTopic): {equipmentNo:0,laneNum:4,statisticsCycle:60,time:1695275100110,vehicleLanes:[{averageParkingNum:0.5,averageSpeed:6.1,lane:1,laneFlow:2,maxQueueLength:12,nonVehicleAverageTravelTime:0.0,overStopLineFlow:2,pedestrianAverageTravelTime:0,vehicleAverageDelay:15.3,vehicleAverageTravelTime:0.2},{averageParkingNum:0.0,averageSpeed:35.7,lane:2,laneFlow:1,maxQueueLength:0,nonVehicleAverageTravelTime:0.0,overStopLineFlow:1,pedestrianAverageTravelTime:0,vehicleAverageDelay:0.0,vehicleAverageTravelTime:0.0},{averageParkingNum:0.0,averageSpeed:0.0,lane:3,laneFlow:3,maxQueueLength:0,nonVehicleAverageTravelTime:0.0,overStopLineFlow:0,pedestrianAverageTravelTime:0,vehicleAverageDelay:0.0,vehicleAverageTravelTime:0.0},{averageParkingNum:0.0,averageSpeed:25.4,lane:4,laneFlow:1,maxQueueLength:0,nonVehicleAverageTravelTime:0.0,overStopLineFlow:5,pedestrianAverageTravelTime:0,vehicleAverageDelay:0.0,vehicleAverageTravelTime:1.6}]}最终测试发现列表转化为jsonarray字符串无法打印。
