From 951901d1c6782c5da461c12dc0370ba08723a0f8 Mon Sep 17 00:00:00 2001 From: pancm <1060589146@qq.com> Date: Fri, 25 Aug 2023 17:07:07 +0800 Subject: [PATCH] springboot-prometheus-canal --- .../Maven__com_carrotsearch_hppc_0_7_1.xml | 13 -- ...aformat_jackson_dataformat_cbor_2_8_10.xml | 13 -- ...taformat_jackson_dataformat_cbor_2_9_8.xml | 13 -- ...format_jackson_dataformat_smile_2_8_10.xml | 13 -- ...aformat_jackson_dataformat_smile_2_9_8.xml | 13 -- ...aformat_jackson_dataformat_yaml_2_8_10.xml | 13 -- ...taformat_jackson_dataformat_yaml_2_9_8.xml | 13 -- ..._spullara_mustache_java_compiler_0_9_3.xml | 13 -- ...Maven__com_google_code_gson_gson_2_8_0.xml | 13 -- ...Maven__com_google_code_gson_gson_2_8_5.xml | 13 -- .../Maven__com_google_guava_guava_21_0.xml | 13 -- .../Maven__com_tdunning_t_digest_3_0.xml | 13 -- .../Maven__com_tdunning_t_digest_3_2.xml | 13 -- .../Maven__com_vividsolutions_jts_1_13.xml | 13 -- ...aven__commons_codec_commons_codec_1_11.xml | 13 -- ...Maven__commons_codec_commons_codec_1_9.xml | 13 -- ...en__io_netty_netty_buffer_4_1_16_Final.xml | 13 -- ...ven__io_netty_netty_codec_4_1_16_Final.xml | 13 -- ...io_netty_netty_codec_http_4_1_16_Final.xml | 13 -- ...en__io_netty_netty_common_4_1_16_Final.xml | 13 -- ...n__io_netty_netty_handler_4_1_16_Final.xml | 13 -- ...__io_netty_netty_resolver_4_1_16_Final.xml | 13 -- ..._io_netty_netty_transport_4_1_16_Final.xml | 13 -- .../Maven__io_searchbox_jest_6_3_1.xml | 13 -- .../Maven__io_searchbox_jest_common_6_3_1.xml | 13 -- .../Maven__joda_time_joda_time_2_10_1.xml | 13 -- ...__net_sf_jopt_simple_jopt_simple_5_0_2.xml | 13 -- ...e_httpcomponents_httpasyncclient_4_1_3.xml | 13 -- ...e_httpcomponents_httpasyncclient_4_1_4.xml | 13 -- ...apache_httpcomponents_httpclient_4_5_3.xml | 13 -- ...apache_httpcomponents_httpclient_4_5_7.xml | 13 -- ..._apache_httpcomponents_httpcore_4_4_11.xml | 13 -- ...g_apache_httpcomponents_httpcore_4_4_6.xml | 13 -- ...che_httpcomponents_httpcore_nio_4_4_11.xml | 13 -- ...ache_httpcomponents_httpcore_nio_4_4_6.xml | 13 -- ...g_apache_logging_log4j_log4j_api_2_8_2.xml | 13 -- ..._apache_logging_log4j_log4j_core_2_8_2.xml | 13 -- ...e_lucene_lucene_analyzers_common_7_2_1.xml | 13 -- ...e_lucene_lucene_analyzers_common_7_4_0.xml | 13 -- ...he_lucene_lucene_backward_codecs_7_2_1.xml | 13 -- ...he_lucene_lucene_backward_codecs_7_4_0.xml | 13 -- ...n__org_apache_lucene_lucene_core_7_2_1.xml | 13 -- ...n__org_apache_lucene_lucene_core_7_4_0.xml | 13 -- ...rg_apache_lucene_lucene_grouping_7_2_1.xml | 13 -- ...rg_apache_lucene_lucene_grouping_7_4_0.xml | 13 -- ...apache_lucene_lucene_highlighter_7_2_1.xml | 13 -- ...apache_lucene_lucene_highlighter_7_4_0.xml | 13 -- ...n__org_apache_lucene_lucene_join_7_2_1.xml | 13 -- ...n__org_apache_lucene_lucene_join_7_4_0.xml | 13 -- ..._org_apache_lucene_lucene_memory_7_2_1.xml | 13 -- ..._org_apache_lucene_lucene_memory_7_4_0.xml | 13 -- ...n__org_apache_lucene_lucene_misc_7_2_1.xml | 13 -- ...n__org_apache_lucene_lucene_misc_7_4_0.xml | 13 -- ...org_apache_lucene_lucene_queries_7_2_1.xml | 13 -- ...org_apache_lucene_lucene_queries_7_4_0.xml | 13 -- ...apache_lucene_lucene_queryparser_7_2_1.xml | 13 -- ...apache_lucene_lucene_queryparser_7_4_0.xml | 13 -- ...org_apache_lucene_lucene_sandbox_7_2_1.xml | 13 -- ...org_apache_lucene_lucene_sandbox_7_4_0.xml | 13 -- ...g_apache_lucene_lucene_spatial3d_7_2_1.xml | 13 -- ...g_apache_lucene_lucene_spatial3d_7_4_0.xml | 13 -- ...org_apache_lucene_lucene_spatial_7_2_1.xml | 13 -- ...org_apache_lucene_lucene_spatial_7_4_0.xml | 13 -- ...che_lucene_lucene_spatial_extras_7_2_1.xml | 13 -- ...che_lucene_lucene_spatial_extras_7_4_0.xml | 13 -- ...org_apache_lucene_lucene_suggest_7_2_1.xml | 13 -- ...org_apache_lucene_lucene_suggest_7_4_0.xml | 13 -- ...client_elasticsearch_rest_client_6_2_2.xml | 13 -- ...client_elasticsearch_rest_client_6_4_3.xml | 13 -- ...g_elasticsearch_client_transport_6_2_2.xml | 13 -- ...g_elasticsearch_client_transport_6_4_3.xml | 13 -- ..._org_elasticsearch_elasticsearch_6_2_2.xml | 13 -- ..._org_elasticsearch_elasticsearch_6_4_3.xml | 13 -- ..._elasticsearch_elasticsearch_cli_6_2_2.xml | 13 -- ..._elasticsearch_elasticsearch_cli_6_4_3.xml | 13 -- ...elasticsearch_elasticsearch_core_6_2_2.xml | 13 -- ...elasticsearch_elasticsearch_core_6_4_3.xml | 13 -- ...icsearch_elasticsearch_secure_sm_6_4_3.xml | 13 -- ...icsearch_elasticsearch_x_content_6_4_3.xml | 13 -- .../Maven__org_elasticsearch_jna_4_5_1.xml | 13 -- ...arch_plugin_lang_mustache_client_6_2_2.xml | 13 -- ...arch_plugin_lang_mustache_client_6_4_3.xml | 13 -- ...search_plugin_parent_join_client_6_2_2.xml | 13 -- ...search_plugin_parent_join_client_6_4_3.xml | 13 -- ...csearch_plugin_percolator_client_6_2_2.xml | 13 -- ...csearch_plugin_percolator_client_6_4_3.xml | 13 -- ...icsearch_plugin_rank_eval_client_6_2_2.xml | 13 -- ...icsearch_plugin_rank_eval_client_6_4_3.xml | 13 -- ...sticsearch_plugin_reindex_client_6_2_2.xml | 13 -- ...sticsearch_plugin_reindex_client_6_4_3.xml | 13 -- ...h_plugin_transport_netty4_client_6_2_2.xml | 13 -- ...h_plugin_transport_netty4_client_6_4_3.xml | 13 -- .../Maven__org_elasticsearch_securesm_1_2.xml | 13 -- ...n__org_hdrhistogram_HdrHistogram_2_1_9.xml | 13 -- ...g_locationtech_spatial4j_spatial4j_0_6.xml | 13 -- ...arter_data_elasticsearch_2_1_3_RELEASE.xml | 13 -- ...data_spring_data_commons_2_1_5_RELEASE.xml | 13 -- ...pring_data_elasticsearch_3_1_5_RELEASE.xml | 13 -- springboot-prometheus-canal/pom.xml | 91 ++++++++++++++ .../java/com/pancm/PrometheusCanalApp.java | 44 +++++++ .../com/pancm/config/CanalClientRunner.java | 116 ++++++++++++++++++ .../pancm/config/GlobalExceptionHandler.java | 28 +++++ .../pancm/config/PrometheusCustomMonitor.java | 40 ++++++ .../sample/SimpleCanalClientExample.java | 102 +++++++++++++++ .../com/pancm/web/HelloWorldController.java | 25 ++++ .../main/java/com/pancm/web/package-info.java | 8 ++ .../src/main/resources/application.properties | 23 ++++ 107 files changed, 477 insertions(+), 1274 deletions(-) delete mode 100644 .idea/libraries/Maven__com_carrotsearch_hppc_0_7_1.xml delete mode 100644 .idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_cbor_2_8_10.xml delete mode 100644 .idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_cbor_2_9_8.xml delete mode 100644 .idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_smile_2_8_10.xml delete mode 100644 .idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_smile_2_9_8.xml delete mode 100644 .idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_yaml_2_8_10.xml delete mode 100644 .idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_yaml_2_9_8.xml delete mode 100644 .idea/libraries/Maven__com_github_spullara_mustache_java_compiler_0_9_3.xml delete mode 100644 .idea/libraries/Maven__com_google_code_gson_gson_2_8_0.xml delete mode 100644 .idea/libraries/Maven__com_google_code_gson_gson_2_8_5.xml delete mode 100644 .idea/libraries/Maven__com_google_guava_guava_21_0.xml delete mode 100644 .idea/libraries/Maven__com_tdunning_t_digest_3_0.xml delete mode 100644 .idea/libraries/Maven__com_tdunning_t_digest_3_2.xml delete mode 100644 .idea/libraries/Maven__com_vividsolutions_jts_1_13.xml delete mode 100644 .idea/libraries/Maven__commons_codec_commons_codec_1_11.xml delete mode 100644 .idea/libraries/Maven__commons_codec_commons_codec_1_9.xml delete mode 100644 .idea/libraries/Maven__io_netty_netty_buffer_4_1_16_Final.xml delete mode 100644 .idea/libraries/Maven__io_netty_netty_codec_4_1_16_Final.xml delete mode 100644 .idea/libraries/Maven__io_netty_netty_codec_http_4_1_16_Final.xml delete mode 100644 .idea/libraries/Maven__io_netty_netty_common_4_1_16_Final.xml delete mode 100644 .idea/libraries/Maven__io_netty_netty_handler_4_1_16_Final.xml delete mode 100644 .idea/libraries/Maven__io_netty_netty_resolver_4_1_16_Final.xml delete mode 100644 .idea/libraries/Maven__io_netty_netty_transport_4_1_16_Final.xml delete mode 100644 .idea/libraries/Maven__io_searchbox_jest_6_3_1.xml delete mode 100644 .idea/libraries/Maven__io_searchbox_jest_common_6_3_1.xml delete mode 100644 .idea/libraries/Maven__joda_time_joda_time_2_10_1.xml delete mode 100644 .idea/libraries/Maven__net_sf_jopt_simple_jopt_simple_5_0_2.xml delete mode 100644 .idea/libraries/Maven__org_apache_httpcomponents_httpasyncclient_4_1_3.xml delete mode 100644 .idea/libraries/Maven__org_apache_httpcomponents_httpasyncclient_4_1_4.xml delete mode 100644 .idea/libraries/Maven__org_apache_httpcomponents_httpclient_4_5_3.xml delete mode 100644 .idea/libraries/Maven__org_apache_httpcomponents_httpclient_4_5_7.xml delete mode 100644 .idea/libraries/Maven__org_apache_httpcomponents_httpcore_4_4_11.xml delete mode 100644 .idea/libraries/Maven__org_apache_httpcomponents_httpcore_4_4_6.xml delete mode 100644 .idea/libraries/Maven__org_apache_httpcomponents_httpcore_nio_4_4_11.xml delete mode 100644 .idea/libraries/Maven__org_apache_httpcomponents_httpcore_nio_4_4_6.xml delete mode 100644 .idea/libraries/Maven__org_apache_logging_log4j_log4j_api_2_8_2.xml delete mode 100644 .idea/libraries/Maven__org_apache_logging_log4j_log4j_core_2_8_2.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_analyzers_common_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_analyzers_common_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_backward_codecs_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_backward_codecs_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_core_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_core_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_grouping_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_grouping_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_highlighter_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_highlighter_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_join_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_join_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_memory_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_memory_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_misc_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_misc_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_queries_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_queries_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_queryparser_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_queryparser_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_sandbox_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_sandbox_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_spatial3d_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_spatial3d_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_spatial_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_spatial_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_spatial_extras_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_spatial_extras_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_suggest_7_2_1.xml delete mode 100644 .idea/libraries/Maven__org_apache_lucene_lucene_suggest_7_4_0.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_client_elasticsearch_rest_client_6_2_2.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_client_elasticsearch_rest_client_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_client_transport_6_2_2.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_client_transport_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_elasticsearch_6_2_2.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_elasticsearch_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_elasticsearch_cli_6_2_2.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_elasticsearch_cli_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_elasticsearch_core_6_2_2.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_elasticsearch_core_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_elasticsearch_secure_sm_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_elasticsearch_x_content_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_jna_4_5_1.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_lang_mustache_client_6_2_2.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_lang_mustache_client_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_parent_join_client_6_2_2.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_parent_join_client_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_percolator_client_6_2_2.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_percolator_client_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_rank_eval_client_6_2_2.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_rank_eval_client_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_reindex_client_6_2_2.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_reindex_client_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_transport_netty4_client_6_2_2.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_plugin_transport_netty4_client_6_4_3.xml delete mode 100644 .idea/libraries/Maven__org_elasticsearch_securesm_1_2.xml delete mode 100644 .idea/libraries/Maven__org_hdrhistogram_HdrHistogram_2_1_9.xml delete mode 100644 .idea/libraries/Maven__org_locationtech_spatial4j_spatial4j_0_6.xml delete mode 100644 .idea/libraries/Maven__org_springframework_boot_spring_boot_starter_data_elasticsearch_2_1_3_RELEASE.xml delete mode 100644 .idea/libraries/Maven__org_springframework_data_spring_data_commons_2_1_5_RELEASE.xml delete mode 100644 .idea/libraries/Maven__org_springframework_data_spring_data_elasticsearch_3_1_5_RELEASE.xml create mode 100644 springboot-prometheus-canal/pom.xml create mode 100644 springboot-prometheus-canal/src/main/java/com/pancm/PrometheusCanalApp.java create mode 100644 springboot-prometheus-canal/src/main/java/com/pancm/config/CanalClientRunner.java create mode 100644 springboot-prometheus-canal/src/main/java/com/pancm/config/GlobalExceptionHandler.java create mode 100644 springboot-prometheus-canal/src/main/java/com/pancm/config/PrometheusCustomMonitor.java create mode 100644 springboot-prometheus-canal/src/main/java/com/pancm/sample/SimpleCanalClientExample.java create mode 100644 springboot-prometheus-canal/src/main/java/com/pancm/web/HelloWorldController.java create mode 100644 springboot-prometheus-canal/src/main/java/com/pancm/web/package-info.java create mode 100644 springboot-prometheus-canal/src/main/resources/application.properties diff --git a/.idea/libraries/Maven__com_carrotsearch_hppc_0_7_1.xml b/.idea/libraries/Maven__com_carrotsearch_hppc_0_7_1.xml deleted file mode 100644 index 8569576..0000000 --- a/.idea/libraries/Maven__com_carrotsearch_hppc_0_7_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_cbor_2_8_10.xml b/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_cbor_2_8_10.xml deleted file mode 100644 index a447509..0000000 --- a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_cbor_2_8_10.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_cbor_2_9_8.xml b/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_cbor_2_9_8.xml deleted file mode 100644 index 085ee90..0000000 --- a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_cbor_2_9_8.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_smile_2_8_10.xml b/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_smile_2_8_10.xml deleted file mode 100644 index 91017e0..0000000 --- a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_smile_2_8_10.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_smile_2_9_8.xml b/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_smile_2_9_8.xml deleted file mode 100644 index cc51fc2..0000000 --- a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_smile_2_9_8.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_yaml_2_8_10.xml b/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_yaml_2_8_10.xml deleted file mode 100644 index 88c8172..0000000 --- a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_yaml_2_8_10.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_yaml_2_9_8.xml b/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_yaml_2_9_8.xml deleted file mode 100644 index 5ed1c65..0000000 --- a/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_yaml_2_9_8.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_github_spullara_mustache_java_compiler_0_9_3.xml b/.idea/libraries/Maven__com_github_spullara_mustache_java_compiler_0_9_3.xml deleted file mode 100644 index 87dac79..0000000 --- a/.idea/libraries/Maven__com_github_spullara_mustache_java_compiler_0_9_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_google_code_gson_gson_2_8_0.xml b/.idea/libraries/Maven__com_google_code_gson_gson_2_8_0.xml deleted file mode 100644 index 6e5d5b7..0000000 --- a/.idea/libraries/Maven__com_google_code_gson_gson_2_8_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_google_code_gson_gson_2_8_5.xml b/.idea/libraries/Maven__com_google_code_gson_gson_2_8_5.xml deleted file mode 100644 index 2888f96..0000000 --- a/.idea/libraries/Maven__com_google_code_gson_gson_2_8_5.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_google_guava_guava_21_0.xml b/.idea/libraries/Maven__com_google_guava_guava_21_0.xml deleted file mode 100644 index a923456..0000000 --- a/.idea/libraries/Maven__com_google_guava_guava_21_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_tdunning_t_digest_3_0.xml b/.idea/libraries/Maven__com_tdunning_t_digest_3_0.xml deleted file mode 100644 index 953dcce..0000000 --- a/.idea/libraries/Maven__com_tdunning_t_digest_3_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_tdunning_t_digest_3_2.xml b/.idea/libraries/Maven__com_tdunning_t_digest_3_2.xml deleted file mode 100644 index 791d040..0000000 --- a/.idea/libraries/Maven__com_tdunning_t_digest_3_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__com_vividsolutions_jts_1_13.xml b/.idea/libraries/Maven__com_vividsolutions_jts_1_13.xml deleted file mode 100644 index b7e360b..0000000 --- a/.idea/libraries/Maven__com_vividsolutions_jts_1_13.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__commons_codec_commons_codec_1_11.xml b/.idea/libraries/Maven__commons_codec_commons_codec_1_11.xml deleted file mode 100644 index 4c8ff54..0000000 --- a/.idea/libraries/Maven__commons_codec_commons_codec_1_11.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__commons_codec_commons_codec_1_9.xml b/.idea/libraries/Maven__commons_codec_commons_codec_1_9.xml deleted file mode 100644 index a66d039..0000000 --- a/.idea/libraries/Maven__commons_codec_commons_codec_1_9.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__io_netty_netty_buffer_4_1_16_Final.xml b/.idea/libraries/Maven__io_netty_netty_buffer_4_1_16_Final.xml deleted file mode 100644 index 17f20f0..0000000 --- a/.idea/libraries/Maven__io_netty_netty_buffer_4_1_16_Final.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__io_netty_netty_codec_4_1_16_Final.xml b/.idea/libraries/Maven__io_netty_netty_codec_4_1_16_Final.xml deleted file mode 100644 index 6321eb5..0000000 --- a/.idea/libraries/Maven__io_netty_netty_codec_4_1_16_Final.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__io_netty_netty_codec_http_4_1_16_Final.xml b/.idea/libraries/Maven__io_netty_netty_codec_http_4_1_16_Final.xml deleted file mode 100644 index 35b8179..0000000 --- a/.idea/libraries/Maven__io_netty_netty_codec_http_4_1_16_Final.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__io_netty_netty_common_4_1_16_Final.xml b/.idea/libraries/Maven__io_netty_netty_common_4_1_16_Final.xml deleted file mode 100644 index bf89a8f..0000000 --- a/.idea/libraries/Maven__io_netty_netty_common_4_1_16_Final.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__io_netty_netty_handler_4_1_16_Final.xml b/.idea/libraries/Maven__io_netty_netty_handler_4_1_16_Final.xml deleted file mode 100644 index 91d55de..0000000 --- a/.idea/libraries/Maven__io_netty_netty_handler_4_1_16_Final.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__io_netty_netty_resolver_4_1_16_Final.xml b/.idea/libraries/Maven__io_netty_netty_resolver_4_1_16_Final.xml deleted file mode 100644 index b0ff2a1..0000000 --- a/.idea/libraries/Maven__io_netty_netty_resolver_4_1_16_Final.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__io_netty_netty_transport_4_1_16_Final.xml b/.idea/libraries/Maven__io_netty_netty_transport_4_1_16_Final.xml deleted file mode 100644 index be7e279..0000000 --- a/.idea/libraries/Maven__io_netty_netty_transport_4_1_16_Final.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__io_searchbox_jest_6_3_1.xml b/.idea/libraries/Maven__io_searchbox_jest_6_3_1.xml deleted file mode 100644 index fc1b6e5..0000000 --- a/.idea/libraries/Maven__io_searchbox_jest_6_3_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__io_searchbox_jest_common_6_3_1.xml b/.idea/libraries/Maven__io_searchbox_jest_common_6_3_1.xml deleted file mode 100644 index 87cea1b..0000000 --- a/.idea/libraries/Maven__io_searchbox_jest_common_6_3_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__joda_time_joda_time_2_10_1.xml b/.idea/libraries/Maven__joda_time_joda_time_2_10_1.xml deleted file mode 100644 index 9f7554a..0000000 --- a/.idea/libraries/Maven__joda_time_joda_time_2_10_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__net_sf_jopt_simple_jopt_simple_5_0_2.xml b/.idea/libraries/Maven__net_sf_jopt_simple_jopt_simple_5_0_2.xml deleted file mode 100644 index 9c0855d..0000000 --- a/.idea/libraries/Maven__net_sf_jopt_simple_jopt_simple_5_0_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_httpcomponents_httpasyncclient_4_1_3.xml b/.idea/libraries/Maven__org_apache_httpcomponents_httpasyncclient_4_1_3.xml deleted file mode 100644 index d5da2b5..0000000 --- a/.idea/libraries/Maven__org_apache_httpcomponents_httpasyncclient_4_1_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_httpcomponents_httpasyncclient_4_1_4.xml b/.idea/libraries/Maven__org_apache_httpcomponents_httpasyncclient_4_1_4.xml deleted file mode 100644 index fe2908c..0000000 --- a/.idea/libraries/Maven__org_apache_httpcomponents_httpasyncclient_4_1_4.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_httpcomponents_httpclient_4_5_3.xml b/.idea/libraries/Maven__org_apache_httpcomponents_httpclient_4_5_3.xml deleted file mode 100644 index c82bb7c..0000000 --- a/.idea/libraries/Maven__org_apache_httpcomponents_httpclient_4_5_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_httpcomponents_httpclient_4_5_7.xml b/.idea/libraries/Maven__org_apache_httpcomponents_httpclient_4_5_7.xml deleted file mode 100644 index 18d2e57..0000000 --- a/.idea/libraries/Maven__org_apache_httpcomponents_httpclient_4_5_7.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_4_4_11.xml b/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_4_4_11.xml deleted file mode 100644 index e5fd71a..0000000 --- a/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_4_4_11.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_4_4_6.xml b/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_4_4_6.xml deleted file mode 100644 index a9f6e19..0000000 --- a/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_4_4_6.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_nio_4_4_11.xml b/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_nio_4_4_11.xml deleted file mode 100644 index b896685..0000000 --- a/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_nio_4_4_11.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_nio_4_4_6.xml b/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_nio_4_4_6.xml deleted file mode 100644 index 3613e21..0000000 --- a/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_nio_4_4_6.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_logging_log4j_log4j_api_2_8_2.xml b/.idea/libraries/Maven__org_apache_logging_log4j_log4j_api_2_8_2.xml deleted file mode 100644 index d5c9995..0000000 --- a/.idea/libraries/Maven__org_apache_logging_log4j_log4j_api_2_8_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_logging_log4j_log4j_core_2_8_2.xml b/.idea/libraries/Maven__org_apache_logging_log4j_log4j_core_2_8_2.xml deleted file mode 100644 index 3f4b686..0000000 --- a/.idea/libraries/Maven__org_apache_logging_log4j_log4j_core_2_8_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_analyzers_common_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_analyzers_common_7_2_1.xml deleted file mode 100644 index fb36d0a..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_analyzers_common_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_analyzers_common_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_analyzers_common_7_4_0.xml deleted file mode 100644 index 42ec915..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_analyzers_common_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_backward_codecs_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_backward_codecs_7_2_1.xml deleted file mode 100644 index 75695b9..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_backward_codecs_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_backward_codecs_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_backward_codecs_7_4_0.xml deleted file mode 100644 index 4a01d5b..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_backward_codecs_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_core_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_core_7_2_1.xml deleted file mode 100644 index fce6873..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_core_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_core_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_core_7_4_0.xml deleted file mode 100644 index ec81d59..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_core_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_grouping_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_grouping_7_2_1.xml deleted file mode 100644 index f2c9c69..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_grouping_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_grouping_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_grouping_7_4_0.xml deleted file mode 100644 index 4836c10..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_grouping_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_highlighter_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_highlighter_7_2_1.xml deleted file mode 100644 index 5eb3779..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_highlighter_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_highlighter_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_highlighter_7_4_0.xml deleted file mode 100644 index c6b7431..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_highlighter_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_join_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_join_7_2_1.xml deleted file mode 100644 index ab60b52..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_join_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_join_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_join_7_4_0.xml deleted file mode 100644 index abc6c2f..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_join_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_memory_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_memory_7_2_1.xml deleted file mode 100644 index 86ec7ee..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_memory_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_memory_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_memory_7_4_0.xml deleted file mode 100644 index e8b27fa..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_memory_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_misc_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_misc_7_2_1.xml deleted file mode 100644 index 7a27c21..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_misc_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_misc_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_misc_7_4_0.xml deleted file mode 100644 index d12ac8e..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_misc_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_queries_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_queries_7_2_1.xml deleted file mode 100644 index a25bc89..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_queries_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_queries_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_queries_7_4_0.xml deleted file mode 100644 index 5bb6dbc..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_queries_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_queryparser_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_queryparser_7_2_1.xml deleted file mode 100644 index 1acbfd9..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_queryparser_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_queryparser_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_queryparser_7_4_0.xml deleted file mode 100644 index 4f97720..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_queryparser_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_sandbox_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_sandbox_7_2_1.xml deleted file mode 100644 index a35ef48..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_sandbox_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_sandbox_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_sandbox_7_4_0.xml deleted file mode 100644 index c7ad123..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_sandbox_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial3d_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_spatial3d_7_2_1.xml deleted file mode 100644 index b2fd18f..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial3d_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial3d_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_spatial3d_7_4_0.xml deleted file mode 100644 index 495ab49..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial3d_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_7_2_1.xml deleted file mode 100644 index 85811bc..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_7_4_0.xml deleted file mode 100644 index 11c7ae4..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_extras_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_extras_7_2_1.xml deleted file mode 100644 index bb01f96..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_extras_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_extras_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_extras_7_4_0.xml deleted file mode 100644 index 16434d5..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_spatial_extras_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_suggest_7_2_1.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_suggest_7_2_1.xml deleted file mode 100644 index 4607be2..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_suggest_7_2_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_apache_lucene_lucene_suggest_7_4_0.xml b/.idea/libraries/Maven__org_apache_lucene_lucene_suggest_7_4_0.xml deleted file mode 100644 index 337aaf4..0000000 --- a/.idea/libraries/Maven__org_apache_lucene_lucene_suggest_7_4_0.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_client_elasticsearch_rest_client_6_2_2.xml b/.idea/libraries/Maven__org_elasticsearch_client_elasticsearch_rest_client_6_2_2.xml deleted file mode 100644 index e530752..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_client_elasticsearch_rest_client_6_2_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_client_elasticsearch_rest_client_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_client_elasticsearch_rest_client_6_4_3.xml deleted file mode 100644 index e487a6a..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_client_elasticsearch_rest_client_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_client_transport_6_2_2.xml b/.idea/libraries/Maven__org_elasticsearch_client_transport_6_2_2.xml deleted file mode 100644 index 206951d..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_client_transport_6_2_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_client_transport_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_client_transport_6_4_3.xml deleted file mode 100644 index fad93fa..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_client_transport_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_6_2_2.xml b/.idea/libraries/Maven__org_elasticsearch_elasticsearch_6_2_2.xml deleted file mode 100644 index 2299794..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_6_2_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_elasticsearch_6_4_3.xml deleted file mode 100644 index f2e3fcd..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_cli_6_2_2.xml b/.idea/libraries/Maven__org_elasticsearch_elasticsearch_cli_6_2_2.xml deleted file mode 100644 index 090a20b..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_cli_6_2_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_cli_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_elasticsearch_cli_6_4_3.xml deleted file mode 100644 index 9beabfc..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_cli_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_core_6_2_2.xml b/.idea/libraries/Maven__org_elasticsearch_elasticsearch_core_6_2_2.xml deleted file mode 100644 index a8aab49..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_core_6_2_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_core_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_elasticsearch_core_6_4_3.xml deleted file mode 100644 index 3135541..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_core_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_secure_sm_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_elasticsearch_secure_sm_6_4_3.xml deleted file mode 100644 index 396810a..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_secure_sm_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_x_content_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_elasticsearch_x_content_6_4_3.xml deleted file mode 100644 index 0fc1f95..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_elasticsearch_x_content_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_jna_4_5_1.xml b/.idea/libraries/Maven__org_elasticsearch_jna_4_5_1.xml deleted file mode 100644 index ba56761..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_jna_4_5_1.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_lang_mustache_client_6_2_2.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_lang_mustache_client_6_2_2.xml deleted file mode 100644 index f0a5228..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_lang_mustache_client_6_2_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_lang_mustache_client_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_lang_mustache_client_6_4_3.xml deleted file mode 100644 index 8bc4788..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_lang_mustache_client_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_parent_join_client_6_2_2.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_parent_join_client_6_2_2.xml deleted file mode 100644 index 793ed29..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_parent_join_client_6_2_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_parent_join_client_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_parent_join_client_6_4_3.xml deleted file mode 100644 index c281035..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_parent_join_client_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_percolator_client_6_2_2.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_percolator_client_6_2_2.xml deleted file mode 100644 index 055d2a2..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_percolator_client_6_2_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_percolator_client_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_percolator_client_6_4_3.xml deleted file mode 100644 index 481f19a..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_percolator_client_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_rank_eval_client_6_2_2.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_rank_eval_client_6_2_2.xml deleted file mode 100644 index 9c50bd1..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_rank_eval_client_6_2_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_rank_eval_client_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_rank_eval_client_6_4_3.xml deleted file mode 100644 index 0a9b636..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_rank_eval_client_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_reindex_client_6_2_2.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_reindex_client_6_2_2.xml deleted file mode 100644 index 454a564..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_reindex_client_6_2_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_reindex_client_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_reindex_client_6_4_3.xml deleted file mode 100644 index e463cad..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_reindex_client_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_transport_netty4_client_6_2_2.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_transport_netty4_client_6_2_2.xml deleted file mode 100644 index 7c57d32..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_transport_netty4_client_6_2_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_plugin_transport_netty4_client_6_4_3.xml b/.idea/libraries/Maven__org_elasticsearch_plugin_transport_netty4_client_6_4_3.xml deleted file mode 100644 index 24aaf1f..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_plugin_transport_netty4_client_6_4_3.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_elasticsearch_securesm_1_2.xml b/.idea/libraries/Maven__org_elasticsearch_securesm_1_2.xml deleted file mode 100644 index 4d8618d..0000000 --- a/.idea/libraries/Maven__org_elasticsearch_securesm_1_2.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_hdrhistogram_HdrHistogram_2_1_9.xml b/.idea/libraries/Maven__org_hdrhistogram_HdrHistogram_2_1_9.xml deleted file mode 100644 index 04cc804..0000000 --- a/.idea/libraries/Maven__org_hdrhistogram_HdrHistogram_2_1_9.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_locationtech_spatial4j_spatial4j_0_6.xml b/.idea/libraries/Maven__org_locationtech_spatial4j_spatial4j_0_6.xml deleted file mode 100644 index 7e41151..0000000 --- a/.idea/libraries/Maven__org_locationtech_spatial4j_spatial4j_0_6.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_data_elasticsearch_2_1_3_RELEASE.xml b/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_data_elasticsearch_2_1_3_RELEASE.xml deleted file mode 100644 index 4bdc67c..0000000 --- a/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_data_elasticsearch_2_1_3_RELEASE.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_springframework_data_spring_data_commons_2_1_5_RELEASE.xml b/.idea/libraries/Maven__org_springframework_data_spring_data_commons_2_1_5_RELEASE.xml deleted file mode 100644 index ef16406..0000000 --- a/.idea/libraries/Maven__org_springframework_data_spring_data_commons_2_1_5_RELEASE.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/.idea/libraries/Maven__org_springframework_data_spring_data_elasticsearch_3_1_5_RELEASE.xml b/.idea/libraries/Maven__org_springframework_data_spring_data_elasticsearch_3_1_5_RELEASE.xml deleted file mode 100644 index 74ef488..0000000 --- a/.idea/libraries/Maven__org_springframework_data_spring_data_elasticsearch_3_1_5_RELEASE.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - - - - - - - - - \ No newline at end of file diff --git a/springboot-prometheus-canal/pom.xml b/springboot-prometheus-canal/pom.xml new file mode 100644 index 0000000..3a6b9ce --- /dev/null +++ b/springboot-prometheus-canal/pom.xml @@ -0,0 +1,91 @@ + + 4.0.0 + + 1.0.0 + springboot-prometheus-canal + 0.0.1-SNAPSHOT + jar + + springboot-prometheus-canal + http://maven.apache.org + + + UTF-8 + UTF-8 + 1.8 + 1.8 + 1.8 + + + + org.springframework.boot + spring-boot-starter-parent + 2.1.3.RELEASE + + + + + + org.springframework.boot + spring-boot-starter-web + + + org.springframework.boot + spring-boot-starter-actuator + + + io.micrometer + micrometer-registry-prometheus + + + + org.springframework.boot + spring-boot-starter-test + test + + + org.springframework.boot + spring-boot-devtools + true + test + + + com.alibaba.otter + canal.client + 1.1.3 + + + mysql + mysql-connector-java + 5.1.35 + + + org.projectlombok + lombok + 1.16.18 + + + + compile + springboot-prometheus-canal + + + org.springframework.boot + spring-boot-maven-plugin + + true + com.pancm.App + + + + + repackage + + + + + + + + diff --git a/springboot-prometheus-canal/src/main/java/com/pancm/PrometheusCanalApp.java b/springboot-prometheus-canal/src/main/java/com/pancm/PrometheusCanalApp.java new file mode 100644 index 0000000..2fc5730 --- /dev/null +++ b/springboot-prometheus-canal/src/main/java/com/pancm/PrometheusCanalApp.java @@ -0,0 +1,44 @@ +package com.pancm; + +import lombok.extern.slf4j.Slf4j; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + + +/** + * +* @Title: ActuatorApp +* @Description: +启动程序之后，在浏览器输入: http://localhost:8284/actuator 加上 + 1. /autoconfig 可以得到配置生效信息 + 2. /configprops 可以得到属性的内容和默认值 + 3. /beans 可 以得到bean的别名、类型、是否单例、类的地址、依赖等信息 + 4. /dump 可 以得到线程名、线程ID、线程的状态、是否等待锁资源等信息 + 5. /env 可以得到环境变量、JVM 属性、命令行参数、项目使用的jar包等信息 + 5.1 /sun.boot.library.path 可以得到JDK安装路径 + 6. /health 可以得到磁盘检测和数据库检测等信息 + 7. /mappings 可以得到全部的URI路径，以及它们和控制器的映射关系 + 8. /metrics 可以得到JVM内容使用、GC情况、类加载信息 + 8.1 /gc.* 可以得到GC相关信息 + 8.2 /mem.* 可以得到内存信息 + ... + 9. /info 可以得到自定义的配置信息 + 10. /shutdown 可以进行关闭程序 post请求 + 11. /trace 可以得到所Web请求的详细信息 + 12./prometheus 可以通过Prometheus查看信息 + + +* @Version:1.0.0 +* @author pancm +* @date 2019年1月17日 + */ +@SpringBootApplication +@Slf4j +public class PrometheusCanalApp +{ + public static void main( String[] args ) + { + SpringApplication.run(PrometheusCanalApp.class, args); + log.info("PrometheusCanalApp启动成功！"); + } +} diff --git a/springboot-prometheus-canal/src/main/java/com/pancm/config/CanalClientRunner.java b/springboot-prometheus-canal/src/main/java/com/pancm/config/CanalClientRunner.java new file mode 100644 index 0000000..69219ce --- /dev/null +++ b/springboot-prometheus-canal/src/main/java/com/pancm/config/CanalClientRunner.java @@ -0,0 +1,116 @@ +package com.pancm.config; + + +import com.alibaba.otter.canal.client.CanalConnector; +import com.alibaba.otter.canal.client.CanalConnectors; +import com.alibaba.otter.canal.common.utils.AddressUtils; +import com.alibaba.otter.canal.protocol.CanalEntry; +import com.alibaba.otter.canal.protocol.CanalEntry.Column; +import com.alibaba.otter.canal.protocol.CanalEntry.EntryType; +import com.alibaba.otter.canal.protocol.CanalEntry.EventType; +import com.alibaba.otter.canal.protocol.CanalEntry.RowChange; +import com.alibaba.otter.canal.protocol.Message; +import lombok.extern.slf4j.Slf4j; +import org.springframework.boot.ApplicationArguments; +import org.springframework.boot.ApplicationRunner; +import org.springframework.core.annotation.Order; +import org.springframework.stereotype.Component; + +import java.net.InetSocketAddress; +import java.util.List; + + +/** + * @Author pancm + * @Description canal配置 + * @Date 2023/8/25 + * @Param + * @return + **/ +@Component +@Order(1) +@Slf4j +public class CanalClientRunner implements ApplicationRunner { + + + + @Override + public void run(ApplicationArguments args) throws Exception { + // 创建链接 + CanalConnector connector = CanalConnectors.newSingleConnector(new InetSocketAddress(AddressUtils.getHostIp(), + 11111), "example", "", ""); + int batchSize = 1000; + int emptyCount = 0; + try { + connector.connect(); + connector.subscribe(".*\\..*"); + connector.rollback(); + int totalEmptyCount = 1200; + while (true) { + Message message = connector.getWithoutAck(batchSize); // 获取指定数量的数据 + long batchId = message.getId(); + int size = message.getEntries().size(); + if (batchId == -1 || size == 0) { + emptyCount++; + System.out.println("empty count : " + emptyCount); + try { + Thread.sleep(1000); + } catch (InterruptedException e) { + } + } else { + emptyCount = 0; + // System.out.printf("message[batchId=%s,size=%s] \n", batchId, size); + printEntry(message.getEntries()); + } + + connector.ack(batchId); // 提交确认 + // connector.rollback(batchId); // 处理失败, 回滚数据 + } + + } finally { + connector.disconnect(); + } + } + + private static void printEntry(List entrys) { + for (CanalEntry.Entry entry : entrys) { + if (entry.getEntryType() == EntryType.TRANSACTIONBEGIN || entry.getEntryType() == EntryType.TRANSACTIONEND) { + continue; + } + + RowChange rowChage = null; + try { + rowChage = RowChange.parseFrom(entry.getStoreValue()); + } catch (Exception e) { + throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:" + entry.toString(), + e); + } + + CanalEntry.EventType eventType = rowChage.getEventType(); + int propsCount = rowChage.getPropsCount(); + System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s,propsCount:%s", + entry.getHeader().getLogfileName(), entry.getHeader().getLogfileOffset(), + entry.getHeader().getSchemaName(), entry.getHeader().getTableName(), + eventType,propsCount)); + + for (CanalEntry.RowData rowData : rowChage.getRowDatasList()) { + if (eventType == EventType.DELETE) { + printColumn(rowData.getBeforeColumnsList()); + } else if (eventType == CanalEntry.EventType.INSERT) { + printColumn(rowData.getAfterColumnsList()); + } else { + System.out.println("-------> before"); + printColumn(rowData.getBeforeColumnsList()); + System.out.println("-------> after"); + printColumn(rowData.getAfterColumnsList()); + } + } + } + } + + private static void printColumn(List columns) { + for (Column column : columns) { + System.out.println(column.getName() + " : " + column.getValue() + " update=" + column.getUpdated()); + } + } +} diff --git a/springboot-prometheus-canal/src/main/java/com/pancm/config/GlobalExceptionHandler.java b/springboot-prometheus-canal/src/main/java/com/pancm/config/GlobalExceptionHandler.java new file mode 100644 index 0000000..c11e81f --- /dev/null +++ b/springboot-prometheus-canal/src/main/java/com/pancm/config/GlobalExceptionHandler.java @@ -0,0 +1,28 @@ +package com.pancm.config; + +import org.springframework.web.bind.annotation.ControllerAdvice; +import org.springframework.web.bind.annotation.ExceptionHandler; +import org.springframework.web.bind.annotation.ResponseBody; + +import javax.annotation.Resource; + +/** + * @Author pancm + * @Description 全局异常捕获 + * @Date 2020/8/18 + * @Param + * @return + **/ +@ControllerAdvice +public class GlobalExceptionHandler { + + @Resource + private PrometheusCustomMonitor monitor; + + @ResponseBody + @ExceptionHandler(value = Exception.class) + public String handle(Exception e) { + monitor.getRequestErrorCount().increment(); + return "error, count:"+monitor.getRequestErrorCount().count()+" message: " + e.getMessage(); + } +} diff --git a/springboot-prometheus-canal/src/main/java/com/pancm/config/PrometheusCustomMonitor.java b/springboot-prometheus-canal/src/main/java/com/pancm/config/PrometheusCustomMonitor.java new file mode 100644 index 0000000..a0aa0ca --- /dev/null +++ b/springboot-prometheus-canal/src/main/java/com/pancm/config/PrometheusCustomMonitor.java @@ -0,0 +1,40 @@ +package com.pancm.config; + +import io.micrometer.core.instrument.Counter; +import io.micrometer.core.instrument.DistributionSummary; +import io.micrometer.core.instrument.MeterRegistry; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; + + +/** + * @Author pancm + * @Description + * @Date 2020/8/18 + * @Param + * @return + **/ +@Component +public class PrometheusCustomMonitor { + + /** + * 记录请求出错次数 + */ + private Counter requestErrorCount; + private final MeterRegistry registry; + @Autowired + public PrometheusCustomMonitor(MeterRegistry registry) { + this.registry = registry; + } + @PostConstruct + private void init() { + requestErrorCount = registry.counter("requests_error_total", "status", "error"); + } + public Counter getRequestErrorCount() { + return requestErrorCount; + } + + +} diff --git a/springboot-prometheus-canal/src/main/java/com/pancm/sample/SimpleCanalClientExample.java b/springboot-prometheus-canal/src/main/java/com/pancm/sample/SimpleCanalClientExample.java new file mode 100644 index 0000000..d67d700 --- /dev/null +++ b/springboot-prometheus-canal/src/main/java/com/pancm/sample/SimpleCanalClientExample.java @@ -0,0 +1,102 @@ +package com.pancm.sample; + +import java.net.InetSocketAddress; +import java.util.List; + + +import com.alibaba.otter.canal.client.CanalConnectors; +import com.alibaba.otter.canal.client.CanalConnector; +import com.alibaba.otter.canal.common.utils.AddressUtils; +import com.alibaba.otter.canal.protocol.Message; +import com.alibaba.otter.canal.protocol.CanalEntry.Column; +import com.alibaba.otter.canal.protocol.CanalEntry.Entry; +import com.alibaba.otter.canal.protocol.CanalEntry.EntryType; +import com.alibaba.otter.canal.protocol.CanalEntry.EventType; +import com.alibaba.otter.canal.protocol.CanalEntry.RowChange; +import com.alibaba.otter.canal.protocol.CanalEntry.RowData; + + +public class SimpleCanalClientExample { + + + public static void main(String args[]) { + // 创建链接 + CanalConnector connector = CanalConnectors.newSingleConnector(new InetSocketAddress(AddressUtils.getHostIp(), + 11111), "example", "", ""); + int batchSize = 1000; + int emptyCount = 0; + try { + connector.connect(); + connector.subscribe(".*\\..*"); + connector.rollback(); + int totalEmptyCount = 1200; + while (emptyCount < totalEmptyCount) { + Message message = connector.getWithoutAck(batchSize); // 获取指定数量的数据 + long batchId = message.getId(); + int size = message.getEntries().size(); + if (batchId == -1 || size == 0) { + emptyCount++; + System.out.println("empty count : " + emptyCount); + try { + Thread.sleep(1000); + } catch (InterruptedException e) { + } + } else { + emptyCount = 0; + // System.out.printf("message[batchId=%s,size=%s] \n", batchId, size); + printEntry(message.getEntries()); + } + + connector.ack(batchId); // 提交确认 + // connector.rollback(batchId); // 处理失败, 回滚数据 + } + + System.out.println("empty too many times, exit"); + } finally { + connector.disconnect(); + } + } + + private static void printEntry(List entrys) { + for (Entry entry : entrys) { + if (entry.getEntryType() == EntryType.TRANSACTIONBEGIN || entry.getEntryType() == EntryType.TRANSACTIONEND) { + continue; + } + + RowChange rowChage = null; + try { + rowChage = RowChange.parseFrom(entry.getStoreValue()); + } catch (Exception e) { + throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:" + entry.toString(), + e); + } + + EventType eventType = rowChage.getEventType(); + System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s", + entry.getHeader().getLogfileName(), entry.getHeader().getLogfileOffset(), + entry.getHeader().getSchemaName(), entry.getHeader().getTableName(), + eventType)); + + for (RowData rowData : rowChage.getRowDatasList()) { + if (eventType == EventType.DELETE) { + printColumn(rowData.getBeforeColumnsList()); + } else if (eventType == EventType.INSERT) { + printColumn(rowData.getAfterColumnsList()); + } else { + System.out.println("-------> before"); + printColumn(rowData.getBeforeColumnsList()); + System.out.println("-------> after"); + printColumn(rowData.getAfterColumnsList()); + } + } + } + } + + private static void printColumn(List columns) { + for (Column column : columns) { + System.out.println(column.getName() + " : " + column.getValue() + " update=" + column.getUpdated()); + } + } + + +} \ No newline at end of file diff --git a/springboot-prometheus-canal/src/main/java/com/pancm/web/HelloWorldController.java b/springboot-prometheus-canal/src/main/java/com/pancm/web/HelloWorldController.java new file mode 100644 index 0000000..8af0852 --- /dev/null +++ b/springboot-prometheus-canal/src/main/java/com/pancm/web/HelloWorldController.java @@ -0,0 +1,25 @@ +package com.pancm.web; + +import com.pancm.config.PrometheusCustomMonitor; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.util.StringUtils; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +@RestController +public class HelloWorldController { + + @Autowired + PrometheusCustomMonitor prometheusCustomMonitor; + + + @RequestMapping("/hello/{name}") + public String index(@PathVariable String name) throws Exception { + if(!"pancm".equals(name)){ + throw new Exception("出错了"); + } + return "Hello " + name; + } + +} diff --git a/springboot-prometheus-canal/src/main/java/com/pancm/web/package-info.java b/springboot-prometheus-canal/src/main/java/com/pancm/web/package-info.java new file mode 100644 index 0000000..1283b08 --- /dev/null +++ b/springboot-prometheus-canal/src/main/java/com/pancm/web/package-info.java @@ -0,0 +1,8 @@ +/** +* @Title: package-info +* @Description: +* @Version:1.0.0 +* @author pancm +* @date 2019年1月17日 +*/ +package com.pancm.web; \ No newline at end of file diff --git a/springboot-prometheus-canal/src/main/resources/application.properties b/springboot-prometheus-canal/src/main/resources/application.properties new file mode 100644 index 0000000..ab9a9fe --- /dev/null +++ b/springboot-prometheus-canal/src/main/resources/application.properties @@ -0,0 +1,23 @@ +spring.port = 8787 +spring.application.name=springboot-prometheus-canal +# /health˵ ¶ϸϢ +management.endpoint.health.show-details=always +# "*" ¶еĶ˵ ָ˵㣬","ֿ +management.endpoints.web.exposure.include=* +# ֵͬ +management.endpoints.web.exposure.exclude= +# ʽӦ +management.endpoint.shutdown.enabled=true +# ΪָһΪTagTagPrometheusṩһӶʵָɸѡ +management.metrics.tags.application=${spring.application.name} + +info.app.encoding=@project.build.sourceEncoding@ +info.app.java.source=@java.version@ +info.app.java.target=@java.version@ +info.app.name=@project.name@ +info.app.description=@project.description@ +info.app.version=@project.version@ + + + +