## SparkStreamingUseOpenCV
#introduction
Spark Streaming与OpenCV传感器数据实时获取:熟悉OpenCV的使用，获取本机的摄像头的图像数据，并通过SparkStreaming做实时分析
#Client
client使用OpenCV抓取摄像头数据，按照一定的时间，捕捉每帧图像，将图像数据重新编码后按照JSON格式通过kafka发送到Server上
#Server
Spark Streaming实时接收来自kafka的多客户端的图像数据，并对数据做以下处理：将图像数据解码后重新还原成图像，对图像调用OpenCV的人脸识别模块，标记出人脸区域，将重新构建的图像存进HBase数据库做原始数据备份，同时将图像数据传给web socket监听端口。图像处理的模块采用的是松耦合的结构
，可以替换为其它图像处理模块。
#Display
web socket服务将接受的图像数据按照client不同，分别显示在页面上
Spark Streaming与OpenCV传感器数据实时获取
需积分: 5 25 浏览量
2024-03-16
06:43:16
上传
评论 1
收藏 605KB ZIP 举报
Spark Streaming与OpenCV传感器数据实时获取 （336个子文件） 
StreamingServer$.class 5KB StreamingServer$$anonfun$main$1$$anonfun$apply$1$$anonfun$apply$2.class 4KB StreamingClient.class 4KB StreamingServer$$anonfun$main$1$$anonfun$apply$1.class 2KB StreamingServer$$anonfun$main$1$$anonfun$apply$1$$anonfun$apply$2$$anonfun$apply$3.class 2KB StreamingServer$$anonfun$main$1.class 1KB StreamingServer.class 1KB test$.class 777B test.class 613B .DS_Store 6KB .DS_Store 6KB .DS_Store 6KB SUOCV-server-scala.iml 17KB SUOCV-client-java.iml 15KB StreamingClient.java 4KB README.md 916B MANIFEST.MF 4KB MANIFEST.MF 3KB .name 18B .name 17B StreamingServer.scala 4KB test.scala 256B haarcascade_frontalface_alt.xml 661KB haarcascade_frontalface_alt.xml 661KB workspace.xml 57KB workspace.xml 53KB SUOCV_server_scala_jar.xml 15KB SUOCV_client_java_jar.xml 13KB uiDesigner.xml 9KB uiDesigner.xml 9KB pom.xml 5KB pom.xml 4KB hbase-site.xml 1KB compiler.xml 1KB compiler.xml 1KB misc.xml 1KB misc.xml 1KB Maven__org_scala_lang_scala_library_2_10_4.xml 1KB Maven__com_sun_jersey_jersey_test_framework_jersey_test_framework_grizzly2_1_9.xml 735B Maven__com_sun_jersey_jersey_test_framework_jersey_test_framework_grizzly2_1_9.xml 735B Maven__com_sun_jersey_jersey_test_framework_jersey_test_framework_core_1_9.xml 707B Maven__com_sun_jersey_jersey_test_framework_jersey_test_framework_core_1_9.xml 707B Maven__org_apache_hadoop_hadoop_mapreduce_client_jobclient_2_2_0.xml 694B Maven__org_apache_hadoop_hadoop_mapreduce_client_jobclient_2_2_0.xml 694B Maven__com_fasterxml_jackson_module_jackson_module_scala_2_10_2_4_4.xml 682B Maven__com_fasterxml_jackson_module_jackson_module_scala_2_10_2_4_4.xml 682B Maven__org_apache_hadoop_hadoop_mapreduce_client_shuffle_2_2_0.xml 680B Maven__org_apache_hadoop_hadoop_mapreduce_client_shuffle_2_2_0.xml 680B Maven__org_eclipse_jetty_orbit_javax_servlet_3_0_0_v201112011016.xml 676B Maven__org_eclipse_jetty_orbit_javax_servlet_3_0_0_v201112011016.xml 676B Maven__org_apache_hadoop_hadoop_mapreduce_client_common_2_2_0.xml 673B Maven__org_apache_hadoop_hadoop_mapreduce_client_common_2_2_0.xml 673B Maven__com_github_stephenc_findbugs_findbugs_annotations_1_3_9_1.xml 661B Maven__org_apache_hadoop_hadoop_mapreduce_client_core_2_2_0.xml 659B Maven__org_apache_hadoop_hadoop_mapreduce_client_core_2_2_0.xml 659B Maven__org_apache_hadoop_hadoop_mapreduce_client_app_2_2_0.xml 652B Maven__org_apache_hadoop_hadoop_mapreduce_client_app_2_2_0.xml 652B Maven__org_apache_hbase_hbase_annotations_0_98_17_hadoop2.xml 648B Maven__org_apache_spark_spark_network_shuffle_2_10_1_4_0.xml 641B Maven__org_apache_spark_spark_streaming_kafka_2_10_1_4_1.xml 641B Maven__org_apache_spark_spark_network_shuffle_2_10_1_4_0.xml 641B Maven__org_apache_spark_spark_streaming_kafka_2_10_1_4_1.xml 641B Maven__org_apache_hadoop_hadoop_yarn_server_common_2_2_0.xml 638B Maven__org_apache_hadoop_hadoop_yarn_server_common_2_2_0.xml 638B Maven__org_spark_project_akka_akka_remote_2_10_2_3_4_spark.xml 637B Maven__org_spark_project_akka_akka_remote_2_10_2_3_4_spark.xml 637B Maven__org_apache_spark_spark_network_common_2_10_1_4_0.xml 634B Maven__org_apache_spark_spark_network_common_2_10_1_4_0.xml 634B Maven__com_fasterxml_jackson_core_jackson_annotations_2_4_0.xml 632B Maven__org_spark_project_protobuf_protobuf_java_2_5_0_spark.xml 632B Maven__com_fasterxml_jackson_core_jackson_annotations_2_4_0.xml 632B Maven__org_spark_project_protobuf_protobuf_java_2_5_0_spark.xml 632B Maven__org_spark_project_akka_akka_slf4j_2_10_2_3_4_spark.xml 630B Maven__org_spark_project_akka_akka_actor_2_10_2_3_4_spark.xml 630B Maven__org_spark_project_akka_akka_slf4j_2_10_2_3_4_spark.xml 630B Maven__org_spark_project_akka_akka_actor_2_10_2_3_4_spark.xml 630B Maven__org_apache_hbase_hbase_protocol_0_98_17_hadoop2.xml 627B Maven__org_glassfish_grizzly_grizzly_http_servlet_2_1_2.xml 619B Maven__org_glassfish_grizzly_grizzly_http_servlet_2_1_2.xml 619B Maven__commons_beanutils_commons_beanutils_core_1_8_0.xml 617B Maven__commons_beanutils_commons_beanutils_core_1_8_0.xml 617B Maven__org_glassfish_external_management_api_3_0_0_b012.xml 616B Maven__org_glassfish_external_management_api_3_0_0_b012.xml 616B Maven__org_apache_hbase_hbase_client_0_98_17_hadoop2.xml 613B Maven__org_apache_hbase_hbase_common_0_98_17_hadoop2.xml 613B Maven__commons_configuration_commons_configuration_1_6.xml 612B Maven__org_glassfish_grizzly_grizzly_http_server_2_1_2.xml 612B Maven__commons_configuration_commons_configuration_1_6.xml 612B Maven__org_glassfish_grizzly_grizzly_http_server_2_1_2.xml 612B Maven__com_fasterxml_jackson_core_jackson_databind_2_4_4.xml 611B Maven__com_fasterxml_jackson_core_jackson_databind_2_4_4.xml 611B Maven__commons_collections_commons_collections_3_2_2.xml 604B Maven__org_glassfish_gmbal_gmbal_api_only_3_0_0_b023.xml 604B Maven__commons_collections_commons_collections_3_2_1.xml 604B Maven__org_glassfish_gmbal_gmbal_api_only_3_0_0_b023.xml 604B Maven__org_codehaus_jackson_jackson_mapper_asl_1_8_8.xml 601B Maven__org_apache_spark_spark_streaming_2_10_1_4_1.xml 599B Maven__org_glassfish_grizzly_grizzly_framework_2_1_2.xml 598B Maven__org_glassfish_grizzly_grizzly_framework_2_1_2.xml 598B Maven__com_esotericsoftware_reflectasm_reflectasm_shaded_1_07.xml 596B共 336 条
- 1
- 2
- 3
- 4
资源评论
